try {
return resultSet.next();
} catch (SQLException e) {
- throw new RuntimeException(e);
+ throw new DataReaderException(e);
}
}
try {
return resultSet.getObject(name);
} catch (SQLException e) {
- throw new RuntimeException(e);
+ throw new DataReaderException(e);
}
}
try {
return new FlowKey(resultSet.getString("dg_name"), resultSet.getString("dg_version"), resultSet.getString("dg_module"));
} catch (SQLException e) {
- throw new RuntimeException(e);
+ throw new DataReaderException(e);
}
}
}
@Override
public Iterable<ConfigurationEntry<FlowKey>> getEntries() {
- return new Iterable<ConfigurationEntry<FlowKey>>() {
- @Override
- public Iterator<ConfigurationEntry<FlowKey>> iterator() {
- return new ResultSetIterator();
- }
- };
+ return ResultSetIterator::new;
}
@Override
RankedAttributesResolver<FlowKey> read() {
try {
try (Connection conn = DBUtils.getConnection("sdnctl")) {
- try (PreparedStatement stmt = conn.prepareStatement(getQueryStmt())) {
- try (ResultSet res = stmt.executeQuery()) {
- if (res.next()) {
- res.beforeFirst();
- ConfigurationSet<FlowKey> resolverConfig = new ConfigurationSetAdaptor(res);
- return AbstractRankedAttributesResolverFactory.getInstance().create(resolverConfig);
- } else {
- throw new IllegalStateException();
- }
- }
- }
+ return getFlowKeyRankedAttributesResolver(conn);
}
} catch (SQLException e) {
- throw new RuntimeException(e);
+ throw new DataReaderException(e);
+ }
+ }
+
+ private RankedAttributesResolver<FlowKey> getFlowKeyRankedAttributesResolver(Connection conn) throws SQLException {
+ try (PreparedStatement stmt = conn.prepareStatement(getQueryStmt())) {
+ try (ResultSet res = stmt.executeQuery()) {
+ if (res.next()) {
+ res.beforeFirst();
+ ConfigurationSet<FlowKey> resolverConfig = new ConfigurationSetAdaptor(res);
+ return AbstractRankedAttributesResolverFactory.getInstance().create(resolverConfig);
+ } else {
+ throw new IllegalStateException();
+ }
+ }
}
}
}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : APPC
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Copyright (C) 2017 Amdocs
+ * =============================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * ECOMP is a trademark and service mark of AT&T Intellectual Property.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.appc.dg.common.impl;
+
+public class DataReaderException extends RuntimeException{
+
+ public DataReaderException(Throwable cause) {
+ super(cause);
+ }
+}