classic_query_forwarder.cc File Reference

#include "classic_query_forwarder.h"
#include <charconv>
#include <limits>
#include <memory>
#include <system_error>
#include <variant>
#include "classic_connection_base.h"
#include "classic_frame.h"
#include "classic_lazy_connect.h"
#include "harness_assert.h"
#include "mysql/harness/stdx/expected.h"
#include "mysqld_error.h"
#include "mysqlrouter/classic_protocol_message.h"
#include "mysqlrouter/utils.h"
#include "show_warnings_parser.h"
#include "sql/lex.h"
#include "sql_exec_context.h"
#include "sql_lexer.h"
#include "sql_lexer_thd.h"
#include "sql_parser.h"

Functions
static std::ostream &	operator<< (std::ostream &os, stdx::flags< StmtClassifier > flags)
static stdx::flags< StmtClassifier >	classify (const std::string &stmt, bool forbid_set_trackers)
static uint64_t	get_error_count (MysqlRoutingClassicConnectionBase *connection)
static uint64_t	get_warning_count (MysqlRoutingClassicConnectionBase *connection)
static stdx::expected< void, std::error_code >	send_resultset (Channel *src_channel, ClassicProtocolState *src_protocol, std::vector< classic_protocol::message::server::ColumnMeta > columns, std::vector< classic_protocol::message::server::Row > rows)
std::vector< classic_protocol::message::server::Row >	rows_from_warnings (MysqlRoutingClassicConnectionBase *connection, ShowWarnings::Verbosity verbosity, uint64_t row_count, uint64_t offset)
static stdx::expected< void, std::error_code >	show_count (MysqlRoutingClassicConnectionBase *connection, const char *name, uint64_t count)
static const char *	show_warning_count_name (ShowWarningCount::Verbosity verbosity, ShowWarningCount::Scope scope)
static stdx::expected< void, std::error_code >	show_warning_count (MysqlRoutingClassicConnectionBase *connection, ShowWarningCount::Verbosity verbosity, ShowWarningCount::Scope scope)
static stdx::expected< void, std::error_code >	show_warnings (MysqlRoutingClassicConnectionBase *connection, ShowWarnings::Verbosity verbosity, uint64_t row_count, uint64_t offset)
static stdx::expected< std::variant< std::monostate, ShowWarningCount, ShowWarnings >, std::string >	intercept_diagnostics_area_queries (std::string_view stmt)

Function Documentation

classify()

static stdx::flags< StmtClassifier > classify ( const std::string &  stmt, bool  forbid_set_trackers  )

static

get_error_count()

static uint64_t get_error_count ( MysqlRoutingClassicConnectionBase *  connection )

static

get_warning_count()

static uint64_t get_warning_count ( MysqlRoutingClassicConnectionBase *  connection )

static

intercept_diagnostics_area_queries()

static stdx::expected< std::variant< std::monostate, ShowWarningCount, ShowWarnings >, std::string > intercept_diagnostics_area_queries ( std::string_view  stmt )

static

operator<<()

static std::ostream & operator<< ( std::ostream &  os, stdx::flags< StmtClassifier >  flags  )

static

rows_from_warnings()

std::vector< classic_protocol::message::server::Row > rows_from_warnings	(	MysqlRoutingClassicConnectionBase *	connection,
		ShowWarnings::Verbosity	verbosity,
		uint64_t	row_count,
		uint64_t	offset
	)

send_resultset()

static stdx::expected< void, std::error_code > send_resultset ( Channel *  src_channel, ClassicProtocolState *  src_protocol, std::vector< classic_protocol::message::server::ColumnMeta >  columns, std::vector< classic_protocol::message::server::Row >  rows  )

static

show_count()

static stdx::expected< void, std::error_code > show_count ( MysqlRoutingClassicConnectionBase *  connection, const char *  name, uint64_t  count  )

static

show_warning_count()

static stdx::expected< void, std::error_code > show_warning_count ( MysqlRoutingClassicConnectionBase *  connection, ShowWarningCount::Verbosity  verbosity, ShowWarningCount::Scope  scope  )

static

show_warning_count_name()

static const char * show_warning_count_name ( ShowWarningCount::Verbosity  verbosity, ShowWarningCount::Scope  scope  )

static

show_warnings()

static stdx::expected< void, std::error_code > show_warnings ( MysqlRoutingClassicConnectionBase *  connection, ShowWarnings::Verbosity  verbosity, uint64_t  row_count, uint64_t  offset  )

static