You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by nn...@apache.org on 2020/04/06 22:17:52 UTC
[geode] branch develop updated: GEODE-7864: Closing the query
statements after execution. (#4873)
This is an automated email from the ASF dual-hosted git repository.
nnag pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push:
new d4b7c14 GEODE-7864: Closing the query statements after execution. (#4873)
d4b7c14 is described below
commit d4b7c1459c10ed1934080ef4a398b9d6232cfb45
Author: Nabarun Nag <na...@users.noreply.github.com>
AuthorDate: Mon Apr 6 15:17:26 2020 -0700
GEODE-7864: Closing the query statements after execution. (#4873)
---
.../java/org/apache/geode/internal/jta/CacheUtils.java | 16 +++++++++-------
1 file changed, 9 insertions(+), 7 deletions(-)
diff --git a/geode-junit/src/main/java/org/apache/geode/internal/jta/CacheUtils.java b/geode-junit/src/main/java/org/apache/geode/internal/jta/CacheUtils.java
index 530ca78..2ce567e 100644
--- a/geode-junit/src/main/java/org/apache/geode/internal/jta/CacheUtils.java
+++ b/geode-junit/src/main/java/org/apache/geode/internal/jta/CacheUtils.java
@@ -144,12 +144,13 @@ public class CacheUtils {
String sql = "select * from " + tableName;
Connection conn = ds.getConnection();
- Statement sm = conn.createStatement();
- ResultSet rs = sm.executeQuery(sql);
- while (rs.next()) {
- System.out.println("id " + rs.getString(1) + " name " + rs.getString(2));
+ try (Statement sm = conn.createStatement()) {
+ ResultSet rs = sm.executeQuery(sql);
+ while (rs.next()) {
+ System.out.println("id " + rs.getString(1) + " name " + rs.getString(2));
+ }
+ rs.close();
}
- rs.close();
conn.close();
}
@@ -159,8 +160,9 @@ public class CacheUtils {
Connection conn = ds.getConnection();
// System.out.println (" trying to drop table: " + tableName);
String sql = "drop table " + tableName;
- Statement sm = conn.createStatement();
- sm.execute(sql);
+ try (Statement sm = conn.createStatement()) {
+ sm.execute(sql);
+ }
conn.close();
}