gerrit.onap Code Review - ccsdk/features.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP : ccsdk features
   4  * ================================================================================
   5  * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
   6  * All rights reserved.
   7  * ================================================================================
   8  * Update Copyright (C) 2021 Samsung Electronics Intellectual Property. All rights reserved.
   9  * =================================================================================================
  10  * Licensed under the Apache License, Version 2.0 (the "License");
  11  * you may not use this file except in compliance with the License.
  12  * You may obtain a copy of the License at
  13  *
  14  *     http://www.apache.org/licenses/LICENSE-2.0
  15  *
  16  * Unless required by applicable law or agreed to in writing, software
  17  * distributed under the License is distributed on an "AS IS" BASIS,
  18  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  19  * See the License for the specific language governing permissions and
  20  * limitations under the License.
  21  * ============LICENSE_END=========================================================
  22  *
  23  */
  24 package org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.data;
  25
  26 import java.io.IOException;
  27 import java.sql.ResultSet;
  28 import java.sql.SQLException;
  29 import java.util.ArrayList;
  30 import java.util.List;
  31 import java.util.Map;
  32 import java.util.concurrent.TimeUnit;
  33 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.SqlDBClient;
  34 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.SqlDBConfig;
  35 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.data.entity.HtDatabaseEventsService;
  36 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.data.entity.HtDatabaseMaintenanceService;
  37 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.data.rpctypehelper.QueryResult;
  38 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.database.SqlDBReaderWriter;
  39 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.database.SqlDBReaderWriterUserdata;
  40 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.database.SqlDBStatusReader;
  41 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.query.DeleteQuery;
  42 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
  43 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DatabaseDataProvider;
  44 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.HtDatabaseMaintenance;
  45 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.HtDatabaseMediatorserver;
  46 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.HtUserdataManager;
  47 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.InventoryTreeProvider;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.CreateMaintenanceInput;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.CreateMaintenanceOutputBuilder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.CreateMediatorServerInput;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.CreateMediatorServerOutputBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.CreateNetworkElementConnectionOutputBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteMaintenanceInput;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteMaintenanceOutputBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteMediatorServerInput;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteMediatorServerOutputBuilder;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteNetworkElementConnectionInput;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteNetworkElementConnectionOutputBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.Entity;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.EntityInput;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.Guicutthrough;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.GuicutthroughBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.MaintenanceEntity;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.MediatorServerEntity;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.NetworkElementConnectionEntity;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadCmlogListOutputBuilder;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadConnectionlogListOutputBuilder;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadEventlogListOutputBuilder;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadFaultcurrentListOutputBuilder;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadFaultlogListOutputBuilder;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadGuiCutThroughEntryOutputBuilder;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadInventoryDeviceListOutputBuilder;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadInventoryListOutputBuilder;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadMaintenanceListOutputBuilder;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadMediatorServerListOutputBuilder;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadNetworkElementConnectionListOutputBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata15mDeviceListOutputBuilder;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata15mListOutputBuilder;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata15mLtpListOutputBuilder;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata24hDeviceListOutputBuilder;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata24hListOutputBuilder;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata24hLtpListOutputBuilder;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadStatusOutputBuilder;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateMaintenanceInput;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateMaintenanceOutputBuilder;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateMediatorServerInput;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateMediatorServerOutputBuilder;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateNetworkElementConnectionInput;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateNetworkElementConnectionOutputBuilder;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.entity.input.Filter;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.entity.input.FilterKey;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.mediator.server.list.output.Data;
  93 import org.slf4j.Logger;
  94 import org.slf4j.LoggerFactory;
  95
  96 public class SqlDBDataProvider extends HtDatabaseEventsService implements DatabaseDataProvider {
  97
  98     private static final Logger LOG = LoggerFactory.getLogger(SqlDBDataProvider.class);
  99
 100     private static final String EXCEPTION_UNABLE_TO_WRITE_IN_DATABASE = "unable to write data to database";
 101     private static final String EXCEPTION_UNABLE_TO_UPDATE_IN_DATABASE = "unable to update data in database";
 102     private static final String EXCEPTION_UNABLE_TO_REMOVE_FROM_DATABASE = "unable to remove data from database";
 103
 104     private final HtDatabaseMediatorserver dbMediatorServerService;
 105     private final HtDatabaseMaintenance dbMaintenanceService;
 106     private final SqlDBReaderWriter<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.mediator.server.list.output.Data> mediatorserverRW;
 107     private final SqlDBReaderWriter<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.maintenance.list.output.Data> maintenanceRW;
 108     private final SqlDBStatusReader readStatus;
 109     private final HtUserdataManager usermanager;
 110     private final InventoryTreeProvider inventoryTreeProvider;
 111     private final String guicutthroughOverride;
 112
 113     public SqlDBReaderWriter<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.maintenance.list.output.Data> getMaintenanceReaderWriter() {
 114         return this.maintenanceRW;
 115     }
 116
 117     public SqlDBReaderWriter<Data> getMediatorServerReaderWriter() {
 118         return this.mediatorserverRW;
 119     }
 120
 121     public SqlDBDataProvider(SqlDBConfig config, String guicutthroughOverride) {
 122         this(config, true, guicutthroughOverride);
 123     }
 124
 125     public SqlDBDataProvider(SqlDBConfig config, boolean initControllerId, String guicutthroughOverride) {
 126         super(config);
 127         this.guicutthroughOverride = guicutthroughOverride;
 128
 129         this.mediatorserverRW = new SqlDBReaderWriter<>(this.dbClient, Entity.MediatorServer, config.getDbSuffix(),
 130                 org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.mediator.server.list.output.Data.class,
 131                 this.controllerId).setWriteInterface(MediatorServerEntity.class);
 132
 133         this.maintenanceRW = new SqlDBReaderWriter<>(this.dbClient, Entity.Maintenancemode, config.getDbSuffix(),
 134                 org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.maintenance.list.output.Data.class,
 135                 this.controllerId).setWriteInterface(MaintenanceEntity.class);
 136
 137         this.readStatus = new SqlDBStatusReader(this.dbClient, this.controllerId);
 138
 139         this.dbMediatorServerService = new HtDatabaseMediatorserver() {
 140
 141             @Override
 142             public List<MediatorServerEntity> getAll() {
 143                 return SqlDBDataProvider.this.mediatorserverRW.readAll(MediatorServerEntity.class);
 144             }
 145         };
 146         this.dbMaintenanceService = new HtDatabaseMaintenanceService(this);
 147         this.usermanager = new HtUserdataManagerImpl(
 148                 new SqlDBReaderWriterUserdata(this.dbClient, Entity.Userdata, config.getDbSuffix()));
 149         if (initControllerId) {
 150             try {
 151                 this.setControllerId();
 152             } catch (SQLException e) {
 153                 LOG.warn("problem setting controllerId: ", e);
 154             }
 155         }
 156         this.inventoryTreeProvider = new SqlDbInventoryTreeProvider(this.dbClient, this.getControllerId());
 157
 158     }
 159
 160     /*-------------------------
 161      * Provide access to model API
 162      */
 163
 164     @Override
 165     public ReadFaultcurrentListOutputBuilder readFaultCurrentList(EntityInput input) {
 166
 167         ReadFaultcurrentListOutputBuilder outputBuilder = new ReadFaultcurrentListOutputBuilder();
 168
 169         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.faultcurrent.list.output.Data> result =
 170                 this.eventRWFaultCurrent.getData(input);
 171         outputBuilder.setData(result.getResult());
 172         outputBuilder.setPagination(
 173                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.faultcurrent.list.output.PaginationBuilder(
 174                         result.getPagination()).build());
 175         return outputBuilder;
 176     }
 177
 178     @Override
 179     public ReadFaultlogListOutputBuilder readFaultLogList(EntityInput input) {
 180         ReadFaultlogListOutputBuilder outputBuilder = new ReadFaultlogListOutputBuilder();
 181         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.faultlog.list.output.Data> result =
 182                 this.eventRWFaultLog.getData(input);
 183         outputBuilder.setData(result.getResult());
 184         outputBuilder.setPagination(
 185                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.faultlog.list.output.PaginationBuilder(
 186                         result.getPagination()).build());
 187         return outputBuilder;
 188     }
 189
 190     @Override
 191     public ReadCmlogListOutputBuilder readCMLogList(EntityInput input) {
 192         ReadCmlogListOutputBuilder outputBuilder = new ReadCmlogListOutputBuilder();
 193         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.cmlog.list.output.Data> result =
 194                 this.eventRWCMLog.getData(input);
 195         outputBuilder.setData(result.getResult());
 196         outputBuilder.setPagination(
 197                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.cmlog.list.output.PaginationBuilder(
 198                         result.getPagination()).build());
 199         return outputBuilder;
 200     }
 201
 202     @Override
 203     public ReadMaintenanceListOutputBuilder readMaintenanceList(EntityInput input) {
 204         ReadMaintenanceListOutputBuilder outputBuilder = new ReadMaintenanceListOutputBuilder();
 205         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.maintenance.list.output.Data> result =
 206                 this.maintenanceRW.getData(input);
 207         outputBuilder.setData(result.getResult());
 208         outputBuilder.setPagination(
 209                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.maintenance.list.output.PaginationBuilder(
 210                         result.getPagination()).build());
 211         return outputBuilder;
 212     }
 213
 214     @Override
 215     public ReadMediatorServerListOutputBuilder readMediatorServerList(EntityInput input) {
 216
 217         ReadMediatorServerListOutputBuilder outputBuilder = new ReadMediatorServerListOutputBuilder();
 218         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.mediator.server.list.output.Data> result =
 219                 this.mediatorserverRW.getData(input);
 220         outputBuilder.setData(result.getResult());
 221         outputBuilder.setPagination(
 222                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.mediator.server.list.output.PaginationBuilder(
 223                         result.getPagination()).build());
 224         return outputBuilder;
 225     }
 226
 227     @Override
 228     public ReadNetworkElementConnectionListOutputBuilder readNetworkElementConnectionList(EntityInput input) {
 229         ReadNetworkElementConnectionListOutputBuilder outputBuilder =
 230                 new ReadNetworkElementConnectionListOutputBuilder();
 231         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.network.element.connection.list.output.Data> result =
 232                 this.networkelementConnectionRW.getData(input);
 233         outputBuilder.setData(result.getResult());
 234         outputBuilder.setPagination(
 235                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.network.element.connection.list.output.PaginationBuilder(
 236                         result.getPagination()).build());
 237         return outputBuilder;
 238     }
 239
 240     @Override
 241     public ReadInventoryListOutputBuilder readInventoryList(EntityInput input) {
 242         ReadInventoryListOutputBuilder outputBuilder = new ReadInventoryListOutputBuilder();
 243         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.inventory.list.output.Data> result =
 244                 this.equipmentRW.getData(input);
 245         outputBuilder.setData(result.getResult());
 246         outputBuilder.setPagination(
 247                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.inventory.list.output.PaginationBuilder(
 248                         result.getPagination()).build());
 249         return outputBuilder;
 250     }
 251
 252     @Override
 253     public ReadInventoryDeviceListOutputBuilder readInventoryDeviceList(EntityInput input) {
 254         ReadInventoryDeviceListOutputBuilder outputBuilder = new ReadInventoryDeviceListOutputBuilder();
 255         QueryResult<String> result = this.equipmentRW.getDataDeviceList(input);
 256         outputBuilder.setPagination(
 257                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.inventory.device.list.output.PaginationBuilder(
 258                         result.getPagination()).build());
 259         outputBuilder.setData(result.getResultSet());
 260         return outputBuilder;
 261     }
 262
 263     @Override
 264     public ReadConnectionlogListOutputBuilder readConnectionlogList(EntityInput input) {
 265         ReadConnectionlogListOutputBuilder outputBuilder = new ReadConnectionlogListOutputBuilder();
 266         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.connectionlog.list.output.Data> result =
 267                 this.connectionlogRW.getData(input);
 268         outputBuilder.setData(result.getResult());
 269         outputBuilder.setPagination(
 270                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.connectionlog.list.output.PaginationBuilder(
 271                         result.getPagination()).build());
 272         return outputBuilder;
 273     }
 274
 275     @Override
 276     public ReadEventlogListOutputBuilder readEventlogList(EntityInput input) throws IOException {
 277         ReadEventlogListOutputBuilder outputBuilder = new ReadEventlogListOutputBuilder();
 278         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.eventlog.list.output.Data> result =
 279                 this.eventlogRW.getData(input);
 280         outputBuilder.setData(result.getResult());
 281         outputBuilder.setPagination(
 282                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.eventlog.list.output.PaginationBuilder(
 283                         result.getPagination()).build());
 284         return outputBuilder;
 285     }
 286
 287     @Override
 288     public ReadPmdata15mListOutputBuilder readPmdata15mList(EntityInput input) {
 289         ReadPmdata15mListOutputBuilder outputBuilder = new ReadPmdata15mListOutputBuilder();
 290         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._15m.list.output.Data> result =
 291                 this.pm15mRW.getData(input);
 292         LOG.debug("Read data: readPmdata15mList: {}", result);
 293         outputBuilder.setData(result.getResult());
 294         outputBuilder.setPagination(
 295                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._15m.list.output.PaginationBuilder(
 296                         result.getPagination()).build());
 297         return outputBuilder;
 298     }
 299
 300     @Override
 301     public ReadPmdata24hListOutputBuilder readPmdata24hList(EntityInput input) {
 302         ReadPmdata24hListOutputBuilder outputBuilder = new ReadPmdata24hListOutputBuilder();
 303         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._24h.list.output.Data> result =
 304                 this.pm24hRW.getData(input);
 305         outputBuilder.setData(result.getResult());
 306         outputBuilder.setPagination(
 307                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._24h.list.output.PaginationBuilder(
 308                         result.getPagination()).build());
 309         return outputBuilder;
 310     }
 311
 312     @Override
 313     public ReadPmdata15mLtpListOutputBuilder readPmdata15mLtpList(EntityInput input) throws IOException {
 314         ReadPmdata15mLtpListOutputBuilder outputBuilder = new ReadPmdata15mLtpListOutputBuilder();
 315         QueryResult<String> result = this.pm15mRW.getDataLtpList(input);
 316         outputBuilder.setPagination(
 317                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._15m.ltp.list.output.PaginationBuilder(
 318                         result.getPagination()).build());
 319         outputBuilder.setData(result.getResultSet());
 320         return outputBuilder;
 321     }
 322
 323     @Override
 324     public ReadPmdata15mDeviceListOutputBuilder readPmdata15mDeviceList(EntityInput input) throws IOException {
 325         ReadPmdata15mDeviceListOutputBuilder outputBuilder = new ReadPmdata15mDeviceListOutputBuilder();
 326         QueryResult<String> result = this.pm15mRW.getDataDeviceList(input);
 327         outputBuilder.setPagination(
 328                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._15m.device.list.output.PaginationBuilder(
 329                         result.getPagination()).build());
 330         outputBuilder.setData(result.getResultSet());
 331         return outputBuilder;
 332     }
 333
 334     @Override
 335     public ReadPmdata24hLtpListOutputBuilder readPmdata24hLtpList(EntityInput input) throws IOException {
 336
 337         QueryResult<String> result = this.pm24hRW.getDataLtpList(input);
 338
 339         ReadPmdata24hLtpListOutputBuilder outputBuilder = new ReadPmdata24hLtpListOutputBuilder();
 340         new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._24h.ltp.list.output.PaginationBuilder();
 341         outputBuilder.setPagination(
 342                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._24h.ltp.list.output.PaginationBuilder(
 343                         result.getPagination()).build());
 344         outputBuilder.setData(result.getResultSet());
 345         return outputBuilder;
 346     }
 347
 348     @Override
 349     public ReadPmdata24hDeviceListOutputBuilder readPmdata24hDeviceList(EntityInput input) throws IOException {
 350
 351         QueryResult<String> result = pm24hRW.getDataDeviceList(input);
 352
 353         ReadPmdata24hDeviceListOutputBuilder outputBuilder = new ReadPmdata24hDeviceListOutputBuilder();
 354         outputBuilder.setPagination(
 355                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._24h.device.list.output.PaginationBuilder(
 356                         result.getPagination()).build());
 357         outputBuilder.setData(result.getResultSet());
 358         return outputBuilder;
 359     }
 360
 361     @Override
 362     public ReadStatusOutputBuilder readStatus(EntityInput input) throws IOException {
 363         QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.status.output.Data> result =
 364                 readStatus.getDataStatus(input);
 365
 366         ReadStatusOutputBuilder outputBuilder = new ReadStatusOutputBuilder();
 367         outputBuilder.setData(result.getResult());
 368         return outputBuilder;
 369     }
 370
 371     @Override
 372     public CreateNetworkElementConnectionOutputBuilder createNetworkElementConnection(
 373             NetworkElementConnectionEntity input) throws IOException {
 374         String id = this.networkelementConnectionRW.updateOrInsert(input, input.getNodeId());
 375         if (id == null) {
 376             throw new IOException(EXCEPTION_UNABLE_TO_WRITE_IN_DATABASE);
 377         }
 378         CreateNetworkElementConnectionOutputBuilder builder = new CreateNetworkElementConnectionOutputBuilder();
 379         builder.setId(id).setNodeId(input.getNodeId()).setHost(input.getHost()).setPort(input.getPort())
 380                 .setUsername(input.getUsername()).setPassword(input.getPassword()).setIsRequired(input.getIsRequired())
 381                 .setCoreModelCapability(input.getCoreModelCapability()).setDeviceType(input.getDeviceType());
 382         return builder;
 383     }
 384
 385     @Override
 386     public UpdateNetworkElementConnectionOutputBuilder updateNetworkElementConnection(
 387             UpdateNetworkElementConnectionInput input) throws IOException {
 388         String id = this.networkelementConnectionRW.update(input, input.getId());
 389         if (id == null) {
 390             throw new IOException(EXCEPTION_UNABLE_TO_UPDATE_IN_DATABASE);
 391         }
 392         UpdateNetworkElementConnectionOutputBuilder builder = new UpdateNetworkElementConnectionOutputBuilder();
 393         builder.setId(id).setNodeId(input.getNodeId()).setHost(input.getHost()).setPort(input.getPort())
 394                 .setUsername(input.getUsername()).setPassword(input.getPassword())
 395                 .setCoreModelCapability(input.getCoreModelCapability()).setDeviceType(input.getDeviceType());
 396         return builder;
 397     }
 398
 399     @Override
 400     public DeleteNetworkElementConnectionOutputBuilder deleteNetworkElementConnection(
 401             DeleteNetworkElementConnectionInput input) throws IOException {
 402         boolean removed = this.networkelementConnectionRW.remove(input.getId()) > 0;
 403         if (!removed) {
 404             throw new IOException(EXCEPTION_UNABLE_TO_REMOVE_FROM_DATABASE);
 405         }
 406         return new DeleteNetworkElementConnectionOutputBuilder();
 407     }
 408
 409     @Override
 410     public DeleteMediatorServerOutputBuilder deleteMediatorServer(DeleteMediatorServerInput input) throws IOException {
 411         boolean removed = this.mediatorserverRW.remove(input.getId()) > 0;
 412         if (!removed) {
 413             throw new IOException(EXCEPTION_UNABLE_TO_REMOVE_FROM_DATABASE);
 414         }
 415         return new DeleteMediatorServerOutputBuilder();
 416     }
 417
 418     @Override
 419     public DeleteMaintenanceOutputBuilder deleteMaintenance(DeleteMaintenanceInput input) throws IOException {
 420         boolean removed = this.maintenanceRW.remove(input.getId()) > 0;
 421         if (!removed) {
 422             throw new IOException(EXCEPTION_UNABLE_TO_REMOVE_FROM_DATABASE);
 423         }
 424         return new DeleteMaintenanceOutputBuilder();
 425     }
 426
 427     @Override
 428     public UpdateMaintenanceOutputBuilder updateMaintenance(UpdateMaintenanceInput input) throws IOException {
 429         if (input.getId() == null) {
 430             throw new IOException("please give the id for updating entry");
 431         }
 432         String id = this.maintenanceRW.update(input, input.getId());
 433         if (id == null) {
 434             throw new IOException(EXCEPTION_UNABLE_TO_UPDATE_IN_DATABASE);
 435         }
 436         UpdateMaintenanceOutputBuilder builder = new UpdateMaintenanceOutputBuilder(input).setId(id);
 437         return builder;
 438     }
 439
 440     @Override
 441     public UpdateMediatorServerOutputBuilder updateMediatorServer(UpdateMediatorServerInput input) throws IOException {
 442         if (input.getId() == null) {
 443             throw new IOException("please give the id for updating entry");
 444         }
 445         String id = this.mediatorserverRW.update(input, input.getId());
 446         if (id == null) {
 447             throw new IOException(EXCEPTION_UNABLE_TO_UPDATE_IN_DATABASE);
 448         }
 449         UpdateMediatorServerOutputBuilder builder = new UpdateMediatorServerOutputBuilder();
 450         builder.setId(id).setName(input.getName()).setUrl(input.getUrl());
 451         return builder;
 452     }
 453
 454     @Override
 455     public CreateMaintenanceOutputBuilder createMaintenance(CreateMaintenanceInput input) throws IOException {
 456         String id = this.maintenanceRW.write(input, input.getNodeId());
 457         if (id == null) {
 458             throw new IOException(EXCEPTION_UNABLE_TO_WRITE_IN_DATABASE);
 459         }
 460         CreateMaintenanceOutputBuilder builder = new CreateMaintenanceOutputBuilder(input).setId(id);
 461         return builder;
 462     }
 463
 464     @Override
 465     public CreateMediatorServerOutputBuilder createMediatorServer(CreateMediatorServerInput input) throws IOException {
 466         String id = this.mediatorserverRW.write(input, null);
 467
 468         if (id == null) {
 469             throw new IOException(EXCEPTION_UNABLE_TO_WRITE_IN_DATABASE);
 470         }
 471         CreateMediatorServerOutputBuilder builder = new CreateMediatorServerOutputBuilder();
 472         builder.setId(id).setName(input.getName()).setUrl(input.getUrl());
 473         return builder;
 474     }
 475
 476     @Override
 477     public ReadGuiCutThroughEntryOutputBuilder readGuiCutThroughEntry(EntityInput input) {
 478         ReadGuiCutThroughEntryOutputBuilder outputBuilder = new ReadGuiCutThroughEntryOutputBuilder();
 479
 480         if (!guicutthroughOverride.isEmpty()) {
 481             if (input.getFilter() != null) {
 482                 // Iterate through the Filter map, get the ID and populate the GuicutThrough object accordingly.
 483                 Map<FilterKey, Filter> inputFilter = input.getFilter();
 484                 List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.gui.cut.through.entry.output.Data> gcData =
 485                         new ArrayList<>();
 486                 for (FilterKey fk : inputFilter.keySet()) {
 487                     String fkVal = inputFilter.get(fk).getFiltervalue();
 488                     if (fkVal != null) {
 489                         addGcItem(gcData, fkVal);
 490                     }
 491                     for (String fkVals : inputFilter.get(fk).getFiltervalues()) {
 492                         addGcItem(gcData, fkVals);
 493                     }
 494                 }
 495                 outputBuilder.setData(gcData);
 496             }
 497         } else {
 498             QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.gui.cut.through.entry.output.Data> result =
 499                     this.guicutthroughRW.getData(input);
 500             outputBuilder.setData(result.getResult());
 501         }
 502         outputBuilder.setPagination(
 503                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.gui.cut.through.entry.output.PaginationBuilder()
 504                         .build());
 505         return outputBuilder;
 506     }
 507
 508     private void addGcItem(
 509             List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.gui.cut.through.entry.output.Data> gcData,
 510             String value) {
 511         Guicutthrough gcItem = new GuicutthroughBuilder().setId(value).setName(value)
 512                 .setWeburi(guicutthroughOverride + "/" + value).build();
 513         org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.gui.cut.through.entry.output.DataBuilder gcDataBuilder =
 514                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.gui.cut.through.entry.output.DataBuilder(
 515                         gcItem);
 516         gcData.add(gcDataBuilder.build());
 517     }
 518
 519     @Override
 520     public boolean waitForYellowDatabaseStatus(long timeout, TimeUnit unit) {
 521         return true;
 522     }
 523
 524     @Override
 525     public DataProvider getDataProvider() {
 526         return this;
 527     }
 528
 529     @Override
 530     public HtDatabaseMaintenance getHtDatabaseMaintenance() {
 531         return this.dbMaintenanceService;
 532     }
 533
 534     @Override
 535     public HtDatabaseMediatorserver getHtDatabaseMediatorServer() {
 536         return this.dbMediatorServerService;
 537     }
 538
 539     public boolean delete(Entity e, List<Filter> filters) throws SQLException {
 540         DeleteQuery query = new DeleteQuery(e, filters);
 541         return this.dbClient.write(query.toSql());
 542
 543     }
 544
 545     public SqlDBClient getDBService() {
 546         return this.dbClient;
 547     }
 548
 549     public boolean setControllerId() throws SQLException {
 550         if (this.controllerId == null) {
 551             return true;
 552         }
 553         LOG.info("set controllerId {}", this.controllerId);
 554         String query = String.format("SELECT * FROM `%s` WHERE `id`='%s'", this.controllerTableName, this.controllerId);
 555         LOG.trace(query);
 556         ResultSet data = this.dbClient.read(query);
 557
 558         if (data == null || !data.next()) {
 559             query = String.format("INSERT INTO `%s` (`id`,`desc`) VALUES ('%s','%s')", this.controllerTableName,
 560                     this.controllerId, "");
 561             LOG.trace(query);
 562             try {
 563                 if (data != null) {
 564                     data.close();
 565                 }
 566             } catch (SQLException ignore) {
 567             }
 568             return this.dbClient.write(query);
 569         } else {
 570             this.controllerId = data.getString(0);
 571             LOG.trace("controllerId already set");
 572         }
 573         return true;
 574     }
 575
 576     public void waitForDatabaseReady(int i, TimeUnit unit) {
 577         this.dbClient.waitForYellowStatus(unit.convert(i, TimeUnit.MILLISECONDS));
 578     }
 579
 580     public String getControllerId() {
 581         return this.controllerId;
 582     }
 583
 584     @Override
 585     public HtUserdataManager getUserManager() {
 586         return this.usermanager;
 587     }
 588
 589     @Override
 590     public InventoryTreeProvider getInventoryTreeProvider() {
 591         return this.inventoryTreeProvider;
 592     }
 593
 594 }