diff --git a/src/main/java/ru/rt/restream/reindexer/Reindexer.java b/src/main/java/ru/rt/restream/reindexer/Reindexer.java
index 6213d53..79337d6 100644
--- a/src/main/java/ru/rt/restream/reindexer/Reindexer.java
+++ b/src/main/java/ru/rt/restream/reindexer/Reindexer.java
@@ -251,7 +251,7 @@ public<T> QueryResultIterator<T> execSql(String query, Class<T> itemClass) {
         }
         ReindexerNamespace<T> namespace = getNamespace(namespaceName, itemClass);
         PayloadType pt = namespace.getPayloadType();
-        long[] ptVersions = pt == null ? new long[]{0} : new long[]{pt.getVersion()};
+        long[] ptVersions = pt == null ? new long[]{0} : new long[]{pt.getVersion() ^ pt.getStateToken()};
         RequestContext ctx = binding.select(query, false, Integer.MAX_VALUE, ptVersions);
         QueryResult queryResult = ctx.getQueryResult();
         for (PayloadType payloadType : queryResult.getPayloadTypes()) {