Packages

final class CassandraSession extends NoSerializationVerificationNeeded

Data Access Object for Cassandra. The statements are expressed in Apache Cassandra Query Language (CQL) syntax.

See even CQL for Datastax Enterprise.

The init hook is called before the underlying session is used by other methods, so it can be used for things like creating the keyspace and tables.

All methods are non-blocking.

Source
CassandraSession.scala
Linear Supertypes
NoSerializationVerificationNeeded, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CassandraSession
  2. NoSerializationVerificationNeeded
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new CassandraSession(system: ActorSystem, sessionProvider: CqlSessionProvider, executionContext: ExecutionContext, log: LoggingAdapter, metricsCategory: String, init: (CqlSession) => Future[Done], onClose: () => Unit)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. def close(executionContext: ExecutionContext): Future[Done]

    Closes the underlying Cassandra session.

    Closes the underlying Cassandra session.

    executionContext

    when used after actor system termination, the a different execution context must be provided

  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. def executeDDL(stmt: String): Future[Done]

    Execute CQL commands to manage database resources (create, replace, alter, and drop tables, indexes, user-defined types, etc).

    Execute CQL commands to manage database resources (create, replace, alter, and drop tables, indexes, user-defined types, etc).

    The returned Future is completed when the command is done, or if the statement fails.

  10. def executeWrite(stmt: String, bindValues: AnyRef*): Future[Done]

    Prepare, bind and execute one statement in one go.

    Prepare, bind and execute one statement in one go.

    See Inserting and updating data.

    The configured write consistency level is used.

    The returned Future is completed when the statement has been successfully executed, or if it fails.

  11. def executeWrite(stmt: Statement[_]): Future[Done]

    Execute one statement.

    Execute one statement. First you must prepare the statement and bind its parameters.

    See Inserting and updating data.

    The configured write consistency level is used if a specific consistency level has not been set on the Statement.

    The returned Future is completed when the statement has been successfully executed, or if it fails.

  12. def executeWriteBatch(batch: BatchStatement): Future[Done]

    Execute several statements in a batch.

    Execute several statements in a batch. First you must prepare the statements and bind its parameters.

    See Batching data insertion and updates.

    The configured write consistency level is used if a specific consistency level has not been set on the BatchStatement.

    The returned Future is completed when the batch has been successfully executed, or if it fails.

  13. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. def prepare(stmt: String): Future[PreparedStatement]

    Create a PreparedStatement that can be bound and used in executeWrite or select multiple times.

  21. def select(stmt: String, bindValues: AnyRef*): Source[Row, NotUsed]

    Prepare, bind and execute a select statement in one go.

    Prepare, bind and execute a select statement in one go.

    See Querying data.

    The configured read consistency level is used.

    Note that you have to connect a Sink that consumes the messages from this Source and then run the stream.

  22. def select(stmt: Future[Statement[_]]): Source[Row, NotUsed]

    Execute a select statement created by prepare.

    Execute a select statement created by prepare.

    See Querying data.

    The configured read consistency level is used if a specific consistency level has not been set on the Statement.

    Note that you have to connect a Sink that consumes the messages from this Source and then run the stream.

  23. def select(stmt: Statement[_]): Source[Row, NotUsed]

    Execute a select statement.

    Execute a select statement. First you must prepare the statement and bind its parameters.

    See Querying data.

    The configured read consistency level is used if a specific consistency level has not been set on the Statement.

    Note that you have to connect a Sink that consumes the messages from this Source and then run the stream.

  24. def selectAll(stmt: String, bindValues: AnyRef*): Future[Seq[Row]]

    Prepare, bind and execute a select statement in one go.

    Prepare, bind and execute a select statement in one go. Only use this method when you know that the result is small, e.g. includes a LIMIT clause. Otherwise you should use the select method that returns a Source.

    The configured read consistency level is used.

    The returned Future is completed with the found rows.

  25. def selectAll(stmt: Statement[_]): Future[Seq[Row]]

    Execute a select statement.

    Execute a select statement. First you must prepare the statement and bind its parameters. Only use this method when you know that the result is small, e.g. includes a LIMIT clause. Otherwise you should use the select method that returns a Source.

    The configured read consistency level is used if a specific consistency level has not been set on the Statement.

    The returned Future is completed with the found rows.

  26. def selectOne(stmt: String, bindValues: AnyRef*): Future[Option[Row]]

    Prepare, bind and execute a select statement that returns one row.

    Prepare, bind and execute a select statement that returns one row.

    The configured read consistency level is used.

    The returned Future is completed with the first row, if any.

  27. def selectOne(stmt: Statement[_]): Future[Option[Row]]

    Execute a select statement that returns one row.

    Execute a select statement that returns one row. First you must prepare the statement and bind its parameters.

    The configured read consistency level is used if a specific consistency level has not been set on the Statement.

    The returned Future is completed with the first row, if any.

  28. def serverMetaData: Future[CassandraServerMetaData]

    Meta data about the Cassandra server, such as its version.

  29. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  30. def toString(): String
    Definition Classes
    AnyRef → Any
  31. def underlying(): Future[CqlSession]

    The Session of the underlying Datastax Java Driver.

    The Session of the underlying Datastax Java Driver. Can be used in case you need to do something that is not provided by the API exposed by this class. Be careful to not use blocking calls.

  32. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  33. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  34. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from NoSerializationVerificationNeeded

Inherited from AnyRef

Inherited from Any

Ungrouped