com.datastax.driver.core

Class AbstractSession

java.lang.Object

com.datastax.driver.core.AbstractSession

All Implemented Interfaces:

AsyncInitSession, Session, Closeable, AutoCloseable

public abstract class AbstractSession
extends Object
implements Session, AsyncInitSession

Abstract implementation of the Session interface. This is primarly intended to make mocking easier.

Nested Class Summary

Nested classes/interfaces inherited from interface com.datastax.driver.core.Session

Session.State

Constructor Summary

Constructors

Constructor and Description
AbstractSession()

Method Summary

Modifier and Type	Method and Description
void	close() Initiates a shutdown of this session instance and blocks until that shutdown completes.
ResultSet	execute(Statement statement) Executes the provided query.
ResultSet	execute(String query) Executes the provided query.
ResultSet	execute(String query, Object... values) Executes the provided query using the provided value.
ResultSetFuture	executeAsync(String query) Executes the provided query asynchronously.
ResultSetFuture	executeAsync(String query, Object... values) Executes the provided query asynchronously using the provided values.
PreparedStatement	prepare(RegularStatement statement) Prepares the provided query.
PreparedStatement	prepare(String query) Prepares the provided query string.
com.google.common.util.concurrent.ListenableFuture<PreparedStatement>	prepareAsync(RegularStatement statement) Prepares the provided query asynchronously.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.datastax.driver.core.AsyncInitSession

initAsync

Methods inherited from interface com.datastax.driver.core.Session

closeAsync, executeAsync, getCluster, getLoggedKeyspace, getState, init, isClosed, prepareAsync

Constructor Detail

AbstractSession

public AbstractSession()

Method Detail

execute

public ResultSet execute(String query)

Executes the provided query. This is a convenience method for execute(new SimpleStatement(query)).

Specified by:

execute in interface Session

Parameters:

query - the CQL query to execute.

Returns:

the result of the query. That result will never be null but can be empty (and will be for any non SELECT query).

execute

public ResultSet execute(String query,
                         Object... values)

Executes the provided query using the provided value. This is a convenience method for execute(new SimpleStatement(query, values)).

Specified by:

execute in interface Session

Parameters:

query - the CQL query to execute.

values - values required for the execution of query. See SimpleStatement.SimpleStatement(String, Object...) for more detail.

Returns:

the result of the query. That result will never be null but can be empty (and will be for any non SELECT query).

execute

public ResultSet execute(Statement statement)

Executes the provided query. This method blocks until at least some result has been received from the database. However, for SELECT queries, it does not guarantee that the result has been received in full. But it does guarantee that some response has been received from the database, and in particular guarantee that if the request is invalid, an exception will be thrown by this method.

Specified by:

execute in interface Session

Parameters:

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

Returns:

the result of the query. That result will never be null but can be empty (and will be for any non SELECT query).

executeAsync

public ResultSetFuture executeAsync(String query)

Executes the provided query asynchronously.

This is a convenience method for executeAsync(new SimpleStatement(query)).

Specified by:

executeAsync in interface Session

Parameters:

query - the CQL query to execute.

Returns:

a future on the result of the query.

executeAsync

public ResultSetFuture executeAsync(String query,
                                    Object... values)

Executes the provided query asynchronously using the provided values. This is a convenience method for executeAsync(new SimpleStatement(query, values)).

Specified by:

executeAsync in interface Session

Parameters:

query - the CQL query to execute.

values - values required for the execution of query. See SimpleStatement.SimpleStatement(String, Object...) for more detail.

Returns:

a future on the result of the query.

prepare

public PreparedStatement prepare(String query)

Prepares the provided query string.

Specified by:

prepare in interface Session

Parameters:

query - the CQL query string to prepare

Returns:

the prepared statement corresponding to query.

prepare

public PreparedStatement prepare(RegularStatement statement)

Prepares the provided query.

This method is essentially a shortcut for prepare(statement.getQueryString()), but note that the resulting PreparedStatement will inherit the query properties set on statement. Concretely, this means that in the following code:

   RegularStatement toPrepare = new SimpleStatement("SELECT * FROM test WHERE k=?").setConsistencyLevel(ConsistencyLevel.QUORUM);
   PreparedStatement prepared = session.prepare(toPrepare);
   session.execute(prepared.bind("someValue"));
 

the final execution will be performed with Quorum consistency.

Please note that if the same CQL statement is prepared more than once, all calls to this method will return the same PreparedStatement object but the method will still apply the properties of the prepared Statement to this object.

Specified by:

prepare in interface Session

Parameters:

statement - the statement to prepare

Returns:

the prepared statement corresponding to statement.

prepareAsync

public com.google.common.util.concurrent.ListenableFuture<PreparedStatement> prepareAsync(RegularStatement statement)

Prepares the provided query asynchronously.

This method is essentially a shortcut for prepareAsync(statement.getQueryString()), but with the additional effect that the resulting PreparedStatement will inherit the query properties set on statement.

Please note that if the same CQL statement is prepared more than once, all calls to this method will return the same PreparedStatement object but the method will still apply the properties of the prepared Statement to this object.

Specified by:

prepareAsync in interface Session

Parameters:

statement - the statement to prepare

Returns:

a future on the prepared statement corresponding to statement.

See Also:

Session.prepare(RegularStatement)

close

public void close()

Initiates a shutdown of this session instance and blocks until that shutdown completes.

This method is a shortcut for closeAsync().get().

Note that this method does not close the corresponding Cluster instance (which holds additional resources, in particular internal executors that must be shut down in order for the client program to terminate). If you want to do so, use Cluster.close(), but note that it will close all sessions created from that cluster.

Specified by:

close in interface Session

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable