/* Copyright (C) 2010-2020 Kentoku Shiba Copyright (C) 2019-2020 MariaDB corp 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; version 2 of the License. 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 */ /* This SQL script creates system tables for SPIDER or fixes incompatibilities if ones already exist. */ static LEX_STRING spider_init_queries[] = { {C_STRING_WITH_LEN( "create table if not exists mysql.spider_xa(" " format_id int not null default 0," " gtrid_length int not null default 0," " bqual_length int not null default 0," " data char(128) charset binary not null default ''," " status char(8) not null default ''," " primary key (data, format_id, gtrid_length)," " key idx1 (status)" ") engine=MyISAM default charset=utf8 collate=utf8_bin" )}, {C_STRING_WITH_LEN( "create table if not exists mysql.spider_xa_member(" " format_id int not null default 0," " gtrid_length int not null default 0," " bqual_length int not null default 0," " data char(128) charset binary not null default ''," " scheme char(64) not null default ''," " host char(64) not null default ''," " port char(5) not null default ''," " socket text not null," " username char(64) not null default ''," " password char(64) not null default ''," " ssl_ca text," " ssl_capath text," " ssl_cert text," " ssl_cipher char(64) default null," " ssl_key text," " ssl_verify_server_cert tinyint not null default 0," " default_file text," " default_group char(64) default null," " dsn char(64) default null," " key idx1 (data, format_id, gtrid_length, host)" ") engine=MyISAM default charset=utf8 collate=utf8_bin" )}, {C_STRING_WITH_LEN( "create table if not exists mysql.spider_xa_failed_log(" " format_id int not null default 0," " gtrid_length int not null default 0," " bqual_length int not null default 0," " data char(128) charset binary not null default ''," " scheme char(64) not null default ''," " host char(64) not null default ''," " port char(5) not null default ''," " socket text not null," " username char(64) not null default ''," " password char(64) not null default ''," " ssl_ca text," " ssl_capath text," " ssl_cert text," " ssl_cipher char(64) default null," " ssl_key text," " ssl_verify_server_cert tinyint not null default 0," " default_file text," " default_group char(64) default null," " dsn char(64) default null," " thread_id int default null," " status char(8) not null default ''," " failed_time timestamp not null default current_timestamp," " key idx1 (data, format_id, gtrid_length, host)" ") engine=MyISAM default charset=utf8 collate=utf8_bin" )}, {C_STRING_WITH_LEN( "create table if not exists mysql.spider_tables(" " db_name char(64) not null default ''," " table_name char(199) not null default ''," " link_id int not null default 0," " priority bigint not null default 0," " server char(64) default null," " scheme char(64) default null," " host char(64) default null," " port char(5) default null," " socket text," " username char(64) default null," " password char(64) default null," " ssl_ca text," " ssl_capath text," " ssl_cert text," " ssl_cipher char(64) default null," " ssl_key text," " ssl_verify_server_cert tinyint not null default 0," " monitoring_binlog_pos_at_failing tinyint not null default 0," " default_file text," " default_group char(64) default null," " dsn char(64) default null," " tgt_db_name char(64) default null," " tgt_table_name char(64) default null," " link_status tinyint not null default 1," " block_status tinyint not null default 0," " static_link_id char(64) default null," " primary key (db_name, table_name, link_id)," " key idx1 (priority)," " unique key uidx1 (db_name, table_name, static_link_id)" ") engine=MyISAM default charset=utf8 collate=utf8_bin" )}, {C_STRING_WITH_LEN( "create table if not exists mysql.spider_link_mon_servers(" " db_name char(64) not null default ''," " table_name char(199) not null default ''," " link_id char(64) not null default ''," " sid int unsigned not null default 0," " server char(64) default null," " scheme char(64) default null," " host char(64) default null," " port char(5) default null," " socket text," " username char(64) default null," " password char(64) default null," " ssl_ca text," " ssl_capath text," " ssl_cert text," " ssl_cipher char(64) default null," " ssl_key text," " ssl_verify_server_cert tinyint not null default 0," " default_file text," " default_group char(64) default null," " dsn char(64) default null," " primary key (db_name, table_name, link_id, sid)" ") engine=MyISAM default charset=utf8 collate=utf8_bin" )}, {C_STRING_WITH_LEN( "create table if not exists mysql.spider_link_failed_log(" " db_name char(64) not null default ''," " table_name char(199) not null default ''," " link_id char(64) not null default ''," " failed_time timestamp not null default current_timestamp" ") engine=MyISAM default charset=utf8 collate=utf8_bin" )}, {C_STRING_WITH_LEN( "create table if not exists mysql.spider_table_position_for_recovery(" " db_name char(64) not null default ''," " table_name char(199) not null default ''," " failed_link_id int not null default 0," " source_link_id int not null default 0," " file text," " position text," " gtid text," " primary key (db_name, table_name, failed_link_id, source_link_id)" ") engine=MyISAM default charset=utf8 collate=utf8_bin" )}, {C_STRING_WITH_LEN( "create table if not exists mysql.spider_table_sts(" " db_name char(64) not null default ''," " table_name char(199) not null default ''," " data_file_length bigint unsigned not null default 0," " max_data_file_length bigint unsigned not null default 0," " index_file_length bigint unsigned not null default 0," " records bigint unsigned not null default 0," " mean_rec_length bigint unsigned not null default 0," " check_time datetime not null default '0000-00-00 00:00:00'," " create_time datetime not null default '0000-00-00 00:00:00'," " update_time datetime not null default '0000-00-00 00:00:00'," " checksum bigint unsigned default null," " primary key (db_name, table_name)" ") engine=MyISAM default charset=utf8 collate=utf8_bin" )}, {C_STRING_WITH_LEN( "create table if not exists mysql.spider_table_crd(" " db_name char(64) not null default ''," " table_name char(199) not null default ''," " key_seq int unsigned not null default 0," " cardinality bigint not null default 0," " primary key (db_name, table_name, key_seq)" ") engine=MyISAM default charset=utf8 collate=utf8_bin" )}, /* If tables already exist and their definition differ from the latest ones, we fix them here. */ {C_STRING_WITH_LEN( "drop procedure if exists mysql.spider_fix_one_table" )}, {C_STRING_WITH_LEN( "drop procedure if exists mysql.spider_fix_system_tables" )}, {C_STRING_WITH_LEN( "create procedure mysql.spider_fix_one_table" " (tab_name char(255) charset utf8 collate utf8_bin," " test_col_name char(255) charset utf8 collate utf8_bin," " _sql text charset utf8 collate utf8_bin)" "begin" " set @col_exists := 0;" " select 1 into @col_exists from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = tab_name" " AND COLUMN_NAME = test_col_name;" " if @col_exists = 0 then" " select @stmt := _sql;" " prepare sp_stmt1 from @stmt;" " execute sp_stmt1;" " end if;" "end;" )}, {C_STRING_WITH_LEN( "create procedure mysql.spider_fix_system_tables()" "begin" " select substring_index(substring_index(version(), '-', 2), '-', -1)" " into @server_name;" " if @server_name regexp '^[0-9]+$' then" " select substring_index(substring_index(version(), '-', 3), '-', -1)" " into @server_name;" " end if;" " select substring_index(version(), '.', 1)" " into @server_major_version;" " select substring_index(substring_index(version(), '.', 2), '.', -1)" " into @server_minor_version;" /* Fix for 0.5 */ " call mysql.spider_fix_one_table('spider_tables', 'server'," " 'alter table mysql.spider_tables" " add server char(64) default null," " add scheme char(64) default null," " add host char(64) default null," " add port char(5) default null," " add socket char(64) default null," " add username char(64) default null," " add password char(64) default null," " add tgt_db_name char(64) default null," " add tgt_table_name char(64) default null');" /* Fix for version 0.17 */ " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_xa'" " AND COLUMN_NAME = 'data';" " if @col_type != 'binary(128)' then" " alter table mysql.spider_xa" " modify data binary(128) not null default '';" " end if;" " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_xa_member'" " AND COLUMN_NAME = 'data';" " if @col_type != 'binary(128)' then" " alter table mysql.spider_xa_member" " modify data binary(128) not null default '';" " end if;" /* Fix for version 2.7 */ " call mysql.spider_fix_one_table('spider_tables', 'link_id'," " 'alter table mysql.spider_tables" " add column link_id int not null default 0 after table_name," " drop primary key," " add primary key (db_name, table_name, link_id)');" /* Fix for version 2.8 */ " call mysql.spider_fix_one_table('spider_tables', 'link_status'," " 'alter table mysql.spider_tables" " add column link_status tinyint not null default 1');" /* Fix for version 2.10 */ " call mysql.spider_fix_one_table('spider_xa_member', 'ssl_ca'," " 'alter table mysql.spider_xa_member" " add column ssl_ca char(64) default null after password," " add column ssl_capath char(64) default null after ssl_ca," " add column ssl_cert char(64) default null after ssl_capath," " add column ssl_cipher char(64) default null after ssl_cert," " add column ssl_key char(64) default null after ssl_cipher," " add column ssl_verify_server_cert tinyint not null default 0" " after ssl_key," " add column default_file char(64) default null" " after ssl_verify_server_cert," " add column default_group char(64) default null after default_file');" " call mysql.spider_fix_one_table('spider_tables', 'ssl_ca'," " 'alter table mysql.spider_tables" " add column ssl_ca char(64) default null after password," " add column ssl_capath char(64) default null after ssl_ca," " add column ssl_cert char(64) default null after ssl_capath," " add column ssl_cipher char(64) default null after ssl_cert," " add column ssl_key char(64) default null after ssl_cipher," " add column ssl_verify_server_cert tinyint not null default 0" " after ssl_key," " add column default_file char(64) default null" " after ssl_verify_server_cert," " add column default_group char(64) default null after default_file');" " call mysql.spider_fix_one_table('spider_link_mon_servers', 'ssl_ca'," " 'alter table mysql.spider_link_mon_servers" " add column ssl_ca char(64) default null after password," " add column ssl_capath char(64) default null after ssl_ca," " add column ssl_cert char(64) default null after ssl_capath," " add column ssl_cipher char(64) default null after ssl_cert," " add column ssl_key char(64) default null after ssl_cipher," " add column ssl_verify_server_cert tinyint not null default 0" " after ssl_key," " add column default_file char(64) default null" " after ssl_verify_server_cert," " add column default_group char(64) default null after default_file');" /* Fix for version 2.28 */ " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_link_mon_servers'" " AND COLUMN_NAME = 'sid';" " if @col_type != 'int(10) unsigned' then" " alter table mysql.spider_link_mon_servers" " modify sid int unsigned not null default 0;" " end if;" /* Fix for version 3.1 */ " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_xa_member'" " AND COLUMN_NAME = 'socket';" " if @col_type = 'char(64)' then" " alter table mysql.spider_xa_member" " drop primary key," " add index idx1 (data, format_id, gtrid_length, host)," " modify socket text not null," " modify ssl_ca text," " modify ssl_capath text," " modify ssl_cert text," " modify ssl_key text," " modify default_file text;" " end if;" " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_tables'" " AND COLUMN_NAME = 'socket';" " if @col_type = 'char(64)' then" " alter table mysql.spider_tables" " modify socket text," " modify ssl_ca text," " modify ssl_capath text," " modify ssl_cert text," " modify ssl_key text," " modify default_file text;" " end if;" " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_link_mon_servers'" " AND COLUMN_NAME = 'socket';" " if @col_type = 'char(64)' then" " alter table mysql.spider_link_mon_servers" " modify socket text," " modify ssl_ca text," " modify ssl_capath text," " modify ssl_cert text," " modify ssl_key text," " modify default_file text;" " end if;" /* Fix for version 3.3.0 */ " call mysql.spider_fix_one_table('spider_tables'," " 'monitoring_binlog_pos_at_failing'," " 'alter table mysql.spider_tables" " add monitoring_binlog_pos_at_failing tinyint not null default 0" " after ssl_verify_server_cert');" /* Fix for version 3.3.6 */ " call mysql.spider_fix_one_table('spider_tables', 'block_status'," " 'alter table mysql.spider_tables" " add column block_status tinyint not null default 0" " after link_status');" " call mysql.spider_fix_one_table('spider_tables', 'static_link_id'," " 'alter table mysql.spider_tables" " add column static_link_id char(64) default null after block_status," " add unique index uidx1 (db_name, table_name, static_link_id)');" " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_link_mon_servers'" " AND COLUMN_NAME = 'link_id';" " if @col_type != 'char(64)' then" " alter table mysql.spider_link_mon_servers" " modify link_id char(64) not null default '';" " end if;" " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_link_failed_log'" " AND COLUMN_NAME = 'link_id';" " if @col_type != 'char(64)' then" " alter table mysql.spider_link_failed_log" " modify link_id char(64) not null default '';" " end if;" /* Fix for version 3.3.10 */ " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_tables'" " AND COLUMN_NAME = 'table_name';" " if @col_type != 'char(199)' then" " alter table mysql.spider_tables" " modify table_name char(199) not null default '';" " end if;" " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_link_mon_servers'" " AND COLUMN_NAME = 'table_name';" " if @col_type != 'char(199)' then" " alter table mysql.spider_link_mon_servers" " modify table_name char(199) not null default '';" " end if;" " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_link_failed_log'" " AND COLUMN_NAME = 'table_name';" " if @col_type != 'char(199)' then" " alter table mysql.spider_link_failed_log" " modify table_name char(199) not null default '';" " end if;" " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_table_position_for_recovery'" " AND COLUMN_NAME = 'table_name';" " if @col_type != 'char(199)' then" " alter table mysql.spider_table_position_for_recovery" " modify table_name char(199) not null default '';" " end if;" " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_table_sts'" " AND COLUMN_NAME = 'table_name';" " if @col_type != 'char(199)' then" " alter table mysql.spider_table_sts" " modify table_name char(199) not null default '';" " end if;" " select COLUMN_TYPE INTO @col_type from INFORMATION_SCHEMA.COLUMNS" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_table_crd'" " AND COLUMN_NAME = 'table_name';" " if @col_type != 'char(199)' then" " alter table mysql.spider_table_crd" " modify table_name char(199) not null default '';" " end if;" /* Fix for version 3.3.15 */ " call mysql.spider_fix_one_table('spider_table_sts', 'checksum'," " 'alter table mysql.spider_table_sts" " add column checksum bigint unsigned default null after update_time');" /* Fix for MariaDB 10.4: Crash-Safe system tables */ " if @server_name = 'MariaDB' and" " (" " @server_major_version > 10 or" " (" " @server_major_version = 10 and" " @server_minor_version >= 4" " )" " )" " then" " select ENGINE INTO @engine_name from INFORMATION_SCHEMA.TABLES" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_link_failed_log';" " if @engine_name != 'Aria' then" " alter table mysql.spider_link_failed_log" " engine=Aria transactional=1;" " end if;" " select ENGINE INTO @engine_name from INFORMATION_SCHEMA.TABLES" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_link_mon_servers';" " if @engine_name != 'Aria' then" " alter table mysql.spider_link_mon_servers" " engine=Aria transactional=1;" " end if;" " select ENGINE INTO @engine_name from INFORMATION_SCHEMA.TABLES" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_table_crd';" " if @engine_name != 'Aria' then" " alter table mysql.spider_table_crd" " engine=Aria transactional=1;" " end if;" " select ENGINE INTO @engine_name from INFORMATION_SCHEMA.TABLES" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_table_position_for_recovery';" " if @engine_name != 'Aria' then" " alter table mysql.spider_table_position_for_recovery" " engine=Aria transactional=1;" " end if;" " select ENGINE INTO @engine_name from INFORMATION_SCHEMA.TABLES" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_table_sts';" " if @engine_name != 'Aria' then" " alter table mysql.spider_table_sts" " engine=Aria transactional=1;" " end if;" " select ENGINE INTO @engine_name from INFORMATION_SCHEMA.TABLES" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_tables';" " if @engine_name != 'Aria' then" " alter table mysql.spider_tables" " engine=Aria transactional=1;" " end if;" " select ENGINE INTO @engine_name from INFORMATION_SCHEMA.TABLES" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_xa';" " if @engine_name != 'Aria' then" " alter table mysql.spider_xa" " engine=Aria transactional=1;" " end if;" " select ENGINE INTO @engine_name from INFORMATION_SCHEMA.TABLES" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_xa_failed_log';" " if @engine_name != 'Aria' then" " alter table mysql.spider_xa_failed_log" " engine=Aria transactional=1;" " end if;" " select ENGINE INTO @engine_name from INFORMATION_SCHEMA.TABLES" " where TABLE_SCHEMA = 'mysql'" " AND TABLE_NAME = 'spider_xa_member';" " if @engine_name != 'Aria' then" " alter table mysql.spider_xa_member" " engine=Aria transactional=1;" " end if;" " end if;" " if @server_name = 'MariaDB' and" " (" " @server_major_version > 10 or" " (" " @server_major_version = 10 and" " @server_minor_version >= 6" " )" " )" " then" " /* table for ddl pushdown */" " create table if not exists mysql.spider_rewrite_tables(" " table_id bigint unsigned not null auto_increment," " db_name char(64) not null default ''," " table_name char(64) not null default ''," " primary key (table_id)," " unique uk1(db_name, table_name)" " ) engine=Aria transactional=1 default charset=utf8 collate=utf8_bin;" " create table if not exists mysql.spider_rewrite_table_tables(" " table_id bigint unsigned not null," " partition_id bigint unsigned not null auto_increment," " partition_method varchar(18) default ''," " partition_expression varchar(64) default ''," " subpartition_method varchar(12) default ''," " subpartition_expression varchar(64) default ''," " connection_str text not null default ''," " comment_str text not null default ''," " primary key (table_id, partition_id)," " unique uk1(table_id, partition_method, partition_expression," " subpartition_method, subpartition_expression)" " ) engine=Aria transactional=1 default charset=utf8 collate=utf8_bin;" " create table if not exists mysql.spider_rewrite_table_partitions(" " table_id bigint unsigned not null," " partition_id bigint unsigned not null," " partition_ordinal_position bigint unsigned not null auto_increment," " partition_name varchar(64) not null default ''," " partition_description varchar(64) not null default ''," " connection_str text not null default ''," " comment_str text not null default ''," " primary key (table_id, partition_id, partition_ordinal_position)," " unique key uk1 (table_id, partition_id, partition_name)" " ) engine=Aria transactional=1 default charset=utf8 collate=utf8_bin;" " create table if not exists mysql.spider_rewrite_table_subpartitions(" " table_id bigint unsigned not null," " partition_id bigint unsigned not null," " partition_ordinal_position bigint unsigned not null," " subpartition_ordinal_position bigint unsigned not null" " auto_increment," " subpartition_name varchar(64) not null default ''," " subpartition_description varchar(64) not null default ''," " connection_str text not null default ''," " comment_str text not null default ''," " primary key (table_id, partition_id, partition_ordinal_position," " subpartition_ordinal_position)," " unique key uk1 (table_id, partition_id, partition_ordinal_position," " subpartition_name)" " ) engine=Aria transactional=1 default charset=utf8 collate=utf8_bin;" " create table if not exists mysql.spider_rewritten_tables(" " db_name char(64) not null," " table_name char(64) not null," " table_id bigint unsigned not null," " partition_id bigint unsigned not null," " primary key (db_name, table_name, table_id, partition_id)" " ) engine=Aria transactional=1 default charset=utf8 collate=utf8_bin;" " end if;" /* Fix for version 3.4 */ " call mysql.spider_fix_one_table('spider_link_mon_servers', 'dsn'," " 'alter table mysql.spider_link_mon_servers" " add column dsn char(64) default null after default_group');" " call mysql.spider_fix_one_table('spider_tables', 'dsn'," " 'alter table mysql.spider_tables" " add column dsn char(64) default null after default_group');" " call mysql.spider_fix_one_table('spider_xa_failed_log', 'dsn'," " 'alter table mysql.spider_xa_failed_log" " add column dsn char(64) default null after default_group');" " call mysql.spider_fix_one_table('spider_xa_member', 'dsn'," " 'alter table mysql.spider_xa_member" " add column dsn char(64) default null after default_group');" "end;" )}, {C_STRING_WITH_LEN( "call mysql.spider_fix_system_tables" )}, {C_STRING_WITH_LEN( "drop procedure mysql.spider_fix_one_table" )}, {C_STRING_WITH_LEN( "drop procedure mysql.spider_fix_system_tables" )}, /* Install a plugin and UDFs */ {C_STRING_WITH_LEN( "drop procedure if exists mysql.spider_plugin_installer" )}, {C_STRING_WITH_LEN( "create procedure mysql.spider_plugin_installer()" "begin" " set @win_plugin := IF(@@version_compile_os like 'Win%', 1, 0);" /* Install spider plugin */ /* " set @have_spider_i_s_plugin := 0;" " select @have_spider_i_s_plugin := 1 from INFORMATION_SCHEMA.plugins" " where PLUGIN_NAME = 'SPIDER';" " set @have_spider_plugin := 0;" " select @have_spider_plugin := 1 from mysql.plugin" " where name = 'spider';" " if @have_spider_i_s_plugin = 0 then" " if @have_spider_plugin = 1 then" " / *" " spider plugin is present in mysql.plugin but not in" " information_schema.plugins. Remove spider plugin entry" " in mysql.plugin first." " * /" " delete from mysql.plugin where name = 'spider';" " end if;" " if @win_plugin = 0 then " " install plugin spider soname 'ha_spider.so';" " else" " install plugin spider soname 'ha_spider.dll';" " end if;" " end if;" */ /* Install spider_alloc_mem plugin */ " set @have_spider_i_s_alloc_mem_plugin := 0;" " select @have_spider_i_s_alloc_mem_plugin := 1" " from INFORMATION_SCHEMA.plugins" " where PLUGIN_NAME = 'SPIDER_ALLOC_MEM';" " set @have_spider_alloc_mem_plugin := 0;" " select @have_spider_alloc_mem_plugin := 1 from mysql.plugin" " where name = 'spider_alloc_mem';" " if @have_spider_i_s_alloc_mem_plugin = 0 then" " if @have_spider_alloc_mem_plugin = 1 then" " /*" " spider_alloc_mem plugin is present in mysql.plugin but not in" " information_schema.plugins. Remove spider_alloc_mem plugin entry" " in mysql.plugin first." " */" " delete from mysql.plugin where name = 'spider_alloc_mem';" " end if;" " if @win_plugin = 0 then " " install plugin spider_alloc_mem soname 'ha_spider.so';" " else" " install plugin spider_alloc_mem soname 'ha_spider.dll';" " end if;" " end if;" /* Install spider_wrapper_protocols plugin */ " set @have_spider_i_s_wrapper_protocols_plugin := 0;" " select @have_spider_i_s_wrapper_protocols_plugin := 1" " from INFORMATION_SCHEMA.plugins" " where PLUGIN_NAME = 'SPIDER_WRAPPER_PROTOCOLS';" " set @have_spider_wrapper_protocols_plugin := 0;" " select @have_spider_wrapper_protocols_plugin := 1 from mysql.plugin" " where name = 'spider_wrapper_protocols';" " if @have_spider_i_s_wrapper_protocols_plugin = 0 then" " if @have_spider_wrapper_protocols_plugin = 1 then" " /*" " spider_wrapper_protocols plugin is present in mysql.plugin but not in" " information_schema.plugins. Remove spider_wrapper_protocols plugin entry" " in mysql.plugin first." " */" " delete from mysql.plugin where name = 'spider_wrapper_protocols';" " end if;" " if @win_plugin = 0 then " " install plugin spider_wrapper_protocols soname 'ha_spider.so';" " else" " install plugin spider_wrapper_protocols soname 'ha_spider.dll';" " end if;" " end if;" " set @have_spider_direct_sql_udf := 0;" " select @have_spider_direct_sql_udf := 1 from mysql.func" " where name = 'spider_direct_sql';" " if @have_spider_direct_sql_udf = 0 then" " if @win_plugin = 0 then " " create function spider_direct_sql returns int" " soname 'ha_spider.so';" " else" " create function spider_direct_sql returns int" " soname 'ha_spider.dll';" " end if;" " end if;" " set @have_spider_bg_direct_sql_udf := 0;" " select @have_spider_bg_direct_sql_udf := 1 from mysql.func" " where name = 'spider_bg_direct_sql';" " if @have_spider_bg_direct_sql_udf = 0 then" " if @win_plugin = 0 then " " create aggregate function spider_bg_direct_sql returns int" " soname 'ha_spider.so';" " else" " create aggregate function spider_bg_direct_sql returns int" " soname 'ha_spider.dll';" " end if;" " end if;" " set @have_spider_ping_table_udf := 0;" " select @have_spider_ping_table_udf := 1 from mysql.func" " where name = 'spider_ping_table';" " if @have_spider_ping_table_udf = 0 then" " if @win_plugin = 0 then " " create function spider_ping_table returns int" " soname 'ha_spider.so';" " else" " create function spider_ping_table returns int" " soname 'ha_spider.dll';" " end if;" " end if;" " set @have_spider_copy_tables_udf := 0;" " select @have_spider_copy_tables_udf := 1 from mysql.func" " where name = 'spider_copy_tables';" " if @have_spider_copy_tables_udf = 0 then" " if @win_plugin = 0 then " " create function spider_copy_tables returns int" " soname 'ha_spider.so';" " else" " create function spider_copy_tables returns int" " soname 'ha_spider.dll';" " end if;" " end if;" " set @have_spider_flush_table_mon_cache_udf := 0;" " select @have_spider_flush_table_mon_cache_udf := 1 from mysql.func" " where name = 'spider_flush_table_mon_cache';" " if @have_spider_flush_table_mon_cache_udf = 0 then" " if @win_plugin = 0 then " " create function spider_flush_table_mon_cache returns int" " soname 'ha_spider.so';" " else" " create function spider_flush_table_mon_cache returns int" " soname 'ha_spider.dll';" " end if;" " end if;" " if @server_name = 'MariaDB' and" " (" " @server_major_version > 10 or" " (" " @server_major_version = 10 and" " @server_minor_version >= 6" " )" " )" " then" /* Install spider_rewrite plugin */ " set @have_spider_i_s_rewrite_plugin := 0;" " select @have_spider_i_s_rewrite_plugin := 1" " from INFORMATION_SCHEMA.plugins" " where PLUGIN_NAME = 'SPIDER_REWRITE';" " set @have_spider_rewrite_plugin := 0;" " select @have_spider_rewrite_plugin := 1 from mysql.plugin" " where name = 'spider_rewrite';" " if @have_spider_i_s_rewrite_plugin = 0 then" " if @have_spider_rewrite_plugin = 1 then" " /*" " spider_rewrite plugin is present in mysql.plugin but not in" " information_schema.plugins. Remove spider_rewrite plugin entry" " in mysql.plugin first." " */" " delete from mysql.plugin where name = 'spider_rewrite';" " end if;" " if @win_plugin = 0 then " " install plugin spider_rewrite soname 'ha_spider.so';" " else" " install plugin spider_rewrite soname 'ha_spider.dll';" " end if;" " end if;" " set @have_spider_flush_rewrite_cache_udf := 0;" " select @have_spider_flush_rewrite_cache_udf := 1 from mysql.func" " where name = 'spider_flush_rewrite_cache';" " if @have_spider_flush_rewrite_cache_udf = 0 then" " if @win_plugin = 0 then " " create function spider_flush_rewrite_cache returns int" " soname 'ha_spider.so';" " else" " create function spider_flush_rewrite_cache returns int" " soname 'ha_spider.dll';" " end if;" " end if;" " end if;" "end;" )}, {C_STRING_WITH_LEN( "call mysql.spider_plugin_installer" )}, {C_STRING_WITH_LEN( "drop procedure mysql.spider_plugin_installer" )}, {C_STRING_WITH_LEN("")} };