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

void	BindDate (int iprm, int64_t value)

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< CCassConnection >	GetConnection (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

CCassQuery &	operator= (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< CCassConnection >	m_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< CCassQueryCbRef >	m_cb_ref

weak_ptr< CCassDataCallbackReceiver >	m_ondata3

TCassQueryOnExecuteCallback	m_onexecute

void *	m_onexecute_data

string	m_execution_host

Friends
class	CCassConnection

class	CCassQueryCbRef

Detailed Description

Definition at line 775 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 860 of file cass_driver.hpp.

References eFatal, m_connection, and RAISE_DB_ERROR.

◆ ~CCassQuery()

CCassQuery::~CCassQuery ( )

virtual

Definition at line 1203 of file cass_driver.cpp.

References Close(), and m_onexecute_data.

Member Function Documentation

◆ Bind()

void CCassQuery::Bind ( void )

private

Definition at line 1267 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 1326 of file cass_driver.cpp.

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

◆ BindDate()

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

Definition at line 1332 of file cass_driver.cpp.

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

◆ BindInt16()

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

Definition at line 1292 of file cass_driver.cpp.

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

◆ BindInt32()

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

Definition at line 1298 of file cass_driver.cpp.

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

◆ BindInt64()

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

Definition at line 1305 of file cass_driver.cpp.

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

◆ BindInt8()

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

Definition at line 1286 of file cass_driver.cpp.

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

◆ BindList()

template<typename I >

void CCassQuery::BindList	(	int	iprm,
		I	begin,
		I	end,
		size_t	sz
	)

inline

Definition at line 957 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 950 of file cass_driver.hpp.

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

◆ BindNull()

void CCassQuery::BindNull ( int iprm )

Definition at line 1280 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

Definition at line 971 of file cass_driver.hpp.

References set< Key, Compare >::begin(), BindSet(), set< Key, Compare >::end(), and set< Key, Compare >::size().

◆ BindSet() [2/2]

template<typename I >

void CCassQuery::BindSet	(	int	iprm,
		I	begin,
		I	end,
		size_t	sz
	)

inline

Definition at line 964 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 1319 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 1312 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 977 of file cass_driver.hpp.

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

◆ CheckParamAssigned()

void CCassQuery::CheckParamAssigned ( int iprm ) const

inlineprivate

Definition at line 785 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

Definition at line 795 of file cass_driver.hpp.

References m_params, and RAISE_DB_ERROR.

Referenced by BindBytes(), BindDate(), BindInt16(), BindInt32(), BindInt64(), BindInt8(), BindList(), BindMap(), BindNull(), BindSet(), BindStr(), and BindTuple().

◆ Close()

void CCassQuery::Close ( void )

virtual

Definition at line 1198 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`
	)

Definition at line 1511 of file cass_driver.cpp.

References Bind(), GetFuture(), m_async, m_batch, m_connection, m_is_prepared, m_page_size, m_page_start, m_params, m_qtimeoutms, m_results_expected, m_row, m_serial_consistency, m_sql, m_statement, m_use_per_request_timeout, RAISE_CASS_ERROR, RAISE_DB_ERROR, SetEOF(), and Wait().

Referenced by RestartExecute().

◆ FieldGetBlobRaw()

template<typename F = int>

size_t CCassQuery::FieldGetBlobRaw	(	F	ifld,
		const unsigned char **	rawbuf
	)		const

inline

Definition at line 1431 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 1455 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 1414 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

Definition at line 1057 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert< bool >(), GetColumn(), and GetColumnDef().

◆ FieldGetBoolValue() [2/2]

template<typename F = int>

bool CCassQuery::FieldGetBoolValue	(	F	ifld,
		bool	_default
	)		const

inline

Definition at line 1071 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetContainerValue()

template<typename I , typename F = int>

void CCassQuery::FieldGetContainerValue	(	F	ifld,
		I	insert_iterator
	)		const

inline

Definition at line 1212 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert(), GetColumn(), GetColumnDef(), RAISE_DB_ERROR, and rapidjson::value.

◆ FieldGetFloatValue() [1/2]

template<typename F = int>

double CCassQuery::FieldGetFloatValue ( F ifld ) const

inline

Definition at line 1167 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert< double >(), GetColumn(), and GetColumnDef().

◆ FieldGetFloatValue() [2/2]

template<typename F = int>

double CCassQuery::FieldGetFloatValue	(	F	ifld,
		double	_default
	)		const

inline

Definition at line 1182 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetInt16Value() [1/2]

template<typename F = int>

int16_t CCassQuery::FieldGetInt16Value ( F ifld ) const

inline

Definition at line 1101 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert< int16_t >(), GetColumn(), and GetColumnDef().

◆ FieldGetInt16Value() [2/2]

template<typename F = int>

int16_t CCassQuery::FieldGetInt16Value	(	F	ifld,
		int16_t	_default
	)		const

inline

Definition at line 1115 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetInt32Value() [1/2]

template<typename F = int>

int32_t CCassQuery::FieldGetInt32Value ( F ifld ) const

inline

Definition at line 1123 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert< int32_t >(), GetColumn(), and GetColumnDef().

◆ FieldGetInt32Value() [2/2]

template<typename F = int>

int32_t CCassQuery::FieldGetInt32Value	(	F	ifld,
		int32_t	_default
	)		const

inline

Definition at line 1137 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetInt64Value() [1/2]

template<typename F = int>

int64_t CCassQuery::FieldGetInt64Value ( F ifld ) const

inline

Definition at line 1145 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert< int64_t >(), GetColumn(), and GetColumnDef().

◆ FieldGetInt64Value() [2/2]

template<typename F = int>

int64_t CCassQuery::FieldGetInt64Value	(	F	ifld,
		int64_t	_default
	)		const

inline

Definition at line 1159 of file cass_driver.hpp.

References GetColumn().

◆ FieldGetInt8Value() [1/2]

template<typename F = int>

int8_t CCassQuery::FieldGetInt8Value ( F ifld ) const

inline

Definition at line 1079 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert< int8_t >(), GetColumn(), and GetColumnDef().

◆ FieldGetInt8Value() [2/2]

template<typename F = int>

int8_t CCassQuery::FieldGetInt8Value	(	F	ifld,
		int8_t	_default
	)		const

inline

Definition at line 1093 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

Definition at line 1367 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert(), GetColumn(), GetColumnDef(), ncbi::grid::netcache::search::fields::key, RAISE_DB_ERROR, result, and val.

◆ FieldGetSetValues() [1/2]

template<typename T , typename F = int>

void CCassQuery::FieldGetSetValues	(	F	ifld,
		std::set< T > &	values
	)		const

inline

Definition at line 1327 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert(), GetColumn(), GetColumnDef(), RAISE_DB_ERROR, T, and rapidjson::value.

◆ FieldGetSetValues() [2/2]

template<typename T , typename F = int>

void CCassQuery::FieldGetSetValues	(	F	ifld,
		std::vector< T > &	values
	)		const

inline

Definition at line 1289 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert(), GetColumn(), GetColumnDef(), RAISE_DB_ERROR, T, and rapidjson::value.

◆ FieldGetStrValue() [1/2]

template<typename F = int>

string CCassQuery::FieldGetStrValue ( F ifld ) const

inline

Definition at line 1190 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert< string >(), GetColumn(), and GetColumnDef().

Referenced by FieldGetStrValue().

◆ FieldGetStrValue() [2/2]

template<typename F = int>

void CCassQuery::FieldGetStrValue	(	F	ifld,
		string &	value
	)		const

inline

Definition at line 1259 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 1204 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 1265 of file cass_driver.hpp.

References FieldGetStrValueDef(), and rapidjson::value.

◆ FieldGetTupleValue()

template<typename T , typename F = int>

T CCassQuery::FieldGetTupleValue ( F ifld ) const

inline

Definition at line 1271 of file cass_driver.hpp.

References CException::AddToMessage(), Convert::CassValueConvert(), GetColumn(), GetColumnDef(), t, and T.

◆ FieldIsNull()

template<typename F = int>

bool CCassQuery::FieldIsNull ( F ifld ) const

inline

Definition at line 998 of file cass_driver.hpp.

References GetColumn().

Referenced by FieldType().

◆ FieldType()

template<typename F = int>

CCassDataType CCassQuery::FieldType ( F ifld ) const

inline

Definition at line 1005 of file cass_driver.hpp.

References dtBlob, dtBoolean, dtCollection, dtCounter, dtCustom, dtDate, dtFloat, dtInteger, dtNetwork, dtNull, dtText, dtTimestamp, dtUnknown, dtUuid, FieldIsNull(), and GetColumn().

◆ GetColumn() [1/4]

template<>

const CassValue * CCassQuery::GetColumn ( const char * name ) const

Definition at line 1918 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 1905 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

Definition at line 836 of file cass_driver.hpp.

References F.

Referenced by FieldGetBlobRaw(), FieldGetBlobSize(), FieldGetBlobValue(), FieldGetBoolValue(), FieldGetContainerValue(), FieldGetFloatValue(), FieldGetInt16Value(), FieldGetInt32Value(), FieldGetInt64Value(), FieldGetInt8Value(), FieldGetMapValue(), FieldGetSetValues(), FieldGetStrValue(), FieldGetStrValueDef(), FieldGetTupleValue(), FieldIsNull(), and FieldType().

◆ GetColumn() [4/4]

template<>

const CassValue * CCassQuery::GetColumn ( int ifld ) const

Definition at line 1891 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 1942 of file cass_driver.cpp.

References string, and ToString().

◆ GetColumnDef() [2/4]

template<>

string CCassQuery::GetColumnDef ( const string & name ) const

Definition at line 1937 of file cass_driver.cpp.

References ToString().

◆ GetColumnDef() [3/4]

template<typename F >

string CCassQuery::GetColumnDef ( F ifld ) const

inlineprivate

Definition at line 843 of file cass_driver.hpp.

References F.

Referenced by FieldGetBoolValue(), FieldGetContainerValue(), FieldGetFloatValue(), FieldGetInt16Value(), FieldGetInt32Value(), FieldGetInt64Value(), FieldGetInt8Value(), FieldGetMapValue(), FieldGetSetValues(), FieldGetStrValue(), and FieldGetTupleValue().

◆ GetColumnDef() [4/4]

template<>

string CCassQuery::GetColumnDef ( int ifld ) const

Definition at line 1932 of file cass_driver.cpp.

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

◆ GetConnection()

shared_ptr<CCassConnection> CCassQuery::GetConnection ( void )

inline

Definition at line 1467 of file cass_driver.hpp.

References m_connection.

◆ GetFuture()

void CCassQuery::GetFuture ( )

private

Definition at line 1672 of file cass_driver.cpp.

References gettime(), IsActive(), m_batch, m_connection, m_future, m_futuretime, m_iterator, m_ondata3, m_result, m_statement, RAISE_DB_ERROR, and SetupOnDataCallback().

Referenced by Execute(), IsReady(), Query(), RunBatch(), and Wait().

◆ GetRequestTimeoutMs()

unsigned int CCassQuery::GetRequestTimeoutMs ( ) const

Definition at line 1191 of file cass_driver.cpp.

References m_connection, m_qtimeoutms, and m_use_per_request_timeout.

◆ GetSQL()

string CCassQuery::GetSQL ( ) const

Definition at line 1255 of file cass_driver.cpp.

References m_sql.

◆ InternalClose()

void CCassQuery::InternalClose ( bool closebatch )

private

Definition at line 1209 of file cass_driver.cpp.

References m_allow_prepare, m_async, m_batch, m_cb_ref, m_connection, m_future, m_futuretime, m_is_prepared, m_iterator, m_page_size, m_page_start, m_params, m_result, m_results_expected, m_row, and m_statement.

Referenced by Close(), and SetSQL().

◆ IsActive()

bool CCassQuery::IsActive ( void ) const

inline

Definition at line 927 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 1987 of file cass_driver.cpp.

References m_async.

◆ IsEOF()

bool CCassQuery::IsEOF ( void ) const

virtual

Definition at line 1982 of file cass_driver.cpp.

References m_EOF.

◆ IsReady()

bool CCassQuery::IsReady ( void )

Definition at line 1665 of file cass_driver.cpp.

References GetFuture(), and m_future.

◆ NewBatch()

void CCassQuery::NewBatch ( void )

Definition at line 1384 of file cass_driver.cpp.

References IsActive(), m_batch, m_connection, m_qtimeoutms, m_use_per_request_timeout, RAISE_CASS_ERROR, and RAISE_DB_ERROR.

◆ NextRow()

async_rslt_t CCassQuery::NextRow ( )

Definition at line 1833 of file cass_driver.cpp.

References ar_dataready, ar_done, b, IsActive(), m_async, m_iterator, m_page_size, m_page_start, m_qtimeoutms, m_result, m_row, m_statement, RAISE_CASS_ERROR, RAISE_DB_ERROR, SetEOF(), and Wait().

◆ operator=()

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

privatedelete

◆ ParamAsInt32()

int32_t CCassQuery::ParamAsInt32 ( int iprm )

Definition at line 1338 of file cass_driver.cpp.

References CheckParamAssigned(), and m_params.

◆ ParamAsInt64()

int64_t CCassQuery::ParamAsInt64 ( int iprm )

Definition at line 1345 of file cass_driver.cpp.

References CheckParamAssigned(), and m_params.

◆ ParamAsStr() [1/2]

string CCassQuery::ParamAsStr ( int iprm ) const

Definition at line 1352 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 1359 of file cass_driver.cpp.

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

◆ ParamAsStrForDebug()

string CCassQuery::ParamAsStrForDebug ( int iprm ) const

Definition at line 1365 of file cass_driver.cpp.

References CheckParamAssigned(), and m_params.

Referenced by Restart().

◆ ParamCount()

size_t CCassQuery::ParamCount ( void ) const

inline

Definition at line 983 of file cass_driver.hpp.

References m_params.

Referenced by Restart(), and ToString().

◆ ParamType()

CassValueType CCassQuery::ParamType ( int iprm ) const

Definition at line 1371 of file cass_driver.cpp.

References CheckParamAssigned(), and m_params.

Referenced by ToString().

◆ ProcessFutureResult()

void CCassQuery::ProcessFutureResult ( )

private

Definition at line 1772 of file cass_driver.cpp.

References GetErrorCodeByDriverRC(), m_batch, m_cb_ref, m_connection, m_future, m_futuretime, m_iterator, m_onexecute, m_onexecute_data, m_page_start, m_result, m_results_expected, m_statement, ProduceCassandraQueryErrorMessage(), RAISE_CASS_QUERY_ERROR, RAISE_DB_ERROR, and SetEOF().

Referenced by Wait().

◆ Query()

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