You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/03/28 11:51:15 UTC
[6/7] ignite git commit: Removed debug code.
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 <sb...@gridgain.com>
Authored: Wed Mar 22 18:05:54 2017 +0300
Committer: sboikov <sb...@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);
}