You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2023/04/05 03:00:41 UTC

[james-project] 02/02: [FIX] Ranged search in CassandraFirstUnseenDAO was including too much results

This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit 7b064d702c9e4f11682670d6f6dae7a10fb5030f
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Tue Apr 4 17:56:15 2023 +0700

    [FIX] Ranged search in CassandraFirstUnseenDAO was including too much results
---
 .../james/mailbox/cassandra/mail/CassandraFirstUnseenDAO.java      | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraFirstUnseenDAO.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraFirstUnseenDAO.java
index 6611a13ca6..b140164294 100644
--- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraFirstUnseenDAO.java
+++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraFirstUnseenDAO.java
@@ -227,7 +227,8 @@ public class CassandraFirstUnseenDAO {
                 return listUnseen(cassandraId);
             case FROM:
                 return cassandraAsyncExecutor.executeRows(
-                    listStatement.bind()
+                    selectFromUidStatement.bind()
+                        .setLong(UID_FROM, range.getUidFrom().asLong())
                         .set(MAILBOX_ID, cassandraId.asUuid(), TypeCodecs.TIMEUUID))
                     .map(this::asMessageUid);
             case RANGE:
@@ -239,8 +240,8 @@ public class CassandraFirstUnseenDAO {
                     .map(this::asMessageUid);
             case ONE:
                 return cassandraAsyncExecutor.executeRows(
-                    selectFromUidStatement.bind()
-                        .setLong(UID_FROM, range.getUidFrom().asLong())
+                    selectOneUidStatement.bind()
+                        .setLong(UID, range.getUidFrom().asLong())
                         .set(MAILBOX_ID, cassandraId.asUuid(), TypeCodecs.TIMEUUID))
                     .map(this::asMessageUid);
             default:


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org