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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
