mirror of
https://github.com/MariaDB/server.git
synced 2025-02-02 20:11:42 +01:00
4e72191ce9
Backport of functionality in private 5.2 tree. Added new language to parser, new mysql.servers table and associated code to be used by the federated storage engine to allow central connection information per WL entry. libmysqld/Makefile.am: WL# 3031 Added sql_servers.cc to libmysqld Makefile.am mysql-test/lib/init_db.sql: WL# 3031 Added mysql.servers creation to init_db.sql, which is in turn called by mysql-test-run.pl scripts/mysql_create_system_tables.sh: WL# 3031 Added mysql.servers table creation to script called by non-perl mysql-test-run sql/Makefile.am: WL# 3031 Added sql_servers source and headers to Makefile.am to be built sql/lex.h: WL# 3031 Added tokens needed for SERVERS scheme sql/mysql_priv.h: WL #3031 Added sql_servers.h to mysql_priv.h so mysqld.cc and other code can link with sql_servers code sql/mysqld.cc: WL# 3031 Added servers_free and servers_init to mysqld sql/sql_lex.cc: WL# 3031 Added lex->server_options parameter initialisation sql/sql_lex.h: WL #3031 Added SQLCOM commands needed for sql_server actions sql/sql_parse.cc: WL# 3031 Added switch actions for new SQLCOM sql_server actions sql/sql_yacc.yy: WL #3031 Added tokens needed for sql_servers, CREATE/DROP/ALTER server functionality sql/share/errmsg.txt: WL# 3031 Added two new errors to errormsg.sys storage/federated/ha_federated.cc: WL #3031 Modified federated storage engine to use new connection scheme (servers table) if connection string only specifies connection name vs. complete URL storage/federated/ha_federated.h: WL# 3031 Added new share members needed for connection scheme sql/sql_servers.cc: WL #3031 sql_servers.cc - all methods required for manipulating mysql.servers table to work with federated new connection scheme (CREATE/ALTER/DROP SERVER ...) sql/sql_servers.h: WL #3031 New header file for sql_servers functionality mysql-test/r/federated_server.result: WL #3031 New test results for testing new connection scheme sql/sql_yacc.yy.bak: WL #3031 Added tokens and definitions required for new CREATE/ALTER/DROP SERVER for sql_servers functionality. See WL for details. mysql-test/t/federated_server.test: WL #3031 New test for testing CREATE/ALTER/DROP SERVER, as well as testing that federated works with both tradition connection scheme as well as new connection scheme.
66 lines
2.9 KiB
C
66 lines
2.9 KiB
C
/* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; either version 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
|
|
|
|
#include "slave.h" // for tables_ok(), rpl_filter
|
|
|
|
/* structs */
|
|
typedef struct st_federated_server
|
|
{
|
|
char *server_name;
|
|
long port;
|
|
uint server_name_length;
|
|
char *db, *scheme, *username, *password, *socket, *owner, *host, *sport;
|
|
} FOREIGN_SERVER;
|
|
|
|
/* cache handlers */
|
|
my_bool servers_init(bool dont_read_server_table);
|
|
static my_bool servers_load(THD *thd, TABLE_LIST *tables);
|
|
my_bool servers_reload(THD *thd);
|
|
my_bool get_server_from_table_to_cache(TABLE *table);
|
|
void servers_free(bool end=0);
|
|
|
|
/* insert functions */
|
|
int create_server(THD *thd, LEX_SERVER_OPTIONS *server_options);
|
|
int insert_server(THD *thd, FOREIGN_SERVER *server_options);
|
|
int insert_server_record(TABLE *table, FOREIGN_SERVER *server);
|
|
int insert_server_record_into_cache(FOREIGN_SERVER *server);
|
|
void store_server_fields_for_insert(TABLE *table, FOREIGN_SERVER *server);
|
|
void store_server_fields_for_insert(TABLE *table,
|
|
FOREIGN_SERVER *existing,
|
|
FOREIGN_SERVER *altered);
|
|
int prepare_server_struct_for_insert(LEX_SERVER_OPTIONS *server_options,
|
|
FOREIGN_SERVER *server);
|
|
|
|
/* drop functions */
|
|
int drop_server(THD *thd, LEX_SERVER_OPTIONS *server_options);
|
|
int delete_server_record(TABLE *table,
|
|
char *server_name,
|
|
int server_name_length);
|
|
int delete_server_record_in_cache(LEX_SERVER_OPTIONS *server_options);
|
|
|
|
/* update functions */
|
|
int alter_server(THD *thd, LEX_SERVER_OPTIONS *server_options);
|
|
int prepare_server_struct_for_update(LEX_SERVER_OPTIONS *server_options,
|
|
FOREIGN_SERVER *existing,
|
|
FOREIGN_SERVER *altered);
|
|
int update_server(THD *thd, FOREIGN_SERVER *existing, FOREIGN_SERVER *altered);
|
|
int update_server_record(TABLE *table, FOREIGN_SERVER *server);
|
|
int update_server_record_in_cache(FOREIGN_SERVER *existing,
|
|
FOREIGN_SERVER *altered);
|
|
/* utility functions */
|
|
void merge_server_struct(FOREIGN_SERVER *from, FOREIGN_SERVER *to);
|
|
FOREIGN_SERVER *get_server_by_name(const char *server_name);
|
|
my_bool server_exists_in_table(THD *thd, char *server_name);
|