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