diff --git a/src/java/com/samskivert/jdbc/depot/FindAllQuery.java b/src/java/com/samskivert/jdbc/depot/FindAllQuery.java index 9965b70..30e6ba6 100644 --- a/src/java/com/samskivert/jdbc/depot/FindAllQuery.java +++ b/src/java/com/samskivert/jdbc/depot/FindAllQuery.java @@ -269,19 +269,21 @@ public abstract class FindAllQuery new KeySet(_type, keys))); PreparedStatement stmt = _builder.prepare(conn); try { + Set> got = new HashSet>(); ResultSet rs = stmt.executeQuery(); int cnt = 0, dups = 0; while (rs.next()) { T obj = _marsh.createObject(rs); - if (entities.put(_marsh.getPrimaryKey(obj), obj) != null) { + Key key = _marsh.getPrimaryKey(obj); + if (entities.put(key, obj) != null) { dups++; } + got.add(key); cnt++; } if (cnt != keys.size()) { - log.warning("Row count mismatch in second pass [origQuery=" + origStmt + - ", wanted=" + keys + ", got=" + entities.keySet() + - ", dups=" + dups + "]", new Exception()); + log.warning("Row count mismatch in second pass", "origQuery", origStmt, + "wanted", keys, "got", got, "dups", dups, new Exception()); } } finally {