#include <result.h>

Inheritance diagram for shcore::polyglot::database::DbResult:

Public Member Functions
	~DbResult () override

const jit_executor::db::IRow *	fetch_one () override

bool	next_resultset () override

std::unique_ptr< jit_executor::db::Warning >	fetch_one_warning () override

int64_t	get_auto_increment_value () const override

bool	has_resultset () override

uint64_t	get_affected_row_count () const override

uint64_t	get_fetched_row_count () const override

uint64_t	get_warning_count () const override

std::string	get_info () const override

const std::vector< std::string > &	get_gtids () const override

const std::vector< std::shared_ptr< IColumn > > &	get_metadata () const override

std::string	get_statement_id () const override

void	buffer () override

void	rewind () override

bool	is_buffered ()

Public Member Functions inherited from jit_executor::db::IResult
	IResult ()=default

double	get_execution_time () const

void	set_execution_time (double time)

virtual	~IResult ()=default

Protected Member Functions
	DbResult (std::shared_ptr< Session > owner, uint64_t affected_rows, uint64_t last_insert_id, const char *info, bool buffered)

void	reset (std::shared_ptr< MYSQL_RES > res)

bool	pre_fetch_row ()

bool	pre_fetch_rows (bool persistent)

void	stop_pre_fetch ()

void	fetch_metadata ()

void	fetch_statement_id ()

Type	map_data_type (int raw_type, int flags)

virtual std::shared_ptr< Field_names >	field_names () const

Protected Attributes
std::deque< Row_copy >	_pre_fetched_rows

shcore::atomic_flag	_stop_pre_fetch

bool	_pre_fetched = false

bool	_persistent_pre_fetch = false

bool	_pre_fetched_clear_at_end = false

std::weak_ptr< shcore::polyglot::database::Session >	_session

std::vector< std::shared_ptr< IColumn > >	_metadata

std::unique_ptr< Row >	_row

std::weak_ptr< MYSQL_RES >	_result

std::vector< std::string >	_gtids

std::shared_ptr< Field_names >	_field_names

uint64_t	_affected_rows = 0

uint64_t	_last_insert_id = 0

uint64_t	_fetched_row_count = 0

std::string	_info

std::list< std::unique_ptr< Warning > >	_warnings

bool	_has_resultset = false

bool	_fetched_warnings = false

bool	m_buffered = false

std::optional< std::string >	m_statement_id

Protected Attributes inherited from jit_executor::db::IResult
double	m_execution_time = 0.0

Friends
class	Session

Constructor & Destructor Documentation

◆ ~DbResult()

shcore::polyglot::database::DbResult::~DbResult ( )

overridedefault

◆ DbResult()

shcore::polyglot::database::DbResult::DbResult	(	std::shared_ptr< Session >	owner,
		uint64_t	affected_rows,
		uint64_t	last_insert_id,
		const char *	info,
		bool	buffered
	)

protected

Member Function Documentation

◆ buffer()

void shcore::polyglot::database::DbResult::buffer ( )

overridevirtual

Implements jit_executor::db::IResult.

◆ fetch_metadata()

void shcore::polyglot::database::DbResult::fetch_metadata ( )

protected

◆ fetch_one()

const IRow * shcore::polyglot::database::DbResult::fetch_one ( )

overridevirtual

Implements jit_executor::db::IResult.

◆ fetch_one_warning()

std::unique_ptr< Warning > shcore::polyglot::database::DbResult::fetch_one_warning ( )

overridevirtual

Implements jit_executor::db::IResult.

◆ fetch_statement_id()

void shcore::polyglot::database::DbResult::fetch_statement_id ( )

protected

◆ field_names()

std::shared_ptr< Field_names > shcore::polyglot::database::DbResult::field_names ( ) const

protectedvirtual

◆ get_affected_row_count()

uint64_t shcore::polyglot::database::DbResult::get_affected_row_count ( ) const

inlineoverridevirtual

Implements jit_executor::db::IResult.

◆ get_auto_increment_value()

int64_t shcore::polyglot::database::DbResult::get_auto_increment_value ( ) const

inlineoverridevirtual

Implements jit_executor::db::IResult.

◆ get_fetched_row_count()

uint64_t shcore::polyglot::database::DbResult::get_fetched_row_count ( ) const

inlineoverridevirtual

Implements jit_executor::db::IResult.

◆ get_gtids()

const std::vector< std::string > & shcore::polyglot::database::DbResult::get_gtids ( ) const

inlineoverridevirtual

Implements jit_executor::db::IResult.

◆ get_info()

std::string shcore::polyglot::database::DbResult::get_info ( ) const

inlineoverridevirtual

Implements jit_executor::db::IResult.

◆ get_metadata()

const std::vector< std::shared_ptr< IColumn > > & shcore::polyglot::database::DbResult::get_metadata ( ) const

inlineoverridevirtual

Implements jit_executor::db::IResult.

◆ get_statement_id()

std::string shcore::polyglot::database::DbResult::get_statement_id ( ) const

overridevirtual

Reimplemented from jit_executor::db::IResult.

◆ get_warning_count()

uint64_t shcore::polyglot::database::DbResult::get_warning_count ( ) const

