NCBI C++ ToolKit
Classes | Public Member Functions | Static Public Attributes | Protected Member Functions | Private Member Functions | Private Attributes | Friends | List of all members
CCassQuery Class Reference

Search Toolkit Book for CCassQuery

#include <objtools/pubseq_gateway/impl/cassandra/cass_driver.hpp>

+ Inheritance diagram for CCassQuery:
+ Collaboration diagram for CCassQuery:

Classes

class  CNotImplemented
 

Public Member Functions

virtual ~CCassQuery ()
 
virtual void Close (void)
 
void SetTimeout ()
 CCassQuery. More...
 
void SetTimeout (unsigned int t)
 
unsigned int Timeout (void) const
 
void UsePerRequestTimeout (bool value)
 
unsigned int GetRequestTimeoutMs () const
 
bool IsReady (void)
 
void NewBatch (void)
 
async_rslt_t RunBatch ()
 
void SetSQL (const string &sql, unsigned int PrmCount)
 
void SetHost (const string &hostname)
 
void Query (TCassConsistency c=CCassConsistency::kLocalQuorum, bool run_async=false, bool allow_prepare=true, unsigned int page_size=DEFAULT_PAGE_SIZE)
 
void RestartQuery (TCassConsistency c=CCassConsistency::kLocalQuorum)
 
void Execute (TCassConsistency c=CCassConsistency::kLocalQuorum, bool run_async=false, bool allow_prepare=true)
 
void RestartExecute (TCassConsistency c=CCassConsistency::kLocalQuorum)
 
void Restart (TCassConsistency c=CCassConsistency::kLocalQuorum)
 
void SetSerialConsistency (TCassConsistency c)
 
bool IsActive (void) const
 
virtual async_rslt_t WaitAsync (unsigned int timeoutmks)
 
string GetSQL () const
 
virtual string ToString (void) const
 
virtual bool IsEOF (void) const
 
virtual bool IsAsync (void) const
 
void BindNull (int iprm)
 
void BindInt8 (int iprm, int8_t value)
 
void BindInt16 (int iprm, int16_t value)
 
void BindInt32 (int iprm, int32_t value)
 
void BindInt64 (int iprm, int64_t value)
 
void BindStr (int iprm, const string &value)
 
void BindStr (int iprm, const char *value)
 
void BindBytes (int iprm, const unsigned char *buf, size_t len)
 
template<typename K , typename V >
void BindMap (int iprm, const map< K, V > &value)
 
template<typename I >
void BindList (int iprm, I begin, I end, size_t sz)
 
template<typename I >
void BindSet (int iprm, I begin, I end, size_t sz)
 
template<typename I >
void BindSet (int iprm, const set< I > &v)
 
template<typename ... T>
void BindTuple (int iprm, const tuple< T... > &value)
 
size_t ParamCount (void) const
 
CassValueType ParamType (int iprm) const
 
int32_t ParamAsInt32 (int iprm)
 
int64_t ParamAsInt64 (int iprm)
 
string ParamAsStr (int iprm) const
 
void ParamAsStr (int iprm, string &value) const
 
string ParamAsStrForDebug (int iprm) const
 
async_rslt_t NextRow ()
 
template<typename F = int>
bool FieldIsNull (F ifld) const
 
template<typename F = int>
CCassDataType FieldType (F ifld) const
 
template<typename F = int>
bool FieldGetBoolValue (F ifld) const
 
template<typename F = int>
bool FieldGetBoolValue (F ifld, bool _default) const
 
template<typename F = int>
int8_t FieldGetInt8Value (F ifld) const
 
template<typename F = int>
int8_t FieldGetInt8Value (F ifld, int8_t _default) const
 
template<typename F = int>
int16_t FieldGetInt16Value (F ifld) const
 
template<typename F = int>
int16_t FieldGetInt16Value (F ifld, int16_t _default) const
 
template<typename F = int>
int32_t FieldGetInt32Value (F ifld) const
 
