mirror of
https://github.com/MariaDB/server.git
synced 2025-08-08 11:22:35 +03:00
MDEV-27656 Spider: remove #ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
This commit is contained in:
@@ -924,7 +924,6 @@ public:
|
|||||||
longlong pos
|
longlong pos
|
||||||
) = 0;
|
) = 0;
|
||||||
virtual int get_errno() = 0;
|
virtual int get_errno() = 0;
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
virtual int fetch_columns_for_discover_table_structure(
|
virtual int fetch_columns_for_discover_table_structure(
|
||||||
spider_string *str,
|
spider_string *str,
|
||||||
CHARSET_INFO *access_charset
|
CHARSET_INFO *access_charset
|
||||||
@@ -938,7 +937,6 @@ public:
|
|||||||
SPIDER_SHARE *spider_share,
|
SPIDER_SHARE *spider_share,
|
||||||
CHARSET_INFO *access_charset
|
CHARSET_INFO *access_charset
|
||||||
) = 0;
|
) = 0;
|
||||||
#endif
|
|
||||||
virtual uint limit_mode();
|
virtual uint limit_mode();
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -1145,13 +1143,11 @@ public:
|
|||||||
uint alias_length
|
uint alias_length
|
||||||
) = 0;
|
) = 0;
|
||||||
virtual bool need_change_db_table_name() = 0;
|
virtual bool need_change_db_table_name() = 0;
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
virtual int discover_table_structure(
|
virtual int discover_table_structure(
|
||||||
SPIDER_TRX *trx,
|
SPIDER_TRX *trx,
|
||||||
SPIDER_SHARE *spider_share,
|
SPIDER_SHARE *spider_share,
|
||||||
spider_string *str
|
spider_string *str
|
||||||
) = 0;
|
) = 0;
|
||||||
#endif
|
|
||||||
virtual bool checksum_support();
|
virtual bool checksum_support();
|
||||||
};
|
};
|
||||||
|
|
||||||
|
@@ -138,7 +138,6 @@ static const char *name_quote_str = SPIDER_SQL_NAME_QUOTE_STR;
|
|||||||
#define SPIDER_SQL_BINLOG_GTID_POS_STR "select binlog_gtid_pos"
|
#define SPIDER_SQL_BINLOG_GTID_POS_STR "select binlog_gtid_pos"
|
||||||
#define SPIDER_SQL_BINLOG_GTID_POS_LEN sizeof(SPIDER_SQL_BINLOG_GTID_POS_STR) - 1
|
#define SPIDER_SQL_BINLOG_GTID_POS_LEN sizeof(SPIDER_SQL_BINLOG_GTID_POS_STR) - 1
|
||||||
|
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
#define SPIDER_SQL_SHOW_COLUMNS_STR "show columns from "
|
#define SPIDER_SQL_SHOW_COLUMNS_STR "show columns from "
|
||||||
#define SPIDER_SQL_SHOW_COLUMNS_LEN sizeof(SPIDER_SQL_SHOW_COLUMNS_STR) - 1
|
#define SPIDER_SQL_SHOW_COLUMNS_LEN sizeof(SPIDER_SQL_SHOW_COLUMNS_STR) - 1
|
||||||
#define SPIDER_SQL_SELECT_COLUMNS_STR "select `column_name`,`column_default`,`is_nullable`,`character_set_name`,`collation_name`,`column_type`,`extra` from `information_schema`.`columns` where `table_schema` = "
|
#define SPIDER_SQL_SELECT_COLUMNS_STR "select `column_name`,`column_default`,`is_nullable`,`character_set_name`,`collation_name`,`column_type`,`extra` from `information_schema`.`columns` where `table_schema` = "
|
||||||
@@ -154,7 +153,6 @@ static const char *name_quote_str = SPIDER_SQL_NAME_QUOTE_STR;
|
|||||||
#define SPIDER_SQL_SPATIAL_LEN sizeof(SPIDER_SQL_SPATIAL_STR) - 1
|
#define SPIDER_SQL_SPATIAL_LEN sizeof(SPIDER_SQL_SPATIAL_STR) - 1
|
||||||
#define SPIDER_SQL_USING_HASH_STR " using hash"
|
#define SPIDER_SQL_USING_HASH_STR " using hash"
|
||||||
#define SPIDER_SQL_USING_HASH_LEN sizeof(SPIDER_SQL_USING_HASH_STR) - 1
|
#define SPIDER_SQL_USING_HASH_LEN sizeof(SPIDER_SQL_USING_HASH_STR) - 1
|
||||||
#endif
|
|
||||||
|
|
||||||
#define SPIDER_SQL_SHOW_RECORDS_RECORDS_POS 0
|
#define SPIDER_SQL_SHOW_RECORDS_RECORDS_POS 0
|
||||||
#define SPIDER_SQL_EXPLAIN_SELECT_RECORDS_POS 8
|
#define SPIDER_SQL_EXPLAIN_SELECT_RECORDS_POS 8
|
||||||
@@ -1383,7 +1381,6 @@ int spider_db_mbase_result::get_errno()
|
|||||||
DBUG_RETURN(store_error_num);
|
DBUG_RETURN(store_error_num);
|
||||||
}
|
}
|
||||||
|
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
int spider_db_mbase_result::fetch_columns_for_discover_table_structure(
|
int spider_db_mbase_result::fetch_columns_for_discover_table_structure(
|
||||||
spider_string *str,
|
spider_string *str,
|
||||||
CHARSET_INFO *access_charset
|
CHARSET_INFO *access_charset
|
||||||
@@ -1756,7 +1753,6 @@ int spider_db_mbase_result::fetch_table_for_discover_table_structure(
|
|||||||
}
|
}
|
||||||
DBUG_RETURN(0);
|
DBUG_RETURN(0);
|
||||||
}
|
}
|
||||||
#endif
|
|
||||||
|
|
||||||
spider_db_mbase::spider_db_mbase(
|
spider_db_mbase::spider_db_mbase(
|
||||||
SPIDER_CONN *conn,
|
SPIDER_CONN *conn,
|
||||||
@@ -8374,7 +8370,6 @@ bool spider_mbase_share::need_change_db_table_name()
|
|||||||
DBUG_RETURN(!same_db_table_name);
|
DBUG_RETURN(!same_db_table_name);
|
||||||
}
|
}
|
||||||
|
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
int spider_mbase_share::discover_table_structure(
|
int spider_mbase_share::discover_table_structure(
|
||||||
SPIDER_TRX *trx,
|
SPIDER_TRX *trx,
|
||||||
SPIDER_SHARE *spider_share,
|
SPIDER_SHARE *spider_share,
|
||||||
@@ -8678,7 +8673,6 @@ int spider_mbase_share::discover_table_structure(
|
|||||||
}
|
}
|
||||||
DBUG_RETURN(error_num);
|
DBUG_RETURN(error_num);
|
||||||
}
|
}
|
||||||
#endif
|
|
||||||
|
|
||||||
bool spider_mbase_share::checksum_support()
|
bool spider_mbase_share::checksum_support()
|
||||||
{
|
{
|
||||||
|
@@ -352,7 +352,6 @@ public:
|
|||||||
longlong pos
|
longlong pos
|
||||||
);
|
);
|
||||||
int get_errno();
|
int get_errno();
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
int fetch_columns_for_discover_table_structure(
|
int fetch_columns_for_discover_table_structure(
|
||||||
spider_string *str,
|
spider_string *str,
|
||||||
CHARSET_INFO *access_charset
|
CHARSET_INFO *access_charset
|
||||||
@@ -366,7 +365,6 @@ public:
|
|||||||
SPIDER_SHARE *spider_share,
|
SPIDER_SHARE *spider_share,
|
||||||
CHARSET_INFO *access_charset
|
CHARSET_INFO *access_charset
|
||||||
);
|
);
|
||||||
#endif
|
|
||||||
};
|
};
|
||||||
|
|
||||||
class spider_db_mysql_result: public spider_db_mbase_result
|
class spider_db_mysql_result: public spider_db_mbase_result
|
||||||
@@ -672,13 +670,11 @@ public:
|
|||||||
int *table_name_pos
|
int *table_name_pos
|
||||||
);
|
);
|
||||||
bool need_change_db_table_name();
|
bool need_change_db_table_name();
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
int discover_table_structure(
|
int discover_table_structure(
|
||||||
SPIDER_TRX *trx,
|
SPIDER_TRX *trx,
|
||||||
SPIDER_SHARE *spider_share,
|
SPIDER_SHARE *spider_share,
|
||||||
spider_string *str
|
spider_string *str
|
||||||
);
|
);
|
||||||
#endif
|
|
||||||
bool checksum_support();
|
bool checksum_support();
|
||||||
protected:
|
protected:
|
||||||
int create_table_names_str();
|
int create_table_names_str();
|
||||||
|
@@ -1079,7 +1079,6 @@ int spider_db_oracle_result::get_errno()
|
|||||||
DBUG_RETURN(store_error_num);
|
DBUG_RETURN(store_error_num);
|
||||||
}
|
}
|
||||||
|
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
int spider_db_oracle_result::fetch_columns_for_discover_table_structure(
|
int spider_db_oracle_result::fetch_columns_for_discover_table_structure(
|
||||||
spider_string *str,
|
spider_string *str,
|
||||||
CHARSET_INFO *access_charset
|
CHARSET_INFO *access_charset
|
||||||
@@ -1107,7 +1106,6 @@ int spider_db_oracle_result::fetch_table_for_discover_table_structure(
|
|||||||
DBUG_PRINT("info",("spider this=%p", this));
|
DBUG_PRINT("info",("spider this=%p", this));
|
||||||
DBUG_RETURN(HA_ERR_WRONG_COMMAND);
|
DBUG_RETURN(HA_ERR_WRONG_COMMAND);
|
||||||
}
|
}
|
||||||
#endif
|
|
||||||
|
|
||||||
spider_db_oracle::spider_db_oracle(
|
spider_db_oracle::spider_db_oracle(
|
||||||
SPIDER_CONN *conn
|
SPIDER_CONN *conn
|
||||||
@@ -5404,7 +5402,6 @@ bool spider_oracle_share::need_change_db_table_name()
|
|||||||
DBUG_RETURN(!same_db_table_name);
|
DBUG_RETURN(!same_db_table_name);
|
||||||
}
|
}
|
||||||
|
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
int spider_oracle_share::discover_table_structure(
|
int spider_oracle_share::discover_table_structure(
|
||||||
SPIDER_TRX *trx,
|
SPIDER_TRX *trx,
|
||||||
SPIDER_SHARE *spider_share,
|
SPIDER_SHARE *spider_share,
|
||||||
@@ -5414,7 +5411,6 @@ int spider_oracle_share::discover_table_structure(
|
|||||||
DBUG_PRINT("info",("spider this=%p", this));
|
DBUG_PRINT("info",("spider this=%p", this));
|
||||||
DBUG_RETURN(HA_ERR_WRONG_COMMAND);
|
DBUG_RETURN(HA_ERR_WRONG_COMMAND);
|
||||||
}
|
}
|
||||||
#endif
|
|
||||||
|
|
||||||
spider_oracle_handler::spider_oracle_handler(
|
spider_oracle_handler::spider_oracle_handler(
|
||||||
ha_spider *spider,
|
ha_spider *spider,
|
||||||
|
@@ -272,7 +272,6 @@ public:
|
|||||||
longlong pos
|
longlong pos
|
||||||
);
|
);
|
||||||
int get_errno();
|
int get_errno();
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
int fetch_columns_for_discover_table_structure(
|
int fetch_columns_for_discover_table_structure(
|
||||||
spider_string *str,
|
spider_string *str,
|
||||||
CHARSET_INFO *access_charset
|
CHARSET_INFO *access_charset
|
||||||
@@ -286,7 +285,6 @@ public:
|
|||||||
SPIDER_SHARE *spider_share,
|
SPIDER_SHARE *spider_share,
|
||||||
CHARSET_INFO *access_charset
|
CHARSET_INFO *access_charset
|
||||||
);
|
);
|
||||||
#endif
|
|
||||||
/* for oracle */
|
/* for oracle */
|
||||||
int set_column_info();
|
int set_column_info();
|
||||||
};
|
};
|
||||||
@@ -558,13 +556,11 @@ public:
|
|||||||
int *table_name_pos
|
int *table_name_pos
|
||||||
);
|
);
|
||||||
bool need_change_db_table_name();
|
bool need_change_db_table_name();
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
int discover_table_structure(
|
int discover_table_structure(
|
||||||
SPIDER_TRX *trx,
|
SPIDER_TRX *trx,
|
||||||
SPIDER_SHARE *spider_share,
|
SPIDER_SHARE *spider_share,
|
||||||
spider_string *str
|
spider_string *str
|
||||||
);
|
);
|
||||||
#endif
|
|
||||||
private:
|
private:
|
||||||
int create_table_names_str();
|
int create_table_names_str();
|
||||||
void free_table_names_str();
|
void free_table_names_str();
|
||||||
|
@@ -6633,9 +6633,7 @@ int spider_db_init(
|
|||||||
spider_hton->flush_logs = spider_flush_logs;
|
spider_hton->flush_logs = spider_flush_logs;
|
||||||
spider_hton->commit = spider_commit;
|
spider_hton->commit = spider_commit;
|
||||||
spider_hton->rollback = spider_rollback;
|
spider_hton->rollback = spider_rollback;
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
spider_hton->discover_table_structure = spider_discover_table_structure;
|
spider_hton->discover_table_structure = spider_discover_table_structure;
|
||||||
#endif
|
|
||||||
if (spider_param_support_xa())
|
if (spider_param_support_xa())
|
||||||
{
|
{
|
||||||
spider_hton->prepare = spider_xa_prepare;
|
spider_hton->prepare = spider_xa_prepare;
|
||||||
@@ -8582,7 +8580,6 @@ double spider_rand(
|
|||||||
DBUG_RETURN(my_rnd(&rand));
|
DBUG_RETURN(my_rnd(&rand));
|
||||||
}
|
}
|
||||||
|
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
int spider_discover_table_structure_internal(
|
int spider_discover_table_structure_internal(
|
||||||
SPIDER_TRX *trx,
|
SPIDER_TRX *trx,
|
||||||
SPIDER_SHARE *spider_share,
|
SPIDER_SHARE *spider_share,
|
||||||
@@ -8948,7 +8945,6 @@ int spider_discover_table_structure(
|
|||||||
str.length());
|
str.length());
|
||||||
DBUG_RETURN(error_num);
|
DBUG_RETURN(error_num);
|
||||||
}
|
}
|
||||||
#endif
|
|
||||||
|
|
||||||
int spider_create_spider_object_for_share(
|
int spider_create_spider_object_for_share(
|
||||||
SPIDER_TRX *trx,
|
SPIDER_TRX *trx,
|
||||||
|
@@ -730,7 +730,6 @@ double spider_rand(
|
|||||||
uint32 rand_source
|
uint32 rand_source
|
||||||
);
|
);
|
||||||
|
|
||||||
#ifdef SPIDER_HAS_DISCOVER_TABLE_STRUCTURE
|
|
||||||
int spider_discover_table_structure_internal(
|
int spider_discover_table_structure_internal(
|
||||||
SPIDER_TRX *trx,
|
SPIDER_TRX *trx,
|
||||||
SPIDER_SHARE *spider_share,
|
SPIDER_SHARE *spider_share,
|
||||||
@@ -743,7 +742,6 @@ int spider_discover_table_structure(
|
|||||||
TABLE_SHARE *share,
|
TABLE_SHARE *share,
|
||||||
HA_CREATE_INFO *info
|
HA_CREATE_INFO *info
|
||||||
);
|
);
|
||||||
#endif
|
|
||||||
|
|
||||||
int spider_create_spider_object_for_share(
|
int spider_create_spider_object_for_share(
|
||||||
SPIDER_TRX *trx,
|
SPIDER_TRX *trx,
|
||||||
|
Reference in New Issue
Block a user