Package database.impl

Class Cassandra

java.lang.Object

database.Database

database.impl.Cassandra

public class Cassandra
extends Database

Field Summary

Fields inherited from class database.Database

databaseName, host, password, port, username

Constructor Summary

Constructors

Constructor	Description
Cassandra(Configuration conf)
Cassandra(String host, Integer port, String username, String password, String databaseName)

Method Summary

Modifier and Type	Method	Description
void	connect()
void	createDatabaseIfNotExists()	Creates the keyspace if not exists.
void	disconnect()
void	dropDatabaseIfExists()	Deletes keyspace if exists previously.
com.datastax.oss.driver.api.core.cql.ResultSet	execute(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)
CompletionStage<com.datastax.oss.driver.api.core.cql.AsyncResultSet>	executeAsync(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)	Executes a CQL query implementing semaphore strategy to throttle async writes for congestion control.
CompletionStage<com.datastax.oss.driver.api.core.cql.AsyncResultSet>	executeAsyncWithSession(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)	Executes a bound CQL query implementing semaphore strategy to throttle async writes for congestion control.
com.datastax.oss.driver.api.core.CqlSession	getSession()

Methods inherited from class database.Database

getDatabaseName, getHost, getPassword, getPort, getUsername

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Cassandra

public Cassandra(Configuration conf)

Cassandra

public Cassandra(String host,
 Integer port,
 String username,
 String password,
 String databaseName)

Method Details

connect

public void connect()
             throws DBInitException

Specified by:

connect in class Database

Throws:

DBInitException

disconnect

public void disconnect()

Specified by:

disconnect in class Database

dropDatabaseIfExists

public void dropDatabaseIfExists()

Deletes keyspace if exists previously.

Specified by:

dropDatabaseIfExists in class Database

createDatabaseIfNotExists

public void createDatabaseIfNotExists()

Creates the keyspace if not exists.

Specified by:

createDatabaseIfNotExists in class Database

execute

public com.datastax.oss.driver.api.core.cql.ResultSet execute(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)

Specified by:

execute in class Database

executeAsync

public CompletionStage<com.datastax.oss.driver.api.core.cql.AsyncResultSet> executeAsync(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)

Executes a CQL query implementing semaphore strategy to throttle async writes for congestion control. See also this and this.

Specified by:

executeAsync in class Database

Parameters:

statement - the CQL query to execute (that can be any Statement).

Returns:

a CompletionStage.

executeAsyncWithSession

public CompletionStage<com.datastax.oss.driver.api.core.cql.AsyncResultSet> executeAsyncWithSession(com.datastax.oss.driver.api.core.cql.SimpleStatement statement)

Executes a bound CQL query implementing semaphore strategy to throttle async writes for congestion control. See also this and this.

Specified by:

executeAsyncWithSession in class Database

Parameters:

statement - the CQL query to execute (that can be any Statement).

Returns:

a CompletionStage.

getSession

public com.datastax.oss.driver.api.core.CqlSession getSession()

Specified by:

getSession in class Database