try includeDeleted = false

akka · Sep 5, 2022 · 066b643 · 066b643
1 parent f13e344
commit 066b643
Showing 1 changed file with 13 additions and 13 deletions.
diff --git a/core/src/main/scala/akka/persistence/jdbc/query/dao/legacy/ByteArrayReadJournalDao.scala b/core/src/main/scala/akka/persistence/jdbc/query/dao/legacy/ByteArrayReadJournalDao.scala
@@ -124,19 +124,19 @@ trait OracleReadJournalDao extends ReadJournalDao {
       val theTag = s"%$tag%"
 
       val selectStatement =
-        if (readJournalConfig.includeDeleted)
-          sql"""
-            SELECT "#$ordering", "#$deleted", "#$persistenceId", "#$sequenceNumber", "#$message", "#$tags"
-            FROM (
-              SELECT * FROM #$theTableName
-              WHERE "#$tags" LIKE $theTag
-              AND "#$ordering" > $theOffset
-              AND "#$ordering" <= $maxOffset
-              ORDER BY "#$ordering"
-            )
-            WHERE rownum <= $max""".as[JournalRow]
-        else
-          sql"""
+//        if (readJournalConfig.includeDeleted)
+//          sql"""
+//            SELECT "#$ordering", "#$deleted", "#$persistenceId", "#$sequenceNumber", "#$message", "#$tags"
+//            FROM (
+//              SELECT * FROM #$theTableName
+//              WHERE "#$tags" LIKE $theTag
+//              AND "#$ordering" > $theOffset
+//              AND "#$ordering" <= $maxOffset
+//              ORDER BY "#$ordering"
+//            )
+//            WHERE rownum <= $max""".as[JournalRow]
+//        else
+        sql"""
             SELECT "#$ordering", "#$deleted", "#$persistenceId", "#$sequenceNumber", "#$message", "#$tags"
             FROM (
               SELECT * FROM #$theTableName