You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by rc...@apache.org on 2021/06/28 10:29:40 UTC
[james-project] 01/04: JAMES-3516 Add threadId column to
messageIdTable and imapUidTable
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit ade4a75e8805cdf978dfa3491ef421c136e028d7
Author: quanth <hq...@linagora.com>
AuthorDate: Mon Jun 21 11:42:08 2021 +0700
JAMES-3516 Add threadId column to messageIdTable and imapUidTable
---
.../james/mailbox/cassandra/modules/CassandraMessageModule.java | 2 ++
.../apache/james/mailbox/cassandra/table/CassandraMessageIdTable.java | 4 +++-
.../org/apache/james/mailbox/cassandra/table/MessageIdToImapUid.java | 4 +++-
3 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraMessageModule.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraMessageModule.java
index 6b51570..92d6306 100644
--- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraMessageModule.java
+++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraMessageModule.java
@@ -55,6 +55,7 @@ public interface CassandraMessageModule {
.addPartitionKey(CassandraMessageIds.MAILBOX_ID, timeuuid())
.addClusteringColumn(CassandraMessageIds.IMAP_UID, bigint())
.addColumn(CassandraMessageIds.MESSAGE_ID, timeuuid())
+ .addColumn(CassandraMessageIdTable.THREAD_ID, timeuuid())
.addColumn(CassandraMessageIdTable.MOD_SEQ, bigint())
.addColumn(Flag.ANSWERED, cboolean())
.addColumn(Flag.DELETED, cboolean())
@@ -75,6 +76,7 @@ public interface CassandraMessageModule {
.addPartitionKey(CassandraMessageIds.MESSAGE_ID, timeuuid())
.addClusteringColumn(CassandraMessageIds.MAILBOX_ID, timeuuid())
.addClusteringColumn(CassandraMessageIds.IMAP_UID, bigint())
+ .addColumn(MessageIdToImapUid.THREAD_ID, timeuuid())
.addColumn(MessageIdToImapUid.MOD_SEQ, bigint())
.addColumn(Flag.ANSWERED, cboolean())
.addColumn(Flag.DELETED, cboolean())
diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/table/CassandraMessageIdTable.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/table/CassandraMessageIdTable.java
index 9ca58fa..a3ad5e6 100644
--- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/table/CassandraMessageIdTable.java
+++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/table/CassandraMessageIdTable.java
@@ -29,6 +29,8 @@ public interface CassandraMessageIdTable {
String MOD_SEQ = "modSeq";
- String[] FIELDS = { MESSAGE_ID, MAILBOX_ID, IMAP_UID, MOD_SEQ,
+ String THREAD_ID = "threadId";
+
+ String[] FIELDS = { MESSAGE_ID, MAILBOX_ID, IMAP_UID, THREAD_ID, MOD_SEQ,
Flag.ANSWERED, Flag.DELETED, Flag.DRAFT, Flag.FLAGGED, Flag.RECENT, Flag.SEEN, Flag.USER, Flag.USER_FLAGS};
}
diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/table/MessageIdToImapUid.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/table/MessageIdToImapUid.java
index 4e7fc79..8294117 100644
--- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/table/MessageIdToImapUid.java
+++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/table/MessageIdToImapUid.java
@@ -32,6 +32,8 @@ public interface MessageIdToImapUid {
String MOD_SEQ = "modSeq";
String MOD_SEQ_LOWERCASE = MOD_SEQ.toLowerCase(Locale.US);
- String[] FIELDS = { MESSAGE_ID, MAILBOX_ID, IMAP_UID, MOD_SEQ,
+ String THREAD_ID = "threadId";
+
+ String[] FIELDS = { MESSAGE_ID, MAILBOX_ID, IMAP_UID, THREAD_ID, MOD_SEQ,
Flag.ANSWERED, Flag.DELETED, Flag.DRAFT, Flag.FLAGGED, Flag.RECENT, Flag.SEEN, Flag.USER, Flag.USER_FLAGS };
}
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org