OpenSDN source code
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Classes | Public Member Functions | Private Types | Private Member Functions | Private Attributes | Static Private Attributes | List of all members
cass::cql::CqlIfImpl Class Reference

#include <cql_if_impl.h>

Collaboration diagram for cass::cql::CqlIfImpl:
Collaboration graph
[legend]

Classes

struct  SessionState
 

Public Member Functions

 CqlIfImpl (EventManager *evm, const std::vector< std::string > &cassandra_ips, int cassandra_port, const std::string &cassandra_user, const std::string &cassandra_password, bool use_ssl, const std::string &ca_certs_path, interface::CassLibrary *cci)
 
virtual ~CqlIfImpl ()
 
bool CreateKeyspaceIfNotExistsSync (const std::string &keyspace, const std::string &replication_factor, CassConsistency consistency)
 
bool UseKeyspaceSync (const std::string &keyspace, CassConsistency consistency)
 
bool UseKeyspaceSyncOnSchemaSession (const std::string &keyspace, CassConsistency consistency)
 
bool CreateTableIfNotExistsSync (const GenDb::NewCf &cf, const std::string &compaction_strategy, CassConsistency consistency)
 
bool CreateIndexIfNotExistsSync (const std::string &cfname, const std::string &column, const std::string &indexname, CassConsistency consistency, const GenDb::ColIndexMode::type index_mode)
 
bool LocatePrepareInsertIntoTable (const GenDb::NewCf &cf)
 
bool IsTablePresent (const std::string &table)
 
int IsTableStatic (const std::string &table)
 
bool IsTableDynamic (const std::string &table)
 
bool InsertIntoTableSync (std::auto_ptr< GenDb::ColList > v_columns, CassConsistency consistency)
 
bool InsertIntoTableAsync (std::auto_ptr< GenDb::ColList > v_columns, CassConsistency consistency, impl::CassAsyncQueryCallback cb)
 
bool InsertIntoTablePrepareAsync (std::auto_ptr< GenDb::ColList > v_columns, CassConsistency consistency, impl::CassAsyncQueryCallback cb)
 
bool IsInsertIntoTablePrepareSupported (const std::string &table)
 
bool SelectFromTableSync (const std::string &cfname, const GenDb::DbDataValueVec &rkey, CassConsistency consistency, GenDb::NewColVec *out)
 
bool SelectFromTableSync (const std::string &cfname, CassConsistency consistency, GenDb::ColListVec *out)
 
bool SelectFromTableClusteringKeyRangeSync (const std::string &cfname, const GenDb::DbDataValueVec &rkey, const GenDb::ColumnNameRange &ck_range, CassConsistency consistency, GenDb::NewColVec *out)
 
bool SelectFromTableClusteringKeyRangeFieldNamesSync (const std::string &cfname, const GenDb::DbDataValueVec &rkey, const GenDb::ColumnNameRange &ck_range, CassConsistency consistency, const GenDb::FieldNamesToReadVec &read_vec, GenDb::NewColVec *out)
 
bool SelectFromTableClusteringKeyRangeFieldNamesSync (const std::string &cfname, const std::vector< GenDb::DbDataValueVec > &rkeys, const GenDb::ColumnNameRange &ck_range, CassConsistency consistency, const GenDb::FieldNamesToReadVec &read_vec, GenDb::ColListVec *out)
 
bool SelectFromTableAsync (const std::string &cfname, const GenDb::DbDataValueVec &rkey, CassConsistency consistency, cass::cql::impl::CassAsyncQueryCallback cb)
 
bool SelectFromTableClusteringKeyRangeAsync (const std::string &cfname, const GenDb::DbDataValueVec &rkey, const GenDb::ColumnNameRange &ck_range, CassConsistency consistency, cass::cql::impl::CassAsyncQueryCallback cb)
 
bool SelectFromTableClusteringKeyRangeAndIndexValueAsync (const std::string &cfname, const GenDb::DbDataValueVec &rkey, const GenDb::ColumnNameRange &ck_range, const GenDb::WhereIndexInfoVec &where_vec, const GenDb::FieldNamesToReadVec &read_vec, CassConsistency consistency, cass::cql::impl::CassAsyncQueryCallback cb)
 
bool ConnectSync ()
 
bool ConnectSchemaSync ()
 
bool DisconnectSync ()
 
bool DisconnectSchemaSync ()
 
void SetRequestTimeout (uint32_t timeout_ms)
 
bool GetMetrics (Metrics *metrics) const
 

Private Types

typedef boost::unordered_map
< std::string,
impl::CassPreparedPtr > 		CassPreparedMapType
 

Private Member Functions

bool InsertIntoTableInternal (std::auto_ptr< GenDb::ColList > v_columns, CassConsistency consistency, bool sync, impl::CassAsyncQueryCallback cb)
 
bool GetPrepareInsertIntoTable (const std::string &table_name, impl::CassPreparedPtr *prepared) const
 
bool PrepareInsertIntoTableSync (const GenDb::NewCf &cf, impl::CassPreparedPtr *prepared)
 
