com.baidu.hugegraph.backend.store.cassandra

类 CassandraSessionPool.Session

java.lang.Object

com.baidu.hugegraph.backend.store.BackendSession.AbstractBackendSession

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

所有已实现的接口:

BackendSession

封闭类:

CassandraSessionPool

public final class CassandraSessionPool.Session
extends BackendSession.AbstractBackendSession

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

嵌套类概要

从接口继承的嵌套类/接口 com.baidu.hugegraph.backend.store.BackendSession

BackendSession.AbstractBackendSession

字段概要

从类继承的字段 com.baidu.hugegraph.backend.store.BackendSession.AbstractBackendSession

opened

构造器概要

构造器

构造器和说明
Session()

方法概要

限定符和类型	方法和说明
com.datastax.driver.core.BatchStatement	add(com.datastax.driver.core.Statement statement)
int	aggregateTimeout()
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()

从类继承的方法 com.baidu.hugegraph.backend.store.BackendSession.AbstractBackendSession

attach, closeable, created, detach, txState, txState, update, updated

从类继承的方法 java.lang.Object

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

从接口继承的方法 com.baidu.hugegraph.backend.store.BackendSession

reconnectIfNeeded, reset

构造器详细资料

Session

public Session()

方法详细资料

add

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

rollback

public void rollback()

commit

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

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()

指定者:

opened 在接口中 BackendSession

覆盖:

opened 在类中 BackendSession.AbstractBackendSession

closed

public boolean closed()

指定者:

closed 在接口中 BackendSession

覆盖:

closed 在类中 BackendSession.AbstractBackendSession

close

public void close()

hasChanges

public boolean hasChanges()

statements

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

keyspace

public String keyspace()

metadata

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

aggregateTimeout

public int aggregateTimeout()