Sonar fix in LogFileReader.java

https://sonar.onap.org/project/issues?id=org.onap.dmaap.datarouter%3Aparent&open=AWHFaQoGEU5FCDfKtnUf&resolved=false&severities=BLOCKER&types=BUG

Issue-ID: DMAAP-721
Change-Id: I61a0a0b5f934ac74cd49020abcc2aca0f0c69df3
Signed-off-by: Amaresh Kumar <kamaresh@in.ibm.com>

1 files changed, 15 insertions, 15 deletions

diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java
index 8975f161..110c63de 100644
--- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java
+++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java
@@ -188,6 +188,7 @@ public class LogfileLoader extends Thread {
                         try {

                             Thread.sleep(1000L);

                         } catch (InterruptedException e) {

+                            Thread.currentThread().interrupt();

                         }

                         idle = false;

                     } else {

@@ -332,26 +333,25 @@ public class LogfileLoader extends Thread {
         Connection conn = null;

         try {

             conn = db.getConnection();

-            Statement stmt = conn.createStatement();

-            // Build a bitset of all records in the LOG_RECORDS table

-            // We need to run this SELECT in stages, because otherwise we run out of memory!

             RLEBitSet nbs = new RLEBitSet();

-            final long stepsize = 6000000L;

-            boolean go_again = true;

-            for (long i = 0; go_again; i += stepsize) {

-                String sql = String.format("select RECORD_ID from LOG_RECORDS LIMIT %d,%d", i, stepsize);

-                try(ResultSet rs = stmt.executeQuery(sql)) {

-                    go_again = false;

-                    while (rs.next()) {

-                        long n = rs.getLong("RECORD_ID");

-                        nbs.set(n);

-                        go_again = true;

+            try(Statement stmt = conn.createStatement()) {

+                // Build a bitset of all records in the LOG_RECORDS table

+                // We need to run this SELECT in stages, because otherwise we run out of memory!

+                final long stepsize = 6000000L;

+                boolean go_again = true;

+                for (long i = 0; go_again; i += stepsize) {

+                    String sql = String.format("select RECORD_ID from LOG_RECORDS LIMIT %d,%d", i, stepsize);

+                    try (ResultSet rs = stmt.executeQuery(sql)) {

+                        go_again = false;

+                        while (rs.next()) {

+                            long n = rs.getLong("RECORD_ID");

+                            nbs.set(n);

+                            go_again = true;

+                        }

                     }

                 }

             }

-            stmt.close();

             seq_set = nbs;

-

             // Compare with the range for this server

             // Determine the next ID for this set of record IDs

             RLEBitSet tbs = (RLEBitSet) nbs.clone();