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 <[email protected]> Authored: Wed Mar 22 18:05:54 2017 +0300 Committer: Alexey Goncharuk <[email protected]> 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); }