template<typename F = int>
int32_t FieldGetInt32Value (F ifld, int32_t _default) const
 
template<typename F = int>
int64_t FieldGetInt64Value (F ifld) const
 
template<typename F = int>
int64_t FieldGetInt64Value (F ifld, int64_t _default) const
 
template<typename F = int>
double FieldGetFloatValue (F ifld) const
 
template<typename F = int>
double FieldGetFloatValue (F ifld, double _default) const
 
template<typename F = int>
string FieldGetStrValue (F ifld) const
 
template<typename F = int>
string FieldGetStrValueDef (F ifld, const string &_default) const
 
template<typename I , typename F = int>
void FieldGetContainerValue (F ifld, I insert_iterator) const
 
template<typename F = int>
void FieldGetStrValue (F ifld, string &value) const
 
template<typename F = int>
void FieldGetStrValueDef (F ifld, string &value, const string &_default) const
 
template<typename T , typename F = int>
T FieldGetTupleValue (F ifld) const
 
template<typename T , typename F = int>
void FieldGetSetValues (F ifld, std::vector< T > &values) const
 
template<typename T , typename F = int>
void FieldGetSetValues (F ifld, std::set< T > &values) const
 
template<typename K , typename V , typename F = int>
void FieldGetMapValue (F ifld, map< K, V > &result) const
 
template<typename F = int>
size_t FieldGetBlobValue (F ifld, unsigned char *buf, size_t len) const
 
template<typename F = int>
size_t FieldGetBlobRaw (F ifld, const unsigned char **rawbuf) const
 
template<typename F = int>
size_t FieldGetBlobSize (F ifld) const
 
shared_ptr< CCassConnectionGetConnection (void)
 
void SetOnData3 (shared_ptr< CCassDataCallbackReceiver > cb)
 
void SetOnExecute (void(*Cb)(CCassQuery &, void *), void *Data)
 
template<>
const CassValue * GetColumn (int ifld) const
 
template<>
const CassValue * GetColumn (const string &name) const
 
template<>
const CassValue * GetColumn (const char *name) const
 
template<>
string GetColumnDef (int ifld) const
 
template<>
string GetColumnDef (const string &name) const
 
template<>
string GetColumnDef (const char *name) const
 

Static Public Attributes

static const unsigned int DEFAULT_PAGE_SIZE = 4096
 

Protected Member Functions

 CCassQuery (const shared_ptr< CCassConnection > &connection)
 

Private Member Functions

 CCassQuery (const CCassQuery &)=delete
 
CCassQueryoperator= (const CCassQuery &)=delete
 
void CheckParamAssigned (int iprm) const
 
void CheckParamExists (int iprm) const
 
async_rslt_t Wait (unsigned int timeoutmks)
 
void Bind (void)
 
template<typename F >
const CassValue * GetColumn (F ifld) const
 
template<typename F >
string GetColumnDef (F ifld) const
 
void GetFuture ()
 
void ProcessFutureResult ()
 
void SetupOnDataCallback ()
 
void InternalClose (bool closebatch)
 
void SetEOF (bool Value)
 

Private Attributes

shared_ptr< CCassConnectionm_connection
 
unsigned int m_qtimeoutms
 
bool m_use_per_request_timeout {false}
 
int64_t m_futuretime
 
CassFuture * m_future
 
CassBatch * m_batch
 
CassStatement * m_statement
 
const CassResult * m_result
 
CassIterator * m_iterator
 
const CassRow * m_row
 
unsigned int m_page_size
 
bool m_EOF
 
bool m_page_start
 
CCassParams m_params
 
string m_sql
 
bool m_results_expected
 
bool m_async
 
bool m_allow_prepare
 
bool m_is_prepared
 
TCassConsistency m_serial_consistency
 
shared_ptr< CCassQueryCbRefm_cb_ref
 
weak_ptr< CCassDataCallbackReceiverm_ondata3
 
TCassQueryOnExecuteCallback m_onexecute
 
void * m_onexecute_data
 
string m_execution_host
 

Friends

class CCassConnection
 
