2 * ============LICENSE_START=======================================================
3 * ONAP : ccsdk features
4 * ================================================================================
5 * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
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
14 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
24 package org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.data;
26 import java.io.IOException;
27 import java.sql.ResultSet;
28 import java.sql.SQLException;
29 import java.util.List;
30 import java.util.concurrent.TimeUnit;
31 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.DatabaseDataProvider;
32 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.SqlDBClient;
33 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.SqlDBConfig;
34 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.data.entity.HtDatabaseEventsService;
35 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.data.entity.HtDatabaseMaintenanceService;
36 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.data.rpctypehelper.QueryResult;
37 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.database.SqlDBReaderWriter;
38 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.database.SqlDBReaderWriterUserdata;
39 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.database.SqlDBStatusReader;
40 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.query.DeleteQuery;
41 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
42 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.HtDatabaseMaintenance;
43 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.HtDatabaseMediatorserver;
44 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.HtUserdataManager;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.CreateMaintenanceInput;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.CreateMaintenanceOutputBuilder;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.CreateMediatorServerInput;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.CreateMediatorServerOutputBuilder;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.CreateNetworkElementConnectionOutputBuilder;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteMaintenanceInput;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteMaintenanceOutputBuilder;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteMediatorServerInput;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteMediatorServerOutputBuilder;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteNetworkElementConnectionInput;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.DeleteNetworkElementConnectionOutputBuilder;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.Entity;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.EntityInput;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.MaintenanceEntity;
59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.MediatorServerEntity;
60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.NetworkElementConnectionEntity;
61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadCmlogListOutputBuilder;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadConnectionlogListOutputBuilder;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadEventlogListOutputBuilder;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadFaultcurrentListOutputBuilder;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadFaultlogListOutputBuilder;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadGuiCutThroughEntryOutputBuilder;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadInventoryListOutputBuilder;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadMaintenanceListOutputBuilder;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadMediatorServerListOutputBuilder;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadNetworkElementConnectionListOutputBuilder;
71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata15mDeviceListOutputBuilder;
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata15mListOutputBuilder;
73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata15mLtpListOutputBuilder;
74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata24hDeviceListOutputBuilder;
75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata24hListOutputBuilder;
76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadPmdata24hLtpListOutputBuilder;
77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.ReadStatusOutputBuilder;
78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateMaintenanceInput;
79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateMaintenanceOutputBuilder;
80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateMediatorServerInput;
81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateMediatorServerOutputBuilder;
82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateNetworkElementConnectionInput;
83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.UpdateNetworkElementConnectionOutputBuilder;
84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.entity.input.Filter;
85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.mediator.server.list.output.Data;
86 import org.slf4j.Logger;
87 import org.slf4j.LoggerFactory;
90 public class SqlDBDataProvider extends HtDatabaseEventsService implements DatabaseDataProvider {
92 private static final Logger LOG = LoggerFactory.getLogger(SqlDBDataProvider.class);
94 private static final String EXCEPTION_UNABLE_TO_WRITE_IN_DATABASE = "unable to write data to database";
95 private static final String EXCEPTION_UNABLE_TO_UPDATE_IN_DATABASE = "unable to update data in database";
96 private static final String EXCEPTION_UNABLE_TO_REMOVE_FROM_DATABASE = "unable to remove data from database";
98 private final HtDatabaseMediatorserver dbMediatorServerService;
99 private final HtDatabaseMaintenance dbMaintenanceService;
100 private final SqlDBReaderWriter<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.mediator.server.list.output.Data> mediatorserverRW;
101 private final SqlDBReaderWriter<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.maintenance.list.output.Data> maintenanceRW;
102 private final SqlDBStatusReader readStatus;
103 private final HtUserdataManager usermanager;
106 public SqlDBReaderWriter<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.maintenance.list.output.Data> getMaintenanceReaderWriter() {
107 return this.maintenanceRW;
110 public SqlDBReaderWriter<Data> getMediatorServerReaderWriter() {
111 return this.mediatorserverRW;
114 public SqlDBDataProvider(SqlDBConfig config) {
118 public SqlDBDataProvider(SqlDBConfig config, boolean initControllerId) {
121 this.mediatorserverRW = new SqlDBReaderWriter<>(this.dbClient, Entity.MediatorServer, config.getDbSuffix(),
122 org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.mediator.server.list.output.Data.class,
123 this.controllerId).setWriteInterface(MediatorServerEntity.class);
125 this.maintenanceRW = new SqlDBReaderWriter<>(this.dbClient, Entity.Maintenancemode, config.getDbSuffix(),
126 org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.maintenance.list.output.Data.class,
127 this.controllerId).setWriteInterface(MaintenanceEntity.class);
129 this.readStatus = new SqlDBStatusReader(this.dbClient, this.controllerId);
131 this.dbMediatorServerService = new HtDatabaseMediatorserver() {
134 public List<MediatorServerEntity> getAll() {
135 return SqlDBDataProvider.this.mediatorserverRW.readAll(MediatorServerEntity.class);
138 this.dbMaintenanceService = new HtDatabaseMaintenanceService(this);
139 this.usermanager = new HtUserdataManagerImpl(new SqlDBReaderWriterUserdata(this.dbClient,
140 Entity.Userdata, config.getDbSuffix()));
141 if (initControllerId) {
143 this.setControllerId();
144 } catch (SQLException e) {
145 LOG.warn("problem setting controllerId: ", e);
151 /*-------------------------
152 * Provide access to model API
156 public ReadFaultcurrentListOutputBuilder readFaultCurrentList(EntityInput input) {
158 ReadFaultcurrentListOutputBuilder outputBuilder = new ReadFaultcurrentListOutputBuilder();
160 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.faultcurrent.list.output.Data> result =
161 this.eventRWFaultCurrent.getData(input);
162 outputBuilder.setData(result.getResult());
163 outputBuilder.setPagination(
164 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.faultcurrent.list.output.PaginationBuilder(
165 result.getPagination()).build());
166 return outputBuilder;
170 public ReadFaultlogListOutputBuilder readFaultLogList(EntityInput input) {
171 ReadFaultlogListOutputBuilder outputBuilder = new ReadFaultlogListOutputBuilder();
172 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.faultlog.list.output.Data> result =
173 this.eventRWFaultLog.getData(input);
174 outputBuilder.setData(result.getResult());
175 outputBuilder.setPagination(
176 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.faultlog.list.output.PaginationBuilder(
177 result.getPagination()).build());
178 return outputBuilder;
182 public ReadCmlogListOutputBuilder readCMLogList(EntityInput input) {
183 ReadCmlogListOutputBuilder outputBuilder = new ReadCmlogListOutputBuilder();
184 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.cmlog.list.output.Data>
186 this.eventRWCMLog.getData(input);
187 outputBuilder.setData(result.getResult());
188 outputBuilder.setPagination(
189 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.cmlog.list.output.PaginationBuilder(
190 result.getPagination()).build());
191 return outputBuilder;
195 public ReadMaintenanceListOutputBuilder readMaintenanceList(EntityInput input) {
196 ReadMaintenanceListOutputBuilder outputBuilder = new ReadMaintenanceListOutputBuilder();
197 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.maintenance.list.output.Data> result =
198 this.maintenanceRW.getData(input);
199 outputBuilder.setData(result.getResult());
200 outputBuilder.setPagination(
201 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.maintenance.list.output.PaginationBuilder(
202 result.getPagination()).build());
203 return outputBuilder;
207 public ReadMediatorServerListOutputBuilder readMediatorServerList(EntityInput input) {
209 ReadMediatorServerListOutputBuilder outputBuilder = new ReadMediatorServerListOutputBuilder();
210 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.mediator.server.list.output.Data> result =
211 this.mediatorserverRW.getData(input);
212 outputBuilder.setData(result.getResult());
213 outputBuilder.setPagination(
214 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.mediator.server.list.output.PaginationBuilder(
215 result.getPagination()).build());
216 return outputBuilder;
220 public ReadNetworkElementConnectionListOutputBuilder readNetworkElementConnectionList(EntityInput input) {
221 ReadNetworkElementConnectionListOutputBuilder outputBuilder =
222 new ReadNetworkElementConnectionListOutputBuilder();
223 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.network.element.connection.list.output.Data> result =
224 this.networkelementConnectionRW.getData(input);
225 outputBuilder.setData(result.getResult());
226 outputBuilder.setPagination(
227 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.network.element.connection.list.output.PaginationBuilder(
228 result.getPagination()).build());
229 return outputBuilder;
233 public ReadInventoryListOutputBuilder readInventoryList(EntityInput input) {
234 ReadInventoryListOutputBuilder outputBuilder = new ReadInventoryListOutputBuilder();
235 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.inventory.list.output.Data> result =
236 this.equipmentRW.getData(input);
237 outputBuilder.setData(result.getResult());
238 outputBuilder.setPagination(
239 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.inventory.list.output.PaginationBuilder(
240 result.getPagination()).build());
241 return outputBuilder;
245 public ReadConnectionlogListOutputBuilder readConnectionlogList(EntityInput input) {
246 ReadConnectionlogListOutputBuilder outputBuilder = new ReadConnectionlogListOutputBuilder();
247 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.connectionlog.list.output.Data> result =
248 this.connectionlogRW.getData(input);
249 outputBuilder.setData(result.getResult());
250 outputBuilder.setPagination(
251 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.connectionlog.list.output.PaginationBuilder(
252 result.getPagination()).build());
253 return outputBuilder;
257 public ReadEventlogListOutputBuilder readEventlogList(EntityInput input) throws IOException {
258 ReadEventlogListOutputBuilder outputBuilder = new ReadEventlogListOutputBuilder();
259 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.eventlog.list.output.Data> result =
260 this.eventlogRW.getData(input);
261 outputBuilder.setData(result.getResult());
262 outputBuilder.setPagination(
263 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.eventlog.list.output.PaginationBuilder(
264 result.getPagination()).build());
265 return outputBuilder;
269 public ReadPmdata15mListOutputBuilder readPmdata15mList(EntityInput input) {
270 ReadPmdata15mListOutputBuilder outputBuilder = new ReadPmdata15mListOutputBuilder();
271 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._15m.list.output.Data> result =
272 this.pm15mRW.getData(input);
273 LOG.debug("Read data: readPmdata15mList: {}", result);
274 outputBuilder.setData(result.getResult());
275 outputBuilder.setPagination(
276 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._15m.list.output.PaginationBuilder(
277 result.getPagination()).build());
278 return outputBuilder;
282 public ReadPmdata24hListOutputBuilder readPmdata24hList(EntityInput input) {
283 ReadPmdata24hListOutputBuilder outputBuilder = new ReadPmdata24hListOutputBuilder();
284 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._24h.list.output.Data> result =
285 this.pm24hRW.getData(input);
286 outputBuilder.setData(result.getResult());
287 outputBuilder.setPagination(
288 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._24h.list.output.PaginationBuilder(
289 result.getPagination()).build());
290 return outputBuilder;
294 public ReadPmdata15mLtpListOutputBuilder readPmdata15mLtpList(EntityInput input) throws IOException {
295 ReadPmdata15mLtpListOutputBuilder outputBuilder = new ReadPmdata15mLtpListOutputBuilder();
296 QueryResult<String> result = this.pm15mRW.getDataLtpList(input);
297 outputBuilder.setPagination(
298 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._15m.ltp.list.output.PaginationBuilder(
299 result.getPagination()).build());
300 outputBuilder.setData(result.getResult());
301 return outputBuilder;
305 public ReadPmdata15mDeviceListOutputBuilder readPmdata15mDeviceList(EntityInput input) throws IOException {
306 ReadPmdata15mDeviceListOutputBuilder outputBuilder = new ReadPmdata15mDeviceListOutputBuilder();
307 QueryResult<String> result = this.pm15mRW.getDataDeviceList(input);
308 outputBuilder.setPagination(
309 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._15m.device.list.output.PaginationBuilder(
310 result.getPagination()).build());
311 outputBuilder.setData(result.getResult());
312 return outputBuilder;
316 public ReadPmdata24hLtpListOutputBuilder readPmdata24hLtpList(EntityInput input) throws IOException {
318 QueryResult<String> result = this.pm24hRW.getDataLtpList(input);
320 ReadPmdata24hLtpListOutputBuilder outputBuilder = new ReadPmdata24hLtpListOutputBuilder();
321 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._24h.ltp.list.output.PaginationBuilder();
322 outputBuilder.setPagination(
323 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._24h.ltp.list.output.PaginationBuilder(
324 result.getPagination()).build());
325 outputBuilder.setData(result.getResult());
326 return outputBuilder;
330 public ReadPmdata24hDeviceListOutputBuilder readPmdata24hDeviceList(EntityInput input) throws IOException {
332 QueryResult<String> result = pm24hRW.getDataDeviceList(input);
334 ReadPmdata24hDeviceListOutputBuilder outputBuilder = new ReadPmdata24hDeviceListOutputBuilder();
335 outputBuilder.setPagination(
336 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.pmdata._24h.device.list.output.PaginationBuilder(
337 result.getPagination()).build());
338 outputBuilder.setData(result.getResult());
339 return outputBuilder;
343 public ReadStatusOutputBuilder readStatus() throws IOException {
344 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.status.output.Data> result =
345 readStatus.getDataStatus();
347 ReadStatusOutputBuilder outputBuilder = new ReadStatusOutputBuilder();
348 outputBuilder.setData(result.getResult());
349 return outputBuilder;
353 public CreateNetworkElementConnectionOutputBuilder createNetworkElementConnection(
354 NetworkElementConnectionEntity input) throws IOException {
355 String id = this.networkelementConnectionRW.write(input, input.getNodeId());
357 throw new IOException(EXCEPTION_UNABLE_TO_WRITE_IN_DATABASE);
359 CreateNetworkElementConnectionOutputBuilder builder = new CreateNetworkElementConnectionOutputBuilder();
360 builder.setId(id).setNodeId(input.getNodeId()).setHost(input.getHost()).setPort(input.getPort())
361 .setUsername(input.getUsername()).setPassword(input.getPassword()).setIsRequired(input.getIsRequired())
362 .setCoreModelCapability(input.getCoreModelCapability()).setDeviceType(input.getDeviceType());
367 public UpdateNetworkElementConnectionOutputBuilder updateNetworkElementConnection(
368 UpdateNetworkElementConnectionInput input) throws IOException {
369 String id = this.networkelementConnectionRW.update(input, input.getId());
371 throw new IOException(EXCEPTION_UNABLE_TO_UPDATE_IN_DATABASE);
373 UpdateNetworkElementConnectionOutputBuilder builder = new UpdateNetworkElementConnectionOutputBuilder();
374 builder.setId(id).setNodeId(input.getNodeId()).setHost(input.getHost()).setPort(input.getPort())
375 .setUsername(input.getUsername()).setPassword(input.getPassword())
376 .setCoreModelCapability(input.getCoreModelCapability()).setDeviceType(input.getDeviceType());
381 public DeleteNetworkElementConnectionOutputBuilder deleteNetworkElementConnection(
382 DeleteNetworkElementConnectionInput input) throws IOException {
383 boolean removed = this.networkelementConnectionRW.remove(input.getId()) > 0;
385 throw new IOException(EXCEPTION_UNABLE_TO_REMOVE_FROM_DATABASE);
387 return new DeleteNetworkElementConnectionOutputBuilder();
391 public DeleteMediatorServerOutputBuilder deleteMediatorServer(DeleteMediatorServerInput input) throws IOException {
392 boolean removed = this.mediatorserverRW.remove(input.getId()) > 0;
394 throw new IOException(EXCEPTION_UNABLE_TO_REMOVE_FROM_DATABASE);
396 return new DeleteMediatorServerOutputBuilder();
400 public DeleteMaintenanceOutputBuilder deleteMaintenance(DeleteMaintenanceInput input) throws IOException {
401 boolean removed = this.maintenanceRW.remove(input.getId()) > 0;
403 throw new IOException(EXCEPTION_UNABLE_TO_REMOVE_FROM_DATABASE);
405 return new DeleteMaintenanceOutputBuilder();
409 public UpdateMaintenanceOutputBuilder updateMaintenance(UpdateMaintenanceInput input) throws IOException {
410 if (input.getId() == null) {
411 throw new IOException("please give the id for updating entry");
413 String id = this.maintenanceRW.update(input, input.getId());
415 throw new IOException(EXCEPTION_UNABLE_TO_UPDATE_IN_DATABASE);
417 UpdateMaintenanceOutputBuilder builder = new UpdateMaintenanceOutputBuilder(input).setId(id);
422 public UpdateMediatorServerOutputBuilder updateMediatorServer(UpdateMediatorServerInput input) throws IOException {
423 if (input.getId() == null) {
424 throw new IOException("please give the id for updating entry");
426 String id = this.mediatorserverRW.update(input, input.getId());
428 throw new IOException(EXCEPTION_UNABLE_TO_UPDATE_IN_DATABASE);
430 UpdateMediatorServerOutputBuilder builder = new UpdateMediatorServerOutputBuilder();
431 builder.setId(id).setName(input.getName()).setUrl(input.getUrl());
436 public CreateMaintenanceOutputBuilder createMaintenance(CreateMaintenanceInput input) throws IOException {
437 String id = this.maintenanceRW.write(input, input.getNodeId());
439 throw new IOException(EXCEPTION_UNABLE_TO_WRITE_IN_DATABASE);
441 CreateMaintenanceOutputBuilder builder = new CreateMaintenanceOutputBuilder(input).setId(id);
446 public CreateMediatorServerOutputBuilder createMediatorServer(CreateMediatorServerInput input) throws IOException {
447 String id = this.mediatorserverRW.write(input, null);
450 throw new IOException(EXCEPTION_UNABLE_TO_WRITE_IN_DATABASE);
452 CreateMediatorServerOutputBuilder builder = new CreateMediatorServerOutputBuilder();
453 builder.setId(id).setName(input.getName()).setUrl(input.getUrl());
458 public ReadGuiCutThroughEntryOutputBuilder readGuiCutThroughEntry(EntityInput input) {
459 ReadGuiCutThroughEntryOutputBuilder outputBuilder = new ReadGuiCutThroughEntryOutputBuilder();
460 QueryResult<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.gui.cut.through.entry.output.Data> result =
461 this.guicutthroughRW.getData(input);
462 outputBuilder.setData(result.getResult());
463 outputBuilder.setPagination(
464 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.read.gui.cut.through.entry.output.PaginationBuilder()
466 return outputBuilder;
472 public boolean waitForYellowDatabaseStatus(long timeout, TimeUnit unit) {
477 public DataProvider getDataProvider() {
482 public HtDatabaseMaintenance getHtDatabaseMaintenance() {
483 return this.dbMaintenanceService;
487 public HtDatabaseMediatorserver getHtDatabaseMediatorServer() {
488 return this.dbMediatorServerService;
491 public boolean delete(Entity e, List<Filter> filters) throws SQLException {
492 DeleteQuery query = new DeleteQuery(e, filters);
493 return this.dbClient.write(query.toSql());
497 public SqlDBClient getDBService() {
498 return this.dbClient;
501 public boolean setControllerId() throws SQLException {
502 if (this.controllerId == null) {
505 LOG.info("set controllerId {}", this.controllerId);
507 String.format("SELECT * FROM `%s` WHERE `id`='%s';", this.controllerTableName, this.controllerId);
509 ResultSet data = this.dbClient.read(query);
511 if (data == null || !data.next()) {
512 query = String.format("INSERT INTO `%s` (`id`,`desc`) VALUES ('%s','%s')", this.controllerTableName,
513 this.controllerId, "");
515 try { data.close(); } catch (SQLException ignore) { }
516 return this.dbClient.write(query);
518 LOG.trace("controllerId already set");
523 public void waitForDatabaseReady(int i, TimeUnit unit) {
524 this.dbClient.waitForYellowStatus(unit.convert(i, TimeUnit.MILLISECONDS));
527 public String getControllerId() {
528 return this.controllerId;
532 public HtUserdataManager getUserManager() {
533 return this.usermanager;