From 331730befd8782d7a994a41a65f4ae550ccb28ed Mon Sep 17 00:00:00 2001
From: madschemas <155993105+MadSchemas@users.noreply.github.com>
Date: Fri, 10 Jul 2026 09:50:39 +0300
Subject: [PATCH] [fix] Fix pt/tm versions calcs for sql selects

---
 src/main/java/ru/rt/restream/reindexer/Reindexer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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()) {