<dependency>
<groupId>org.apache.cassandra</groupId>
<artifactId>cassandra-driver-core</artifactId>
<version>3.11.0</version>
</dependency>
<dependency>
<groupId>com.github.nosan</groupId>
<artifactId>cassandra-jdbc-driver-parent</artifactId>
<version>1.1.0</version>
</dependency>
import com.github.nosan.embedded.cassandra.api.CassandraBuilder;
import com.github.nosan.embedded.cassandra.api.CassandraSource;
import com.github.nosan.embedded.cassandra.spring.EmbeddedCassandra;
import com.github.nosan.embedded.cassandra.spring.EmbeddedCassandraBuilder;
import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.CqlSessionBuilder;
import com.github.nosan.embedded.cassandra.api.CassandraContext;
import com.github.nosan.embedded.cassandra.api.DataDirectoryCustomizer;
public class CassandraConfiguration {
@Bean
public CassandraSource cassandraSource() {
return new EmbeddedCassandraBuilder()
.setVersion("3.11.0")
.setDataDirectory(new File("data/directory"))
.build();
}
@Bean
public CassandraBuilder cassandraBuilder() {
return new CassandraBuilder()
.withTarball(cassandraSource().getCassandra())
.withJvmOptions("-Xmx512m", "-Xms512m");
}
@Bean
public EmbeddedCassandra embeddedCassandra() {
return new EmbeddedCassandra(cassandraBuilder());
}
@Bean
public CqlSession cqlSession() {
CqlSessionBuilder builder = CqlSession.builder();
return builder.build();
}
}
try (Connection connection = DriverManager.getConnection("jdbc:cassandra://localhost:9042/")) {
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("SELECT * FROM users");
while (resultSet.next()) {
}
} catch (SQLException ex) {
}