class CCassQueryCbRef
 

Detailed Description

Definition at line 728 of file cass_driver.hpp.

Constructor & Destructor Documentation

◆ CCassQuery() [1/2]

CCassQuery::CCassQuery ( const CCassQuery )
privatedelete

◆ CCassQuery() [2/2]

CCassQuery::CCassQuery ( const shared_ptr< CCassConnection > &  connection)
inlineexplicitprotected

Definition at line 813 of file cass_driver.hpp.

References eFatal, m_connection, and RAISE_DB_ERROR.

◆ ~CCassQuery()

CCassQuery::~CCassQuery ( )
virtual

Definition at line 1148 of file cass_driver.cpp.

References Close(), and m_onexecute_data.

Member Function Documentation

◆ Bind()

void CCassQuery::Bind ( void  )
private

Definition at line 1212 of file cass_driver.cpp.

References cnt, m_params, m_statement, and RAISE_DB_ERROR.

Referenced by Execute(), and Query().

◆ BindBytes()

void CCassQuery::BindBytes ( int  iprm,
const unsigned char *  buf,
size_t  len 
)

Definition at line 1271 of file cass_driver.cpp.

References buf, CheckParamExists(), len, and m_params.

◆ BindInt16()

void CCassQuery::BindInt16 ( int  iprm,
int16_t  value 
)

Definition at line 1237 of file cass_driver.cpp.

References CheckParamExists(), m_params, and rapidjson::value.

◆ BindInt32()

void CCassQuery::BindInt32 ( int  iprm,
int32_t  value 
)

Definition at line 1243 of file cass_driver.cpp.

References CheckParamExists(), m_params, and rapidjson::value.

◆ BindInt64()

void CCassQuery::BindInt64 ( int  iprm,
int64_t  value 
)

Definition at line 1250 of file cass_driver.cpp.

References CheckParamExists(), m_params, and rapidjson::value.

◆ BindInt8()

void CCassQuery::BindInt8 ( int  iprm,
int8_t  value 
)

Definition at line 1231 of file cass_driver.cpp.

References CheckParamExists(), m_params, and rapidjson::value.

◆ BindList()

template<typename I >
void CCassQuery::BindList ( int  iprm,
begin,
end,
size_t  sz 
)
inline

Definition at line 909 of file cass_driver.hpp.

References CheckParamExists(), and m_params.

◆ BindMap()

template<typename K , typename V >
void CCassQuery::BindMap ( int  iprm,
const map< K, V > &  value 
)
inline

Definition at line 902 of file cass_driver.hpp.

References CheckParamExists(), K, m_params, and rapidjson::value.

◆ BindNull()

void CCassQuery::BindNull ( int  iprm)

Definition at line 1225 of file cass_driver.cpp.

References CheckParamExists(), and m_params.

◆ BindSet() [1/2]

template<typename I >
void CCassQuery::BindSet ( int  iprm,
const set< I > &  v 
)
inline

◆ BindSet() [2/2]

template<typename I >
void CCassQuery::BindSet ( int  iprm,
begin,
end,
size_t  sz 
)
inline

Definition at line 916 of file cass_driver.hpp.

References CheckParamExists(), and m_params.

Referenced by BindSet().

◆ BindStr() [1/2]

void CCassQuery::BindStr ( int  iprm,
const char *  value 
)

Definition at line 1264 of file cass_driver.cpp.

References CheckParamExists(), m_params, and rapidjson::value.

◆ BindStr() [2/2]

void CCassQuery::BindStr ( int  iprm,
const string value 
)

Definition at line 1257 of file cass_driver.cpp.

References CheckParamExists(), m_params, and rapidjson::value.

◆ BindTuple()

template<typename ... T>
void CCassQuery::BindTuple ( int  iprm,
const tuple< T... > &  value 
)
inline

Definition at line 929 of file cass_driver.hpp.

References CheckParamExists(), m_params, and rapidjson::value.

◆ CheckParamAssigned()

