com.baidu.hugegraph.backend.store.cassandra

Class CassandraSessionPool.Session

java.lang.Object

com.baidu.hugegraph.backend.store.BackendSession

com.baidu.hugegraph.backend.store.cassandra.CassandraSessionPool.Session

Enclosing class:

CassandraSessionPool

public final class CassandraSessionPool.Session
extends BackendSession

The Session class is a wrapper of driver Session Expect every thread hold a its own session(wrapper)

Constructor Summary

Constructors

Constructor and Description
Session()

Method Summary

Modifier and Type	Method and Description
com.datastax.driver.core.BatchStatement	add(com.datastax.driver.core.Statement statement)
void	close()
boolean	closed()
com.datastax.driver.core.ResultSet	commit()
void	commitAsync()
com.datastax.driver.core.ResultSet	execute(com.datastax.driver.core.Statement statement)
com.datastax.driver.core.ResultSet	execute(String statement)
com.datastax.driver.core.ResultSet	execute(String statement, Object... args)
boolean	hasChanges()
String	keyspace()
com.datastax.driver.core.Metadata	metadata()
void	open()
boolean	opened()
com.datastax.driver.core.ResultSet	query(com.datastax.driver.core.Statement statement)
void	rollback()
Collection<com.datastax.driver.core.Statement>	statements()

Methods inherited from class com.baidu.hugegraph.backend.store.BackendSession

attach, closeable, detach, txState, txState

Methods inherited from class java.lang.Object

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

Constructor Detail

Session

public Session()

Method Detail

add

public com.datastax.driver.core.BatchStatement add(com.datastax.driver.core.Statement statement)

rollback

public void rollback()

Specified by:

rollback in class BackendSession

commit

public com.datastax.driver.core.ResultSet commit()

Specified by:

commit in class BackendSession

commitAsync

public void commitAsync()

query

public com.datastax.driver.core.ResultSet query(com.datastax.driver.core.Statement statement)

execute

public com.datastax.driver.core.ResultSet execute(com.datastax.driver.core.Statement statement)

execute

public com.datastax.driver.core.ResultSet execute(String statement)

execute

public com.datastax.driver.core.ResultSet execute(String statement,
                                                  Object... args)

open

public void open()

opened

public boolean opened()

closed

public boolean closed()

Specified by:

closed in class BackendSession

close

public void close()

Specified by:

close in class BackendSession

hasChanges

public boolean hasChanges()

Specified by:

hasChanges in class BackendSession

statements

public Collection<com.datastax.driver.core.Statement> statements()

keyspace

public String keyspace()

metadata

public com.datastax.driver.core.Metadata metadata()