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

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