void CCassQuery::CheckParamAssigned ( int  iprm) const
inlineprivate

Definition at line 738 of file cass_driver.hpp.

References m_params, and RAISE_DB_ERROR.

Referenced by ParamAsInt32(), ParamAsInt64(), ParamAsStr(), ParamAsStrForDebug(), and ParamType().

◆ CheckParamExists()

void CCassQuery::CheckParamExists ( int  iprm) const
inlineprivate

◆ Close()

void CCassQuery::Close ( void  )
virtual

Definition at line 1143 of file cass_driver.cpp.

References InternalClose().

Referenced by Query(), RestartExecute(), RestartQuery(), and ~CCassQuery().

◆ Execute()

void CCassQuery::Execute ( TCassConsistency  c = CCassConsistency::kLocalQuorum,
bool  run_async = false,
bool  allow_prepare = true 
)

◆ FieldGetBlobRaw()

template<typename F = int>
size_t CCassQuery::FieldGetBlobRaw ( F  ifld,
const unsigned char **  rawbuf 
) const
inline

Definition at line 1381 of file cass_driver.hpp.

References GetColumn(), output, and RAISE_CASS_ERROR.

◆ FieldGetBlobSize()

template<typename F = int>
size_t CCassQuery::FieldGetBlobSize ( F  ifld) const
inline

Definition at line 1405 of file cass_driver.hpp.

References GetColumn(), output, and RAISE_CASS_ERROR.

◆ FieldGetBlobValue()

template<typename F = int>
size_t CCassQuery::FieldGetBlobValue ( F  ifld,
unsigned char *  buf,
size_t  len 
) const
inline

Definition at line 1364 of file cass_driver.hpp.

References buf, GetColumn(), len, output, RAISE_CASS_ERROR, and RAISE_DB_ERROR.

◆ FieldGetBoolValue() [1/2]

template<typename F = int>
bool CCassQuery::FieldGetBoolValue ( F  ifld) const
inline

◆ FieldGetBoolValue() [2/2]

template<typename F = int>
bool CCassQuery::FieldGetBoolValue ( F  ifld,
bool  _default 
) const
inline

Definition at line 1021 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetContainerValue()

template<typename I , typename F = int>
void CCassQuery::FieldGetContainerValue ( F  ifld,
insert_iterator 
) const
inline

◆ FieldGetFloatValue() [1/2]

template<typename F = int>
double CCassQuery::FieldGetFloatValue ( F  ifld) const
inline

◆ FieldGetFloatValue() [2/2]

template<typename F = int>
double CCassQuery::FieldGetFloatValue ( F  ifld,
double  _default 
) const
inline

Definition at line 1132 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetInt16Value() [1/2]

template<typename F = int>
int16_t CCassQuery::FieldGetInt16Value ( F  ifld) const
inline

◆ FieldGetInt16Value() [2/2]

template<typename F = int>
int16_t CCassQuery::FieldGetInt16Value ( F  ifld,
int16_t  _default 
) const
inline

Definition at line 1065 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetInt32Value() [1/2]

template<typename F = int>
int32_t CCassQuery::FieldGetInt32Value ( F  ifld) const
inline

◆ FieldGetInt32Value() [2/2]

template<typename F = int>
int32_t CCassQuery::FieldGetInt32Value ( F  ifld,
int32_t  _default 
) const
inline

Definition at line 1087 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetInt64Value() [1/2]

template<typename F = int>
int64_t CCassQuery::FieldGetInt64Value ( F  ifld) const
inline

◆ FieldGetInt64Value() [2/2]

template<typename F = int>
int64_t CCassQuery::FieldGetInt64Value ( F  ifld,
int64_t  _default 
) const
inline

Definition at line 1109 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetInt8Value() [1/2]

template<typename F = int>
int8_t CCassQuery::FieldGetInt8Value ( F  ifld) const
inline

◆ FieldGetInt8Value() [2/2]

template<typename F = int>
int8_t CCassQuery::FieldGetInt8Value ( F  ifld,
int8_t  _default 
) const
inline

