org.teiid.cassandra

Class BaseCassandraConnection

java.lang.Object

org.teiid.cassandra.BaseCassandraConnection

All Implemented Interfaces:

Connection, CassandraConnection

Direct Known Subclasses:

CassandraConnectionImpl

public abstract class BaseCassandraConnection
extends Object
implements CassandraConnection

Constructor Summary

Constructors

Constructor and Description
BaseCassandraConnection(CassandraConfiguration config)
BaseCassandraConnection(CassandraConfiguration config, com.datastax.driver.core.Metadata metadata)

Method Summary

Modifier and Type	Method and Description
void	close()
com.datastax.driver.core.ResultSetFuture	executeBatch(List<String> updates) Execute a batch of updates
com.datastax.driver.core.ResultSetFuture	executeBatch(String update, List<Object[]> values) Execute a bulk update
com.datastax.driver.core.ResultSetFuture	executeQuery(String query) Executes a CQL query.
com.datastax.driver.core.VersionNumber	getVersion() Get the version in use for this connection
com.datastax.driver.core.KeyspaceMetadata	keyspaceInfo() Returns metadata about Cassandra keyspace (column families, columns metadata etc.)

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseCassandraConnection

public BaseCassandraConnection(CassandraConfiguration config)

BaseCassandraConnection

public BaseCassandraConnection(CassandraConfiguration config,
                               com.datastax.driver.core.Metadata metadata)

Method Detail

executeQuery

public com.datastax.driver.core.ResultSetFuture executeQuery(String query)

Description copied from interface: CassandraConnection

Executes a CQL query.

Specified by:

executeQuery in interface CassandraConnection

keyspaceInfo

public com.datastax.driver.core.KeyspaceMetadata keyspaceInfo()
                                                       throws TranslatorException

Description copied from interface: CassandraConnection

Returns metadata about Cassandra keyspace (column families, columns metadata etc.)

Specified by:

keyspaceInfo in interface CassandraConnection

Throws:

TranslatorException

executeBatch

public com.datastax.driver.core.ResultSetFuture executeBatch(List<String> updates)

Description copied from interface: CassandraConnection

Execute a batch of updates

Specified by:

executeBatch in interface CassandraConnection

Returns:

executeBatch

public com.datastax.driver.core.ResultSetFuture executeBatch(String update,
                                                             List<Object[]> values)

Description copied from interface: CassandraConnection

Execute a bulk update

Specified by:

executeBatch in interface CassandraConnection

Returns:

getVersion

public com.datastax.driver.core.VersionNumber getVersion()

Description copied from interface: CassandraConnection

Get the version in use for this connection

Specified by:

getVersion in interface CassandraConnection

Returns:

close

public void close()

Specified by:

close in interface Connection