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

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