X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=datarouter-prov%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdatarouter%2Fprovisioning%2Fbeans%2FLogRecord.java;h=70b8e6a05291935bc989feaa79499936d6f253d6;hb=94ff05ac011b5ec80142a4c9a084415bb21c6aed;hp=1853ee306f7b423a5f3445451d7ceeb026a5f098;hpb=a1cc0279360b09663c1b59fd0b89a1c2e081dfbd;p=dmaap%2Fdatarouter.git

diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/LogRecord.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/LogRecord.java
index 1853ee30..70b8e6a0 100644
--- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/LogRecord.java
+++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/LogRecord.java
@@ -59,23 +59,23 @@ public class LogRecord extends BaseLogRecord {
         Connection conn = null;
         try {
             conn = db.getConnection();
-            Statement stmt = conn.createStatement();
-            Iterator<Long[]> iter = bs.getRangeIterator();
-            PreparedStatement ps = conn.prepareStatement(sql);
-            while (iter.hasNext()) {
-                Long[] n = iter.next();
-                ps.setLong(1, n[0]);
-                ps.setLong(2, n[1]);
-                ResultSet rs = ps.executeQuery();
-                while (rs.next()) {
-                    LogRecord lr = new LogRecord(rs);
-                    os.write(lr.toString().getBytes());
+            try(Statement stmt = conn.createStatement()) {
+                Iterator<Long[]> iter = bs.getRangeIterator();
+                try(PreparedStatement ps = conn.prepareStatement(sql)) {
+                    while (iter.hasNext()) {
+                        Long[] n = iter.next();
+                        ps.setLong(1, n[0]);
+                        ps.setLong(2, n[1]);
+                        try(ResultSet rs = ps.executeQuery()) {
+                            while (rs.next()) {
+                                LogRecord lr = new LogRecord(rs);
+                                os.write(lr.toString().getBytes());
+                            }
+                            ps.clearParameters();
+                        }
+                    }
                 }
-                rs.close();
-                ps.clearParameters();
             }
-            ps.close();
-            stmt.close();
         } catch (SQLException e) {
             e.printStackTrace();
         } finally {