Package database.impl

Class Cassandra

java.lang.Object
database.Database
database.impl.Cassandra
public class Cassandra extends Database

  • Constructor Details

  • 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