29#ifndef MYSQLSHDK_LIBS_DB_MYSQL_RESULT_H_
30#define MYSQLSHDK_LIBS_DB_MYSQL_RESULT_H_
82 const std::vector<std::shared_ptr<IColumn>> &
get_metadata()
const override {
93 DbResult(std::shared_ptr<Session> owner, uint64_t affected_rows,
94 uint64_t last_insert_id,
const char *info,
bool buffered);
95 void reset(std::shared_ptr<MYSQL_RES> res);
114 virtual std::shared_ptr<Field_names>
field_names()
const;
116 std::weak_ptr<shcore::polyglot::database::Session>
_session;
A row of result or a row of metadata A row is a collection of Column values or Column metadata.
Definition: protocol_local_v2.h:92
Definition: jit_executor_db_interface.h:57
Definition: jit_executor_db_interface.h:151
Definition: jit_executor_db_interface.h:82
std::unique_ptr< Row > _row
Definition: result.h:118
uint64_t _affected_rows
Definition: result.h:122
virtual std::shared_ptr< Field_names > field_names() const
Definition: result.cc:394
DbResult(std::shared_ptr< Session > owner, uint64_t affected_rows, uint64_t last_insert_id, const char *info, bool buffered)
Definition: result.cc:45
std::deque< Row_copy > _pre_fetched_rows
Definition: result.h:97
uint64_t get_affected_row_count() const override
Definition: result.h:75
bool next_resultset() override
Definition: result.cc:274
uint64_t _fetched_row_count
Definition: result.h:124
std::weak_ptr< MYSQL_RES > _result
Definition: result.h:119
uint64_t _last_insert_id
Definition: result.h:123
const std::vector< std::string > & get_gtids() const override
Definition: result.h:81
std::string get_statement_id() const override
Definition: result.cc:270
const jit_executor::db::IRow * fetch_one() override
Definition: result.cc:192
void fetch_metadata()
Definition: result.cc:157
const std::vector< std::shared_ptr< IColumn > > & get_metadata() const override
Definition: result.h:82
std::string get_info() const override
Definition: result.h:80
bool m_buffered
Definition: result.h:129
bool has_resultset() override
Definition: result.h:74
std::vector< std::shared_ptr< IColumn > > _metadata
Definition: result.h:117
bool _pre_fetched
Definition: result.h:100
uint64_t get_warning_count() const override
Definition: result.cc:296
uint64_t get_fetched_row_count() const override
Definition: result.h:78
std::vector< std::string > _gtids
Definition: result.h:120
void rewind() override
Definition: result.cc:288
bool pre_fetch_row()
Definition: result.cc:361
shcore::atomic_flag _stop_pre_fetch
Definition: result.h:99
bool pre_fetch_rows(bool persistent)
Definition: result.cc:375
std::optional< std::string > m_statement_id
Definition: result.h:130
bool _persistent_pre_fetch
Definition: result.h:101
void buffer() override
Definition: result.cc:353
bool _pre_fetched_clear_at_end
Definition: result.h:102
bool _fetched_warnings
Definition: result.h:128
Type map_data_type(int raw_type, int flags)
Definition: result.cc:404
void fetch_statement_id()
Definition: result.cc:262
bool _has_resultset
Definition: result.h:127
std::unique_ptr< jit_executor::db::Warning > fetch_one_warning() override
Definition: result.cc:301
std::shared_ptr< Field_names > _field_names
Definition: result.h:121
std::weak_ptr< shcore::polyglot::database::Session > _session
Definition: result.h:116
std::list< std::unique_ptr< Warning > > _warnings
Definition: result.h:126
std::string _info
Definition: result.h:125
bool is_buffered()
Definition: result.h:90
void reset(std::shared_ptr< MYSQL_RES > res)
Definition: result.cc:333
void stop_pre_fetch()
Definition: result.cc:392
int64_t get_auto_increment_value() const override
Definition: result.h:73
mrs::interface::RestHandler::HttpResult::Type Type
Definition: handler_content_file.cc:42
static int flags[50]
Definition: hp_test1.cc:40
This file defines the client API to MySQL and also the ABI of the dynamically linked libmysqlclient.
uint64_t my_ulonglong
Definition: mysql.h:54
AuthorizeManager::Session Session
Definition: authorize_manager.cc:75
Definition: file_system_exceptions.h:34
Definition: jit_executor_db_interface.h:144