Definition at line 1043 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetMapValue()

template<typename K , typename V , typename F = int>
void CCassQuery::FieldGetMapValue ( F  ifld,
map< K, V > &  result 
) const
inline

◆ FieldGetSetValues() [1/2]

template<typename T , typename F = int>
void CCassQuery::FieldGetSetValues ( F  ifld,
std::set< T > &  values 
) const
inline

◆ FieldGetSetValues() [2/2]

template<typename T , typename F = int>
void CCassQuery::FieldGetSetValues ( F  ifld,
std::vector< T > &  values 
) const
inline

◆ FieldGetStrValue() [1/2]

template<typename F = int>
string CCassQuery::FieldGetStrValue ( F  ifld) const
inline

◆ FieldGetStrValue() [2/2]

template<typename F = int>
void CCassQuery::FieldGetStrValue ( F  ifld,
string value 
) const
inline

Definition at line 1209 of file cass_driver.hpp.

References FieldGetStrValue(), and rapidjson::value.

◆ FieldGetStrValueDef() [1/2]

template<typename F = int>
string CCassQuery::FieldGetStrValueDef ( F  ifld,
const string _default 
) const
inline

Definition at line 1154 of file cass_driver.hpp.

References GetColumn().

Referenced by FieldGetStrValueDef().

◆ FieldGetStrValueDef() [2/2]

template<typename F = int>
void CCassQuery::FieldGetStrValueDef ( F  ifld,
string value,
const string _default 
) const
inline

Definition at line 1215 of file cass_driver.hpp.

References FieldGetStrValueDef(), and rapidjson::value.

◆ FieldGetTupleValue()

template<typename T , typename F = int>
T CCassQuery::FieldGetTupleValue ( F  ifld) const
inline

◆ FieldIsNull()

template<typename F = int>
bool CCassQuery::FieldIsNull ( F  ifld) const
inline

Definition at line 950 of file cass_driver.hpp.

References GetColumn().

Referenced by FieldType().

◆ FieldType()

template<typename F = int>
CCassDataType CCassQuery::FieldType ( F  ifld) const
inline

◆ GetColumn() [1/4]

template<>
const CassValue * CCassQuery::GetColumn ( const char *  name) const

Definition at line 1858 of file cass_driver.cpp.

References m_row, and RAISE_DB_ERROR.

◆ GetColumn() [2/4]

template<>
const CassValue * CCassQuery::GetColumn ( const string name) const

Definition at line 1845 of file cass_driver.cpp.

References m_row, and RAISE_DB_ERROR.

◆ GetColumn() [3/4]

template<typename F >
const CassValue* CCassQuery::GetColumn ( F  ifld) const
inlineprivate

◆ GetColumn() [4/4]

template<>
const CassValue * CCassQuery::GetColumn ( int  ifld) const

Definition at line 1831 of file cass_driver.cpp.

References m_row, and RAISE_DB_ERROR.

◆ GetColumnDef() [1/4]

template<>
string CCassQuery::GetColumnDef ( const char *  name) const

Definition at line 1882 of file cass_driver.cpp.

References string, and ToString().

◆ GetColumnDef() [2/4]

template<>
string CCassQuery::GetColumnDef ( const string name) const

Definition at line 1877 of file cass_driver.cpp.

References ToString().

◆ GetColumnDef() [3/4]

template<typename F >
string CCassQuery::GetColumnDef ( F  ifld) const
inlineprivate

◆ GetColumnDef() [4/4]

template<>
string CCassQuery::GetColumnDef ( int  ifld) const

Definition at line 1872 of file cass_driver.cpp.

References NStr::NumericToString(), and ToString().

◆ GetConnection()

shared_ptr<CCassConnection> CCassQuery::GetConnection ( void  )
inline

Definition at line 1417 of file cass_driver.hpp.

References m_connection.

◆ GetFuture()

void CCassQuery::GetFuture ( )
private

◆ GetRequestTimeoutMs()

