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