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