unsigned int CCassQuery::GetRequestTimeoutMs ( ) const

Definition at line 1136 of file cass_driver.cpp.

References m_connection, m_qtimeoutms, and m_use_per_request_timeout.

◆ GetSQL()

string CCassQuery::GetSQL ( ) const

Definition at line 1200 of file cass_driver.cpp.

References m_sql.

◆ InternalClose()

void CCassQuery::InternalClose ( bool  closebatch)
private

◆ IsActive()

bool CCassQuery::IsActive ( void  ) const
inline

Definition at line 880 of file cass_driver.hpp.

References m_batch, m_row, and m_statement.

Referenced by GetFuture(), NewBatch(), NextRow(), and Query().

◆ IsAsync()

bool CCassQuery::IsAsync ( void  ) const
virtual

Definition at line 1927 of file cass_driver.cpp.

References m_async.

◆ IsEOF()

bool CCassQuery::IsEOF ( void  ) const
virtual

Definition at line 1922 of file cass_driver.cpp.

References m_EOF.

◆ IsReady()

bool CCassQuery::IsReady ( void  )

Definition at line 1605 of file cass_driver.cpp.

References GetFuture(), and m_future.

◆ NewBatch()

void CCassQuery::NewBatch ( void  )

◆ NextRow()

async_rslt_t CCassQuery::NextRow ( )

◆ operator=()

CCassQuery& CCassQuery::operator= ( const CCassQuery )
privatedelete

◆ ParamAsInt32()

int32_t CCassQuery::ParamAsInt32 ( int  iprm)

Definition at line 1278 of file cass_driver.cpp.

References CheckParamAssigned(), and m_params.

◆ ParamAsInt64()

int64_t CCassQuery::ParamAsInt64 ( int  iprm)

Definition at line 1285 of file cass_driver.cpp.

References CheckParamAssigned(), and m_params.

◆ ParamAsStr() [1/2]

string CCassQuery::ParamAsStr ( int  iprm) const

Definition at line 1292 of file cass_driver.cpp.

References CheckParamAssigned(), and m_params.

Referenced by ToString().

◆ ParamAsStr() [2/2]

void CCassQuery::ParamAsStr ( int  iprm,
string value 
) const

Definition at line 1299 of file cass_driver.cpp.

References CheckParamAssigned(), m_params, and rapidjson::value.

◆ ParamAsStrForDebug()

string CCassQuery::ParamAsStrForDebug ( int  iprm) const

Definition at line 1305 of file cass_driver.cpp.

References CheckParamAssigned(), and m_params.

Referenced by Restart().

◆ ParamCount()

size_t CCassQuery::ParamCount ( void  ) const
inline

Definition at line 935 of file cass_driver.hpp.

References m_params.

Referenced by Restart(), and ToString().

◆ ParamType()

CassValueType CCassQuery::ParamType ( int  iprm) const

Definition at line 1311 of file cass_driver.cpp.

References CheckParamAssigned(), and m_params.

Referenced by ToString().

◆ ProcessFutureResult()

void CCassQuery::ProcessFutureResult ( )
private

◆ Query()

void CCassQuery::Query ( TCassConsistency  c = CCassConsistency::kLocalQuorum,
bool  run_async = false,
bool  allow_prepare = true,
unsigned int  page_size = DEFAULT_PAGE_SIZE 
)

◆ Restart()

void CCassQuery::Restart ( TCassConsistency  c = CCassConsistency::kLocalQuorum)

◆ RestartExecute()

void CCassQuery::RestartExecute ( TCassConsistency  c = CCassConsistency::kLocalQuorum)

◆ RestartQuery()

void CCassQuery::RestartQuery ( TCassConsistency  c = CCassConsistency::kLocalQuorum)

◆ RunBatch()

async_rslt_t CCassQuery::RunBatch ( )

Definition at line 1576 of file cass_driver.cpp.

References ar_wait, GetFuture(), m_async, m_batch, m_qtimeoutms, RAISE_DB_ERROR, and Wait().

◆ SetEOF()

