testcontainers-java
1package org.testcontainers.containers;
2
3import com.datastax.oss.driver.api.core.CqlIdentifier;
4import com.datastax.oss.driver.api.core.CqlSession;
5import com.datastax.oss.driver.api.core.metadata.schema.KeyspaceMetadata;
6import org.junit.Rule;
7import org.junit.Test;
8
9import static org.assertj.core.api.Assertions.assertThat;
10
11public class CassandraServer4Test {
12
13@Rule
14public CassandraContainer<?> cassandra = new CassandraContainer<>("cassandra:4.1.1");
15
16@Test
17public void testCassandraGetContactPoint() {
18try (
19CqlSession session = CqlSession
20.builder()
21.addContactPoint(this.cassandra.getContactPoint())
22.withLocalDatacenter(this.cassandra.getLocalDatacenter())
23.build()
24) {
25session.execute(
26"CREATE KEYSPACE IF NOT EXISTS test WITH replication = \n" +
27"{'class':'SimpleStrategy','replication_factor':'1'};"
28);
29
30KeyspaceMetadata keyspace = session.getMetadata().getKeyspaces().get(CqlIdentifier.fromCql("test"));
31
32assertThat(keyspace).as("test keyspace created").isNotNull();
33}
34}
35}
36