|
static void | encode_uuid (char *output, const CassUuid &uuid) |
|
static char * | decode_uuid (char *input, CassUuid *output) |
|
static const char * | DbDataType2CassType (const GenDb::DbDataType::type &db_type) |
|
static std::string | DbDataTypes2CassTypes (const GenDb::DbDataTypeVec &v_db_types) |
|
static CassConsistency | Db2CassConsistency (GenDb::DbConsistency::type dconsistency) |
|
static const char * | kQCompactionStrategy ("compaction = {'class': ""'org.apache.cassandra.db.compaction.%s'}") |
|
static const std::string | kQGCGraceSeconds ("gc_grace_seconds = 0") |
|
static const std::string | kQReadRepairChanceDTCS ("read_repair_chance = 0.0") |
|
std::string | StaticCf2CassCreateTableIfNotExists (const GenDb::NewCf &cf, const std::string &compaction_strategy) |
|
std::string | DynamicCf2CassCreateTableIfNotExists (const GenDb::NewCf &cf, const std::string &compaction_strategy, boost::system::error_code *ec) |
|
static std::string | DbColIndexMode2String (const GenDb::ColIndexMode::type index_mode) |
|
std::string | CassCreateIndexIfNotExists (const std::string &cfname, const std::string &column, const std::string &indexname, const GenDb::ColIndexMode::type index_mode) |
|
std::string | StaticCf2CassInsertIntoTable (const GenDb::ColList *v_columns) |
|
std::string | DynamicCf2CassInsertIntoTable (const GenDb::ColList *v_columns) |
|
std::string | StaticCf2CassPrepareInsertIntoTable (const GenDb::NewCf &cf) |
|
std::string | DynamicCf2CassPrepareInsertIntoTable (const GenDb::NewCf &cf, boost::system::error_code *ec) |
|
bool | StaticCf2CassPrepareBind (interface::CassLibrary *cci, CassStatement *statement, const GenDb::ColList *v_columns) |
|
bool | DynamicCf2CassPrepareBind (interface::CassLibrary *cci, CassStatement *statement, const GenDb::ColList *v_columns) |
|
static std::string | CassSelectFromTableInternal (const std::string &table, const std::vector< GenDb::DbDataValueVec > &rkeys, const GenDb::ColumnNameRange &ck_range, const GenDb::FieldNamesToReadVec &read_vec, const GenDb::WhereIndexInfoVec &where_vec) |
|
std::string | ClusteringKeyRangeAndIndexValue2CassSelectFromTable (const std::string &table, const GenDb::DbDataValueVec &rkeys, const GenDb::ColumnNameRange &ck_range, const GenDb::WhereIndexInfoVec &where_vec, const GenDb::FieldNamesToReadVec &read_vec) |
|
std::string | PartitionKey2CassSelectFromTable (const std::string &table, const GenDb::DbDataValueVec &rkeys) |
|
std::string | PartitionKeyAndClusteringKeyRange2CassSelectFromTable (const std::string &table, const GenDb::DbDataValueVec &rkeys, const GenDb::ColumnNameRange &ck_range, const GenDb::FieldNamesToReadVec &read_vec) |
|
std::string | PartitionKeyAndClusteringKeyRange2CassSelectFromTable (const std::string &table, const std::vector< GenDb::DbDataValueVec > &rkeys, const GenDb::ColumnNameRange &ck_range, const GenDb::FieldNamesToReadVec &read_vec) |
|
std::string | CassSelectFromTable (const std::string &table) |
|
static GenDb::DbDataValue | CassValue2DbDataValue (interface::CassLibrary *cci, const CassValue *cvalue) |
|
static bool | PrepareSync (interface::CassLibrary *cci, CassSession *session, const char *query, CassPreparedPtr *prepared) |
|
static bool | ExecuteQuerySyncInternal (interface::CassLibrary *cci, CassSession *session, CassStatement *qstatement, CassResultPtr *result, CassConsistency consistency) |
|
static bool | ExecuteQuerySync (interface::CassLibrary *cci, CassSession *session, const char *query, CassConsistency consistency) |
|
static bool | ExecuteQueryResultSync (interface::CassLibrary *cci, CassSession *session, const char *query, CassResultPtr *result, CassConsistency consistency) |
|
static bool | ExecuteQueryStatementSync (interface::CassLibrary *cci, CassSession *session, CassStatement *statement, CassConsistency consistency) |
|
static GenDb::DbOpResult::type | CassError2DbOpResult (CassError rc) |
|
static void | DynamicCfGetResult (interface::CassLibrary *cci, CassResultPtr *result, const GenDb::FieldNamesToReadVec &read_vec, GenDb::NewColVec *v_columns) |
|
static void | DynamicCfGetResult (interface::CassLibrary *cci, CassResultPtr *result, const GenDb::FieldNamesToReadVec &read_vec, GenDb::ColListVec *v_col_list) |
|
static void | DynamicCfGetResult (interface::CassLibrary *cci, CassResultPtr *result, size_t rk_count, size_t ck_count, GenDb::NewColVec *v_columns) |
|
void | DynamicCfGetResult (interface::CassLibrary *cci, CassResultPtr *result, size_t rk_count, size_t ck_count, GenDb::ColListVec *v_col_list) |
|
static void | StaticCfGetResult (interface::CassLibrary *cci, CassResultPtr *result, GenDb::NewColVec *v_columns) |
|
void | StaticCfGetResult (interface::CassLibrary *cci, CassResultPtr *result, size_t rk_count, GenDb::ColListVec *v_col_list) |
|
static void | OnExecuteQueryAsync (CassFuture *future, void *data) |
|
static void | ExecuteQueryAsyncInternal (interface::CassLibrary *cci, CassSession *session, const char *qid, CassStatement *qstatement, CassConsistency consistency, CassAsyncQueryCallback cb, CassQueryResultContext *rctx=NULL) |
|
static void | ExecuteQueryAsync (interface::CassLibrary *cci, CassSession *session, const char *query, CassConsistency consistency, CassAsyncQueryCallback cb) |
|
static void | ExecuteQueryStatementAsync (interface::CassLibrary *cci, CassSession *session, const char *query_id, CassStatement *qstatement, CassConsistency consistency, CassAsyncQueryCallback cb) |
|
static void | ExecuteQueryResultAsync (interface::CassLibrary *cci, CassSession *session, const char *query, CassConsistency consistency, CassAsyncQueryCallback cb, CassQueryResultContext *rctx) |
|
static bool | DynamicCfGetResultAsync (interface::CassLibrary *cci, CassSession *session, const char *query, CassConsistency consistency, impl::CassAsyncQueryCallback cb, size_t rk_count, size_t ck_count, const std::string &cfname, const GenDb::DbDataValueVec &row_key) |
|
static bool | DynamicCfGetResultSync (interface::CassLibrary *cci, CassSession *session, const char *query, const GenDb::FieldNamesToReadVec &read_vec, CassConsistency consistency, GenDb::NewColVec *v_columns) |
|
static bool | DynamicCfGetResultSync (interface::CassLibrary *cci, CassSession *session, const char *query, const GenDb::FieldNamesToReadVec &read_vec, CassConsistency consistency, GenDb::ColListVec *v_columns) |
|
static bool | DynamicCfGetResultSync (interface::CassLibrary *cci, CassSession *session, const char *query, size_t rk_count, size_t ck_count, CassConsistency consistency, GenDb::NewColVec *v_columns) |
|
static bool | DynamicCfGetResultSync (interface::CassLibrary *cci, CassSession *session, const char *query, size_t rk_count, size_t ck_count, CassConsistency consistency, GenDb::ColListVec *v_col_list) |
|
static bool | StaticCfGetResultAsync (interface::CassLibrary *cci, CassSession *session, const char *query, CassConsistency consistency, impl::CassAsyncQueryCallback cb, const std::string &cfname, const GenDb::DbDataValueVec &row_key) |
|
static bool | StaticCfGetResultSync (interface::CassLibrary *cci, CassSession *session, const char *query, CassConsistency consistency, GenDb::NewColVec *v_columns) |
|
static bool | StaticCfGetResultSync (interface::CassLibrary *cci, CassSession *session, const char *query, size_t rk_count, CassConsistency consistency, GenDb::ColListVec *v_col_list) |
|
static bool | SyncFutureWait (interface::CassLibrary *cci, CassFuture *future) |
|
static const CassTableMeta * | GetCassTableMeta (interface::CassLibrary *cci, const CassSchemaMeta *schema_meta, const std::string &keyspace, const std::string &table, bool log_error) |
|
static bool | IsCassTableMetaPresent (interface::CassLibrary *cci, CassSession *session, const std::string &keyspace, const std::string &table) |
|
static bool | GetCassTableClusteringKeyCount (interface::CassLibrary *cci, CassSession *session, const std::string &keyspace, const std::string &table, size_t *ck_count) |
|
static bool | GetCassTablePartitionKeyCount (interface::CassLibrary *cci, CassSession *session, const std::string &keyspace, const std::string &table, size_t *rk_count) |
|
static log4cplus::LogLevel | Cass2log4Level (CassLogLevel clevel) |
|
static CassLogLevel | Log4Level2CassLogLevel (log4cplus::LogLevel level) |
|
static void | CassLibraryLog (const CassLogMessage *message, void *data) |
|
static std::string | LoadCertFile (const std::string &ca_certs_path) |
|