void CCassQuery::SetEOF ( bool  Value)
private

Definition at line 1317 of file cass_driver.cpp.

References m_EOF, and rapidjson::value.

Referenced by Execute(), NextRow(), ProcessFutureResult(), and Query().

◆ SetHost()

void CCassQuery::SetHost ( const string hostname)

Definition at line 1349 of file cass_driver.cpp.

References m_execution_host.

◆ SetOnData3()

void CCassQuery::SetOnData3 ( shared_ptr< CCassDataCallbackReceiver cb)
inline

◆ SetOnExecute()

void CCassQuery::SetOnExecute ( void(*)(CCassQuery &, void *)  Cb,
void *  Data 
)
inline

Definition at line 1444 of file cass_driver.hpp.

References m_onexecute, and m_onexecute_data.

◆ SetSerialConsistency()

void CCassQuery::SetSerialConsistency ( TCassConsistency  c)

Definition at line 1570 of file cass_driver.cpp.

References m_serial_consistency.

◆ SetSQL()

void CCassQuery::SetSQL ( const string sql,
unsigned int  PrmCount 
)

Definition at line 1204 of file cass_driver.cpp.

References InternalClose(), m_params, m_sql, and sql.

◆ SetTimeout() [1/2]

void CCassQuery::SetTimeout ( void  )

CCassQuery.

Definition at line 1116 of file cass_driver.cpp.

References CASS_DRV_TIMEOUT_MS.

Referenced by RestartExecute(), and RestartQuery().

◆ SetTimeout() [2/2]

void CCassQuery::SetTimeout ( unsigned int  t)

Definition at line 1121 of file cass_driver.cpp.

References m_qtimeoutms, and t.

◆ SetupOnDataCallback()

void CCassQuery::SetupOnDataCallback ( )
private

◆ Timeout()

unsigned int CCassQuery::Timeout ( void  ) const

Definition at line 1126 of file cass_driver.cpp.

References m_qtimeoutms.

◆ ToString()

string CCassQuery::ToString ( void  ) const
virtual

Definition at line 1886 of file cass_driver.cpp.

References i, m_sql, NStr::NumericToString(), ParamAsStr(), ParamCount(), and ParamType().

Referenced by GetColumnDef().

◆ UsePerRequestTimeout()

void CCassQuery::UsePerRequestTimeout ( bool  value)

Definition at line 1131 of file cass_driver.cpp.

References m_use_per_request_timeout, and rapidjson::value.

Referenced by RestartExecute(), and RestartQuery().

◆ Wait()

async_rslt_t CCassQuery::Wait ( unsigned int  timeoutmks)
private

◆ WaitAsync()

async_rslt_t CCassQuery::WaitAsync ( unsigned int  timeoutmks)
virtual

Definition at line 1596 of file cass_driver.cpp.

References m_async, RAISE_DB_ERROR, and Wait().

Friends And Related Function Documentation

◆ CCassConnection

friend class CCassConnection
friend

Definition at line 734 of file cass_driver.hpp.

◆ CCassQueryCbRef

friend class CCassQueryCbRef
friend

Definition at line 735 of file cass_driver.hpp.

Referenced by SetupOnDataCallback().

Member Data Documentation

◆ DEFAULT_PAGE_SIZE

const unsigned int CCassQuery::DEFAULT_PAGE_SIZE = 4096
static

Definition at line 1450 of file cass_driver.hpp.

◆ m_allow_prepare

bool CCassQuery::m_allow_prepare
private

Definition at line 772 of file cass_driver.hpp.

Referenced by InternalClose().

◆ m_async

bool CCassQuery::m_async
private

◆ m_batch

CassBatch* CCassQuery::m_batch
private

◆ m_cb_ref

shared_ptr<CCassQueryCbRef> CCassQuery::m_cb_ref
private

Definition at line 776 of file cass_driver.hpp.

Referenced by InternalClose(), ProcessFutureResult(), and SetupOnDataCallback().

◆ m_connection

