table_access_service.cc File Reference

#include <mysql/components/component_implementation.h>
#include <mysql/components/service.h>
#include <mysql/components/service_implementation.h>
#include <mysql/components/services/table_access_service.h>
#include "table_access_service_impl.h"
#include "my_compiler.h"
#include "my_dbug.h"
#include "sql/current_thd.h"
#include "sql/field.h"
#include "sql/mysqld.h"
#include "sql/mysqld_thd_manager.h"
#include "sql/sql_base.h"
#include "sql/sql_class.h"
#include "sql/sql_lex.h"
#include "sql/table.h"
#include "sql/table_trigger_dispatcher.h"
#include "sql/transaction.h"
#include "thr_lock.h"

Classes
struct	Table_state
class	Table_access_impl
class	TA_table_impl
class	TA_key_impl

Functions
static CHARSET_INFO *	get_api_charset ()
static String *	from_api (my_h_string api)
enum thr_lock_type	convert_lock_type (TA_lock_type api_lock_type)
TA_field_type	field_type_to_api (enum enum_field_types impl_field_type, bool &has_length)
static bool	is_access_to_tables_supported (Table_ref *table_array)
	Checks if access to the specified tables is supported. More...
Table_access	impl_create_table_access (THD *thd, size_t count)
void	impl_destroy_table_access (Table_access api_ta)
size_t	impl_add_table (Table_access api_ta, const char *schema_name, size_t schema_name_length, const char *table_name, size_t table_name_length, TA_lock_type api_lock_type)
int	impl_begin (Table_access api_ta)
int	impl_commit (Table_access api_ta)
int	impl_rollback (Table_access api_ta)
TA_table	impl_get_table (Table_access api_ta, size_t index)
int	impl_check_table_fields (Table_access, TA_table api_table, const TA_table_field_def *fields, size_t fields_count)
int	impl_index_init (Table_access, TA_table api_table, const char *index_name, size_t index_name_length, const TA_index_field_def *fields, size_t fields_count, TA_key *api_key)
int	impl_index_read_map (Table_access, TA_table api_table, size_t num_parts, TA_key api_key)
int	impl_index_first (Table_access, TA_table api_table, TA_key)
int	impl_index_next (Table_access, TA_table api_table, TA_key)
int	impl_index_next_same (Table_access, TA_table api_table, TA_key api_key)
int	impl_index_end (Table_access, TA_table api_table, TA_key api_key)
int	impl_rnd_init (Table_access, TA_table api_table)
int	impl_rnd_next (Table_access, TA_table api_table)
int	impl_rnd_end (Table_access, TA_table api_table)
int	impl_write_row (Table_access, TA_table api_table)
int	impl_update_row (Table_access, TA_table api_table)
int	impl_delete_row (Table_access, TA_table api_table)
static Field *	get_field (TABLE *table, size_t index)
void	impl_set_field_null (Table_access, TA_table api_table, size_t index)
bool	impl_is_field_null (Table_access, TA_table api_table, size_t index)
int	impl_set_field_integer_value (Table_access, TA_table api_table, size_t index, const long long v)
int	impl_get_field_integer_value (Table_access, TA_table api_table, size_t index, long long *v)
int	impl_set_field_varchar_value (Table_access, TA_table api_table, size_t index, my_h_string v)
int	impl_get_field_varchar_value (Table_access, TA_table api_table, size_t index, my_h_string v)
int	impl_set_field_any_value (Table_access, TA_table api_table, size_t index, my_h_string v)
int	impl_get_field_any_value (Table_access, TA_table api_table, size_t index, my_h_string v)
const mysql_service_table_access_v1_t	SERVICE_IMPLEMENTATION (mysql_server, table_access_v1)
const mysql_service_table_access_index_v1_t	SERVICE_IMPLEMENTATION (mysql_server, table_access_index_v1)
const mysql_service_table_access_scan_v1_t	SERVICE_IMPLEMENTATION (mysql_server, table_access_scan_v1)
const mysql_service_table_access_update_v1_t	SERVICE_IMPLEMENTATION (mysql_server, table_access_update_v1)
const mysql_service_field_access_nullability_v1_t	SERVICE_IMPLEMENTATION (mysql_server, field_access_nullability_v1)
const mysql_service_field_integer_access_v1_t	SERVICE_IMPLEMENTATION (mysql_server, field_integer_access_v1)
const mysql_service_field_varchar_access_v1_t	SERVICE_IMPLEMENTATION (mysql_server, field_varchar_access_v1)
const mysql_service_field_any_access_v1_t	SERVICE_IMPLEMENTATION (mysql_server, field_any_access_v1)

Variables
const mysql_service_table_access_factory_v1_t	SERVICE_IMPLEMENTATION (mysql_server, table_access_factory_v1)

Function Documentation

convert_lock_type()

enum thr_lock_type convert_lock_type

(

TA_lock_type

api_lock_type

)

field_type_to_api()

TA_field_type field_type_to_api	(	enum enum_field_types	impl_field_type,
		bool &	has_length
	)

from_api()

static String * from_api ( my_h_string  api )

static

get_api_charset()

static CHARSET_INFO * get_api_charset ( )

static

get_field()

static Field * get_field ( TABLE *  table, size_t  index  )

static

impl_add_table()

size_t impl_add_table	(	Table_access	api_ta,
		const char *	schema_name,
		size_t	schema_name_length,
		const char *	table_name,
		size_t	table_name_length,
		TA_lock_type	api_lock_type
	)

impl_begin()

int impl_begin

(

Table_access

api_ta

)

impl_check_table_fields()