bool InsertIntoTablePrepareInternal (std::auto_ptr< GenDb::ColList > v_columns, CassConsistency consistency, bool sync, impl::CassAsyncQueryCallback cb)
 

Private Attributes

EventManager * evm_
 
interface::CassLibrary * cci_
 
impl::CassClusterPtr cluster_
 
impl::CassSslPtr ssl_
 
impl::CassSessionPtr session_
 
impl::CassSessionPtr schema_session_
 
tbb::atomic< SessionState::type > session_state_
 
tbb::atomic< SessionState::type > schema_session_state_
 
std::string schema_contact_point_
 
std::string keyspace_
 
int io_thread_count_
 
CassPreparedMapType insert_prepared_map_
 
tbb::mutex map_mutex_
 

Static Private Attributes

static const char * kQCreateKeyspaceIfNotExists
 
static const char * kQUseKeyspace
 
static const char * kTaskName
 
static const int kTaskInstance = -1
 

Detailed Description

Definition at line 229 of file cql_if_impl.h.

Member Typedef Documentation

typedef boost::unordered_map<std::string, impl::CassPreparedPtr> cass::cql::CqlIfImpl::CassPreparedMapType
private

Definition at line 349 of file cql_if_impl.h.

Constructor & Destructor Documentation

cass::cql::CqlIfImpl::CqlIfImpl ( EventManager *  evm,
const std::vector< std::string > &  cassandra_ips,
int  cassandra_port,
const std::string &  cassandra_user,
const std::string &  cassandra_password,
bool  use_ssl,
const std::string &  ca_certs_path,
interface::CassLibrary *  cci 
)

Definition at line 1846 of file cql_if.cc.

Here is the call graph for this function:

cass::cql::CqlIfImpl::~CqlIfImpl ( )
virtual

Definition at line 1904 of file cql_if.cc.

Member Function Documentation

bool cass::cql::CqlIfImpl::ConnectSchemaSync ( )

Definition at line 2281 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::ConnectSync ( )

Definition at line 2308 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::CreateIndexIfNotExistsSync ( const std::string &  cfname,
const std::string &  column,
const std::string &  indexname,
CassConsistency  consistency,
const GenDb::ColIndexMode::type  index_mode 
)

Definition at line 2007 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::CreateKeyspaceIfNotExistsSync ( const std::string &  keyspace,
const std::string &  replication_factor,
CassConsistency  consistency 
)

Definition at line 1911 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::CreateTableIfNotExistsSync ( const GenDb::NewCf &  cf,
const std::string &  compaction_strategy,
CassConsistency  consistency 
)

Definition at line 1972 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::DisconnectSchemaSync ( )

Definition at line 2342 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::DisconnectSync ( )

Definition at line 2329 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::GetMetrics ( Metrics *  metrics) const

Definition at line 2356 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::GetPrepareInsertIntoTable ( const std::string &  table_name,
impl::CassPreparedPtr *  prepared 
) const
private

Definition at line 2038 of file cql_if.cc.

bool cass::cql::CqlIfImpl::InsertIntoTableAsync ( std::auto_ptr< GenDb::ColList >  v_columns,
CassConsistency  consistency,
impl::CassAsyncQueryCallback  cb 
)

Definition at line 2154 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::InsertIntoTableInternal ( std::auto_ptr< GenDb::ColList >  v_columns,
CassConsistency  consistency,
bool  sync,
impl::CassAsyncQueryCallback  cb 
)
private

Definition at line 2404 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::InsertIntoTablePrepareAsync ( std::auto_ptr< GenDb::ColList >  v_columns,
CassConsistency  consistency,
impl::CassAsyncQueryCallback  cb 
)

Definition at line 2159 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::InsertIntoTablePrepareInternal ( std::auto_ptr< GenDb::ColList >  v_columns,
CassConsistency  consistency,
bool  sync,
impl::CassAsyncQueryCallback  cb 
)
private

Definition at line 2458 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::InsertIntoTableSync ( std::auto_ptr< GenDb::ColList >  v_columns,
CassConsistency  consistency 
)

Definition at line 2149 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::IsInsertIntoTablePrepareSupported ( const std::string &  table)

Definition at line 2168 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::IsTableDynamic ( const std::string &  table)

Definition at line 2145 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::IsTablePresent ( const std::string &  table)

Definition at line 2050 of file cql_if.cc.

Here is the call graph for this function:

int cass::cql::CqlIfImpl::IsTableStatic ( const std::string &  table)

Definition at line 2058 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::LocatePrepareInsertIntoTable ( const GenDb::NewCf &  cf)

Definition at line 2019 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::PrepareInsertIntoTableSync ( const GenDb::NewCf &  cf,
impl::CassPreparedPtr *  prepared 
)
private

Definition at line 2428 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::SelectFromTableAsync ( const std::string &  cfname,
const GenDb::DbDataValueVec &  rkey,
CassConsistency  consistency,
cass::cql::impl::CassAsyncQueryCallback  cb 
)