shared_ptr<CCassConnection> CCassQuery::m_connection
private

◆ m_EOF

bool CCassQuery::m_EOF
private

Definition at line 766 of file cass_driver.hpp.

Referenced by IsEOF(), SetEOF(), and Wait().

◆ m_execution_host

string CCassQuery::m_execution_host
private

Definition at line 783 of file cass_driver.hpp.

Referenced by Query(), and SetHost().

◆ m_future

CassFuture* CCassQuery::m_future
private

◆ m_futuretime

int64_t CCassQuery::m_futuretime
private

Definition at line 758 of file cass_driver.hpp.

Referenced by GetFuture(), InternalClose(), ProcessFutureResult(), and Wait().

◆ m_is_prepared

bool CCassQuery::m_is_prepared
private

Definition at line 773 of file cass_driver.hpp.

Referenced by Execute(), InternalClose(), Query(), RestartExecute(), and RestartQuery().

◆ m_iterator

CassIterator* CCassQuery::m_iterator
private

Definition at line 763 of file cass_driver.hpp.

Referenced by GetFuture(), InternalClose(), NextRow(), and ProcessFutureResult().

◆ m_ondata3

weak_ptr<CCassDataCallbackReceiver> CCassQuery::m_ondata3
private

Definition at line 778 of file cass_driver.hpp.

Referenced by GetFuture(), SetOnData3(), and SetupOnDataCallback().

◆ m_onexecute

TCassQueryOnExecuteCallback CCassQuery::m_onexecute
private

Definition at line 780 of file cass_driver.hpp.

Referenced by ProcessFutureResult(), and SetOnExecute().

◆ m_onexecute_data

void* CCassQuery::m_onexecute_data
private

Definition at line 781 of file cass_driver.hpp.

Referenced by ProcessFutureResult(), SetOnExecute(), and ~CCassQuery().

◆ m_page_size

unsigned int CCassQuery::m_page_size
private

Definition at line 765 of file cass_driver.hpp.

Referenced by Execute(), InternalClose(), NextRow(), Query(), and RestartQuery().

◆ m_page_start

bool CCassQuery::m_page_start
private

Definition at line 767 of file cass_driver.hpp.

Referenced by Execute(), InternalClose(), NextRow(), ProcessFutureResult(), and Query().

◆ m_params

CCassParams CCassQuery::m_params
private

◆ m_qtimeoutms

unsigned int CCassQuery::m_qtimeoutms
private

◆ m_result

const CassResult* CCassQuery::m_result
private

Definition at line 762 of file cass_driver.hpp.

Referenced by GetFuture(), InternalClose(), NextRow(), ProcessFutureResult(), and Wait().

◆ m_results_expected

bool CCassQuery::m_results_expected
private

Definition at line 770 of file cass_driver.hpp.

Referenced by Execute(), InternalClose(), ProcessFutureResult(), Query(), Restart(), and Wait().

◆ m_row

const CassRow* CCassQuery::m_row
private

Definition at line 764 of file cass_driver.hpp.

Referenced by Execute(), GetColumn(), InternalClose(), IsActive(), and NextRow().

◆ m_serial_consistency

TCassConsistency CCassQuery::m_serial_consistency
private

Definition at line 774 of file cass_driver.hpp.

Referenced by Execute(), Query(), and SetSerialConsistency().

◆ m_sql

string CCassQuery::m_sql
private

Definition at line 769 of file cass_driver.hpp.

Referenced by Execute(), GetSQL(), Query(), Restart(), SetSQL(), ToString(), and Wait().

◆ m_statement

CassStatement* CCassQuery::m_statement
private

◆ m_use_per_request_timeout

bool CCassQuery::m_use_per_request_timeout {false}
private

Definition at line 757 of file cass_driver.hpp.

Referenced by Execute(), GetRequestTimeoutMs(), NewBatch(), Query(), and UsePerRequestTimeout().


The documentation for this class was generated from the following files:
Modified on Mon Apr 22 04:06:03 2024 by modify_doxy.py rev. 669887