/* Copyright (C) 2008-2020 Kentoku Shiba Copyright ( C ) 2019 - 2022 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 #define MYSQL_SERVER 1 #include <my_global.h>#include "mysql_version.h" #include "sql_priv.h" #include "probes_mysql.h" #include "my_getopt.h" #include "sql_class.h" #include "sql_partition.h" #include "sql_servers.h" #include "sql_select.h" #include "tztime.h" #include "sql_parse.h" #include "create_options.h" #include "spd_err.h" #include "spd_param.h" #include "spd_db_include.h" #include "spd_include.h" #include "spd_sys_table.h" #include "ha_spider.h" #include "spd_trx.h" #include "spd_db_conn.h" #include "spd_table.h" #include "spd_conn.h" #include "spd_ping_table.h" #include "spd_direct_sql.h" #include "spd_malloc.h" #include "spd_group_by_handler.h" #include "spd_init_query.h" /* Background thread management */ #ifdef SPIDER_HAS_NEXT_THREAD_ID#define SPIDER_set_next_thread_id(A)void destroy_thd(MYSQL_THD thd);#else inline void SPIDER_set_next_thread_id(THD *A)if (thd)char *) &thd;"" ;return thd;void destroy_thd(MYSQL_THD thd)delete thd;#endif inline MYSQL_THD spider_create_sys_thd(SPIDER_THREAD *thread)if (thd)if (my_net_init(&thd->net, NULL, thd, MYF(0 )))return NULL;return thd;inline void spider_destroy_sys_thd(MYSQL_THD thd)inline MYSQL_THD spider_create_thd()if (!(thd = new THD(next_thread_id())))else #ifdef HAVE_PSI_INTERFACE#endif char *) &thd;return thd;inline void spider_destroy_thd(MYSQL_THD thd)delete thd;struct charset_info_st *spd_charset_utf8mb3_bin;const char **spd_defaults_extra_file;const char **spd_defaults_file;const char **spd_mysqld_unix_port;bool volatile *spd_abort_loop;extern long spider_conn_mutex_id;/** All `SPIDER_DBTON`s */ extern SPIDER_DBTON spider_dbton_mysql;extern SPIDER_DBTON spider_dbton_mariadb;extern volatile ulonglong spider_mon_table_cache_version;extern volatile ulonglong spider_mon_table_cache_version_req;extern ulonglong spider_conn_id;extern Time_zone *UTC;extern ulonglong spider_thread_id;#ifdef HAVE_PSI_INTERFACEstatic PSI_mutex_info all_spider_mutexes[]="tbl" , PSI_FLAG_GLOBAL},"init_error_tbl" , PSI_FLAG_GLOBAL},"wide_share" , PSI_FLAG_GLOBAL},"lgtm_tblhnd_share" , PSI_FLAG_GLOBAL},"conn" , PSI_FLAG_GLOBAL},"open_conn" , PSI_FLAG_GLOBAL},"allocated_thds" , PSI_FLAG_GLOBAL},"mon_table_cache" , PSI_FLAG_GLOBAL},"udf_table_mon" , PSI_FLAG_GLOBAL},"mem_calc" , PSI_FLAG_GLOBAL},"thread_id" , PSI_FLAG_GLOBAL},"conn_id" , PSI_FLAG_GLOBAL},"ipport_count" , PSI_FLAG_GLOBAL},"bg_stss" , PSI_FLAG_GLOBAL},"bg_crds" , PSI_FLAG_GLOBAL},"conn_i" , 0 },"mta_conn" , 0 },"bg_conn_chain" , 0 },"bg_conn_sync" , 0 },"bg_conn" , 0 },"bg_job_stack" , 0 },"bg_mon" , 0 },"bg_direct_sql" , 0 },"mon_list_caller" , 0 },"mon_list_receptor" , 0 },"mon_list_monitor" , 0 },"mon_list_update_status" , 0 },"share" , 0 },"share_sts" , 0 },"share_crd" , 0 },"share_auto_increment" , 0 },"wide_share_sts" , 0 },"wide_share_crd" , 0 },"udf_table" , 0 },"conn_loop_check" , 0 },static PSI_cond_info all_spider_conds[] = {"bg_conn_sync" , 0 },"bg_conn" , 0 },"bg_sts" , 0 },"bg_sts_sync" , 0 },"bg_crd" , 0 },"bg_crd_sync" , 0 },"bg_mon" , 0 },"bg_mon_sleep" , 0 },"bg_direct_sql" , 0 },"udf_table_mon" , 0 },"conn_i" , 0 },"bg_stss" , 0 },"bg_sts_syncs" , 0 },"bg_crds" , 0 },"bg_crd_syncs" , 0 },static PSI_thread_info all_spider_threads[] = {"bg" , 0 },"bg_sts" , 0 },"bg_crd" , 0 },"bg_mon" , 0 },"bg_stss" , 0 },"bg_crds" , 0 },#endif /* The spider table options . All fields are strings , with NULLness indicating unspecified by the user . struct ha_table_option_structchar *auto_increment_mode;char *bgs_mode;char *bulk_size;char *bulk_update_size;char *connect_timeout;char *connection;char *database;char *default_file;char *default_group;char *delete_all_rows_type;char *driver;char *dsn;char *filedsn;char *force_bulk_delete;char *force_bulk_update;char *host;char *idx;char *multi_split_read;char *net_read_timeout;char *net_write_timeout;char *password;char *port;char *priority;char *query_cache;char *query_cache_sync;char *read_only;char *server;char *skip_parallel_search;char *socket;char *ssl_capath;char *ssl_ca;char *ssl_cert;char *ssl_cipher;char *ssl_key;char *ssl_vsc;char *table;char *table_count_mode;char *username;char *use_pushdown_udf;char *wrapper;/* The spider table options with the names used in statements . "AUTO_INCREMENT_MODE" , auto_increment_mode),"BGS_MODE" , bgs_mode),"BULK_SIZE" , bulk_size),"BULK_UPDATE_SIZE" , bulk_update_size),"CONNECT_TIMEOUT" , connect_timeout),"CONNECTION" , connection),"REMOTE_DATABASE" , database),"DEFAULT_FILE" , default_file),"DEFAULT_GROUP" , default_group),"DELETE_ALL_ROWS_TYPE" , delete_all_rows_type),"DRIVER" , driver),"DSN" , dsn),"FILEDSN" , filedsn),"FORCE_BULK_DELETE" , force_bulk_delete),"FORCE_BULK_UPDATE" , force_bulk_update),"REMOTE_HOST" , host),"IDX" , idx),"MULTI_SPLIT_READ" , multi_split_read),"NET_READ_TIMEOUT" , net_read_timeout),"NET_WRITE_TIMEOUT" , net_write_timeout),"REMOTE_PASSWORD" , password),"REMOTE_PORT" , port),"PRIORITY" , priority),"QUERY_CACHE" , query_cache),"QUERY_CACHE_SYNC" , query_cache_sync),"READ_ONLY" , read_only),"REMOTE_SERVER" , server),"SKIP_PARALLEL_SEARCH" , skip_parallel_search),"REMOTE_SOCKET" , socket),"SSL_CAPATH" , ssl_capath),"SSL_CA" , ssl_ca),"SSL_CERT" , ssl_cert),"SSL_CIPHER" , ssl_cipher),"SSL_KEY" , ssl_key),"SSL_VSC" , ssl_vsc),"REMOTE_TABLE" , table),"TABLE_COUNT_MODE" , table_count_mode),"REMOTE_USERNAME" , username),"USE_PUSHDOWN_UDF" , use_pushdown_udf),"WRAPPER" , wrapper),/** Determines how to populate sts ( stat ) / crd ( cardinality ) of a spider share enum ha_sts_crd_get_type0 , /* Get by copying from wide_share */ 1 , /* Get by executing a sql query */ 2 , /* Get by executing a sql query after 3 /* Get by executing a sql query after extern HASH spider_open_connections;extern HASH spider_ipport_conns;extern uint spider_open_connections_id;extern const char *spider_open_connections_func_name;extern const char *spider_open_connections_file_name;extern ulong spider_open_connections_line_no;extern pthread_mutex_t spider_conn_mutex;extern HASH *spider_udf_table_mon_list_hash;extern uint spider_udf_table_mon_list_hash_id;extern const char *spider_udf_table_mon_list_hash_func_name;extern const char *spider_udf_table_mon_list_hash_file_name;extern ulong spider_udf_table_mon_list_hash_line_no;extern pthread_mutex_t *spider_udf_table_mon_mutexes;extern pthread_cond_t *spider_udf_table_mon_conds;extern pthread_mutex_t spider_open_conn_mutex;extern pthread_mutex_t spider_mon_table_cache_mutex;extern DYNAMIC_ARRAY spider_mon_table_cache;extern uint spider_mon_table_cache_id;extern const char *spider_mon_table_cache_func_name;extern const char *spider_mon_table_cache_file_name;extern ulong spider_mon_table_cache_line_no;const char *spider_open_tables_func_name;const char *spider_open_tables_file_name;/** All the `SPIDER_INIT_ERROR_TABLE`s */ const char *spider_init_error_tables_func_name;const char *spider_init_error_tables_file_name;extern pthread_mutex_t spider_thread_id_mutex;extern pthread_mutex_t spider_conn_id_mutex;extern pthread_mutex_t spider_ipport_conn_mutex;const char *spider_open_wide_share_func_name;const char *spider_open_wide_share_file_name;const char *spider_lgtm_tblhnd_share_hash_func_name;const char *spider_lgtm_tblhnd_share_hash_file_name;const char *spider_allocated_thds_func_name;const char *spider_allocated_thds_file_name;extern pthread_mutex_t spider_mem_calc_mutex;extern const char *spider_alloc_func_name[SPIDER_MEM_CALC_LIST_NUM];extern const char *spider_alloc_file_name[SPIDER_MEM_CALC_LIST_NUM];extern ulong spider_alloc_line_no[SPIDER_MEM_CALC_LIST_NUM];extern ulonglong spider_total_alloc_mem[SPIDER_MEM_CALC_LIST_NUM];extern longlong spider_current_alloc_mem[SPIDER_MEM_CALC_LIST_NUM];extern ulonglong spider_alloc_mem_count[SPIDER_MEM_CALC_LIST_NUM];extern ulonglong spider_free_mem_count[SPIDER_MEM_CALC_LIST_NUM];static char spider_wild_many = '%' , spider_wild_one = '_' ,'\\' ;/** ` spider_unique_id ` is used for identifying a spider table . It is set to be a concatenation of the MAC address and the PID , give or take some separators static char spider_unique_id_buf[1 + 12 + 1 + (16 * 2 ) + 1 + 1 ];// for spider_open_tables const uchar *spider_tbl_get_key(const void *share_,auto share= static_cast <const SPIDER_SHARE *>(share_);"spider_tbl_get_key" );reinterpret_cast <const uchar *>(share->table_name));const uchar *spider_wide_share_get_key(const void *share_,auto share= static_cast <const SPIDER_WIDE_SHARE *>(share_);"spider_wide_share_get_key" );reinterpret_cast <const uchar *>(share->table_name));const uchar *spider_lgtm_tblhnd_share_hash_get_key(const void *share_,auto share= static_cast <const SPIDER_LGTM_TBLHND_SHARE *>(share_);"spider_lgtm_tblhnd_share_hash_get_key" );reinterpret_cast <const uchar *>(share->table_name));const uchar *spider_link_get_key(const void *link_for_hash_,auto link_for_hash=static_cast <const SPIDER_LINK_FOR_HASH *>(link_for_hash_);"spider_link_get_key" );reinterpret_cast <const uchar *>(link_for_hash->db_table_str->ptr()));const uchar *spider_udf_tbl_mon_list_key(const void *table_mon_list_,auto table_mon_list=static_cast <const SPIDER_TABLE_MON_LIST *>(table_mon_list_);"spider_udf_tbl_mon_list_key" );"info" ,("spider hash key=%s" , table_mon_list->key));"info" ,("spider hash key length=%u" , table_mon_list->key_length));reinterpret_cast <const uchar *>(table_mon_list->key));const uchar *spider_allocated_thds_get_key(const void *thd,"spider_allocated_thds_get_key" );sizeof (THD *);reinterpret_cast <const uchar *>(thd));#ifdef HAVE_PSI_INTERFACEstatic void init_spider_psi_keys()"init_spider_psi_keys" );if (PSI_server == NULL)"spider" , all_spider_mutexes,"spider" , all_spider_conds,"spider" , all_spider_threads,#endif int spider_get_server(int link_idxint error_num, length;"spider_get_server" );128 , 0 , MYF(MY_WME));if (!(servergoto error;if (!share->tgt_wrappers[link_idx] && server->scheme)if (!(share->tgt_wrappers[link_idx] =goto error;"info" ,("spider tgt_wrappers=%s" ,if (!share->tgt_hosts[link_idx] && server->host)if (!(share->tgt_hosts[link_idx] =goto error;"info" ,("spider tgt_hosts=%s" , share->tgt_hosts[link_idx]));if (share->tgt_ports[link_idx] == -1 )"info" ,("spider tgt_ports=%ld" , share->tgt_ports[link_idx]));if (!share->tgt_sockets[link_idx] && server->socket)if (!(share->tgt_sockets[link_idx] =goto error;"info" ,("spider tgt_sockets=%s" , share->tgt_sockets[link_idx]));if (!share->tgt_dbs[link_idx] && server->db && (length = strlen(server->db)))if (!(share->tgt_dbs[link_idx] =goto error;"info" ,("spider tgt_dbs=%s" , share->tgt_dbs[link_idx]));if (!share->tgt_usernames[link_idx] && server->username)if (!(share->tgt_usernames[link_idx] =goto error;"info" ,("spider tgt_usernames=%s" ,if (!share->tgt_passwords[link_idx] && server->password)if (!(share->tgt_passwords[link_idx] =goto error;"info" ,("spider tgt_passwords=%s" ,0 ));0 );0 ));0 ), share->server_names[link_idx]);int spider_free_share_alloc(int roop_count;"spider_free_share_alloc" );for (roop_count = SPIDER_DBTON_SIZE - 1 ; roop_count >= 0 ; roop_count--)if (share->dbton_share[roop_count])delete share->dbton_share[roop_count];if (share->server_names)for (roop_count = 0 ; roop_count < (int ) share->server_names_length;if (share->server_names[roop_count])0 ));0 ));if (share->tgt_table_names)for (roop_count = 0 ; roop_count < (int ) share->tgt_table_names_length;if (share->tgt_table_names[roop_count])0 ));0 ));if (share->tgt_dbs)for (roop_count = 0 ; roop_count < (int ) share->tgt_dbs_length;if (share->tgt_dbs[roop_count])0 ));0 ));if (share->tgt_hosts)for (roop_count = 0 ; roop_count < (int ) share->tgt_hosts_length;if (share->tgt_hosts[roop_count])0 ));0 ));if (share->tgt_usernames)for (roop_count = 0 ; roop_count < (int ) share->tgt_usernames_length;if (share->tgt_usernames[roop_count])0 ));0 ));if (share->tgt_passwords)for (roop_count = 0 ; roop_count < (int ) share->tgt_passwords_length;if (share->tgt_passwords[roop_count])0 ));0 ));if (share->tgt_sockets)for (roop_count = 0 ; roop_count < (int ) share->tgt_sockets_length;if (share->tgt_sockets[roop_count])0 ));0 ));if (share->tgt_wrappers)for (roop_count = 0 ; roop_count < (int ) share->tgt_wrappers_length;if (share->tgt_wrappers[roop_count])0 ));0 ));if (share->tgt_ssl_cas)for (roop_count = 0 ; roop_count < (int ) share->tgt_ssl_cas_length;if (share->tgt_ssl_cas[roop_count])0 ));0 ));if (share->tgt_ssl_capaths)for (roop_count = 0 ; roop_count < (int ) share->tgt_ssl_capaths_length;if (share->tgt_ssl_capaths[roop_count])0 ));0 ));if (share->tgt_ssl_certs)for (roop_count = 0 ; roop_count < (int ) share->tgt_ssl_certs_length;if (share->tgt_ssl_certs[roop_count])0 ));0 ));if (share->tgt_ssl_ciphers)for (roop_count = 0 ; roop_count < (int ) share->tgt_ssl_ciphers_length;if (share->tgt_ssl_ciphers[roop_count])0 ));0 ));if (share->tgt_ssl_keys)for (roop_count = 0 ; roop_count < (int ) share->tgt_ssl_keys_length;if (share->tgt_ssl_keys[roop_count])0 ));0 ));if (share->tgt_default_files)for (roop_count = 0 ; roop_count < (int ) share->tgt_default_files_length;if (share->tgt_default_files[roop_count])0 ));0 ));if (share->tgt_default_groups)for (roop_count = 0 ; roop_count < (int ) share->tgt_default_groups_length;if (share->tgt_default_groups[roop_count])0 ));0 ));if (share->tgt_dsns)for (roop_count = 0 ; roop_count < (int ) share->tgt_dsns_length;if (share->tgt_dsns[roop_count])0 ));0 ));if (share->tgt_filedsns)for (roop_count = 0 ; roop_count < (int ) share->tgt_filedsns_length;if (share->tgt_filedsns[roop_count])0 ));0 ));if (share->tgt_drivers)for (roop_count = 0 ; roop_count < (int ) share->tgt_drivers_length;if (share->tgt_drivers[roop_count])0 ));0 ));if (share->tgt_odbc_conn_strs)for (roop_count = 0 ; roop_count < (int ) share->tgt_odbc_conn_strs_length;if (share->tgt_odbc_conn_strs[roop_count])0 ));0 ));if (share->tgt_pk_names)for (roop_count = 0 ; roop_count < (int ) share->tgt_pk_names_length;if (share->tgt_pk_names[roop_count])0 ));0 ));if (share->tgt_sequence_names)for (roop_count = 0 ; roop_count < (int ) share->tgt_sequence_names_length;if (share->tgt_sequence_names[roop_count])0 ));0 ));if (share->static_link_ids)for (roop_count = 0 ; roop_count < (int ) share->static_link_ids_length;if (share->static_link_ids[roop_count])0 ));0 ));if (share->bka_engine)0 ));if (share->conn_keys)0 ));if (share->tgt_ports)0 ));if (share->tgt_ssl_vscs)0 ));if (share->link_statuses)0 ));if (share->monitoring_bg_flag)0 ));if (share->monitoring_bg_kind)0 ));if (share->monitoring_binlog_pos_at_failing)0 ));if (share->monitoring_flag)0 ));if (share->monitoring_kind)0 ));if (share->connect_timeouts)0 ));if (share->net_read_timeouts)0 ));if (share->net_write_timeouts)0 ));if (share->access_balances)0 ));if (share->bka_table_name_types)0 ));if (share->strict_group_bys)0 ));if (share->monitoring_bg_interval)0 ));if (share->monitoring_limit)0 ));if (share->monitoring_sid)0 ));if (share->alter_table.tmp_server_names)0 ));if (share->key_hint)delete [] share->key_hint;if (share->wide_share)0 );/* Free a tmp_share, which has only one link */ void spider_free_tmp_share_alloc("spider_free_tmp_share_alloc" );if (share->server_names && share->server_names[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_table_names && share->tgt_table_names[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_dbs && share->tgt_dbs[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_hosts && share->tgt_hosts[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_usernames && share->tgt_usernames[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_passwords && share->tgt_passwords[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_sockets && share->tgt_sockets[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_wrappers && share->tgt_wrappers[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_ssl_cas && share->tgt_ssl_cas[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_ssl_capaths && share->tgt_ssl_capaths[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_ssl_certs && share->tgt_ssl_certs[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_ssl_ciphers && share->tgt_ssl_ciphers[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_ssl_keys && share->tgt_ssl_keys[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_default_files && share->tgt_default_files[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_default_groups && share->tgt_default_groups[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_dsns && share->tgt_dsns[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_filedsns && share->tgt_filedsns[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_drivers && share->tgt_drivers[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_odbc_conn_strs && share->tgt_odbc_conn_strs[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_pk_names && share->tgt_pk_names[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->tgt_sequence_names && share->tgt_sequence_names[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->static_link_ids && share->static_link_ids[0 ])0 ], MYF(0 ));0 ] = NULL;if (share->bka_engine)0 ));if (share->conn_keys)0 ));if (share->static_key_cardinality)0 ));if (share->key_hint)delete [] share->key_hint;int spider_create_string_list(char ***string_list,char *str,int roop_count;char *tmp_ptr, *tmp_ptr2, *tmp_ptr3, *tmp_ptr4, *esc_ptr;bool find_flg = FALSE ;"spider_create_string_list" );0 ;if (!str)0 );while (*tmp_ptr == ' ' )1 ;bool last_esc_flg = FALSE ;while (TRUE )if ((tmp_ptr2 = strchr(tmp_ptr, ' ' )))FALSE ;FALSE ;while (!find_flg)'\\' );if (!esc_ptr || esc_ptr > tmp_ptr2)TRUE ;else if (esc_ptr == tmp_ptr2 - 1 )TRUE ;1 ;break ;else {TRUE ;2 ;if (find_flg)1 ;while (*tmp_ptr == ' ' )else break ;if (!(*string_list = (char **)_ZEROFILL),sizeof (char *) * (*list_length)),sizeof (int ) * (*list_length)),0 ), HA_ERR_OUT_OF_MEM);while (*tmp_ptr == ' ' )'\0' ;for (roop_count = 0 ; roop_count < (int ) *list_length - 1 ; roop_count++)bool esc_flg = FALSE ;FALSE ;while (TRUE )' ' );while (!find_flg)'\\' );if (!esc_ptr || esc_ptr > tmp_ptr2)TRUE ;else if (esc_ptr == tmp_ptr2 - 1 )TRUE ;1 ;break ;else {TRUE ;2 ;if (find_flg)break ;while (*tmp_ptr == ' ' )'\0' ;if (!((*string_list)[roop_count] = spider_create_string(0 ), HA_ERR_OUT_OF_MEM);if (esc_flg)while (TRUE )'\\' );if (!esc_ptr)break ;switch (*(esc_ptr + 1 ))case 'b' :'\b' ;break ;case 'n' :'\n' ;break ;case 'r' :'\r' ;break ;case 't' :'\t' ;break ;default :1 );break ;do 1 );while (*tmp_ptr4);1 ;"info" ,("spider string_list[%d]=%s" , roop_count,if (!((*string_list)[roop_count] = spider_create_string(0 ), HA_ERR_OUT_OF_MEM);if (last_esc_flg)while (TRUE )'\\' );if (!esc_ptr)break ;switch (*(esc_ptr + 1 ))case 'b' :'\b' ;break ;case 'n' :'\n' ;break ;case 'r' :'\r' ;break ;case 't' :'\t' ;break ;default :1 );break ;do 1 );while (*tmp_ptr4);1 ;"info" ,("spider string_list[%d]=%s" , roop_count,0 );int spider_create_long_list(long **long_list,char *str,long min_val,long max_valint roop_count;char *tmp_ptr;"spider_create_long_list" );0 ;if (!str)0 );while (*tmp_ptr == ' ' )if (*tmp_ptr)1 ;else {0 );while (TRUE )if ((tmp_ptr = strchr(tmp_ptr, ' ' )))1 ;while (*tmp_ptr == ' ' )else break ;if (!(*long_list = (long *)EROFILL),sizeof (long ) * (*list_length)),0 ), HA_ERR_OUT_OF_MEM);for (roop_count = 0 ; roop_count < (int ) *list_length; roop_count++)if (roop_count != 0 )' ' );while (*tmp_ptr == ' ' )'\0' ;if ((*long_list)[roop_count] < min_val)else if ((*long_list)[roop_count] > max_val)#ifndef DBUG_OFFfor (roop_count = 0 ; roop_count < (int ) *list_length; roop_count++)"info" ,("spider long_list[%d]=%ld" , roop_count,#endif 0 );/* Parse a list of nonnegative longs with maximum value max_val . max_val < = INT_MAX , and the list is space separated and could have leading or trailing spaces . int spider_create_bounded_nat_list(long **long_list,char *str,long max_valint i, error_num;char *cur, *tail;"spider_create_bounded_nat_list" );0 ;if (!str)0 );while (*cur == ' ' )if (*cur)1 ;else {0 );while ((cur = strchr(cur, ' ' )))do {while (*cur == ' ' );if (*cur)if (!(*long_list = (long *)44 , MYF(MY_WME | MY_ZEROFILL),sizeof (long ) * (*list_length)),0 ), HA_ERR_OUT_OF_MEM);for (i = 0 ; i < (int ) *list_length; i++)while (*cur == ' ' )if (error_num || (*cur && *cur != ' ' ) || converted < 0 ||1 );long ) converted;0 );int spider_create_longlong_list(char *str,int error_num, roop_count;char *tmp_ptr;"spider_create_longlong_list" );0 ;if (!str)0 );while (*tmp_ptr == ' ' )if (*tmp_ptr)1 ;else {0 );while (TRUE )if ((tmp_ptr = strchr(tmp_ptr, ' ' )))1 ;while (*tmp_ptr == ' ' )else break ;if (!(*longlong_list = (longlong *)MY_ZEROFILL),sizeof (longlong) * (*list_length)),0 ), HA_ERR_OUT_OF_MEM);for (roop_count = 0 ; roop_count < (int ) *list_length; roop_count++)if (roop_count != 0 )' ' );while (*tmp_ptr == ' ' )'\0' ;char **) NULL,if ((*longlong_list)[roop_count] < min_val)else if ((*longlong_list)[roop_count] > max_val)#ifndef DBUG_OFFfor (roop_count = 0 ; roop_count < (int ) *list_length; roop_count++)"info" ,("spider longlong_list[%d]=%lld" , roop_count,#endif 0 );int spider_increase_string_list(char ***string_list,int roop_count;char **tmp_str_list, *tmp_str;"spider_increase_string_list" );if (*list_length == link_count)0 );if (*list_length > 1 )0 ));if (*string_list)0 ];0 ];else {0 ;if (!(tmp_str_list = (char **)MY_ZEROFILL),sizeof (char *) * link_count),sizeof (uint) * link_count),0 ), HA_ERR_OUT_OF_MEM);for (roop_count = 0 ; roop_count < (int ) link_count; roop_count++)if (tmp_str)if (!(tmp_str_list[roop_count] = spider_create_string(goto error;"info" ,("spider string_list[%d]=%s" , roop_count,else if (*string_list)if ((*string_list)[0 ])0 ], MYF(0 ));0 ));1 ) * link_count - 1 ;0 );for (roop_count = 0 ; roop_count < (int ) link_count; roop_count++)if (tmp_str_list[roop_count])0 ));if (tmp_str_list)0 ));0 ), HA_ERR_OUT_OF_MEM);int spider_increase_null_string_list(char ***string_list,int roop_count;char **tmp_str_list;"spider_increase_null_string_list" );if (*list_length == link_count)0 );if (!(tmp_str_list = (char **)_WME | MY_ZEROFILL),sizeof (char *) * link_count),sizeof (uint) * link_count),0 ), HA_ERR_OUT_OF_MEM);for (roop_count = 0 ; roop_count < (int ) *list_length; roop_count++)if (*string_list)0 ));#ifndef DBUG_OFF"info" ,("spider list_length=%u" , *list_length));for (roop_count = 0 ; roop_count < (int ) *list_length; roop_count++)"info" ,("spider string_list[%d]=%s" , roop_count,"NULL" ));"info" ,("spider string_length_list[%d]=%u" , roop_count,#endif 0 );int spider_increase_long_list(long **long_list,int roop_count;long *tmp_long_list, tmp_long;"spider_increase_long_list" );if (*list_length == link_count)0 );if (*list_length > 1 )0 ));if (*long_list)0 ];else 1 ;if (!(tmp_long_list = (long *)_ZEROFILL),sizeof (long ) * link_count),0 ), HA_ERR_OUT_OF_MEM);for (roop_count = 0 ; roop_count < (int ) link_count; roop_count++)"info" ,("spider long_list[%d]=%ld" , roop_count,if (*long_list)0 ));0 );int spider_increase_longlong_list(int roop_count;"spider_increase_longlong_list" );if (*list_length == link_count)0 );if (*list_length > 1 )0 ));if (*longlong_list)0 ];else 1 ;if (!(tmp_longlong_list = (longlong*)E | MY_ZEROFILL),sizeof (longlong) * link_count),0 ), HA_ERR_OUT_OF_MEM);for (roop_count = 0 ; roop_count < (int ) link_count; roop_count++)"info" ,("spider longlong_list[%d]=%lld" , roop_count,if (*longlong_list)0 ));0 );static int spider_set_ll_value(char *strint error_num = 0 ;"spider_set_ll_value" );char **) NULL, &error_num);/* Find the index of a given key name in a table . Return the index if found , or - 1 otherwise . static int spider_find_key_index(char *key_begin, uint key_len,for (uint i= 0 ; i < share->keys; i++)if (share->key_info[i].name.length == key_len &&return i;return -1 ;/* Convert a short key hint verb and append it to a string */ static int spider_convert_and_append_hint_verb(char *short_verb_begin,int short_verb_len,switch (short_verb_len)case 1 :if (!strncasecmp("f" , short_verb_begin, 1 ))return 0 ;if (!strncasecmp("u" , short_verb_begin, 1 ))return 0 ;break ;case 2 :if (!strncasecmp("ig" , short_verb_begin, 2 ))return 0 ;break ;default :return 1 ;return 1 ;/* Parse the IDX spider option */ static int spider_parse_option_hint(char *hint, SPIDER_SHARE *share,char *short_verb_begin= hint, *short_verb_end, *key_begin, *key_end;int key_index;while (*short_verb_begin)while (*short_verb_begin == ' ' || *short_verb_begin == '\t' )if (!*short_verb_begin)break ;while (*short_verb_end && *short_verb_end != ' ' && *short_verb_end != '\t' )while (*key_begin == ' ' || *key_begin == '\t' )while (*key_end && *key_end != ' ' && *key_end != '\t' )if ((key_index=1 )return 1 ;if (spider_convert_and_append_hint_verb(int ) (short_verb_end - short_verb_begin),return 1 ;return 0 ;#define SPIDER_PARAM_LEN(name) name ## _length#define SPIDER_PARAM_LENS(name) name ## _lengths#define SPIDER_PARAM_CHARLEN(name) name ## _charlen#define SPIDER_PARAM_STR(title_name, param_name) \if (!strncasecmp(parse.start_title, title_name, title_length)) \"info" ,("spider " title_name " start" )); \if (!share->param_name) \if ((share->param_name = spider_create_string(parse.start_value, \else { \true ); \goto error; \"info" ,("spider " title_name "=%s" , share->param_name)); \break ; \#define SPIDER_PARAM_STR_LIST(title_name, param_name) \if (!strncasecmp(parse.start_title, title_name, title_length)) \"info" , ("spider " title_name " start" )); \if (!share->param_name) \if ((error_num= spider_create_string_list( \goto error; \if (share->SPIDER_PARAM_LEN(param_name) > 1 && create_table) \"The high availability feature of Spider " \"has been deprecated " \"and will be removed in a future release" ); \break ; \#define SPIDER_PARAM_HINT(title_name, param_name, check_length, max_size, append_method) \if (!strncasecmp(parse.start_title, title_name, check_length)) \"info" ,("spider " title_name " start" )); \"info" ,("spider max_size=%d" , max_size)); \int hint_num = atoi(parse.start_title + check_length); \"info" ,("spider hint_num=%d" , hint_num)); \"info" ,("spider share->param_name=%p" , \if (share->param_name) \if (hint_num < 0 || hint_num >= max_size) \true ); \goto error; \else if (share->param_name[hint_num].length() > 0 ) \break ; \if ((error_num= append_method(&share->param_name[hint_num], \goto error; \"info" ,("spider " title_name "[%d]=%s" , hint_num, \else { \true ); \goto error; \break ; \#define SPIDER_PARAM_NUMHINT(title_name, param_name, check_length, max_size, append_method) \if (!strncasecmp(parse.start_title, title_name, check_length)) \"info" ,("spider " title_name " start" )); \"info" ,("spider max_size=%d" , max_size)); \int hint_num = atoi(parse.start_title + check_length); \"info" ,("spider hint_num=%d" , hint_num)); \"info" ,("spider share->param_name=%p" , share->param_name)); \if (share->param_name) \if (hint_num < 0 || hint_num >= max_size) \true ); \goto error; \else if (share->param_name[hint_num] != -1 ) \break ; \if ((error_num = \goto error; \"info" ,("spider " title_name "[%d]=%lld" , hint_num, \else { \true ); \goto error; \break ; \#define SPIDER_PARAM_LONG_LIST_WITH_MAX(title_name, param_name, \if (!strncasecmp(parse.start_title, title_name, title_length)) \"info" ,("spider " title_name " start" )); \if (!share->param_name) \if ((error_num = spider_create_long_list( \goto error; \break ; \#define SPIDER_PARAM_LONGLONG_LIST_WITH_MAX(title_name, param_name, \if (!strncasecmp(parse.start_title, title_name, title_length)) \"info" ,("spider " title_name " start" )); \if (!share->param_name) \if ((error_num = spider_create_longlong_list( \goto error; \break ; \#define SPIDER_PARAM_INT_WITH_MAX(title_name, param_name, min_val, max_val) \if (!strncasecmp(parse.start_title, title_name, title_length)) \"info" ,("spider " title_name " start" )); \if (share->param_name == -1 ) \if (share->param_name < min_val) \else if (share->param_name > max_val) \"info" ,("spider " title_name "=%d" , share->param_name)); \break ; \#define SPIDER_PARAM_INT(title_name, param_name, min_val) \if (!strncasecmp(parse.start_title, title_name, title_length)) \"info" ,("spider " title_name " start" )); \if (share->param_name == -1 ) \if (share->param_name < min_val) \"info" ,("spider " title_name "=%d" , share->param_name)); \break ; \#define SPIDER_PARAM_DOUBLE(title_name, param_name, min_val) \if (!strncasecmp(parse.start_title, title_name, title_length)) \"info" ,("spider " title_name " start" )); \if (share->param_name == -1 ) \if (share->param_name < min_val) \"info" ,("spider " title_name "=%f" , share->param_name)); \break ; \#define SPIDER_PARAM_LONGLONG(title_name, param_name, min_val) \if (!strncasecmp(parse.start_title, title_name, title_length)) \"info" ,("spider " title_name " start" )); \if (share->param_name == -1 ) \char **) NULL, \if (share->param_name < min_val) \"info" ,("spider " title_name "=%lld" , share->param_name)); \break ; \#define SPIDER_PARAM_DEPRECATED_WARNING(title_name, VER) \if (!strncasecmp(parse.start_title, title_name, title_length) && create_table) \/** Parse an option string into a string list and assign it to a ` SPIDER_SHARE ' field #define SPIDER_OPTION_STR_LIST(option_name, param_name) \if (options && options->option_name) \TRUE ; \if ((error_num= spider_create_string_list( \goto error; \if (share->SPIDER_PARAM_LEN(param_name) > 1 && create_table) \"The high availability feature of Spider " \"has been deprecated " \"and will be removed in a future release" ); \/** Parse an option string into a non - negative int with an upper bound , and assign it to a ` SPIDER_SHARE ' field #define SPIDER_OPTION_BOUNDED_NAT(option_title, option_name, \if (options && options->option_name) \TRUE ; \char *tail= options->option_name + strlen(options->option_name); \if (error_num || *tail || converted < 0 || \0 ), option_title, options->option_name); \goto error; \int ) converted; \/** Parse an option string into a non - negative long array with an upper bound , and assign it to a ` SPIDER_SHARE ' field #define SPIDER_OPTION_BOUNDED_NAT_LIST(option_title, option_name, \if (options && options->option_name) \TRUE ; \if ((error_num = spider_create_bounded_nat_list( \if (error_num != HA_ERR_OUT_OF_MEM) \0 ), option_title, options->option_name); \goto error; \if (share->SPIDER_PARAM_LEN(param_name) > 1 && create_table) \"The high availability feature of Spider " \"has been deprecated " \"and will be removed in a future release" ); \/** Parse an option string into a non - negative ` longlong ' , and assign it to a ` SPIDER_SHARE ' field #define SPIDER_OPTION_NAT_LONGLONG(option_title, option_name, param_name) \if (options && options->option_name) \TRUE ; \char *tail= options->option_name + strlen(options->option_name); \if (error_num || *tail != '\0' || converted < 0 ) \0 ), option_title, options->option_name); \goto error; \/** Parse an option string into a boolean , and assign it to a ` SPIDER_SHARE ' field . #define SPIDER_OPTION_BOOL(option_title, option_name, param_name) \if (options && options->option_name) \TRUE ; \if (!strcmp("YES" , options->option_name) || \"1" , options->option_name)) \TRUE ; \else if (!strcmp("NO" , options->option_name) || \"0" , options->option_name)) \FALSE ; \else \0 ), option_title, options->option_name); \goto error; \/** Parse an option string into index hints , and assign them to ` SPIDER_SHARE : : key_hint ' #define SPIDER_OPTION_HINT(option_title, option_name) \if (options && options->option_name) \TRUE ; \if ((error_num= spider_parse_option_hint(options->option_name, \0 ), option_title, options->option_name); \goto error; \/** Assign - 1 to some ` SPIDER_SHARE ' numeric fields , to indicate they have not been specified by the user yet . static void spider_minus_1(SPIDER_SHARE *share, TABLE_SHARE *table_share)1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;#ifdef HA_CAN_FORCE_BULK_UPDATE1 ;#endif #ifdef HA_CAN_FORCE_BULK_DELETE1 ;#endif 1 ;1 ;1 ;1 ;for (uint i = 0 ; i < table_share->keys; i++)1 ;/** Get the connect info of a certain type . @ param type The type of the connect info . 4 : partition ; 3 : subpartition ; 2 : comment ; 1 : connect_string @ retval 0 Success @ retval 1 Not applicable . That is , the info with the type is missing @ retval HA_ERR_OUT_OF_MEM Failure static int spider_get_connect_info(const int type,const partition_element *part_elem,const partition_element *sub_elem,const TABLE_SHARE* table_share,char *& out)switch (type)case 4 :if (!sub_elem || !sub_elem->part_comment)return 1 ;if (!(out = spider_create_string(return HA_ERR_OUT_OF_MEM;break ;case 3 :if (!part_elem || !part_elem->part_comment)return 1 ;if (!(out = spider_create_string(return HA_ERR_OUT_OF_MEM;break ;case 2 :if (table_share->comment.length == 0 )return 1 ;if (!(out = spider_create_string(return HA_ERR_OUT_OF_MEM;break ;default :if (table_share->option_struct_table->connection == NULL)return 1 ;"info" ,("spider create out string" ));if (!(out = spider_create_string(return HA_ERR_OUT_OF_MEM;break ;return 0 ;/** Find the beginning and end of a parameter title Skip over whitespace to find the beginning of the parameter title . Then skip over non - whitespace / quote / nul chars to find the end of the parameter title @ param start_title The start of the param definition . Will be moved to the start of the param title @ param end_title Will be moved to the end of the param title @ retval false Success @ retval true Failure static bool spider_parse_find_title(char *& start_title, char *& end_title)/* Skip leading whitespaces. */ while (*start_title == ' ' || *start_title == '\r' ||'\n' || *start_title == '\t' )if (*start_title == '\0' )return true ;/* Move over non-whitespace/comma/nul/quote chars (parameter title). */ while (*end_title != ' ' && *end_title != '\r' &&'\n' && *end_title != '\t' &&'\0' && *end_title != ',' &&'\' ' && *end_title != ' "') /* Fail on invalid end: there should be at least one space between if (*end_title == '\' ' || *end_title == ' "' || '\0' || *end_title == ',' )return true ;return false ;/** Find the beginning and the end of a paramter value , and the value delimiter Skip over whitespaces to find the start delimiter , then skip over the param value to find the end delimiter @ param start_value The end of the param title . Will be moved to the start of the param value , just after the delimiter @ param end_value Will be moved to the end of the param value , at the delimiter @ param delim Will be assigned the param value delimiter , either the single or double quote @ retval false Success @ retval true Failure static bool spider_parse_find_value(char *& start_value, char *& end_value,char & delim)/* Skip over whitespaces */ while (*start_value == ' ' || *start_value == '\r' ||'\n' || *start_value == '\t' )if (*start_value != '"' && *start_value != '\' ') return true ;while (1 )/* Escaping */ if (*end_value == '\\' )/* The backslash cannot be at the end */ if (*end_value == '\0' )return true ;else if (*end_value == delim)return false ;else if (*end_value == '\0' )return true ;/** Find the beginning of the next parameter Skip over whitespaces , then check that the first non - whitespace char is a comma or the end of string @ param start_param The end of the param value . Will be moved to the start of the next param definition , just after the comma , if there ' s one ; otherwise will be moved to the end of the string @ retval false Success @ retval true Failure static bool spider_parse_find_next(char *& start_param)/* Skip over whitespaces */ while (*start_param == ' ' || *start_param == '\r' ||'\n' || *start_param == '\t' )/* No more param definitions */ if (*start_param == '\0' )return false ;else if (*start_param == ',' )return false ;else return true ;/** Find the start and end of the current param title and value and the value deliminator . @ param start_param The beginning of the current param definition . Will be mutated to the beginning of the next param definition . @ retval false success @ retval true failure bool st_spider_param_string_parse::locate_param_def(char *& start_param)"parse::locate_param_def" );if (spider_parse_find_title(start_title, end_title))TRUE );if (spider_parse_find_value(start_value, end_value, delim_value))TRUE );/* skip the delim */ 1 ;if (spider_parse_find_next(start_param))TRUE );FALSE );/** Handle parsing failure . Print error and optionally restore param value end delimiter that has been nulled before . @ param restore_delim If true , restore the end value delimiter @ return The error number int st_spider_param_string_parse::fail(bool restore_delim)"spider_parse_print_param_error" );0 );/* Print the error message */ switch (error_num)case ER_SPIDER_INVALID_UDF_PARAM_NUM:0 ), start_title);break ;case ER_SPIDER_INVALID_CONNECT_INFO_NUM:default :0 ), start_title);if (restore_delim)/* Parse connection information specified by COMMENT , CONNECT , or engine - defined options . int spider_parse_connect_info(int error_num = 0 ;char *connect_string = NULL;char *start_param;int title_length, value_length;bool option_specified= FALSE ;"spider_parse_connect_info" );"info" ,("spider partition_info=%s" ,"info" ,("spider part_info=%p" , part_info));"info" ,("spider s->db=%s" , table_share->db.str));"info" ,("spider s->table_name=%s" , table_share->table_name.str));"info" ,("spider s->path=%s" , table_share->path.str));"info" ,"spider s->normalized_path=%s" , table_share->normalized_path.str));/* Find the correct table options, depending on if we are parsing a if (part_info)if (part_info->is_sub_partitioned())else else /* Parse through all option fields, and flip option_specified if "AUTO_INCREMENT_MODE" , auto_increment_mode,3 );"BGS_MODE" , bgs_mode, bgs_mode, 3 );"BULK_SIZE" , bulk_size, bulk_size, 2147483647 );"BULK_UPDATE_SIZE" , bulk_update_size,2147483647 );"CONNECT_TIMEOUT" , connect_timeout,2147483647 );"DELETE_ALL_ROWS_TYPE" , delete_all_rows_type,1 );"FORCE_BULK_DELETE" , force_bulk_delete,"FORCE_BULK_UPDATE" , force_bulk_update,"IDX" , idx);"MULTI_SPLIT_READ" , multi_split_read,2147483647 );"NET_READ_TIMEOUT" , net_read_timeout,2147483647 );"NET_WRITE_TIMEOUT" , net_write_timeout,2147483647 );"REMOTE_PORT" , port, tgt_ports, 65535 );"PRIORITY" , priority, priority);"QUERY_CACHE" , query_cache, query_cache, 2 );"QUERY_CACHE_SYNC" , query_cache_sync,3 );"READ_ONLY" , read_only, read_only_mode);"SKIP_PARALLEL_SEARCH" , skip_parallel_search,3 );"SSL_VSC" , ssl_vsc, tgt_ssl_vscs, 1 );"TABLE_COUNT_MODE" , table_count_mode,3 );"USE_PUSHDOWN_UDF" , use_pushdown_udf, use_pushdown_udf);/* Parse the connect strings, from the most specific level for (int i = 4 ; i > 0 ; i--)if (connect_string)0 ));/* Get the correct connect info for the current level. */ int error_num_1 = spider_get_connect_info(i, part_elem, sub_elem,if (error_num_1 == 1 )continue ;if (error_num_1 == HA_ERR_OUT_OF_MEM)goto error_alloc_conn_string;0 );/* If the COMMENT or CONNECTION string is explicitly ignored for table param parsing , or if any option is specified , skip the parsing . if (spider_param_ignore_comments(current_thd) || option_specified)if (!spider_param_suppress_comment_ignored_warning(current_thd))continue ;if (create_table)"Spider table params in COMMENT or CONNECTION " "strings have been deprecated " "and will be removed in a future release. " "Please use table options instead." );while (*start_param != '\0' )if (parse.locate_param_def(start_param))false );goto error;/* Null the end of the parameter value. */ '\0' ;int ) (parse.end_value - parse.start_value);switch (title_length = (int ) (parse.end_title - parse.start_title))case 0 :true );goto error;case 3 :"abl" , 1104 );"abl" , access_balances, 0 ,2147483647 );"aim" , auto_increment_mode, 0 , 3 );"alc" , 1104 );"alc" , active_link_count, 1 );"bfr" , 1104 );"bfr" , bgs_first_read, 0 );"bmd" , bgs_mode, 0 );"bsr" , 1104 );"bsr" , bgs_second_read, 0 );"bke" , 1104 );"bke" , bka_engine);"bkm" , 1104 );"bkm" , bka_mode, 0 , 2 );"bsz" , bulk_size, 0 );"bum" , 1104 );"bum" , bulk_update_mode, 0 , 2 );"bus" , bulk_update_size, 0 );"cbm" , 1104 );"cbm" , crd_bg_mode, 0 , 2 );"civ" , 1104 );"civ" , crd_interval, 0 );"csr" , 1104 );"csr" , casual_read, 0 , 63 );"csy" , 1104 );"csy" , crd_sync, 0 , 2 );"cto" , connect_timeouts, 0 ,2147483647 );"dat" , delete_all_rows_type, 0 , 1 );"ddi" , 1104 );"ddi" , direct_dup_insert, 0 , 1 );"dff" , tgt_default_files);"dfg" , tgt_default_groups);"dol" , 1104 );"dol" , direct_order_limit, 0 );"drv" , tgt_drivers);"dsn" , tgt_dsns);"erm" , 1104 );"erm" , error_read_mode, 0 , 1 );"ewm" , 1104 );"ewm" , error_write_mode, 0 , 1 );#ifdef HA_CAN_FORCE_BULK_DELETE"fbd" , force_bulk_delete, 0 , 1 );#endif #ifdef HA_CAN_FORCE_BULK_UPDATE"fbu" , force_bulk_update, 0 , 1 );#endif "fds" , tgt_filedsns);"frd" , 1104 );"frd" , first_read, 0 );"iom" , 1104 );"iom" , internal_optimize, 0 , 1 );"iol" , 1104 );"iol" , internal_optimize_local, 0 , 1 );"lmr" , 1104 );"lmr" , low_mem_read, 0 , 1 );"lcs" , 1104 );"lcs" , load_crd_at_startup, 0 , 1 );"lss" , 1104 );"lss" , load_sts_at_startup, 0 , 1 );"lst" , 1104 );"lst" , link_statuses, 0 , 3 );"mbf" , 1104 );"mbf" , monitoring_bg_flag, 0 , 1 );"mbi" , 1104 );"mbi" , monitoring_bg_interval, 0 , 4294967295 LL);"mbk" , 1104 );"mbk" , monitoring_bg_kind, 0 , 3 );"mbp" , 1104 );"mbp" , monitoring_binlog_pos_at_failing, 0 , 2 );"mfg" , 1104 );"mfg" , monitoring_flag, 0 , 1 );"mkd" , 1104 );"mkd" , monitoring_kind, 0 , 3 );"mlt" , 1104 );"mlt" , monitoring_limit, 0 , 9223372036854775807 LL);"mod" , 1104 );"mod" , max_order, 0 );"msi" , 1104 );"msi" , monitoring_sid, 0 , 4294967295 LL);"msr" , multi_split_read, 0 , 2147483647 );"nrt" , net_read_timeouts, 0 ,2147483647 );"nwt" , net_write_timeouts, 0 ,2147483647 );"pkn" , tgt_pk_names);"prt" , priority, 0 );"qch" , query_cache, 0 , 2 );"qcs" , query_cache_sync, 0 , 3 );"qmd" , 1104 );"qmd" , quick_mode, 0 , 3 );"qpb" , 1104 );"qpb" , quick_page_byte, 0 );"qps" , 1104 );"qps" , quick_page_size, 0 );"rom" , read_only_mode, 0 , 1 );"rrt" , 1104 );"rrt" , read_rate, 0 );"rsa" , 1104 );"rsa" , reset_sql_alloc, 0 , 1 );"sbm" , 1104 );"sbm" , sts_bg_mode, 0 , 2 );"sca" , tgt_ssl_cas);"sch" , tgt_ssl_ciphers);"scm" , 1104 );"scm" , select_column_mode, 0 , 1 );"scp" , tgt_ssl_capaths);"scr" , tgt_ssl_certs);"sdc" , 1104 );"sdc" , skip_default_condition, 0 , 1 );"sgb" , 1104 );"sgb" , strict_group_bys, 0 , 1 );"siv" , 1104 );"siv" , sts_interval, 0 );"sky" , tgt_ssl_keys);"sli" , 1104 );"sli" , static_link_ids);"slc" , 1104 );"slc" , store_last_crd, 0 , 1 );"slm" , 1104 );"slm" , selupd_lock_mode, 0 , 2 );"sls" , 1104 );"sls" , store_last_sts, 0 , 1 );"smr" , 1104 );"smr" , static_mean_rec_length, 0 );"spr" , 1104 );"spr" , split_read, 0 );"sps" , skip_parallel_search, 0 , 3 );"sqn" , 1104 );"sqn" , tgt_sequence_names);"srd" , 1104 );"srd" , second_read, 0 );"srt" , 1104 );"srt" , scan_rate, 0 );"srv" , server_names);"ssr" , 1104 );"ssr" , semi_split_read, 0 );"ssl" , 1104 );"ssl" , semi_split_read_limit, 0 );"ssy" , 1104 );"ssy" , sts_sync, 0 , 2 );"srs" , 1104 );"srs" , static_records_for_status, 0 );"svc" , tgt_ssl_vscs, 0 , 1 );"tbl" , tgt_table_names);"tcm" , table_count_mode, 0 , 3 );"upu" , use_pushdown_udf, 0 , 1 );"utc" , 1104 );"utc" , use_table_charset, 0 , 1 );true );goto error;case 4 :"host" , tgt_hosts);"user" , tgt_usernames);"port" , tgt_ports, 0 , 65535 );true );goto error;case 5 :"table" , tgt_table_names);true );goto error;case 6 :"driver" , tgt_drivers);"server" , server_names);"socket" , tgt_sockets);"idx" , key_hint, 3 , (int ) table_share->keys,"ssl_ca" , tgt_ssl_cas);"skc" , 1104 );"skc" , static_key_cardinality, 3 ,int ) table_share->keys, spider_set_ll_value);true );goto error;case 7 :"filedsn" , tgt_filedsns);"wrapper" , tgt_wrappers);"ssl_key" , tgt_ssl_keys);"pk_name" , 1104 );"pk_name" , tgt_pk_names);true );goto error;case 8 :"database" , tgt_dbs);"password" , tgt_passwords);"sts_sync" , 1104 );"sts_sync" , sts_sync, 0 , 2 );"crd_sync" , 1104 );"crd_sync" , crd_sync, 0 , 2 );"priority" , priority, 0 );"bgs_mode" , bgs_mode, 0 );"ssl_cert" , tgt_ssl_certs);"bka_mode" , 1104 );"bka_mode" , bka_mode, 0 , 2 );true );goto error;case 9 :"max_order" , 1104 );"max_order" , max_order, 0 );"bulk_size" , 1104 );"bulk_size" , bulk_size, 0 );"scan_rate" , 1104 );"scan_rate" , scan_rate, 0 );"read_rate" , 1104 );"read_rate" , read_rate, 0 );true );goto error;case 10 :"split_read" , 1104 );"split_read" , split_read, 0 );"quick_mode" , 1104 );"quick_mode" , quick_mode, 0 , 3 );"ssl_cipher" , tgt_ssl_ciphers);"ssl_capath" , tgt_ssl_capaths);"bka_engine" , 1104 );"bka_engine" , bka_engine);"first_read" , 1104 );"first_read" , first_read, 0 );true );goto error;case 11 :"query_cache" , 1104 );"query_cache" , query_cache, 0 , 2 );"crd_bg_mode" , 1104 );"crd_bg_mode" , crd_bg_mode, 0 , 2 );"sts_bg_mode" , 1104 );"sts_bg_mode" , sts_bg_mode, 0 , 2 );"link_status" , 1104 );"link_status" , link_statuses, 0 , 3 );"casual_read" , 1104 );"casual_read" , casual_read, 0 , 63 );true );goto error;case 12 :"sts_interval" , 1104 );"sts_interval" , sts_interval, 0 );"crd_interval" , 1104 );"crd_interval" , crd_interval, 0 );"low_mem_read" , 1104 );"low_mem_read" , low_mem_read, 0 , 1 );"default_file" , tgt_default_files);true );goto error;case 13 :"default_group" , tgt_default_groups);"sequence_name" , 1104 );"sequence_name" , tgt_sequence_names);true );goto error;case 14 :"bgs_first_read" , 1104 );"bgs_first_read" , bgs_first_read, 0 );"read_only_mode" , read_only_mode, 0 , 1 );"access_balance" , 1104 );"access_balance" , access_balances, 0 ,2147483647 );"static_link_id" , 1104 );"static_link_id" , static_link_ids);"store_last_crd" , 1104 );"store_last_crd" , store_last_crd, 0 , 1 );"store_last_sts" , 1104 );"store_last_sts" , store_last_sts, 0 , 1 );true );goto error;case 15 :"reset_sql_alloc" , 1104 );"reset_sql_alloc" , reset_sql_alloc, 0 , 1 );"quick_page_byte" , 1104 );"quick_page_byte" , quick_page_byte, 0 );"quick_page_size" , 1104 );"quick_page_size" , quick_page_size, 0 );"bgs_second_read" , 1104 );"bgs_second_read" , bgs_second_read, 0 );"monitoring_flag" , 1104 );"monitoring_flag" , monitoring_flag, 0 , 1 );"monitoring_kind" , 1104 );"monitoring_kind" , monitoring_kind, 0 , 3 );"semi_split_read" , 1104 );"semi_split_read" , semi_split_read, 0 );"connect_timeout" , connect_timeouts,0 , 2147483647 );"strict_group_by" , 1104 );"strict_group_by" ,0 , 1 );"error_read_mode" , 1104 );"error_read_mode" , error_read_mode, 0 , 1 );true );goto error;case 16 :"multi_split_read" , multi_split_read, 0 , 2147483647 );"selupd_lock_mode" , 1104 );"selupd_lock_mode" , selupd_lock_mode, 0 , 2 );"table_count_mode" , table_count_mode, 0 , 3 );"use_pushdown_udf" , use_pushdown_udf, 0 , 1 );"monitoring_limit" , 1104 );"monitoring_limit" , monitoring_limit, 0 , 9223372036854775807 LL);"bulk_update_mode" , 1104 );"bulk_update_mode" , bulk_update_mode, 0 , 2 );"bulk_update_size" , bulk_update_size, 0 );"net_read_timeout" ,0 , 2147483647 );"error_write_mode" , 1104 );"error_write_mode" , error_write_mode, 0 , 1 );"query_cache_sync" , query_cache_sync, 0 , 3 );true );goto error;case 17 :"internal_optimize" , 1104 );"internal_optimize" , internal_optimize, 0 , 1 );"use_table_charset" , 1104 );"use_table_charset" , use_table_charset, 0 , 1 );"direct_dup_insert" , 1104 );"direct_dup_insert" , direct_dup_insert, 0 , 1 );"active_link_count" , 1104 );"active_link_count" , active_link_count, 1 );"net_write_timeout" ,0 , 2147483647 );#ifdef HA_CAN_FORCE_BULK_DELETE"force_bulk_delete" , force_bulk_delete, 0 , 1 );#endif #ifdef HA_CAN_FORCE_BULK_UPDATE"force_bulk_update" , force_bulk_update, 0 , 1 );#endif true );goto error;case 18 :"select_column_mode" , 1104 );"select_column_mode" , select_column_mode, 0 , 1 );"monitoring_bg_flag" , 1104 );"monitoring_bg_flag" , monitoring_bg_flag, 0 , 1 );"monitoring_bg_kind" , 1104 );"monitoring_bg_kind" , monitoring_bg_kind, 0 , 3 );"direct_order_limit" , 1104 );"direct_order_limit" , direct_order_limit, 0 );true );goto error;case 19 :"auto_increment_mode" , auto_increment_mode, 0 , 3 );"load_crd_at_startup" , 1104 );"load_crd_at_startup" , load_crd_at_startup, 0 , 1 );"load_sts_at_startup" , 1104 );"load_sts_at_startup" , load_sts_at_startup, 0 , 1 );true );goto error;case 20 :"monitoring_server_id" , 1104 );"monitoring_server_id" , monitoring_sid, 0 , 4294967295 LL);"delete_all_rows_type" , delete_all_rows_type, 0 , 1 );"skip_parallel_search" , skip_parallel_search, 0 , 3 );true );goto error;case 21 :"semi_split_read_limit" , 1104 );"semi_split_read_limit" , semi_split_read_limit, 0 );true );goto error;case 22 :"ssl_verify_server_cert" , tgt_ssl_vscs, 0 , 1 );"monitoring_bg_interval" , 1104 );"monitoring_bg_interval" , monitoring_bg_interval, 0 , 4294967295 LL);"skip_default_condition" , 1104 );"skip_default_condition" , skip_default_condition, 0 , 1 );"static_mean_rec_length" , 1104 );"static_mean_rec_length" , static_mean_rec_length, 0 );true );goto error;case 23 :"internal_optimize_local" , 1104 );"internal_optimize_local" , internal_optimize_local, 0 , 1 );true );goto error;case 25 :"static_records_for_status" , 1104 );"static_records_for_status" ,0 );"static_key_cardinality" , 1104 );"static_key_cardinality" , static_key_cardinality,3 , (int ) table_share->keys, spider_set_ll_value);true );goto error;case 32 :"monitoring_binlog_pos_at_failing" , 1104 );"monitoring_binlog_pos_at_failing" ,0 , 2 );true );goto error;default :true );goto error;/* Restore delim */ /* check all_link_count */ 1 ;if (share->all_link_count < share->server_names_length)if (share->all_link_count < share->tgt_table_names_length)if (share->all_link_count < share->tgt_dbs_length)if (share->all_link_count < share->tgt_hosts_length)if (share->all_link_count < share->tgt_usernames_length)if (share->all_link_count < share->tgt_passwords_length)if (share->all_link_count < share->tgt_sockets_length)if (share->all_link_count < share->tgt_wrappers_length)if (share->all_link_count < share->tgt_ssl_cas_length)if (share->all_link_count < share->tgt_ssl_capaths_length)if (share->all_link_count < share->tgt_ssl_certs_length)if (share->all_link_count < share->tgt_ssl_ciphers_length)if (share->all_link_count < share->tgt_ssl_keys_length)if (share->all_link_count < share->tgt_default_files_length)if (share->all_link_count < share->tgt_default_groups_length)if (share->all_link_count < share->tgt_dsns_length)if (share->all_link_count < share->tgt_filedsns_length)if (share->all_link_count < share->tgt_drivers_length)if (share->all_link_count < share->tgt_pk_names_length)if (share->all_link_count < share->tgt_sequence_names_length)if (share->all_link_count < share->static_link_ids_length)if (share->all_link_count < share->tgt_ports_length)if (share->all_link_count < share->tgt_ssl_vscs_length)if (share->all_link_count < share->link_statuses_length)if (share->all_link_count < share->monitoring_binlog_pos_at_failing_length)if (share->all_link_count < share->monitoring_flag_length)if (share->all_link_count < share->monitoring_kind_length)if (share->all_link_count < share->monitoring_limit_length)if (share->all_link_count < share->monitoring_sid_length)if (share->all_link_count < share->monitoring_bg_flag_length)if (share->all_link_count < share->monitoring_bg_kind_length)if (share->all_link_count < share->monitoring_bg_interval_length)if (share->all_link_count < share->connect_timeouts_length)if (share->all_link_count < share->net_read_timeouts_length)if (share->all_link_count < share->net_write_timeouts_length)if (share->all_link_count < share->access_balances_length)if (share->all_link_count < share->bka_table_name_types_length)if (share->all_link_count < share->strict_group_bys_length)if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_string_list(goto error;if ((error_num = spider_increase_null_string_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_longlong_list(goto error;if ((error_num = spider_increase_longlong_list(goto error;if ((error_num = spider_increase_longlong_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;if ((error_num = spider_increase_long_list(goto error;/* copy for tables start */ if (!(share_alter->tmp_server_names = (char **)_ZEROFILL),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (char *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (uint *) * share->all_link_count),sizeof (long ) * share->all_link_count),sizeof (long ) * share->all_link_count),sizeof (long ) * share->all_link_count),sizeof (long ) * share->all_link_count),goto error;sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (char *) * share->all_link_count);sizeof (long ) * share->all_link_count);sizeof (long ) * share->all_link_count);sizeof (long ) * share->all_link_count);sizeof (long ) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);sizeof (uint) * share->all_link_count);/* copy for tables end */ if ((error_num = spider_set_connect_info_default(goto error;if (create_table)for (int roop_count = 0 ; roop_count < (int ) share->all_link_count;int roop_count2;for (roop_count2 = 0 ; roop_count2 < SPIDER_DBTON_SIZE; roop_count2++)if (break ;if (roop_count2 == SPIDER_DBTON_SIZE)"info" ,("spider err tgt_wrappers[%d]=%s" , roop_count,0 ), share->tgt_wrappers[roop_count]);goto error;"info" ,"spider server_names_lengths[%d] = %u" , roop_count,if (share->server_names_lengths[roop_count] > SPIDER_CONNECT_INFO_MAX_LEN)0 ), share->server_names[roop_count], "server" );goto error;"info" ,"spider tgt_table_names_lengths[%d] = %u" , roop_count,if (share->tgt_table_names_lengths[roop_count] >0 ), share->tgt_table_names[roop_count], "table" );goto error;"info" ,"spider tgt_dbs_lengths[%d] = %u" , roop_count,if (share->tgt_dbs_lengths[roop_count] > SPIDER_CONNECT_INFO_MAX_LEN)0 ), share->tgt_dbs[roop_count], "database" );goto error;"info" ,"spider tgt_hosts_lengths[%d] = %u" , roop_count,if (share->tgt_hosts_lengths[roop_count] > SPIDER_CONNECT_INFO_MAX_LEN)0 ), share->tgt_hosts[roop_count], "host" );goto error;"info" ,"spider tgt_usernames_lengths[%d] = %u" , roop_count,if (share->tgt_usernames_lengths[roop_count] >0 ), share->tgt_usernames[roop_count], "user" );goto error;"info" ,"spider tgt_passwords_lengths[%d] = %u" , roop_count,if (share->tgt_passwords_lengths[roop_count] >0 ), share->tgt_passwords[roop_count], "password" );goto error;"info" ,"spider tgt_sockets_lengths[%d] = %u" , roop_count,if (share->tgt_sockets_lengths[roop_count] >0 ), share->tgt_sockets[roop_count], "socket" );goto error;"info" ,"spider tgt_wrappers_lengths[%d] = %u" , roop_count,if (share->tgt_wrappers_lengths[roop_count] >0 ), share->tgt_wrappers[roop_count], "wrapper" );goto error;"info" ,"spider tgt_ssl_cas_lengths[%d] = %u" , roop_count,if (share->tgt_ssl_cas_lengths[roop_count] >0 ), share->tgt_ssl_cas[roop_count], "ssl_ca" );goto error;"info" ,"spider tgt_ssl_capaths_lengths[%d] = %u" , roop_count,if (share->tgt_ssl_capaths_lengths[roop_count] >0 ), share->tgt_ssl_capaths[roop_count], "ssl_capath" );goto error;"info" ,"spider tgt_ssl_certs_lengths[%d] = %u" , roop_count,if (share->tgt_ssl_certs_lengths[roop_count] >0 ), share->tgt_ssl_certs[roop_count], "ssl_cert" );goto error;"info" ,"spider tgt_ssl_ciphers_lengths[%d] = %u" , roop_count,if (share->tgt_ssl_ciphers_lengths[roop_count] >0 ), share->tgt_ssl_ciphers[roop_count], "ssl_cipher" );goto error;"info" ,"spider tgt_ssl_keys_lengths[%d] = %u" , roop_count,if (share->tgt_ssl_keys_lengths[roop_count] >0 ), share->tgt_ssl_keys[roop_count], "ssl_key" );goto error;"info" ,"spider tgt_default_files_lengths[%d] = %u" , roop_count,if (share->tgt_default_files_lengths[roop_count] >0 ), share->tgt_default_files[roop_count], "default_file" );goto error;"info" ,"spider tgt_default_groups_lengths[%d] = %u" , roop_count,if (share->tgt_default_groups_lengths[roop_count] >0 ), share->tgt_default_groups[roop_count], "default_group" );goto error;"info" ,"spider tgt_dsns_lengths[%d] = %u" , roop_count,if (share->tgt_dsns_lengths[roop_count] >0 ), share->tgt_dsns[roop_count], "dsn" );goto error;"info" ,"spider tgt_filedsns_lengths[%d] = %u" , roop_count,if (share->tgt_filedsns_lengths[roop_count] >0 ), share->tgt_filedsns[roop_count], "filedsn" );goto error;"info" ,"spider tgt_drivers_lengths[%d] = %u" , roop_count,if (share->tgt_drivers_lengths[roop_count] >0 ), share->tgt_drivers[roop_count], "driver" );goto error;"info" ,"spider tgt_pk_names_lengths[%d] = %u" , roop_count,if (share->tgt_pk_names_lengths[roop_count] >0 ), share->tgt_pk_names[roop_count], "pk_name" );goto error;"info" ,"spider tgt_sequence_names_lengths[%d] = %u" , roop_count,if (share->tgt_sequence_names_lengths[roop_count] >0 ), share->tgt_sequence_names[roop_count], "sequence_name" );goto error;"info" ,"spider static_link_ids_lengths[%d] = %u" , roop_count,if (share->static_link_ids_lengths[roop_count] >0 ), share->static_link_ids[roop_count], "static_link_id" );goto error;if (share->static_link_ids[roop_count])if (0 &&0 ] >= '0' &&0 ] <= '9' 0 ), share->static_link_ids[roop_count], "static_link_id" );goto error;for (roop_count2 = roop_count + 1 ;int ) share->all_link_count;if (0 ), share->static_link_ids[roop_count],"static_link_id" );goto error;"info" , ("spider share->active_link_count = %d" ,7 ) / 8 ;if (connect_string)0 ));0 );if (connect_string)0 ));/* Set default connect info of a SPIDER_SHARE if needed */ int spider_set_connect_info_default(/* The `SPIDER_SHARE' to set /* partition info used as input */ /* subpartition info used as input */ /* table share info used as input */ bool check_socket;bool check_database;bool check_default_file;bool check_host;bool check_port;bool socket_has_default_value;bool database_has_default_value;bool default_file_has_default_value;bool host_has_default_value;bool port_has_default_value;int error_num, roop_count, roop_count2;"spider_set_connect_info_default" );for (roop_count = 0 ; roop_count < (int ) share->all_link_count; roop_count++)if (share->server_names[roop_count])if ((error_num = spider_get_server(share, roop_count)))if (TRUE ;else {FALSE ;if (!share->tgt_dbs[roop_count] && table_share)TRUE ;else {FALSE ;if (TRUE ;else {FALSE ;if (!share->tgt_hosts[roop_count])TRUE ;else {FALSE ;if (share->tgt_ports[roop_count] == -1 )TRUE ;else {FALSE ;if (check_socket || check_database || check_default_file || check_host ||if (share->tgt_wrappers[roop_count])for (roop_count2 = 0 ; roop_count2 < SPIDER_DBTON_SIZE; roop_count2++)"info" ,("spider share->tgt_wrappers[%d]=%s" , roop_count,"info" ,("spider spider_dbton[%d].wrapper=%s" , roop_count2,"NULL" ));if (if (spider_dbton[roop_count2].db_access_type ==if (check_socket)if (check_database)if (check_default_file)if (check_host)if (check_port)break ;else {FALSE ;FALSE ;FALSE ;FALSE ;FALSE ;if (!share->tgt_wrappers[roop_count])"info" ,("spider create default tgt_wrappers" ));if (if (host_has_default_value)"info" ,("spider create default tgt_hosts" ));if (if (database_has_default_value)"info" ,("spider create default tgt_dbs" ));if (if (!share->tgt_table_names[roop_count] && table_share)"info" ,("spider create default tgt_table_names" ));if (if (default_file_has_default_value)"info" ,("spider create default tgt_default_files" ));if (*spd_defaults_extra_file)if (0 ), HA_ERR_OUT_OF_MEM);else {if (0 ), HA_ERR_OUT_OF_MEM);if (!share->tgt_pk_names[roop_count])"info" ,("spider create default tgt_pk_names" ));if (if (!share->tgt_sequence_names[roop_count])"info" ,("spider create default tgt_sequence_names" ));if (if (port_has_default_value)else if (share->tgt_ports[roop_count] < 0 )0 ;else if (share->tgt_ports[roop_count] > 65535 )65535 ;if (share->tgt_ssl_vscs[roop_count] == -1 )0 ;if (socket_has_default_value)"info" ,("spider create default tgt_sockets" ));char *) MYSQL_UNIX_ADDR);if (char *) MYSQL_UNIX_ADDR,if (share->link_statuses[roop_count] == -1 )if (share->monitoring_bg_flag[roop_count] == -1 )0 ;if (share->monitoring_bg_kind[roop_count] == -1 )0 ;if (share->monitoring_binlog_pos_at_failing[roop_count] == -1 )0 ;if (share->monitoring_flag[roop_count] == -1 )0 ;if (share->monitoring_kind[roop_count] == -1 )0 ;if (share->monitoring_bg_interval[roop_count] == -1 )10000000 ;if (share->monitoring_limit[roop_count] == -1 )1 ;if (share->monitoring_sid[roop_count] == -1 )if (share->access_balances[roop_count] == -1 )100 ;if (share->query_cache == -1 )0 ;if (share->query_cache_sync == -1 )0 ;if (share->scan_rate == -1 )1 ;if (share->read_rate == -1 )0 .0002 ;if (share->priority == -1 )1000000 ;if (share->table_count_mode == -1 )0 ;if (share->active_link_count == -1 )#ifdef HA_CAN_FORCE_BULK_UPDATEif (share->force_bulk_update == -1 )0 ;#endif #ifdef HA_CAN_FORCE_BULK_DELETEif (share->force_bulk_delete == -1 )0 ;#endif if (!share->bka_engine)"info" ,("spider create default bka_engine" ));if (0 );/* This function is a no - op if all share - > tgt_dbs and share - > tgt_table_names are non - null , otherwise it may assign them with db_name and table_name int spider_set_connect_info_default_db_table(const char *db_name,const char *table_name,bool check_database;bool database_has_default_value;"spider_set_connect_info_default_db_table" );for (roop_count = 0 ; roop_count < share->link_count; roop_count++)if (!share->tgt_dbs[roop_count] && db_name)TRUE ;else {FALSE ;if (check_database)if (share->tgt_wrappers[roop_count])for (roop_count2 = 0 ; roop_count2 < SPIDER_DBTON_SIZE; roop_count2++)"info" ,("spider share->tgt_wrappers[%d]=%s" , roop_count,"info" ,("spider spider_dbton[%d].wrapper=%s" , roop_count2,"NULL" ));if (if (spider_dbton[roop_count2].db_access_type ==if (check_database)break ;else {FALSE ;if (database_has_default_value)"info" ,("spider create default tgt_dbs" ));if (if (!share->tgt_table_names[roop_count] && table_name)const char *tmp_ptr;"info" ,("spider create default tgt_table_names" ));if ((tmp_ptr = strstr(table_name, "#P#" )))if (0 );/* Parse ` dbtable_name ' into db name and table name , and call spider_set_connect_info_default_db_table ( ) to set the db / table name values of ` share ' if needed int spider_set_connect_info_default_dbtable(const char *dbtable_name,int dbtable_name_lengthconst char *ptr_db, *ptr_table;"spider_set_connect_info_default_dbtable" );"info" ,("spider ptr_diff_db = %lld" , (longlong) ptr_diff_db));"info" ,("spider ptr_diff_table = %lld" , (longlong) ptr_diff_table));1 ),#ifdef DBUG_TRACEvoid spider_print_keys(const char *key,const char *end_ptr;1 ;"spider_print_keys" );"info" ,("spider key_length=%u" , length));while (key < end_ptr)"info" ,("spider key[%u]=%s" , roop_count, key));'\0' ) + 1 ;#endif void spider_create_conn_key_add_one(int * counter, char ** target, char * src)if (src)char ) *counter;1 , src);/* The conn keys are strings of the following format : 0 \ < idx1 > < value1 > \ 0 \ < idx2 > < value2 > \ 0 . . . \ < idxN > < valueN > \ 0 Where idx1 , idx2 , etc . are the index of first , second , etc . options where the value is specified . We have the wrapper as the first option , host as the second , port as the third , socket as the fourth , and so on ( see below for the order of all options ) . So here would be a conn key where only the host and the port are specified and nothing else : 0 \ 002 localhost \ 000 \ 00303306 \ 000 And it has length 1 + 1 + 9 + 1 + 1 + 5 + 1 = 19 . In case of HA , say we have another link with the same options specified except that the port is 3307 , then we place an extra NUL before placing the next conn_key : 0 \ 002 localhost \ 000 \ 00303306 \ 000 \ 0000 \ 002 localhost \ 000 \ 00303307 \ 000 ^ ^ conn_keys [ 0 ] conn_keys [ 1 ] Thus the total number of chars ( share - > conn_keys_charlen ) needed is ( 19 + 1 ) * 2 = 40 int spider_create_conn_keys(int roop_count;char *tmp_name, port_str[6 ];sizeof (uint) * share->all_link_count;"spider_create_conn_keys" );char *ptr;2 ;char *) my_alloca(length);if (!ptr)0 ;for (int all_link_idx = 0 ; all_link_idx < (int ) share->all_link_count; all_link_idx++)bool get_sql_id = FALSE ;/** Find all ` SPIDER_DBTON ` s with the same wrapper as the target server and set the bitmap . Stop at the first ` SPIDER_DBTON ` whose db_access_type is sql fixme : the logic may be more complicated than the intended one . For one thing , ALL ` SPIDER_DBTON ` s have sql access type . Consider removing everything to do with the db access type . for (int dbton_idx = 0 ; dbton_idx < SPIDER_DBTON_SIZE; dbton_idx++)"info" ,("spider share->tgt_wrappers[%d]=%s" , all_link_idx,"info" ,("spider spider_dbton[%d].wrapper=%s" , dbton_idx,"NULL" ));if (if (TRUE ;break ;if (!get_sql_id)bool tables_on_different_db_are_joinable;if (get_sql_id)else {TRUE ;1 2 : 0 )2 : 0 )5 + 2 2 : 0 )2 : 0 )2 : 0 2 : 0 2 : 0 )] + 2 : 0 )2 : 0 ] + 2 : 0 )2 : 0 )1 + 2 _idx] + 2 : 0 )nk_idx] + 2 : 0 )2 : 0 )2 : 0 )2 : 0 )nk_idx] + 2 : 0 );1 ;if (!(share->conn_keys = (char **)sizeof (char *) * share->all_link_count,sizeof (my_hash_value_type) * share->all_link_count,sizeof (char ) * share->conn_keys_charlen,for (roop_count = 0 ; roop_count < (int ) share->all_link_count; roop_count++)bool tables_on_different_db_are_joinable;if (share->sql_dbton_ids[roop_count] != SPIDER_DBTON_SIZE)else {TRUE ;'0' ;int counter= 0 ;sizeof (port_str), "%05ld" , share->tgt_ports[roop_count]);if (!tables_on_different_db_are_joinable && share->tgt_dbs[roop_count])char ) counter;1 , share->tgt_dbs[roop_count]);char ) counter;'0' + ((char ) share->tgt_ssl_vscs[roop_count]);for (int dbton_idx = 0 ; dbton_idx < SPIDER_DBTON_SIZE; dbton_idx++)if (spider_bit_is_set(share->dbton_bitmap, dbton_idx))0 );const char *table_name,int *error_numint bitmap_size, roop_count;int use_table_charset;char *tmp_name;char buf[MAX_FIELD_WIDTH], *buf_pos;char link_idx_str[SPIDER_SQL_INT_LEN];bool checksum_support = TRUE ;"spider_create_share" );if (!(share = (SPIDER_SHARE *)ILL),sizeof (*share)),1 ),sizeof (*tmp_static_key_cardinality) * table_share->keys),sizeof (*tmp_cardinality) * table_share->fields),sizeof (*tmp_cardinality_upd) * bitmap_size),sizeof (*tmp_table_mon_mutex_bitmap) *7 ) / 8 )),goto error_alloc_share;4096 , 0 , MYF(MY_WME));0 ;0 ;if (table_share->keys > 0 )if (!(share->key_hint = new spider_string[table_share->keys]))goto error_init_hint_string;for (roop_count = 0 ; roop_count < (int ) table_share->keys; roop_count++)"info" ,("spider share->key_hint=%p" , share->key_hint));if ((*error_num = spider_parse_connect_info(share, table_share,0 )))goto error_parse_connect_string;for (roop_count = 0 ; roop_count < (int ) share->all_link_count;sizeof (link_idx_str), "%010d" , roop_count);'\0' ;if (table_share->table_charset && use_table_charset)else if ((*error_num = spider_create_conn_keys(share)))goto error_create_conn_keys;if (share->table_count_mode & 1 )if (share->table_count_mode & 2 )if (mysql_mutex_init(spd_key_mutex_share,goto error_init_mutex;if (mysql_mutex_init(spd_key_mutex_share_sts,goto error_init_sts_mutex;if (mysql_mutex_init(spd_key_mutex_share_crd,goto error_init_crd_mutex;if (!(share->lgtm_tblhnd_share =FALSE , TRUE ,goto error_get_lgtm_tblhnd_share;if (!(share->wide_share =goto error_get_wide_share;for (roop_count = 0 ; roop_count < SPIDER_DBTON_SIZE; roop_count++)if (spider_bit_is_set(share->dbton_bitmap, roop_count))if (!(share->dbton_share[roop_count] =goto error_init_dbton;if ((*error_num = share->dbton_share[roop_count]->init()))goto error_init_dbton;if (FALSE ;if (checksum_support)/* roop_count = SPIDER_DBTON_SIZE - 1 ; for (; roop_count >= 0 ; roop_count--)if (share->dbton_share[roop_count])delete share->dbton_share[roop_count];0 ));/** Checks for spider table self - reference Get the user variable value ( source ) and compare it with the user variable name ( target ) . If the target is a substring of the source , then there is a self - reference @ param thd Connection @ param share The table share @ retval 0 for success , or else the error number int spider_check_for_self_reference(THD *thd, const TABLE_SHARE *share)0 );"spider_check_for_self_reference" );"info" ,("spider loop check param name=%s" , target.c_ptr()));const user_var_entry *loop_check= get_variable(&thd->user_vars, &key, FALSE );if (loop_check && loop_check->type_handler()->result_type() == STRING_RESULT)0 );"-" ));"info" ,("spider loop check expected=%s" , expected.c_ptr()));"info" ,("spider loop check param value=%s" ,if (unlikely(strstr(loop_check->value, expected.c_ptr())))const int error_num = ER_SPIDER_INFINITE_LOOP_NUM;0 ),0 );/** Populate the init_errors and init of share and/or free it */ void spider_share_init_error_free(const bool init,const bool free_shareTRUE ;0 );TRUE ;if (free_share)void spider_lock_udf_table_mon_mutexes(SPIDER_SHARE *share)for (int roop_count = 0 ;int ) spider_udf_table_mon_mutex_count;if (spider_bit_is_set(share->table_mon_mutex_bitmap, roop_count))void spider_unlock_udf_table_mon_mutexes(SPIDER_SHARE *share)for (int roop_count = 0 ;int ) spider_udf_table_mon_mutex_count;if (spider_bit_is_set(share->table_mon_mutex_bitmap, roop_count))/** Initialises the link_statuses of a spider share Open the spider_tables system table , read the link_statuses and update the spider share , and close the table . Frees share if failure @ param thd Connection @ param share The spider share to populate the link_statuses of @ param table_share fixme @ param sql_command The sql command of the thread @ param error_num The error number @ retval true Failure false Success bool spider_share_init_link_statuses(const int sql_command,const bool init_share,int *error_numbool init_mem_root= FALSE ;"spider_share_init_link_statuses" );/* The link statuses need to be refreshed from the spider_tables table if the operation : - Is not a DROP TABLE on a permanent table ; or - Is an ALTER TABLE . Note that SHOW CREATE TABLE is not excluded , because the commands that follow it require up - to - date link statuses . if ((table_share->tmp_table == NO_TMP_TABLE &&/* for alter change link status */ 4096 , 0 , MYF(MY_WME));TRUE ;if (!(table_tables =FALSE ,true , true );0 ));TRUE );if ((*error_num= spider_get_link_statuses(table_tables, share,if (*error_num != HA_ERR_KEY_NOT_FOUND &&true );0 ));TRUE );else sizeof (long ) * share->all_link_count);TRUE ;if (init_mem_root)0 ));FALSE );/** Creates an `ha_spider` for the sts thread of the spider share. */ int spider_share_init_sts(const char * table_name,const bool init_share"spider_share_init_sts" );if (int error_num = spider_create_spider_object_for_share(true );TRUE ;0 );/** Creates an `ha_spider` for the crd thread of the spider share */ int spider_share_init_crd(const char * table_name,const bool init_share"spider_share_init_crd" );if (int error_num = spider_create_spider_object_for_share(true );TRUE ;0 );void *spider_share_malloc_for_spider(const uint id,char ** tmp_name,return spider_bulk_malloc(sizeof (char *) * share->link_count,sizeof (char ) * share->conn_keys_charlen,sizeof (SPIDER_CONN *) * share->link_count,sizeof (uint) * share->link_count,sizeof (uchar) * share->link_bitmap_size,sizeof (ulonglong) * share->link_count,sizeof (ulonglong) * share->link_count,sizeof (uchar) * share->link_bitmap_size,sizeof (int ) * share->link_count,sizeof (void *) * share->link_count,sizeof (TABLE *) * share->link_count,sizeof (TMP_TABLE_PARAM) * share->link_count,sizeof (uchar) * share->link_bitmap_size,sizeof (uchar) * share->link_bitmap_size,sizeof (int ) * share->link_count,sizeof (spider_db_handler *) * SPIDER_DBTON_SIZE,/** Initialise dbton_handlers of a spider . int spider_share_init_spider_dbton_handlers(ha_spider *spider, SPIDER_SHARE *share)int roop_count, error_num= 0 ;for (roop_count = 0 ; roop_count < (int ) share->use_dbton_count;if (!(spider->dbton_handler[dbton_id]=break ;if ((error_num = spider->dbton_handler[dbton_id]->init()))break ;/* Failure: rollback */ if (roop_count < (int ) share->use_dbton_count)for (; roop_count >= 0 ; roop_count--)if (spider->dbton_handler[dbton_id])delete spider->dbton_handler[dbton_id];return error_num;/** Gets or creates connections to all active servers */ bool spider_share_get_conns(ha_spider *spider, SPIDER_SHARE *share,int *error_num)"spider_share_get_conns" );for (int roop_count = spider_conn_link_idx_next(1 ,int ) share->link_count;if (!(spider->conns[roop_count] =FALSE , TRUE ,if (share->monitoring_kind[roop_count] && spider->need_mons[roop_count])0 ,FALSE TRUE );FALSE );/** Handles a failed search for usable servers @ param share The spider share to update its init error @ param table_share The table share @ param search_result The search result , either - 1 ( no usable server ) or - 2 ( out of memory ) @ return Error code associated with the failure int spider_share_handle_search_link_failure(const int search_result,const bool init_share"spider_share_handle_search_link_failure" );if (likely(search_result == -1 )) /* No available servers. */ char *db = (char *) my_alloca(1 + table_share->table_name.length + 1 );if (unlikely(!db))false );char *table_name = db + table_share->db.length + 1 ;'\0' ;'\0' ;0 ), db, table_name);false );false );/** Gets sts and crd for spider_init_share() */ bool spider_share_get_sts_crd(const bool init_share,/* fixme: do we need this? */ const bool has_lock,int *error_numconst bool same_server_link = spider_param_same_server_link(thd);const int load_sts_at_startup =const int load_crd_at_startup ="spider_share_get_sts_crd" );if (!spider->error_mode &&const double sts_interval = spider_param_sts_interval(thd, share->sts_interval);const int sts_mode = spider_param_sts_mode(thd, share->sts_mode);const int auto_increment_mode = spider_param_auto_increment_mode(const int sts_sync = auto_increment_mode == 1 ? 0 :const double crd_interval = spider_param_crd_interval(thd, share->crd_interval);int crd_mode = spider_param_crd_mode(thd, share->crd_mode);/* TODO(MDEV-27996): Delete spider_crd_mode and spider_sts_mode */ if (crd_mode == 3 )1 ;const int crd_sync = spider_param_crd_sync(thd, share->crd_sync);const time_t tmp_time = (time_t) time((time_t*) 0 );if (!has_lock)/* If not enough time has passed since the last init error, abort */ if (const SPIDER_INIT_ERROR_TABLE *spider_init_error_table =FALSE ))"info" ,("spider diff1=%f" ,if (difftime(tmp_time,if (spider_init_error_table->init_error_with_message)0 ));false );TRUE );if ((!same_server_link || load_sts_at_startup) &&1 , HA_STATUS_VARIABLE | HA_STATUS_CONST | HA_STATUS_AUTO))if (*error_num != ER_SPIDER_SYS_TABLE_VERSION_NUM &&else false );TRUE );if ((!same_server_link || load_crd_at_startup) &&1 )))if (*error_num != ER_SPIDER_SYS_TABLE_VERSION_NUM &&else false );TRUE );if (!has_lock)FALSE );/** Initialises a `SPIDER_SHARE` */ bool spider_init_share(const char *table_name,int *error_num,const bool new_sharechar *tmp_name;int search_link_idx;const uint sql_command = thd_sql_command(thd);const bool continue_with_sql_command ="spider_init_share" );if (!share->link_status_init)if (!share->link_status_init &&TRUE );if (!(spider->wide_handler->trx = spider_get_trx(thd, TRUE , error_num)))true );TRUE );/* There's no other place doing anything that ` spider_share_init_sts ( ) ` does or updating ` st_spider_share : : sts_spider_init ` , therefore there ' s no need to if (!share->sts_spider_init &&TRUE );if (!share->crd_spider_init &&TRUE );if (continue_with_sql_command &&true );TRUE );if (!(spider_share_malloc_for_spider(spider, share, SPD_MID_GET_SHARE_1,true );TRUE );0 ], share->conn_keys_charlen);for (int link_idx = 0 ; link_idx < (int ) share->link_count; link_idx++)1 ;1 ;if ((*error_num= spider_share_init_spider_dbton_handlers(spider, share)))false );goto error_after_alloc_conn_keys;if (continue_with_sql_command &&false );goto error_after_alloc_dbton_handler;if (search_link_idx < 0 )goto error_after_alloc_dbton_handler;if (continue_with_sql_command)if (new_share)if (spider_share_get_sts_crd(thd, spider, share, table, true , false ,goto error_after_alloc_dbton_handler;else if (share->init_error)/* fixme: can we move the locking and unlocking into if (share->init_error)if (spider_share_get_sts_crd(thd, spider, share, table, FALSE , TRUE ,goto error_after_alloc_dbton_handler;FALSE ;FALSE );for (int roop_count = 0 ; roop_count < (int ) share->use_dbton_count; ++roop_count)if (spider->dbton_handler[dbton_id])delete spider->dbton_handler[dbton_id];0 ));TRUE );/** Gets or creates a spider share , then initialises it const char *table_name,int *error_num"spider_get_share" );const TABLE_SHARE *top_share = spider->wide_handler->top_share;if (top_share &&const uint length = (uint) strlen(table_name);const my_hash_value_type hash_value =if (!(share = (SPIDER_SHARE*) my_hash_search_using_hash_value(if (!(share = spider_create_share(table_name, table_share,goto error_alloc_share;if (my_hash_insert(&spider_open_tables, (uchar*) share))goto error_hash_insert;if (spider_open_tables.array.max_element > old_elements)0 ;if (spider_init_share(table_name, table, thd, spider, error_num, share,TRUE ))TRUE ;else int sleep_cnt = 0 ;while (!share->init)// avoid for dead loop if (sleep_cnt++ > 1000 )" [WARN SPIDER RESULT] " "Wait share->init too long, table_name %s %s %ld\n" ,0 ], share->tgt_ports[0 ]);0 ),10000 ); // wait 10 ms if (spider_init_share(table_name, table, thd, spider, error_num, share,FALSE ))"info" ,("spider share=%p" , share));void spider_free_share_resource_only("spider_free_share_resource_only" );0 ));int spider_free_share("spider_free_share" );if (!--share->use_count)if (share->sts_spider_init)if (share->crd_spider_init)0 ));0 ));0 );void spider_update_link_status_for_share(const char *table_name,int link_idx,long link_status"spider_update_link_status_for_share" );if ((share = (SPIDER_SHARE*) my_hash_search_using_hash_value("info" , ("spider share->link_status_init=%s" ,"TRUE" : "FALSE" ));if (share->link_status_init)"info" , ("spider share->link_statuses[%d]=%ld" ,const char *table_name,bool locked,bool need_to_create,int *error_numchar *tmp_name;"spider_get_lgtm_tblhnd_share" );if (!locked)if (!(lgtm_tblhnd_share = (SPIDER_LGTM_TBLHND_SHARE*)"info" ,("spider create new lgtm tblhnd share" ));if (!(lgtm_tblhnd_share = (SPIDER_LGTM_TBLHND_SHARE *)| MY_ZEROFILL),sizeof (*lgtm_tblhnd_share)),1 ),goto error_alloc_share;if (mysql_mutex_init(spd_key_mutex_share_auto_increment,goto error_init_auto_increment_mutex;if (my_hash_insert(&spider_lgtm_tblhnd_share_hash,goto error_hash_insert;if (spider_lgtm_tblhnd_share_hash.array.max_element > old_elements)if (!locked)"info" ,("spider lgtm_tblhnd_share=%p" , lgtm_tblhnd_share));0 ));if (!locked)void spider_free_lgtm_tblhnd_share_alloc(bool locked"spider_free_lgtm_tblhnd_share" );if (!locked)0 ));if (!locked)int *error_numchar *tmp_name;"spider_get_wide_share" );if (!(wide_share = (SPIDER_WIDE_SHARE*)"info" ,("spider create new wide share" ));if (!(wide_share = (SPIDER_WIDE_SHARE *)ILL),sizeof (SPIDER_WIDE_SHARE),1 ),sizeof (*tmp_cardinality) * table_share->fields),goto error_alloc_share;0 ;if (mysql_mutex_init(spd_key_mutex_wide_share_sts,goto error_init_sts_mutex;if (mysql_mutex_init(spd_key_mutex_wide_share_crd,goto error_init_crd_mutex;if (my_hash_insert(&spider_open_wide_share, (uchar*) wide_share))goto error_hash_insert;if (spider_open_wide_share.array.max_element > old_elements)"info" ,("spider wide_share=%p" , wide_share));0 ));int spider_free_wide_share("spider_free_wide_share" );if (!--wide_share->use_count)0 ));0 );int spider_open_all_tables(bool lockint error_num, *need_mon, mon_val;/* This share has only one link */ char *db_name, *table_name;char *tmp_connect_info[SPIDER_TMP_SHARE_CHAR_PTR_COUNT];long tmp_long[SPIDER_TMP_SHARE_LONG_COUNT];char **connect_info;long *long_info;"spider_open_all_tables" );if (TRUE , &open_tables_backup,if (1 ))if (error_num != HA_ERR_KEY_NOT_FOUND && error_num != HA_ERR_END_OF_FILE)0 ));else {0 );4096 , 0 , MYF(MY_WME));void *)&tmp_share, 0 , sizeof (SPIDER_SHARE));0 ,sizeof (char *) * SPIDER_TMP_SHARE_CHAR_PTR_COUNT);0 ,sizeof (uint) * SPIDER_TMP_SHARE_UINT_COUNT);0 , sizeof (long ) * SPIDER_TMP_SHARE_LONG_COUNT);0 , sizeof (longlong) * SPIDER_TMP_SHARE_LONGLONG_COUNT);char **) &tmp_connect_info,0 ] = -1 ;do {if (0 ));if (0 ));/* create conn */ if (!(conn= spider_get_conn(&tmp_share, 0 , tmp_share.conn_keys[0 ], trx,FALSE , FALSE , &error_num)))0 ));0 );0 );if ((error_num = spider_db_before_query(conn, &mon_val)))0 );0 ));0 );if (lock && spider_param_use_snapshot_with_flush_tables(thd) == 2 )if (!(spider = new ha_spider()))0 ));if (!(share = (SPIDER_SHARE *)ROFILL),sizeof (*share)),sizeof (char *) * SPIDER_TMP_SHARE_CHAR_PTR_COUNT),sizeof (uint) * SPIDER_TMP_SHARE_UINT_COUNT),sizeof (long ) * SPIDER_TMP_SHARE_LONG_COUNT),sizeof (longlong) * SPIDER_TMP_SHARE_LONGLONG_COUNT),sizeof (SPIDER_CONN *)),sizeof (int )),sizeof (uint)),sizeof (uchar)),delete spider;0 ));void *)share, &tmp_share, sizeof (*share));sizeof (char *) *sizeof (uint) *sizeof (long ) * SPIDER_TMP_SHARE_LONG_COUNT);sizeof (longlong) *0 ] = 0 ;0 ] = 0 ;if ((error_num = spider_create_tmp_dbton_handler(spider)))0 ));delete spider;0 ));/* create another conn */ if ((!(conn= spider_get_conn(&tmp_share, 0 , tmp_share.conn_keys[0 ], trx,TRUE , FALSE , &error_num))))0 ));delete spider;0 ));0 );0 );if (conn->another_ha_last)else {void *) spider;void *) spider;int appended = 0 ;if ((error_num = spider->dbton_handler[conn->dbton_id]->0 , &appended)))0 ));delete spider;0 ));else {while (error_num == 0 );0 ));0 );bool spider_flush_logs(int error_num;"spider_flush_logs" );if (!(trx = spider_get_trx(thd, TRUE , &error_num)))TRUE );if (if (FALSE )) ||TRUE );FALSE );"spider_create_handler" );new (mem_root) ha_spider(hton, table));int spider_close_connection(int roop_count = 0 ;"spider_close_connection" );if (!(trx = (SPIDER_TRX*) thd_get_ha_data(thd, spider_hton_ptr)))0 ); /* transaction is not started */ while ((conn = (SPIDER_CONN*) my_hash_element(&trx->trx_conn_hash,"info" ,("spider conn->table_lock=%d" , conn->table_lock));if (conn->table_lock > 0 )if (!conn->trx_start)FALSE ;if (conn->table_lock != 2 )0 );0 ;TRUE );// suppress network errors at this stage TRUE , false );0 );void spider_drop_database(char * path"spider_drop_database" );bool spider_show_status(enum ha_stat_type stat_type"spider_show_status" );switch (stat_type) {case HA_ENGINE_STATUS:default :FALSE );int spider_db_done(void *pint roop_count;"spider_db_done" );for (roop_count = SPIDER_DBTON_SIZE - 1 ; roop_count >= 0 ; roop_count--)if (spider_dbton[roop_count].deinit)0 ));for (roop_count= spider_udf_table_mon_mutex_count - 1 ;0 ; roop_count--)while ((table_mon_list = (SPIDER_TABLE_MON_LIST *) my_hash_element(0 )))for (roop_count= spider_udf_table_mon_mutex_count - 1 ;0 ; roop_count--)for (roop_count= spider_udf_table_mon_mutex_count - 1 ;0 ; roop_count--)0 ));while ((tmp_thd = (THD *) my_hash_element(&spider_allocated_thds, 0 )))if (trx)FALSE );else while ((conn = (SPIDER_CONN*) my_hash_element(&spider_open_connections, 0 )))while ((lgtm_tblhnd_share = (SPIDER_LGTM_TBLHND_SHARE*) my_hash_element(0 )))TRUE );while ((spider_init_error_table = (SPIDER_INIT_ERROR_TABLE*)0 )))0 ));for (roop_count = 0 ; roop_count < SPIDER_MEM_CALC_LIST_NUM; roop_count++)if (spider_alloc_func_name[roop_count])"info" ,("spider %d %s %s %lu %llu %lld %llu %llu %s" ,"NG" : "OK" 0 );int spider_panic("spider_panic" );0 );static void spider_update_optimizer_costs(OPTIMIZER_COSTS *costs)/* Assume 1 Gigabyte network */ 1000000000 /8 )*1000 .00000 ;0 ; // Not used /* The following costs are copied from ha_innodb . cc The assumption is that the default storage engine used with Spider is InnoDB . 0 .00007013 ;0 .00076597 ;0 .00009900 ;0 .00079112 ;0 .00006087 ;/* Create or fix the system tables . See spd_init_query . h for the details . bool spider_init_system_tables()"spider_init_system_tables" );if (!mysql)TRUE );if (!mysql_real_connect_local(mysql))TRUE );const int size= sizeof (spider_init_queries) / sizeof (spider_init_queries[0 ]);for (int i= 0 ; i < size; i++)const LEX_STRING *query= &spider_init_queries[i];if (mysql_real_query(mysql, query->str, query->length))"[ERROR] SPIDER plugin initialization failed at '%s' by '%s'\n" ,TRUE );if (MYSQL_RES *res= mysql_store_result(mysql))FALSE );/* Spider may be loaded before ddl_recovery ( e . g . with - - plugin - load - add ) , but DDL statements in spider init queries cannot be executed before ddl_recovery , so we execute these queries only after ddl recovery . static int spider_after_ddl_recovery(handlerton *)"fail_spider_ddl_recovery_done" , return 1 ;);return spider_init_system_tables();int spider_db_init(void *pint error_num = HA_ERR_OUT_OF_MEM, roop_count;6 ];"spider_db_init" );0 ;1 ;1 ;0 ;0 ;1 ;const LEX_CSTRING aria_name={STRING_WITH_LEN("Aria" )};if (!plugin_is_ready(&aria_name, MYSQL_STORAGE_ENGINE_PLUGIN))if (spider_param_support_xa())if (my_gethwaddr((uchar *) addr))"get hardware address with error " , errno);/* If we can ' t get the hardware address , we zero it out . The spider_unique_id will then look like : - 000000000000 - PID - 6 );sizeof (spider_unique_id_buf), "-%02x%02x%02x%02x%02x%02x-%lx-" ,0 ], addr[1 ], addr[2 ], addr[3 ], addr[4 ], addr[5 ], (ulong) getpid());0 , sizeof (spider_alloc_func_name));0 , sizeof (spider_alloc_file_name));0 , sizeof (spider_alloc_line_no));0 , sizeof (spider_total_alloc_mem));0 , sizeof (spider_current_alloc_mem));0 , sizeof (spider_alloc_mem_count));0 , sizeof (spider_free_mem_count));#ifndef SPIDER_HAS_NEXT_THREAD_ID#endif const char **) &mysqld_unix_port;#ifdef HAVE_PSI_INTERFACE#endif if (pthread_attr_init(&spider_pt_attr))goto error_pt_attr_init;if (mysql_mutex_init(spd_key_mutex_tbl,goto error_tbl_mutex_init;if (mysql_mutex_init(spd_key_thread_id,goto error_thread_id_mutex_init;if (mysql_mutex_init(spd_key_conn_id,goto error_conn_id_mutex_init;if (mysql_mutex_init(spd_key_mutex_ipport_count,goto error_ipport_count_mutex_init;if (mysql_mutex_init(spd_key_mutex_init_error_tbl,goto error_init_error_tbl_mutex_init;if (mysql_mutex_init(spd_key_mutex_wide_share,goto error_wide_share_mutex_init;if (mysql_mutex_init(spd_key_mutex_lgtm_tblhnd_share,goto error_lgtm_tblhnd_share_mutex_init;if (mysql_mutex_init(spd_key_mutex_conn,goto error_conn_mutex_init;if (mysql_mutex_init(spd_key_mutex_open_conn,goto error_open_conn_mutex_init;if (mysql_mutex_init(spd_key_mutex_allocated_thds,goto error_allocated_thds_mutex_init;if (mysql_mutex_init(spd_key_mutex_mon_table_cache,goto error_mon_table_cache_mutex_init;if (mysql_mutex_init(spd_key_mutex_mem_calc,goto error_mem_calc_mutex_init;if (my_hash_init(PSI_INSTRUMENT_ME, &spider_open_tables,32 , 0 , 0 , spider_tbl_get_key, 0 ,0 ))goto error_open_tables_hash_init;if (my_hash_init(PSI_INSTRUMENT_ME, &spider_init_error_tables,32 , 0 , 0 , spider_tbl_get_key, 0 ,0 ))goto error_init_error_tables_hash_init;if (my_hash_init(PSI_INSTRUMENT_ME, &spider_open_wide_share,32 , 0 , 0 ,0 , 0 ))goto error_open_wide_share_hash_init;if (my_hash_init(PSI_INSTRUMENT_ME, &spider_lgtm_tblhnd_share_hash,32 , 0 , 0 ,0 , 0 ))goto error_lgtm_tblhnd_share_hash_init;if (my_hash_init(PSI_INSTRUMENT_ME, &spider_open_connections,32 , 0 , 0 , spider_conn_get_key, 0 ,0 ))goto error_open_connections_hash_init;if (my_hash_init(PSI_INSTRUMENT_ME, &spider_ipport_conns,32 , 0 , 0 ,0 ))goto error_ipport_conn__hash_init;if (my_hash_init(PSI_INSTRUMENT_ME, &spider_allocated_thds,32 , 0 , 0 ,0 , 0 ))goto error_allocated_thds_hash_init;if (SPD_INIT_DYNAMIC_ARRAY2(&spider_mon_table_cache, sizeof (SPIDER_MON_KEY),64 , 64 , MYF(MY_WME)))goto error_mon_table_cache_array_init;if (!(spider_udf_table_mon_mutexes = (pthread_mutex_t *)sizeof (pthread_mutex_t) *sizeof (pthread_cond_t) *sizeof (HASH) *goto error_alloc_mon_mutxes;for (roop_count = 0 ;int ) spider_udf_table_mon_mutex_count;if (mysql_mutex_init(spd_key_mutex_udf_table_mon,goto error_init_udf_table_mon_mutex;for (roop_count = 0 ;int ) spider_udf_table_mon_mutex_count;if (mysql_cond_init(spd_key_cond_udf_table_mon,goto error_init_udf_table_mon_cond;for (roop_count = 0 ;int ) spider_udf_table_mon_mutex_count;if (my_hash_init(PSI_INSTRUMENT_ME,32 , 0 , 0 ,0 , 0 ))goto error_init_udf_table_mon_list_hash;if (!(spider_table_sts_thread = (SPIDER_THREAD *)sizeof (SPIDER_THREAD)),sizeof (SPIDER_THREAD)),goto error_alloc_table_sts_crd_threads;if ((error_num = spider_create_sts_crd_threads(spider_table_sts_thread, 1 )))goto error_init_table_sts_threads;if ((error_num = spider_create_sts_crd_threads(spider_table_crd_thread, 0 )))goto error_init_table_crd_threads;/** Populates `spider_dbton` with available `SPIDER_DBTON`s */ 0 ;for (roop_count = 0 ; roop_count < (int ) dbton_id; roop_count++)if (spider_dbton[roop_count].init &&goto error_init_dbton;0 );for (roop_count--; roop_count >= 0 ; roop_count--)if (spider_dbton[roop_count].deinit)0 ));1 ;for (; roop_count >= 0 ; roop_count--)1 ;for (; roop_count >= 0 ; roop_count--)1 ;for (; roop_count >= 0 ; roop_count--)0 ));/*error_pt_attr_setstate : char *spider_create_string(const char *str,char *res;"spider_create_string" );if (!(res = (char *) spider_malloc(spider_current_trx, SPD_MID_CREATE_STRING_1, length + 1 '\0' ;char *spider_create_table_name_string(const char *table_name,const char *part_name,const char *sub_namechar *res, *tmp;"spider_create_table_name_string" );if (part_name)sizeof ("#P#" ) - 1 + strlen(part_name);if (sub_name)sizeof ("#SP#" ) - 1 + strlen(sub_name);if (!(res = (char *) spider_malloc(spider_current_trx, SPD_MID_CREATE_TABLE_NAME_STRING_1, length + 1 ,if (part_name)"#P#" );if (sub_name)"#SP#" );/* Get the target partition_elements . The target partition and subpartition are detected by the table name , which is in the form like " t1 # P # pt1 " . void spider_get_partition_info(const char *table_name,const TABLE_SHARE *table_share,char tmp_name[FN_REFLEN + 1 ];bool tmp_flg = FALSE , tmp_find_flg = FALSE ;"spider_get_partition_info" );if (!part_info)if (!memcmp(table_name + table_name_length - 5 , "#TMP#" , 5 ))TRUE ;"info" ,("spider table_name=%s" , table_name));while ((*part_elem = part_it++))if ((*part_elem)->subpartitions.elements)while ((*sub_elem = sub_it++))if (SPIDER_create_subpartition_name(1 , table_share->path.str,"info" ,("spider tmp_name=%s" , tmp_name));if (table_name_length == strlen(tmp_name) &&if (5 ) == '\0' &&5 )FALSE ;TRUE ;else {if (SPIDER_create_partition_name(1 , table_share->path.str,TRUE ))"info" ,("spider tmp_name=%s" , tmp_name));if (table_name_length == strlen(tmp_name) &&if (5 ) == '\0' &&5 )FALSE ;TRUE ;if (tmp_find_flg)"info" ,("spider tmp find" ));"info" ,("spider no hit" ));/** Determines the get type for spider_get_sts() */ enum ha_sts_crd_get_type spider_get_sts_type(double sts_interval,int sts_syncif (sts_sync == 0 )return HA_GET_FETCH;if (!share->wide_share->sts_init)if (!share->wide_share->sts_init)return HA_GET_AFTER_LOCK;return HA_GET_COPY;if (difftime(share->sts_get_time, share->wide_share->sts_get_time) <return HA_GET_COPY;if (!pthread_mutex_trylock(&share->wide_share->sts_mutex))return HA_GET_AFTER_TRYLOCK;return HA_GET_COPY;/** Populates share - > stat or share - > wide_share - > stat with table status . int spider_get_sts(int link_idx,double sts_interval,int sts_mode,int sts_sync,int sts_sync_level,int error_num = 0 ;"spider_get_sts" );enum ha_sts_crd_get_type get_type =if (get_type == HA_GET_COPY)else /* Executes a `show table status` query and store the results in if (get_type >= HA_GET_AFTER_LOCK)if (error_num)if (!share->wide_share->sts_init &&0 ] == spider)int roop_count;double tmp_sts_interval;int tmp_sts_mode;int tmp_sts_sync;for (roop_count = 1 ;int ) partition_handler->no_parts;1 , flag);if (share->wide_share->sts_init)0 ;break ;if (error_num)if (sts_sync >= sts_sync_level && get_type > HA_GET_COPY)TRUE ;TRUE ;0 );/** Determines the get type for spider_get_crd() */ enum ha_sts_crd_get_type spider_get_crd_type(double crd_interval,int crd_syncif (crd_sync == 0 )return HA_GET_FETCH;if (!share->wide_share->crd_init)if (!share->wide_share->crd_init)return HA_GET_AFTER_LOCK;return HA_GET_COPY;if (difftime(share->crd_get_time, share->wide_share->crd_get_time) <return HA_GET_COPY;if (!pthread_mutex_trylock(&share->wide_share->crd_mutex))return HA_GET_AFTER_TRYLOCK;return HA_GET_COPY;/** Populates share - > cardinality or share - > wide_share - > cardinality with table index int spider_get_crd(int link_idx,double crd_interval,int crd_mode,int crd_sync,int crd_sync_levelint error_num = 0 ;"spider_get_crd" );enum ha_sts_crd_get_type get_type =if (get_type == HA_GET_COPY)sizeof (longlong) * table->s->fields);else if (get_type >= HA_GET_AFTER_LOCK)if (error_num)if (!share->wide_share->crd_init &&0 ] == spider)int roop_count;double tmp_crd_interval;int tmp_crd_mode;int tmp_crd_sync;for (roop_count = 1 ;int ) partition_handler->no_parts;1 );if (share->wide_share->crd_init)0 ;sizeof (longlong) * table->s->fields);break ;if (error_num)if (crd_sync >= crd_sync_level && get_type > HA_GET_COPY)sizeof (longlong) * table->s->fields);TRUE ;TRUE ;0 );void spider_set_result_list_param("spider_set_result_list_param" );#ifdef INFO_KIND_FORCE_LIMIT_BEGIN9223372036854775807 LL ?#endif if (spider->support_multi_split_read_sql())else {1 ;/** Gets or creates a ` SPIDER_INIT_ERROR_TABLE ` with the table name from a given ` SPIDER_SHARE ` When creating , also add the newly created object to ` spider_init_error_tables ` @ param trx Transaction @ param share The spider share providing the table name @ param create Whether to create a new ` SPIDER_INIT_ERROR_TABLE ` if one wi th the required table name does not exist yet @ return A ` SPIDER_INIT_ERROR_TABLE ` or NULL if failure bool createchar *tmp_name;"spider_get_init_error_table" );if (!(spider_init_error_table = (SPIDER_INIT_ERROR_TABLE *)if (!create)if (!spider_bulk_malloc(spider_current_trx, SPD_MID_GET_INIT_ERROR_TABLE_1,sizeof (*spider_init_error_table)),1 ),if (my_hash_insert(&spider_init_error_tables,0 ));if (spider_init_error_tables.array.max_element > old_elements)void spider_delete_init_error_table(const char *name"spider_delete_init_error_table" );if ((spider_init_error_table = (SPIDER_INIT_ERROR_TABLE *)0 ));bool spider_check_pk_update(int roop_count;"spider_check_pk_update" );if (table_share->primary_key == MAX_KEY)FALSE );for (roop_count = 0 ;int ) spider_user_defined_key_parts(key_info); roop_count++)if (bitmap_is_set(table->write_set,TRUE );FALSE );/* Set fields of a tmp share which has only one link . For use in monitoring , spider_copy_tables udf etc . void spider_set_tmp_share_pointer(char **tmp_connect_info,long *tmp_long,"spider_set_tmp_share_pointer" );1 ;1 ;0 ];1 ];2 ];3 ];4 ];5 ];6 ];7 ];8 ];9 ];10 ];11 ];12 ];13 ];14 ];15 ];16 ];17 ];18 ];19 ];20 ];23 ];0 ];1 ];2 ];3 ];4 ];5 ];6 ];7 ];13 ];14 ];13 ] = -1 ;15 ];14 ] = -1 ;16 ];17 ];18 ];0 ];1 ];2 ];0 ];1 ];2 ];3 ];4 ];5 ];6 ];7 ];8 ];9 ];10 ];11 ];12 ];13 ];14 ];15 ];16 ];17 ];18 ];19 ];20 ];23 ];1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;1 ;0 ] = -1 ;0 ] = -1 ;0 ] = -1 ;0 ] = -1 ;0 ] = -1 ;0 ] = -1 ;0 ] = -1 ;0 ] = -1 ;0 ;int spider_create_tmp_dbton_share(int error_num;0 ];"spider_create_tmp_dbton_share" );if (!(tmp_share->dbton_share[dbton_id] =if ((error_num = tmp_share->dbton_share[dbton_id]->init()))delete tmp_share->dbton_share[dbton_id];0 );void spider_free_tmp_dbton_share(0 ];"spider_free_tmp_dbton_share" );if (tmp_share->dbton_share[dbton_id])delete tmp_share->dbton_share[dbton_id];int spider_create_tmp_dbton_handler(int error_num;0 ];"spider_create_tmp_dbton_handler" );if (!(tmp_spider->dbton_handler[dbton_id] =if ((error_num = tmp_spider->dbton_handler[dbton_id]->init()))delete tmp_spider->dbton_handler[dbton_id];0 );void spider_free_tmp_dbton_handler(0 ];"spider_create_tmp_dbton_handler" );if (tmp_spider->dbton_handler[dbton_id])delete tmp_spider->dbton_handler[dbton_id];"spider_get_parent_table_list" );"spider_get_index_hint" );if (table_list)"spider_get_select_lex" );if (table_list)void spider_get_select_limit_from_select_lex("spider_get_select_limit_from_select_lex" );9223372036854775807 LL;0 ;if (select_lex && select_lex->limit_params.explicit_limit)0 ;0 ;void spider_get_select_limit("spider_get_select_limit" );double semi_split_read;"spider_split_read_param" );1 ;#ifdef INFO_KIND_FORCE_LIMIT_BEGINif (spider->wide_handler->info_limit < 9223372036854775807 LL)"info" ,("spider info_limit=%lld" ,0 ;0 ;FALSE ;#endif "info" ,("spider result_list->set_split_read=%s" , result_list->set_split_read ? "TRUE" : "FALSE" ));if (!result_list->set_split_read)int bulk_update_mode = spider_param_bulk_update_mode(thd,"info" ,("spider sql_command=%u" ,"info" ,("spider bulk_update_mode=%d" , bulk_update_mode));"info" ,("spider support_bulk_update_sql=%s" ,"TRUE" : "FALSE" ));bool inserting =bool updating =bool deleting =bool replacing ="info" ,("spider updating=%s" , updating ? "TRUE" : "FALSE" ));"info" ,("spider deleting=%s" , deleting ? "TRUE" : "FALSE" ));"info" ,("spider replacing=%s" , replacing ? "TRUE" : "FALSE" ));if (2 ||#ifdef HA_CAN_FORCE_BULK_UPDATE#endif #ifdef HA_CAN_FORCE_BULK_DELETE#endif /* This case must select by one shot */ "info" ,("spider cancel split read" ));9223372036854775807 LL;0 ;9223372036854775807 LL;9223372036854775807 LL;9223372036854775807 LL;0 ;TRUE ;9223372036854775807 LL);#ifdef SPIDER_HAS_EXPLAIN_QUERYbool filesort = FALSE ;if (explain)"info" ,("spider explain=%p" , explain));if (select_lex)"info" ,("spider select_lex=%p" , select_lex));"info" ,("spider select_number=%u" ,if (explain_select)"info" ,("spider explain_select=%p" , explain_select));if (explain_select->using_filesort)"info" ,("spider using filesort" ));TRUE ;#endif #ifdef SPIDER_HAS_EXPLAIN_QUERYif (filesort)0 ;9223372036854775807 LL;else {#endif #ifdef SPIDER_HAS_EXPLAIN_QUERY#endif 0 ;TRUE ;"info" ,("spider result_list->semi_split_read=%f" , result_list->semi_split_read));"info" ,("spider select_lex->explicit_limit=%d" , select_lex ? select_lex->limit_params.explicit_limit : 0 ));"info" ,("spider OPTION_FOUND_ROWS=%s" , select_lex && (select_lex->options & OPTION_FOUND_ROWS) ? "TRUE" : "FALSE" ));"info" ,("spider select_lex->group_list.elements=%u" , select_lex ? select_lex->group_list.elements : 0 ));"info" ,("spider select_lex->with_sum_func=%s" , select_lex && select_lex->with_sum_func ? "TRUE" : "FALSE" ));if (0 &&"info" ,("spider semi_split_read=%f" , semi_split_read));if (semi_split_read >= result_list->semi_split_read_limit)else {if (split_read < 0 )else if (split_read == 0 )1 ;1 );else {else if (result_list->first_read > 0 )"spider_bg_split_read_param" );if (result_list->semi_split_read_base)void spider_first_split_read_param("spider_first_split_read_param" );if (result_list->semi_split_read_base)else if (result_list->second_read > 0 )else 1 ;void spider_next_split_read_param("spider_next_split_read_param" );if (result_list->semi_split_read_base)else if (1 &&0 else bool spider_check_direct_order_limit("spider_check_direct_order_limit" );if (spider_check_index_merge(spider->get_table(),"info" ,("spider set use_index_merge" ));TRUE ;"info" ,("spider SQLCOM_HA_READ=%s" ,"TRUE" : "FALSE" ));"info" ,("spider use_index_merge=%s" ,"TRUE" : "FALSE" ));"info" ,("spider is_clone=%s" ,"TRUE" : "FALSE" ));if (bool first_check = TRUE ;"info" ,("spider select_lex=%p" , select_lex));"info" ,("spider leaf_tables.elements=%u" ,0 ));if (select_lex && (select_lex->options & SELECT_DISTINCT))"info" ,("spider with distinct" ));TRUE ;"info" ,("spider select_limit=%lld" , select_limit));"info" ,("spider offset_limit=%lld" , offset_limit));if (#ifdef SPIDER_ENGINE_CONDITION_PUSHDOWN_IS_ALWAYS_ON#else #endif #ifdef SPIDER_NEED_CHECK_CONDITION_AT_CHECKING_DIRECT_ORDER_LIMIT#endif 1 ||1 "info" ,("spider first_check is FALSE" ));FALSE ;FALSE ;FALSE ;else if (spider_db_append_condition(spider, NULL, 0 , TRUE ))"info" ,("spider FALSE by condition" ));FALSE ;FALSE ;FALSE ;else if ("info" ,("spider this SQL is not aggregate SQL" ));FALSE ;else {for (group = (ORDER *) select_lex->group_list.first; group;if (spider->print_item_type((*group->item), NULL, NULL, 0 ))"info" ,("spider aggregate FALSE by group" ));FALSE ;break ;for (item_sum_ptr = join->sum_funcs; *item_sum_ptr; ++item_sum_ptr)if (spider->print_item_type(*item_sum_ptr, NULL, NULL, 0 ))"info" ,("spider aggregate FALSE by not supported" ));FALSE ;break ;if (!spider_all_part_in_order((ORDER *) select_lex->group_list.first,"info" ,("spider FALSE by group condition" ));FALSE ;FALSE ;"info" ,("spider direct_order_limit=%lld" , direct_order_limit));if (direct_order_limit)"info" ,("spider first_check=%s" ,"TRUE" : "FALSE" ));"info" ,("spider (select_lex->options & OPTION_FOUND_ROWS)=%s" ,"TRUE" : "FALSE" ));"info" ,("spider direct_aggregate=%s" ,"TRUE" : "FALSE" ));"info" ,("spider select_lex->group_list.elements=%u" ,0 ));"info" ,("spider select_lex->with_sum_func=%s" ,"TRUE" : "FALSE" ));"info" ,("spider select_lex->having=%s" ,"TRUE" : "FALSE" ));"info" ,("spider select_lex->order_list.elements=%u" ,0 ));if ("info" ,("spider FALSE by select_lex" ));FALSE );for (order = (ORDER *) select_lex->order_list.first; order;if (spider->print_item_type((*order->item), NULL, NULL, 0 ))"info" ,("spider FALSE by order" ));FALSE );"info" ,("spider TRUE" ));TRUE );"info" ,("spider FALSE by parameter" ));FALSE );bool spider_all_part_in_order("spider_all_part_in_order" );while (TRUE )"info" , ("spider table_name = %s" , table->s->db.str));"info" ,("spider part_info=%p" , table->part_info));if ((part_info = table->part_info))for (part_fields = part_info->full_part_field_array;"info" , ("spider part_field = %s" ,for (ptr = order; ptr; ptr = ptr->next)if (item->type() != Item::FIELD_ITEM)continue ;if (!field)continue ;"info" , ("spider field_name = %s.%s" ,if (*part_fields == spider_field_exchange(table->file, field))break ;if (!ptr)FALSE );if (!(parent = table->pos_in_table_list->parent_l))break ;TRUE );"spider_field_exchange" );"info" ,("spider in field=%p" , field));"info" ,("spider in field->table=%p" , field->table));"info" ,("spider table=%p" , handler->get_table()));if (field->table != handler->get_table())"info" ,("spider out field=%p" , field));int spider_set_direct_limit_offset(#ifndef SPIDER_ENGINE_CONDITION_PUSHDOWN_IS_ALWAYS_ON#endif "spider_set_direct_limit_offset" );if (spider->result_list.direct_limit_offset)TRUE );if (if (spider->partition_handler->owner->TRUE )TRUE ;TRUE );else {FALSE );if (// must be RND_INIT and not be INDEX_INIT FALSE );// limit and offset is non-zero if (!(select_limit && offset_limit))FALSE );// more than one table if (1 FALSE );if (table_list->table->file->partition_ht() != spider_hton_ptr)"info" ,("spider ht1=%u ht2=%u" ,FALSE );// contain where if (#ifdef SPIDER_ENGINE_CONDITION_PUSHDOWN_IS_ALWAYS_ON#else #endif // conditions is null may be no where condition in rand_init FALSE );// ignore condition like 1=1 #ifdef SPIDER_has_Item_has_subqueryif (select_lex->where && select_lex->where->has_subquery())#else if (select_lex->where && select_lex->where->with_subquery())#endif FALSE );if (FALSE );// must not be derived table if (SPIDER_get_linkage(select_lex) == DERIVED_TABLE_TYPE)FALSE );TRUE ;TRUE );bool spider_check_index_merge("spider_check_index_merge" );if (!select_lex)"info" ,("spider select_lex is null" ));FALSE );if (!join)"info" ,("spider join is null" ));FALSE );if (!join->join_tab)"info" ,("spider join->join_tab is null" ));FALSE );for (roop_count = 0 ; roop_count < spider_join_table_count(join); ++roop_count)if (join_tab->table == table)"info" ,("spider join_tab->type=%u" , join_tab->type));if (#ifdef SPIDER_HAS_JT_HASH_INDEX_MERGE#endif TRUE );/* DBUG_PRINT ( " info " , ( " spider join_tab - > quick - > get_type ( ) = % u " , join_tab - > quick ? join_tab - > quick - > get_type ( ) : 0 ) ) ; if ( join_tab - > quick & & join_tab - > quick - > get_type ( ) = = QUICK_SELECT_I : : QS_TYPE_INDEX_MERGE ) { DBUG_RETURN ( TRUE ) ; } "info" ,("spider join_tab->select->quick->get_type()=%u" ,0 ));if (TRUE );break ;FALSE );int spider_compare_for_sort(const void *a_,const void *b_const SPIDER_SORT *a= static_cast <const SPIDER_SORT *>(a_);const SPIDER_SORT *b= static_cast <const SPIDER_SORT *>(b_);"spider_compare_for_sort" );if (a->sort > b->sort)1 );if (a->sort < b->sort)1 );0 );0 ;"spider_calc_for_sort" );while (count--)char *start = va_arg(args, char *), *str;0 ;if ((str = start))128 ;for (; *str; str++)if (*str == spider_wild_prefix && str[1 ])else if (*str == spider_wild_many || *str == spider_wild_one)1 ;if (wild_pos > 127 )127 ;break ;8 ) + wild_pos;/** Generates a random number between 0 and 1 */ double spider_rand(struct my_rnd_struct rand;"spider_rand" );/* generate same as rand function for applications */ 65537 L + 55555555 L),268435457 L));int spider_discover_table_structure_internal(int error_num = 0 , roop_count;"spider_discover_table_structure_internal" );for (roop_count = 0 ; roop_count < SPIDER_DBTON_SIZE; roop_count++)if (spider_bit_is_set(spider_share->dbton_bitmap, roop_count))if ((error_num = spider_share->dbton_share[roop_count]->continue ;break ;int spider_discover_table_structure(int error_num = HA_ERR_WRONG_COMMAND, dummy;const char *table_name = share->path.str;char buf[MAX_FIELD_WIDTH];sizeof (buf), system_charset_info);"spider_discover_table_structure" );0 );if (str.reserve(/* SPIDER_SQL_LCL_NAME_QUOTE_LEN */ 4 + SPIDER_SQL_OPEN_PAREN_LEN if (!(trx = spider_get_trx(thd, TRUE , &error_num)))"info" ,("spider spider_get_trx error" ));0 ));if (!part_info)if (!(spider_share = spider_create_share(table_name, share,if (!error_num)if (TRUE , &open_tables_backup,if (thd->lex->create_info.or_replace())if (!error_num)else {char tmp_name[FN_REFLEN + 1 ];while ((part_elem = part_it++))if ((part_elem)->subpartitions.elements)while ((sub_elem = sub_it++))if ((error_num = SPIDER_create_subpartition_name(1 , table_name,"info" ,("spider tmp_name=%s" , tmp_name));if (!(spider_share = spider_create_share(tmp_name, share,if (!error_num)break ;if (!error_num)break ;else {if ((error_num = SPIDER_create_partition_name(1 , table_name,TRUE )))"info" ,("spider tmp_name=%s" , tmp_name));if (!(spider_share = spider_create_share(tmp_name, share,if (!error_num)break ;if (!error_num)if (TRUE , &open_tables_backup,while ((part_elem = part_it2++))if ((part_elem)->subpartitions.elements)while ((sub_elem = sub_it++))if ((error_num = SPIDER_create_subpartition_name(1 , table_name,"info" ,("spider tmp_name=%s" , tmp_name));if (!(spider_share = spider_create_share(tmp_name, share,if (thd->lex->create_info.or_replace())if (!error_num)if (error_num)break ;if (error_num)break ;else {if ((error_num = SPIDER_create_partition_name(1 , table_name,TRUE )))"info" ,("spider tmp_name=%s" , tmp_name));if (!(spider_share = spider_create_share(tmp_name, share,if (thd->lex->create_info.or_replace())if (!error_num)if (error_num)break ;if (!error_num)else if (share->table_charset)else {if (str.reserve(SPIDER_SQL_CLOSE_PAREN_LEN + SPIDER_SQL_DEFAULT_CHARSET_LEN +2 )if (share->option_struct_table->connection)if (str.reserve(SPIDER_SQL_CONNECTION_LEN +2 ) +2 )))if (str.reserve(SPIDER_SQL_VALUE_QUOTE_LEN))"info" ,("spider part_info=%p" , part_info));if (part_info)char *part_syntax;while ((part_elem = part_it++))if ((part_elem)->subpartitions.elements)while ((sub_elem = sub_it++))if (part_info->fix_parser_data(thd))if (!(part_syntax = SPIDER_generate_partition_syntax(thd, part_info,FALSE , TRUE , info, NULL, NULL)))if (str.reserve(part_syntax_len))0 ));"info" ,("spider str=%s" , str.c_ptr_safe()));TRUE , str.ptr(),int spider_create_spider_object_for_share(int error_num, roop_count, *need_mons;char **conn_keys;"spider_create_spider_object_for_share" );"info" ,("spider trx=%p" , trx));"info" ,("spider share=%p" , share));"info" ,("spider spider_ptr=%p" , spider));"info" ,("spider spider=%p" , (*spider)));if (*spider)/* already exists */ 0 );new (&share->mem_root) ha_spider();if (!(*spider))goto error_spider_alloc;"info" ,("spider spider=%p" , (*spider)));if (!(need_mons = (int *)YF(MY_WME | MY_ZEROFILL),sizeof (int ) * share->link_count),sizeof (SPIDER_CONN *) * share->link_count),sizeof (uint) * share->link_count),sizeof (uchar) * share->link_bitmap_size),sizeof (char *) * share->link_count),sizeof (spider_db_handler *) * SPIDER_DBTON_SIZE),sizeof (SPIDER_WIDE_HANDLER),goto error_need_mons_alloc;"info" ,("spider need_mons=%p" , need_mons));0 ];1 ;for (roop_count = 0 ; roop_count < SPIDER_DBTON_SIZE; roop_count++)if (if (!(dbton_hdl[roop_count] = spider_dbton[roop_count].create_db_handler(goto error_init_db_handler;if ((error_num = dbton_hdl[roop_count]->init()))goto error_init_db_handler;"info" ,("spider share=%p" , (*spider)->share));"info" ,("spider need_mons=%p" , (*spider)->need_mons));0 );for (; roop_count >= 0 ; --roop_count)if (delete dbton_hdl[roop_count];0 ));delete (*spider);void spider_free_spider_object_for_share(int roop_count;"spider_free_spider_object_for_share" );"info" ,("spider share=%p" , share));"info" ,("spider spider_ptr=%p" , spider));"info" ,("spider spider=%p" , (*spider)));for (roop_count = SPIDER_DBTON_SIZE - 1 ; roop_count >= 0 ; --roop_count)if (delete dbton_hdl[roop_count];0 ));delete (*spider);int spider_create_sts_crd_threads(bool is_stsint error_num;"spider_create_sts_crd_threads" );#ifdef HAVE_PSI_INTERFACE#endif if (mysql_mutex_init(mutex_bg,goto error_mutex_init;if (mysql_cond_init(cond_bg,goto error_cond_init;if (mysql_cond_init(cond_bg_syncs,goto error_sync_cond_init;void *) spider_thread) :void *) spider_thread);if (error_num)goto error_thread_create;0 );void spider_free_sts_crd_threads(bool thread_killed;"spider_free_sts_crd_threads" );TRUE ;if (!thread_killed)if (spider_thread->thd_wait)FALSE ;FALSE ;static void *spider_table_bg_sts_crd_action(void *arg,bool is_stsint error_num;/* only needed for crd */ "spider_table_bg_sts_crd_action" );/* init start */ if (!(thd = spider_create_sys_thd(thread)))FALSE ;FALSE ;#ifdef HAVE_PSI_INTERFACE#endif "Spider table background statistics/cardinality" " action handler" );if (!(trx = spider_get_trx(NULL, FALSE , &error_num)))FALSE ;FALSE ;#if !defined (MYSQL_DYNAMIC_PLUGIN) || !defined (_WIN32)#endif /* init end */ if (thd->killed)TRUE ;while (TRUE )"info" ,("spider bg sts/crd loop start" ));if (thread->killed)"info" ,("spider bg sts/crd kill start" ));TRUE );#if !defined (MYSQL_DYNAMIC_PLUGIN) || !defined (_WIN32)#endif if (!thread->queue_first)"info" ,("spider bg sts/crd has no job" ));TRUE ;FALSE ;if (thd->killed)TRUE ;continue ;if (is_sts)TRUE ;else TRUE ;if (is_sts)else if (spider->search_link_idx < 0 )if (spider->search_link_idx >= 0 )double diff_time= is_sts ?double interval= is_sts? share->bg_sts_interval : share->bg_crd_interval;"info" , ("spider difftime=%f" , diff_time));"info" , ("spider bg_sts_interval=%f" , interval));if (diff_time >= interval)if (!conns[spider->search_link_idx])FALSE , FALSE , &error_num);if (conns[spider->search_link_idx])0 ;else {1 ;"info" ,"spider search_link_idx=%d" , spider->search_link_idx));if (spider->search_link_idx >= 0 && conns[spider->search_link_idx])int result = is_sts ?2 , HA_STATUS_CONST | HA_STATUS_VARIABLE) :2 );if (result)1 ;0 , sizeof (int ) * share->link_count);if (thread->queue_first == thread->queue_last)else {if (is_sts)else if (is_sts)FALSE ;FALSE ;else FALSE ;FALSE ;if (thread->first_free_wait)if (thd->killed)TRUE ;void *spider_table_bg_sts_action(void *arg)"spider_table_bg_sts_action" );true ));void *spider_table_bg_crd_action(void *arg)"spider_table_bg_crd_action" );false ));void spider_table_add_share_to_sts_thread("spider_table_add_share_to_sts_thread" );if (if (!share->sts_wait)if (spider_thread->queue_last)"info" ,("spider add to last" ));else {TRUE ;if (spider_thread->thd_wait)void spider_table_add_share_to_crd_thread("spider_table_add_share_to_crd_thread" );if (if (!share->crd_wait)if (spider_thread->queue_last)"info" ,("spider add to last" ));else {TRUE ;if (spider_thread->thd_wait)void spider_table_remove_share_from_sts_thread("spider_table_remove_share_from_sts_thread" );if (share->sts_wait)if (share->sts_wait)if (share->sts_working)"info" ,("spider waiting bg sts start" ));TRUE ;FALSE ;"info" ,("spider waiting bg sts end" ));if (share->sts_prev)if (share->sts_next)"info" ,("spider remove middle one" ));else {"info" ,("spider remove last one" ));else if (share->sts_next) {"info" ,("spider remove first one" ));else {"info" ,("spider empty" ));void spider_table_remove_share_from_crd_thread("spider_table_remove_share_from_crd_thread" );if (share->crd_wait)if (share->crd_wait)if (share->crd_working)"info" ,("spider waiting bg crd start" ));TRUE ;FALSE ;"info" ,("spider waiting bg crd end" ));if (share->crd_prev)if (share->crd_next)"info" ,("spider remove middle one" ));else {"info" ,("spider remove last one" ));else if (share->crd_next) {"info" ,("spider remove first one" ));else {"info" ,("spider empty" ));"spider_duplicate_char" );while (src < ed)if (*src == esc)
Messung V0.5 in Prozent C=99 H=76 G=88
¤ Die Informationen auf dieser Webseite wurden
nach bestem Wissen sorgfältig zusammengestellt. Es wird jedoch weder Vollständigkeit, noch Richtigkeit,
noch Qualität der bereit gestellten Informationen zugesichert.0.765Bemerkung:
(vorverarbeitet am 2026-10-04)
¤ *Bot Zugriff
