You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by rc...@apache.org on 2020/07/28 03:20:47 UTC
[james-project] 19/25: JAMES-3319 Tests for CassandraMailRepository
blob deletion
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 87a0d258decc2e1102cb2ae82b02d79c4523af8e
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Fri Jul 24 11:47:55 2020 +0700
JAMES-3319 Tests for CassandraMailRepository blob deletion
Tests are conducted out both on Deduplication & Passthrough BlobStores
---
.../james/mailrepository/cassandra/CassandraMailRepositoryTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/server/mailrepository/mailrepository-cassandra/src/test/java/org/apache/james/mailrepository/cassandra/CassandraMailRepositoryTest.java b/server/mailrepository/mailrepository-cassandra/src/test/java/org/apache/james/mailrepository/cassandra/CassandraMailRepositoryTest.java
index 3011e98..9ff4496 100644
--- a/server/mailrepository/mailrepository-cassandra/src/test/java/org/apache/james/mailrepository/cassandra/CassandraMailRepositoryTest.java
+++ b/server/mailrepository/mailrepository-cassandra/src/test/java/org/apache/james/mailrepository/cassandra/CassandraMailRepositoryTest.java
@@ -19,6 +19,7 @@
package org.apache.james.mailrepository.cassandra;
+import static com.datastax.driver.core.querybuilder.QueryBuilder.select;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatCode;
@@ -29,6 +30,7 @@ import org.apache.james.backends.cassandra.utils.CassandraUtils;
import org.apache.james.backends.cassandra.versions.CassandraSchemaVersionModule;
import org.apache.james.blob.api.BlobStore;
import org.apache.james.blob.api.HashBlobId;
+import org.apache.james.blob.cassandra.BlobTables;
import org.apache.james.blob.cassandra.CassandraBlobModule;
import org.apache.james.blob.cassandra.CassandraBlobStoreFactory;
import org.apache.james.blob.mail.MimeMessageStore;
@@ -91,7 +93,7 @@ class CassandraMailRepositoryTest {
testee.remove(key1);
- assertThat(cassandra.getConf().execute("SELECT * FROM blobs;"))
+ assertThat(cassandra.getConf().execute(select().from(BlobTables.DefaultBucketBlobTable.TABLE_NAME)))
.isEmpty();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org