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