ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [6/7] ignite git commit: Removed debug code.
Date Tue, 28 Mar 2017 11:51:15 GMT
Removed debug code.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/31dea236
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/31dea236
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/31dea236

Branch: refs/heads/ignite-3477-master
Commit: 31dea23645c3070a329985eceb737f6c352fe100
Parents: d16a487
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Mar 22 18:05:54 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Mar 22 18:05:54 2017 +0300

----------------------------------------------------------------------
 .../ignite/cache/store/jdbc/CacheAbstractJdbcStore.java | 12 +-----------
 1 file changed, 1 insertion(+), 11 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/31dea236/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
index 9077523..a978d86 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
@@ -437,8 +437,6 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
 
                 PreparedStatement stmt = null;
 
-                ResultSet rs = null;
-
                 try {
                     conn = openConnection(true);
 
@@ -460,7 +458,7 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
                             for (int j = 0; j < i; j++)
                                 stmt.setObject(idx++, upperBound[j]);
 
-                    rs = stmt.executeQuery();
+                    ResultSet rs = stmt.executeQuery();
 
                     while (rs.next()) {
                         K key = buildObject(em.cacheName, em.keyType(), em.keyKind(), em.keyColumns(),
em.keyCols, em.loadColIdxs, rs);
@@ -469,14 +467,6 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
                         clo.apply(key, val);
                     }
                 }
-                catch (NullPointerException e){
-                    //todo only for investigation
-                    System.out.println("Got NPE");
-
-                    e.printStackTrace();
-
-                    System.out.println("thread:" + Thread.currentThread().getName() + " conn:"
+ conn + " stmt:" + stmt + " rs:" + rs);
-                }
                 catch (SQLException e) {
                     throw new IgniteCheckedException("Failed to load cache", e);
                 }


Mime
View raw message