X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-xsql%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fdom%2Fxsql%2Fjdbc%2FJDBCResultSet.java;h=37eacd5595975404a03cbf0390e12994d65bbe8c;hp=5abe8a3165bacbd99daff7e1e7e732d51d8b032a;hb=8decf2dbd1e08651d98c9292ba012b3a46005549;hpb=93c9708f8a9a225fa4d814ac98c15aea41fb26ac diff --git a/opendaylight/md-sal/sal-dom-xsql/src/main/java/org/opendaylight/controller/md/sal/dom/xsql/jdbc/JDBCResultSet.java b/opendaylight/md-sal/sal-dom-xsql/src/main/java/org/opendaylight/controller/md/sal/dom/xsql/jdbc/JDBCResultSet.java index 5abe8a3165..37eacd5595 100644 --- a/opendaylight/md-sal/sal-dom-xsql/src/main/java/org/opendaylight/controller/md/sal/dom/xsql/jdbc/JDBCResultSet.java +++ b/opendaylight/md-sal/sal-dom-xsql/src/main/java/org/opendaylight/controller/md/sal/dom/xsql/jdbc/JDBCResultSet.java @@ -46,8 +46,8 @@ public class JDBCResultSet implements Serializable, ResultSet, private List tablesInQuery = new ArrayList(); private Map tablesInQueryMap = new ConcurrentHashMap(); private List fieldsInQuery = new ArrayList(); - private transient LinkedList records = new LinkedList(); - private transient Map currentRecord = null; + private transient LinkedList> records = new LinkedList<>(); + private transient Map currentRecord = null; private boolean finished = false; private int id = 0; private static Integer nextID = new Integer(0); @@ -108,7 +108,7 @@ public class JDBCResultSet implements Serializable, ResultSet, } } - public int isObjectFitCriteria(Map objValues, String tableName) { + public int isObjectFitCriteria(Map objValues, String tableName) { Map> tblCriteria = criteria .get(tableName); if (tblCriteria == null) { @@ -197,10 +197,10 @@ public class JDBCResultSet implements Serializable, ResultSet, return this.records.size(); } - public void addRecord(Map r) { + public void addRecord(Map r) { synchronized (this) { if (records == null) { - records = new LinkedList(); + records = new LinkedList<>(); } records.add(r); this.notifyAll(); @@ -208,7 +208,7 @@ public class JDBCResultSet implements Serializable, ResultSet, } public void addRecord(ArrayList hierarchy) { - Map rec = new HashMap(); + Map rec = new HashMap<>(); for (int i = hierarchy.size() - 1; i >= 0; i--) { Object element = hierarchy.get(i); for (XSQLColumn c : fieldsInQuery) { @@ -230,7 +230,7 @@ public class JDBCResultSet implements Serializable, ResultSet, public boolean next() { this.currentRecord = null; if (records == null) { - records = new LinkedList(); + records = new LinkedList<>(); } while (!finished || records.size() > 0) { synchronized (this) { @@ -260,12 +260,12 @@ public class JDBCResultSet implements Serializable, ResultSet, return false; } - public Map getCurrent() { + public Map getCurrent() { return this.currentRecord; } private void createRecord(Object data, XSQLBluePrintNode node) { - Map rec = new HashMap(); + Map rec = new HashMap<>(); for (XSQLColumn c : this.fieldsInQuery) { if (c.getTableName().equals(node.getBluePrintNodeName())) { try { @@ -285,20 +285,20 @@ public class JDBCResultSet implements Serializable, ResultSet, } public static class Record { - public Map data = new HashMap(); + public Map data = new HashMap<>(); public Object element = null; - public Map getRecord() { + public Map getRecord() { return this.data; } } - private Map collectColumnValues(Object node, XSQLBluePrintNode bpn) { - Map subChildren = XSQLODLUtils.getChildren(node); - Map result = new HashMap(); + private Map collectColumnValues(Object node, XSQLBluePrintNode bpn) { + Map subChildren = XSQLODLUtils.getChildren(node); + Map result = new HashMap<>(); for (Object stc : subChildren.values()) { if (stc.getClass().getName().endsWith("ImmutableAugmentationNode")) { - Map values = XSQLODLUtils.getChildren(stc); + Map values = XSQLODLUtils.getChildren(stc); for (Object key : values.keySet()) { Object val = values.get(key); if (val.getClass().getName().endsWith("ImmutableLeafNode")) { @@ -323,7 +323,7 @@ public class JDBCResultSet implements Serializable, ResultSet, } private void addToData(Record rec, XSQLBluePrintNode bpn, - XSQLBluePrint bluePrint, Map fullRecord) { + XSQLBluePrint bluePrint, Map fullRecord) { XSQLBluePrintNode eNodes[] = bluePrint .getBluePrintNodeByODLTableName(XSQLODLUtils .getNodeIdentiofier(rec.element)); @@ -432,7 +432,7 @@ public class JDBCResultSet implements Serializable, ResultSet, .getBluePrintNodeName()); if (this.criteria.containsKey(bluePrintNode.getBluePrintNodeName()) || bpn != null) { - Map allKeyValues = collectColumnValues(element, bpn); + Map allKeyValues = collectColumnValues(element, bpn); if (!(isObjectFitCriteria(allKeyValues, bpn.getBluePrintNodeName()) == 1)) { return EMPTY_RESULT; @@ -471,7 +471,7 @@ public class JDBCResultSet implements Serializable, ResultSet, } boolean isObjectInCriteria = true; if (bpn != null) { - Map allKeyValues = collectColumnValues(rec.element, bpn); + Map allKeyValues = collectColumnValues(rec.element, bpn); if ((isObjectFitCriteria(allKeyValues, bpn.getBluePrintNodeName()) == 1)) { addToData(rec, bpn, bluePrint, allKeyValues);