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