testcontainers-java

1
package org.testcontainers.containers;
2

3
import com.datastax.oss.driver.api.core.CqlIdentifier;
4
import com.datastax.oss.driver.api.core.CqlSession;
5
import com.datastax.oss.driver.api.core.metadata.schema.KeyspaceMetadata;
6
import org.junit.Rule;
7
import org.junit.Test;
8

9
import static org.assertj.core.api.Assertions.assertThat;
10

11
public class CassandraDriver3Test {
12

13
    @Rule
14
    public CassandraContainer<?> cassandra = new CassandraContainer<>("cassandra:3.11.2");
15

16
    @Test
17
    public void testCassandraGetContactPoint() {
18
        try (
19
            // cassandra {
20
            CqlSession session = CqlSession
21
                .builder()
22
                .addContactPoint(this.cassandra.getContactPoint())
23
                .withLocalDatacenter(this.cassandra.getLocalDatacenter())
24
                .build()
25
            // }
26
        ) {
27
            session.execute(
28
                "CREATE KEYSPACE IF NOT EXISTS test WITH replication = \n" +
29
                "{'class':'SimpleStrategy','replication_factor':'1'};"
30
            );
31

32
            KeyspaceMetadata keyspace = session.getMetadata().getKeyspaces().get(CqlIdentifier.fromCql("test"));
33

34
            assertThat(keyspace).as("keyspace created").isNotNull();
35
        }
36
    }
37
}
38