ha_federated.cc File Reference

#include "storage/federated/ha_federated.h"
#include <mysql/plugin.h>
#include <stdlib.h>
#include <algorithm>
#include <string>
#include "lex_string.h"
#include "map_helpers.h"
#include "my_byteorder.h"
#include "my_compiler.h"
#include "my_dbug.h"
#include "my_macros.h"
#include "my_psi_config.h"
#include "myisam.h"
#include "mysql/psi/mysql_memory.h"
#include "mysql/psi/mysql_mutex.h"
#include "mysql/strings/m_ctype.h"
#include "mysql/strings/my_strtoll10.h"
#include "sql/current_thd.h"
#include "sql/key.h"
#include "sql/mysqld.h"
#include "sql/sql_class.h"
#include "sql/sql_lex.h"
#include "sql/sql_servers.h"
#include "sql_common.h"
#include "string_with_len.h"
#include "strmake.h"
#include "template_utils.h"
#include "unsafe_string_append.h"

Macros
#define	MYSQL_SERVER   1

Functions
static handler *	federated_create_handler (handlerton *hton, TABLE_SHARE *table, bool partitioned, MEM_ROOT *mem_root)
static int	federated_commit (handlerton *hton, THD *thd, bool all)
static int	federated_rollback (handlerton *hton, THD *thd, bool all)
static void	init_federated_psi_keys (void)
static int	federated_db_init (void *p)
static int	federated_done (void *)
static bool	append_ident (String *string, const char *name, size_t length, const char quote_char)
	Append identifiers to the string. More...
static int	parse_url_error (TABLE *table, int error_num)
static int	get_connection (MEM_ROOT *mem_root, FEDERATED_SHARE *share)
static int	parse_url (MEM_ROOT *mem_root, FEDERATED_SHARE *share, TABLE *table, uint table_create_flag)
static bool	emit_key_part_name (String *to, KEY_PART_INFO *part)
static bool	emit_key_part_element (String *to, KEY_PART_INFO *part, bool needs_quotes, bool is_like, uchar *ptr, uint len)
static FEDERATED_SHARE *	get_share (const char *table_name, TABLE *table)
static int	free_share (FEDERATED_SHARE *share)
	mysql_declare_plugin (federated)

Variables
static PSI_memory_key	fe_key_memory_federated_share
static malloc_unordered_map< string, FEDERATED_SHARE * >	federated_open_tables
mysql_mutex_t	federated_mutex
static char	ident_quote_char = '`'
static char	value_quote_char = '\''
static const int	bulk_padding = 64
static const uint	sizeof_trailing_comma = sizeof(", ") - 1
static const uint	sizeof_trailing_and = sizeof(" AND ") - 1
static const uint	sizeof_trailing_where = sizeof(" WHERE ") - 1
static PSI_mutex_key	fe_key_mutex_federated
static PSI_mutex_key	fe_key_mutex_FEDERATED_SHARE_mutex
static PSI_mutex_info	all_federated_mutexes []
static PSI_memory_info	all_federated_memory []
struct st_mysql_storage_engine	federated_storage_engine
	mysql_declare_plugin_end

Macro Definition Documentation

MYSQL_SERVER

#define MYSQL_SERVER   1

Function Documentation

append_ident()

static bool append_ident ( String *  string, const char *  name, size_t  length, const char  quote_char  )

static

Append identifiers to the string.

Parameters

[in,out]	string	The target string.
[in]	name	Identifier name
[in]	length	Length of identifier name in bytes
[in]	quote_char	Quote char to use for quoting identifier.

Returns

Operation Status

Return values

false	OK
true	There was an error appending to the string.

Note

See similar function append_identifier() in sql_show.cc that always quotes based on sql mode.

emit_key_part_element()

static bool emit_key_part_element ( String *  to, KEY_PART_INFO *  part, bool  needs_quotes, bool  is_like, uchar *  ptr, uint  len  )

static

emit_key_part_name()

static bool emit_key_part_name ( String *  to, KEY_PART_INFO *  part  )

static

federated_commit()

static int federated_commit ( handlerton *  hton, THD *  thd, bool  all  )

static

federated_create_handler()

static handler * federated_create_handler ( handlerton *  hton, TABLE_SHARE *  table, bool  partitioned, MEM_ROOT *  mem_root  )

static

federated_db_init()

static int federated_db_init ( void *  p )

static

federated_done()

static int federated_done ( void *  )

static

federated_rollback()

static int federated_rollback ( handlerton *  hton, THD *  thd, bool  all  )

static

free_share()

static int free_share ( FEDERATED_SHARE *  share )

static

get_connection()

static int get_connection ( MEM_ROOT *  mem_root, FEDERATED_SHARE *  share  )

static

get_share()

static FEDERATED_SHARE * get_share ( const char *  table_name, TABLE *  table  )

static

init_federated_psi_keys()

static void init_federated_psi_keys ( void  )

static

mysql_declare_plugin()

mysql_declare_plugin

(

federated

)

parse_url()

static int parse_url ( MEM_ROOT *  mem_root, FEDERATED_SHARE *  share, TABLE *  table, uint  table_create_flag  )

static

parse_url_error()

static int parse_url_error ( TABLE *  table, int  error_num  )

static

Variable Documentation

all_federated_memory

PSI_memory_info all_federated_memory[]

static

Initial value:

= {
    {&fe_key_memory_federated_share, "FEDERATED_SHARE",
     PSI_FLAG_ONLY_GLOBAL_STAT, 0, PSI_DOCUMENT_ME}}

all_federated_mutexes

PSI_mutex_info all_federated_mutexes[]

static

Initial value:

=
{
  { &fe_key_mutex_federated, "federated", PSI_FLAG_SINGLETON, 0, PSI_DOCUMENT_ME},
  { &fe_key_mutex_FEDERATED_SHARE_mutex, "FEDERATED_SHARE::mutex", 0, 0, PSI_DOCUMENT_ME}
}

bulk_padding

const int bulk_padding = 64

static

fe_key_memory_federated_share

PSI_memory_key fe_key_memory_federated_share

static

fe_key_mutex_federated

PSI_mutex_key fe_key_mutex_federated

static

fe_key_mutex_FEDERATED_SHARE_mutex

PSI_mutex_key fe_key_mutex_FEDERATED_SHARE_mutex

static

federated_mutex

mysql_mutex_t federated_mutex

federated_open_tables

malloc_unordered_map<string, FEDERATED_SHARE *> federated_open_tables

static

Initial value:

{
    fe_key_memory_federated_share}

federated_storage_engine

struct st_mysql_storage_engine federated_storage_engine

Initial value:

= {
    MYSQL_HANDLERTON_INTERFACE_VERSION}

ident_quote_char

char ident_quote_char = '`'

static

mysql_declare_plugin_end

mysql_declare_plugin_end

sizeof_trailing_and

const uint sizeof_trailing_and = sizeof(" AND ") - 1

static

sizeof_trailing_comma

const uint sizeof_trailing_comma = sizeof(", ") - 1

static

sizeof_trailing_where

const uint sizeof_trailing_where = sizeof(" WHERE ") - 1

static

value_quote_char

char value_quote_char = '\''

static