overridevirtual

Implements jit_executor::db::IResult.

◆ has_resultset()

bool shcore::polyglot::database::DbResult::has_resultset ( )

inlineoverridevirtual

Implements jit_executor::db::IResult.

◆ is_buffered()

bool shcore::polyglot::database::DbResult::is_buffered ( )

inline

◆ map_data_type()

Type shcore::polyglot::database::DbResult::map_data_type	(	int	raw_type,
		int	flags
	)

protected

◆ next_resultset()

bool shcore::polyglot::database::DbResult::next_resultset ( )

overridevirtual

Implements jit_executor::db::IResult.

◆ pre_fetch_row()

bool shcore::polyglot::database::DbResult::pre_fetch_row ( )

protected

◆ pre_fetch_rows()

bool shcore::polyglot::database::DbResult::pre_fetch_rows ( bool persistent )

protected

◆ reset()

void shcore::polyglot::database::DbResult::reset ( std::shared_ptr< MYSQL_RES > res )

protected

◆ rewind()

void shcore::polyglot::database::DbResult::rewind ( )

overridevirtual

Implements jit_executor::db::IResult.

◆ stop_pre_fetch()

void shcore::polyglot::database::DbResult::stop_pre_fetch ( )

protected

Friends And Related Function Documentation

◆ Session

friend class Session

friend

Member Data Documentation

◆ _affected_rows

uint64_t shcore::polyglot::database::DbResult::_affected_rows = 0

protected

◆ _fetched_row_count

uint64_t shcore::polyglot::database::DbResult::_fetched_row_count = 0

protected

◆ _fetched_warnings

bool shcore::polyglot::database::DbResult::_fetched_warnings = false

protected

◆ _field_names

std::shared_ptr<Field_names> shcore::polyglot::database::DbResult::_field_names

mutableprotected

◆ _gtids

std::vector<std::string> shcore::polyglot::database::DbResult::_gtids

protected

◆ _has_resultset

bool shcore::polyglot::database::DbResult::_has_resultset = false

protected

◆ _info

std::string shcore::polyglot::database::DbResult::_info

protected

◆ _last_insert_id

uint64_t shcore::polyglot::database::DbResult::_last_insert_id = 0

protected

◆ _metadata

std::vector<std::shared_ptr<IColumn> > shcore::polyglot::database::DbResult::_metadata

protected

◆ _persistent_pre_fetch

bool shcore::polyglot::database::DbResult::_persistent_pre_fetch = false

protected

◆ _pre_fetched

bool shcore::polyglot::database::DbResult::_pre_fetched = false

protected

◆ _pre_fetched_clear_at_end

bool shcore::polyglot::database::DbResult::_pre_fetched_clear_at_end = false

protected

◆ _pre_fetched_rows

std::deque<Row_copy> shcore::polyglot::database::DbResult::_pre_fetched_rows

protected

◆ _result

std::weak_ptr<MYSQL_RES> shcore::polyglot::database::DbResult::_result

protected

◆ _row

std::unique_ptr<Row> shcore::polyglot::database::DbResult::_row

protected

◆ _session

std::weak_ptr<shcore::polyglot::database::Session> shcore::polyglot::database::DbResult::_session

protected

◆ _stop_pre_fetch

shcore::atomic_flag shcore::polyglot::database::DbResult::_stop_pre_fetch

protected

◆ _warnings

std::list<std::unique_ptr<Warning> > shcore::polyglot::database::DbResult::_warnings

protected

◆ m_buffered

bool shcore::polyglot::database::DbResult::m_buffered = false

protected

◆ m_statement_id

std::optional<std::string> shcore::polyglot::database::DbResult::m_statement_id

protected

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

router/src/jit_executor/src/database/result.h
router/src/jit_executor/src/database/result.cc

Public Member Functions

Protected Member Functions

Protected Attributes

Friends

Constructor & Destructor Documentation

◆ ~DbResult()

◆ DbResult()

Member Function Documentation

◆ buffer()

◆ fetch_metadata()

◆ fetch_one()

◆ fetch_one_warning()

◆ fetch_statement_id()

◆ field_names()

◆ get_affected_row_count()

◆ get_auto_increment_value()

◆ get_fetched_row_count()

◆ get_gtids()

◆ get_info()

◆ get_metadata()

◆ get_statement_id()

◆ get_warning_count()

◆ has_resultset()

◆ is_buffered()

◆ map_data_type()

◆ next_resultset()

◆ pre_fetch_row()

◆ pre_fetch_rows()

◆ reset()

◆ rewind()

◆ stop_pre_fetch()

Friends And Related Function Documentation

◆ Session

Member Data Documentation

◆ _affected_rows

◆ _fetched_row_count

◆ _fetched_warnings

◆ _field_names

◆ _gtids

◆ _has_resultset

◆ _info

◆ _last_insert_id

◆ _metadata

◆ _persistent_pre_fetch

◆ _pre_fetched

◆ _pre_fetched_clear_at_end

◆ _pre_fetched_rows

◆ _result

◆ _row

◆ _session

◆ _stop_pre_fetch

◆ _warnings

◆ m_buffered

◆ m_statement_id