ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [13/34] ignite git commit: Removed debug code.
Date Thu, 30 Mar 2017 17:25:23 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/c4e7b4e4
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c4e7b4e4
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c4e7b4e4

Branch: refs/heads/ignite-3477-master
Commit: c4e7b4e4756dcee74d4710ae960c73f0f53d6b66
Parents: 594cd3e
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Mar 22 18:05:54 2017 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Committed: Wed Mar 29 19:29:36 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/c4e7b4e4/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 72d73ba..83d7e55 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
@@ -438,8 +438,6 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K,
V>,
 
                 PreparedStatement stmt = null;
 
-                ResultSet rs = null;
-
                 try {
                     conn = openConnection(true);
 
@@ -461,7 +459,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);
@@ -470,14 +468,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