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