int impl_check_table_fields	(	Table_access	,
		TA_table	api_table,
		const TA_table_field_def *	fields,
		size_t	fields_count
	)

impl_commit()

int impl_commit

(

Table_access

api_ta

)

impl_create_table_access()

Table_access impl_create_table_access	(	THD *	thd,
		size_t	count
	)

impl_delete_row()

int impl_delete_row	(	Table_access	,
		TA_table	api_table
	)

impl_destroy_table_access()

void impl_destroy_table_access

(

Table_access

api_ta

)

impl_get_field_any_value()

int impl_get_field_any_value	(	Table_access	,
		TA_table	api_table,
		size_t	index,
		my_h_string	v
	)

impl_get_field_integer_value()

int impl_get_field_integer_value	(	Table_access	,
		TA_table	api_table,
		size_t	index,
		long long *	v
	)

impl_get_field_varchar_value()

int impl_get_field_varchar_value	(	Table_access	,
		TA_table	api_table,
		size_t	index,
		my_h_string	v
	)

impl_get_table()

TA_table impl_get_table	(	Table_access	api_ta,
		size_t	index
	)

impl_index_end()

int impl_index_end	(	Table_access	,
		TA_table	api_table,
		TA_key	api_key
	)

impl_index_first()

int impl_index_first	(	Table_access	,
		TA_table	api_table,
		TA_key
	)

impl_index_init()

int impl_index_init	(	Table_access	,
		TA_table	api_table,
		const char *	index_name,
		size_t	index_name_length,
		const TA_index_field_def *	fields,
		size_t	fields_count,
		TA_key *	api_key
	)

impl_index_next()

int impl_index_next	(	Table_access	,
		TA_table	api_table,
		TA_key
	)

impl_index_next_same()

int impl_index_next_same	(	Table_access	,
		TA_table	api_table,
		TA_key	api_key
	)

impl_index_read_map()

int impl_index_read_map	(	Table_access	,
		TA_table	api_table,
		size_t	num_parts,
		TA_key	api_key
	)

impl_is_field_null()

bool impl_is_field_null	(	Table_access	,
		TA_table	api_table,
		size_t	index
	)

impl_rnd_end()

int impl_rnd_end	(	Table_access	,
		TA_table	api_table
	)

impl_rnd_init()

int impl_rnd_init	(	Table_access	,
		TA_table	api_table
	)

impl_rnd_next()

int impl_rnd_next	(	Table_access	,
		TA_table	api_table
	)

impl_rollback()

int impl_rollback

(

Table_access

api_ta

)

impl_set_field_any_value()

int impl_set_field_any_value	(	Table_access	,
		TA_table	api_table,
		size_t	index,
		my_h_string	v
	)

impl_set_field_integer_value()

int impl_set_field_integer_value	(	Table_access	,
		TA_table	api_table,
		size_t	index,
		const long long	v
	)

impl_set_field_null()

void impl_set_field_null	(	Table_access	,
		TA_table	api_table,
		size_t	index
	)

impl_set_field_varchar_value()

int impl_set_field_varchar_value	(	Table_access	,
		TA_table	api_table,
		size_t	index,
		my_h_string	v
	)

impl_update_row()

int impl_update_row	(	Table_access	,
		TA_table	api_table
	)

impl_write_row()

int impl_write_row	(	Table_access	,
		TA_table	api_table
	)

is_access_to_tables_supported()

static bool is_access_to_tables_supported ( Table_ref *  table_array )

static

Checks if access to the specified tables is supported.

Check if the table access service supports the requested operation for the requested set of tables. This currently includes: not writing to a table that has generated columns not writing to a table that has triggers

Warning

This needs to be called after the tabes are opened.

Parameters

table_array

The list of tables accessed

Return values

true	operation can continue
false	we should stop

SERVICE_IMPLEMENTATION() [1/8]

const mysql_service_field_access_nullability_v1_t SERVICE_IMPLEMENTATION	(	mysql_server	,
		field_access_nullability_v1
	)

SERVICE_IMPLEMENTATION() [2/8]

const mysql_service_field_any_access_v1_t SERVICE_IMPLEMENTATION	(	mysql_server	,
		field_any_access_v1
	)

SERVICE_IMPLEMENTATION() [3/8]

const mysql_service_field_integer_access_v1_t SERVICE_IMPLEMENTATION	(	mysql_server	,
		field_integer_access_v1
	)

SERVICE_IMPLEMENTATION() [4/8]

const mysql_service_field_varchar_access_v1_t SERVICE_IMPLEMENTATION	(	mysql_server	,
		field_varchar_access_v1
	)

SERVICE_IMPLEMENTATION() [5/8]

const mysql_service_table_access_index_v1_t SERVICE_IMPLEMENTATION	(	mysql_server	,
		table_access_index_v1
	)

SERVICE_IMPLEMENTATION() [6/8]

const mysql_service_table_access_scan_v1_t SERVICE_IMPLEMENTATION	(	mysql_server	,
		table_access_scan_v1
	)

SERVICE_IMPLEMENTATION() [7/8]

const mysql_service_table_access_update_v1_t SERVICE_IMPLEMENTATION	(	mysql_server	,
		table_access_update_v1
	)

SERVICE_IMPLEMENTATION() [8/8]

const mysql_service_table_access_v1_t SERVICE_IMPLEMENTATION	(	mysql_server	,
		table_access_v1
	)

Variable Documentation

SERVICE_IMPLEMENTATION

const mysql_service_field_any_access_v1_t SERVICE_IMPLEMENTATION(mysql_server, field_any_access_v1)	(	mysql_server	,
		table_access_factory_v1
	)

Initial value:

= {
    impl_create_table_access, impl_destroy_table_access}