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