Definition at line 2074 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::SelectFromTableClusteringKeyRangeAndIndexValueAsync ( const std::string &  cfname,
const GenDb::DbDataValueVec &  rkey,
const GenDb::ColumnNameRange &  ck_range,
const GenDb::WhereIndexInfoVec &  where_vec,
const GenDb::FieldNamesToReadVec &  read_vec,
CassConsistency  consistency,
cass::cql::impl::CassAsyncQueryCallback  cb 
)

Definition at line 2099 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::SelectFromTableClusteringKeyRangeAsync ( const std::string &  cfname,
const GenDb::DbDataValueVec &  rkey,
const GenDb::ColumnNameRange &  ck_range,
CassConsistency  consistency,
cass::cql::impl::CassAsyncQueryCallback  cb 
)

Definition at line 2123 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::SelectFromTableClusteringKeyRangeFieldNamesSync ( const std::string &  cfname,
const GenDb::DbDataValueVec &  rkey,
const GenDb::ColumnNameRange &  ck_range,
CassConsistency  consistency,
const GenDb::FieldNamesToReadVec &  read_vec,
GenDb::NewColVec *  out 
)

Definition at line 2222 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::SelectFromTableClusteringKeyRangeFieldNamesSync ( const std::string &  cfname,
const std::vector< GenDb::DbDataValueVec > &  rkeys,
const GenDb::ColumnNameRange &  ck_range,
CassConsistency  consistency,
const GenDb::FieldNamesToReadVec &  read_vec,
GenDb::ColListVec *  out 
)

Definition at line 2238 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::SelectFromTableClusteringKeyRangeSync ( const std::string &  cfname,
const GenDb::DbDataValueVec &  rkey,
const GenDb::ColumnNameRange &  ck_range,
CassConsistency  consistency,
GenDb::NewColVec *  out 
)

Definition at line 2255 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::SelectFromTableSync ( const std::string &  cfname,
const GenDb::DbDataValueVec &  rkey,
CassConsistency  consistency,
GenDb::NewColVec *  out 
)

Definition at line 2173 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::SelectFromTableSync ( const std::string &  cfname,
CassConsistency  consistency,
GenDb::ColListVec *  out 
)

Definition at line 2198 of file cql_if.cc.

Here is the call graph for this function:

void cass::cql::CqlIfImpl::SetRequestTimeout ( uint32_t  timeout_ms)

Definition at line 2276 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::UseKeyspaceSync ( const std::string &  keyspace,
CassConsistency  consistency 
)

Definition at line 1950 of file cql_if.cc.

Here is the call graph for this function:

bool cass::cql::CqlIfImpl::UseKeyspaceSyncOnSchemaSession ( const std::string &  keyspace,
CassConsistency  consistency 
)

Definition at line 1928 of file cql_if.cc.

Here is the call graph for this function:

Member Data Documentation

interface::CassLibrary* cass::cql::CqlIfImpl::cci_
private

Definition at line 338 of file cql_if_impl.h.

impl::CassClusterPtr cass::cql::CqlIfImpl::cluster_
private

Definition at line 339 of file cql_if_impl.h.

EventManager* cass::cql::CqlIfImpl::evm_
private

Definition at line 337 of file cql_if_impl.h.

CassPreparedMapType cass::cql::CqlIfImpl::insert_prepared_map_
private

Definition at line 350 of file cql_if_impl.h.

int cass::cql::CqlIfImpl::io_thread_count_
private

Definition at line 347 of file cql_if_impl.h.

std::string cass::cql::CqlIfImpl::keyspace_
private

Definition at line 346 of file cql_if_impl.h.

const char * cass::cql::CqlIfImpl::kQCreateKeyspaceIfNotExists
staticprivate

Definition at line 324 of file cql_if_impl.h.

const char * cass::cql::CqlIfImpl::kQUseKeyspace
staticprivate

Definition at line 325 of file cql_if_impl.h.

const int cass::cql::CqlIfImpl::kTaskInstance = -1
staticprivate

Definition at line 327 of file cql_if_impl.h.

const char * cass::cql::CqlIfImpl::kTaskName
staticprivate

Definition at line 326 of file cql_if_impl.h.

tbb::mutex cass::cql::CqlIfImpl::map_mutex_
mutableprivate

Definition at line 351 of file cql_if_impl.h.

std::string cass::cql::CqlIfImpl::schema_contact_point_
private

Definition at line 345 of file cql_if_impl.h.

impl::CassSessionPtr cass::cql::CqlIfImpl::schema_session_
private

Definition at line 342 of file cql_if_impl.h.

tbb::atomic<SessionState::type> cass::cql::CqlIfImpl::schema_session_state_
private

Definition at line 344 of file cql_if_impl.h.

impl::CassSessionPtr cass::cql::CqlIfImpl::session_
private

Definition at line 341 of file cql_if_impl.h.

tbb::atomic<SessionState::type> cass::cql::CqlIfImpl::session_state_
private

Definition at line 343 of file cql_if_impl.h.

impl::CassSslPtr cass::cql::CqlIfImpl::ssl_
private

Definition at line 340 of file cql_if_impl.h.

The documentation for this class was generated from the following files: