summaryrefslogtreecommitdiff
path: root/storage/spider
diff options
context:
space:
mode:
authorNayuta Yanagisawa <nayuta.yanagisawa@hey.com>2022-01-28 16:08:01 +0900
committerNayuta Yanagisawa <nayuta.yanagisawa@hey.com>2022-02-10 14:58:26 +0900
commit7d4ef290f8056d00670f2853caaa74caa6ee158a (patch)
tree466ff8b6bea1ac71086b28dba5dc2edf20b40d54 /storage/spider
parent4defdb0db56e7beabbfebb8231c83aa686ba1c00 (diff)
downloadmariadb-git-7d4ef290f8056d00670f2853caaa74caa6ee158a.tar.gz
MDEV-27650 Spider: remove #ifdef SPIDER_HAS_GROUP_BY_HANDLER
Diffstat (limited to 'storage/spider')
-rw-r--r--storage/spider/ha_spider.cc6
-rw-r--r--storage/spider/ha_spider.h2
-rw-r--r--storage/spider/spd_conn.cc8
-rw-r--r--storage/spider/spd_db_conn.cc16
-rw-r--r--storage/spider/spd_db_include.h8
-rw-r--r--storage/spider/spd_db_mysql.cc6
-rw-r--r--storage/spider/spd_db_mysql.h6
-rw-r--r--storage/spider/spd_db_oracle.cc6
-rw-r--r--storage/spider/spd_db_oracle.h6
-rw-r--r--storage/spider/spd_group_by_handler.cc2
-rw-r--r--storage/spider/spd_group_by_handler.h2
-rw-r--r--storage/spider/spd_include.h2
-rw-r--r--storage/spider/spd_table.cc6
13 files changed, 0 insertions, 76 deletions
diff --git a/storage/spider/ha_spider.cc b/storage/spider/ha_spider.cc
index fd18743cd8c..cbc68c14cd7 100644
--- a/storage/spider/ha_spider.cc
+++ b/storage/spider/ha_spider.cc
@@ -86,9 +86,7 @@ ha_spider::ha_spider(
sql_kinds = 0;
error_mode = 0;
use_spatial_index = FALSE;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
use_fields = FALSE;
-#endif
dml_inited = FALSE;
use_pre_call = FALSE;
use_pre_action = FALSE;
@@ -152,9 +150,7 @@ ha_spider::ha_spider(
sql_kinds = 0;
error_mode = 0;
use_spatial_index = FALSE;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
use_fields = FALSE;
-#endif
dml_inited = FALSE;
use_pre_call = FALSE;
use_pre_action = FALSE;
@@ -1195,9 +1191,7 @@ int ha_spider::reset()
result_list.set_split_read = FALSE;
result_list.insert_dup_update_pushdown = FALSE;
use_spatial_index = FALSE;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
use_fields = FALSE;
-#endif
error_mode = 0;
DBUG_RETURN(error_num);
}
diff --git a/storage/spider/ha_spider.h b/storage/spider/ha_spider.h
index 64e7b42c686..1cf36890807 100644
--- a/storage/spider/ha_spider.h
+++ b/storage/spider/ha_spider.h
@@ -96,13 +96,11 @@ public:
bool da_status;
bool use_spatial_index;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
uint idx_for_direct_join;
bool use_fields;
spider_fields *fields;
SPIDER_LINK_IDX_CHAIN *link_idx_chain;
SPIDER_LINK_IDX_CHAIN *result_link_idx_chain;
-#endif
/* for mrr */
bool mrr_with_cnt;
diff --git a/storage/spider/spd_conn.cc b/storage/spider/spd_conn.cc
index c936d0ca9c4..1ba9c4edeb7 100644
--- a/storage/spider/spd_conn.cc
+++ b/storage/spider/spd_conn.cc
@@ -1751,7 +1751,6 @@ int spider_set_conn_bg_param(
if (result_list->bgs_phase > 0)
{
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
if (spider->use_fields)
{
SPIDER_LINK_IDX_CHAIN *link_idx_chain;
@@ -1763,7 +1762,6 @@ int spider_set_conn_bg_param(
DBUG_RETURN(error_num);
}
} else {
-#endif
for (
roop_count = spider_conn_link_idx_next(share->link_statuses,
spider->conn_link_idx, -1, share->link_count,
@@ -1778,9 +1776,7 @@ int spider_set_conn_bg_param(
if ((error_num = spider_create_conn_thread(spider->conns[roop_count])))
DBUG_RETURN(error_num);
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
}
-#endif
}
DBUG_RETURN(0);
}
@@ -2222,9 +2218,7 @@ int spider_bg_conn_search(
conn->bg_target = spider;
conn->link_idx = link_idx;
conn->bg_discard_result = discard_result;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
conn->link_idx_chain = spider->link_idx_chain;
-#endif
pthread_mutex_lock(&conn->bg_conn_sync_mutex);
pthread_cond_signal(&conn->bg_conn_cond);
pthread_mutex_unlock(&conn->bg_conn_mutex);
@@ -2366,9 +2360,7 @@ int spider_bg_conn_search(
conn->bg_target = spider;
conn->link_idx = link_idx;
conn->bg_discard_result = discard_result;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
conn->link_idx_chain = spider->link_idx_chain;
-#endif
result_list->bgs_working = TRUE;
conn->bg_search = TRUE;
if (with_lock)
diff --git a/storage/spider/spd_db_conn.cc b/storage/spider/spd_db_conn.cc
index 3c6c6ffd10f..47488384d4b 100644
--- a/storage/spider/spd_db_conn.cc
+++ b/storage/spider/spd_db_conn.cc
@@ -2992,16 +2992,12 @@ int spider_db_fetch_table(
DBUG_RETURN(error_num);
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
if (!spider->use_fields)
{
-#endif
if ((error_num = spider_db_append_match_fetch(spider,
spider->ft_first, spider->ft_current, row)))
DBUG_RETURN(error_num);
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
}
-#endif
for (
field = table->field;
@@ -4560,10 +4556,8 @@ int spider_db_seek_next(
(SPIDER_RESULT*) result_list->current);
int roop_start = 0, roop_end = 1, roop_count, lock_mode, link_ok = 0;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
if (!spider->use_fields)
{
-#endif
lock_mode = spider_conn_lock_mode(spider);
if (lock_mode)
{
@@ -4580,13 +4574,10 @@ int spider_db_seek_next(
roop_start = link_idx;
roop_end = link_idx + 1;
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
}
-#endif
if (result_list->bgs_phase > 0)
{
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
if (spider->use_fields)
{
SPIDER_LINK_IDX_CHAIN *link_idx_chain;
@@ -4610,7 +4601,6 @@ int spider_db_seek_next(
}
}
} else {
-#endif
for (roop_count = roop_start; roop_count < roop_end;
roop_count = spider_conn_link_idx_next(share->link_statuses,
spider->conn_link_idx, roop_count, share->link_count,
@@ -4623,9 +4613,7 @@ int spider_db_seek_next(
DBUG_RETURN(error_num);
}
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
}
-#endif
} else {
if (result_list->current == result_list->bgs_current)
{
@@ -4676,7 +4664,6 @@ int spider_db_seek_next(
}
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
if (spider->use_fields)
{
SPIDER_LINK_IDX_CHAIN *link_idx_chain;
@@ -4801,7 +4788,6 @@ int spider_db_seek_next(
}
}
} else {
-#endif
for (roop_count = roop_start; roop_count < roop_end;
roop_count = spider_conn_link_idx_next(share->link_statuses,
spider->conn_link_idx, roop_count, share->link_count,
@@ -4972,9 +4958,7 @@ int spider_db_seek_next(
}
}
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
}
-#endif
} else {
spider->connection_ids[link_idx] = conn->connection_id;
pthread_mutex_assert_not_owner(&conn->mta_conn_mutex);
diff --git a/storage/spider/spd_db_include.h b/storage/spider/spd_db_include.h
index ca6513efa3e..a7003a437f2 100644
--- a/storage/spider/spd_db_include.h
+++ b/storage/spider/spd_db_include.h
@@ -805,7 +805,6 @@ public:
spider_string *to,
String *from
) = 0;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
virtual int append_from_and_tables(
ha_spider *spider,
spider_fields *fields,
@@ -824,7 +823,6 @@ public:
virtual int append_having(
spider_string *str
) = 0;
-#endif
virtual bool tables_on_different_db_are_joinable();
virtual bool socket_has_default_value();
virtual bool database_has_default_value();
@@ -1173,9 +1171,7 @@ public:
ha_spider *spider;
spider_db_share *db_share;
int first_link_idx;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
SPIDER_LINK_IDX_CHAIN *link_idx_chain;
-#endif
bool strict_group_by;
bool no_where_cond;
spider_db_handler(ha_spider *spider, spider_db_share *db_share) :
@@ -1461,13 +1457,11 @@ public:
virtual bool need_lock_before_set_sql_for_exec(
ulong sql_type
) = 0;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
virtual int set_sql_for_exec(
ulong sql_type,
int link_idx,
SPIDER_LINK_IDX_CHAIN *link_idx_chain
) = 0;
-#endif
virtual int set_sql_for_exec(
ulong sql_type,
int link_idx
@@ -1583,7 +1577,6 @@ public:
int link_idx,
ulong sql_type
) = 0;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
virtual int append_from_and_tables_part(
spider_fields *fields,
ulong sql_type
@@ -1630,7 +1623,6 @@ public:
spider_fields *fields,
ulong sql_type
) = 0;
-#endif
virtual bool check_direct_update(
st_select_lex *select_lex,
longlong select_limit,
diff --git a/storage/spider/spd_db_mysql.cc b/storage/spider/spd_db_mysql.cc
index e538142e7ee..bdf96e2850a 100644
--- a/storage/spider/spd_db_mysql.cc
+++ b/storage/spider/spd_db_mysql.cc
@@ -7018,7 +7018,6 @@ int spider_db_mbase_util::append_escaped_util(
DBUG_RETURN(0);
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int spider_db_mbase_util::append_table(
ha_spider *spider,
spider_fields *fields,
@@ -7604,7 +7603,6 @@ int spider_db_mbase_util::append_having(
str->q_append(SPIDER_SQL_HAVING_STR, SPIDER_SQL_HAVING_LEN);
DBUG_RETURN(0);
}
-#endif
bool spider_db_mbase_util::tables_on_different_db_are_joinable()
{
@@ -13811,7 +13809,6 @@ bool spider_mbase_handler::need_lock_before_set_sql_for_exec(
DBUG_RETURN(FALSE);
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int spider_mbase_handler::set_sql_for_exec(
ulong sql_type,
int link_idx,
@@ -13829,7 +13826,6 @@ int spider_mbase_handler::set_sql_for_exec(
}
DBUG_RETURN(0);
}
-#endif
int spider_mbase_handler::set_sql_for_exec(
ulong sql_type,
@@ -15959,7 +15955,6 @@ int spider_mbase_handler::reset_union_table_name(
DBUG_RETURN(0);
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int spider_mbase_handler::append_from_and_tables_part(
spider_fields *fields,
ulong sql_type
@@ -16282,7 +16277,6 @@ int spider_mbase_handler::append_order_by(
}
DBUG_RETURN(0);
}
-#endif
bool spider_mbase_handler::check_direct_update(
st_select_lex *select_lex,
diff --git a/storage/spider/spd_db_mysql.h b/storage/spider/spd_db_mysql.h
index 195229f782f..35655600840 100644
--- a/storage/spider/spd_db_mysql.h
+++ b/storage/spider/spd_db_mysql.h
@@ -143,7 +143,6 @@ public:
spider_string *to,
String *from
);
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int append_table(
ha_spider *spider,
spider_fields *fields,
@@ -196,7 +195,6 @@ public:
int append_having(
spider_string *str
);
-#endif
bool tables_on_different_db_are_joinable();
bool socket_has_default_value();
bool database_has_default_value();
@@ -1395,13 +1393,11 @@ public:
bool need_lock_before_set_sql_for_exec(
ulong sql_type
);
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int set_sql_for_exec(
ulong sql_type,
int link_idx,
SPIDER_LINK_IDX_CHAIN *link_idx_chain
);
-#endif
int set_sql_for_exec(
ulong sql_type,
int link_idx
@@ -1522,7 +1518,6 @@ public:
int link_idx,
ulong sql_type
);
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int append_from_and_tables_part(
spider_fields *fields,
ulong sql_type
@@ -1593,7 +1588,6 @@ public:
bool use_fields,
spider_fields *fields
);
-#endif
bool check_direct_update(
st_select_lex *select_lex,
longlong select_limit,
diff --git a/storage/spider/spd_db_oracle.cc b/storage/spider/spd_db_oracle.cc
index 7b0d9de77e4..3a5e6d77ed1 100644
--- a/storage/spider/spd_db_oracle.cc
+++ b/storage/spider/spd_db_oracle.cc
@@ -4378,7 +4378,6 @@ int spider_db_oracle_util::append_escaped_util(
DBUG_RETURN(0);
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int spider_db_oracle_util::append_from_and_tables(
ha_spider *spider,
spider_fields *fields,
@@ -4496,7 +4495,6 @@ int spider_db_oracle_util::append_having(
str->q_append(SPIDER_SQL_HAVING_STR, SPIDER_SQL_HAVING_LEN);
DBUG_RETURN(0);
}
-#endif
spider_oracle_share::spider_oracle_share(
st_spider_share *share
@@ -10502,7 +10500,6 @@ bool spider_oracle_handler::need_lock_before_set_sql_for_exec(
DBUG_RETURN(FALSE);
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int spider_oracle_handler::set_sql_for_exec(
ulong sql_type,
int link_idx,
@@ -10547,7 +10544,6 @@ int spider_oracle_handler::set_sql_for_exec(
}
DBUG_RETURN(0);
}
-#endif
int spider_oracle_handler::set_sql_for_exec(
ulong sql_type,
@@ -12436,7 +12432,6 @@ int spider_oracle_handler::reset_union_table_name(
DBUG_RETURN(0);
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int spider_oracle_handler::append_from_and_tables_part(
spider_fields *fields,
ulong sql_type
@@ -12765,7 +12760,6 @@ int spider_oracle_handler::append_order_by(
}
DBUG_RETURN(0);
}
-#endif
spider_oracle_copy_table::spider_oracle_copy_table(
spider_oracle_share *db_share
diff --git a/storage/spider/spd_db_oracle.h b/storage/spider/spd_db_oracle.h
index d47bc9f7ea6..5f7f4e8ff1f 100644
--- a/storage/spider/spd_db_oracle.h
+++ b/storage/spider/spd_db_oracle.h
@@ -144,7 +144,6 @@ public:
spider_string *to,
String *from
);
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int append_from_and_tables(
ha_spider *spider,
spider_fields *fields,
@@ -163,7 +162,6 @@ public:
int append_having(
spider_string *str
);
-#endif
};
class spider_db_oracle_row: public spider_db_row
@@ -1264,13 +1262,11 @@ public:
bool need_lock_before_set_sql_for_exec(
ulong sql_type
);
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int set_sql_for_exec(
ulong sql_type,
int link_idx,
SPIDER_LINK_IDX_CHAIN *link_idx_chain
);
-#endif
int set_sql_for_exec(
ulong sql_type,
int link_idx
@@ -1385,7 +1381,6 @@ public:
int link_idx,
ulong sql_type
);
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
int append_from_and_tables_part(
spider_fields *fields,
ulong sql_type
@@ -1456,7 +1451,6 @@ public:
bool use_fields,
spider_fields *fields
);
-#endif
};
class spider_oracle_copy_table: public spider_db_copy_table
diff --git a/storage/spider/spd_group_by_handler.cc b/storage/spider/spd_group_by_handler.cc
index 03b1454211a..f7af55dfb8e 100644
--- a/storage/spider/spd_group_by_handler.cc
+++ b/storage/spider/spd_group_by_handler.cc
@@ -1164,7 +1164,6 @@ int spider_fields::ping_table_mon_from_table(
DBUG_RETURN(error_num);
}
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
spider_group_by_handler::spider_group_by_handler(
THD *thd_arg,
Query *query_arg,
@@ -2124,4 +2123,3 @@ group_by_handler *spider_create_group_by_handler(
query->order_by = NULL;
DBUG_RETURN(group_by_handler);
}
-#endif
diff --git a/storage/spider/spd_group_by_handler.h b/storage/spider/spd_group_by_handler.h
index 09f82168708..c37a97e2db9 100644
--- a/storage/spider/spd_group_by_handler.h
+++ b/storage/spider/spd_group_by_handler.h
@@ -13,7 +13,6 @@
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
class spider_group_by_handler: public group_by_handler
{
Query query;
@@ -41,4 +40,3 @@ group_by_handler *spider_create_group_by_handler(
THD *thd,
Query *query
);
-#endif
diff --git a/storage/spider/spd_include.h b/storage/spider/spd_include.h
index 56958a2daaf..b365bb2be78 100644
--- a/storage/spider/spd_include.h
+++ b/storage/spider/spd_include.h
@@ -501,10 +501,8 @@ typedef struct st_spider_conn
query_id_t connect_error_query_id;
time_t connect_error_time;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
SPIDER_CONN_HOLDER *conn_holder_for_direct_join;
SPIDER_LINK_IDX_CHAIN *link_idx_chain;
-#endif
SPIDER_IP_PORT_CONN *ip_port_conn;
pthread_mutex_t loop_check_mutex;
diff --git a/storage/spider/spd_table.cc b/storage/spider/spd_table.cc
index 615a148f7af..d583fa411ac 100644
--- a/storage/spider/spd_table.cc
+++ b/storage/spider/spd_table.cc
@@ -6652,9 +6652,7 @@ int spider_db_init(
spider_hton->create = spider_create_handler;
spider_hton->drop_database = spider_drop_database;
spider_hton->show_status = spider_show_status;
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
spider_hton->create_group_by = spider_create_group_by_handler;
-#endif
spider_hton->table_options= spider_table_option_list;
if (my_gethwaddr((uchar *) addr))
@@ -7934,13 +7932,11 @@ longlong spider_split_read_param(
DBUG_PRINT("info",("spider bulk_update_mode=%d", bulk_update_mode));
DBUG_PRINT("info",("spider support_bulk_update_sql=%s",
spider->support_bulk_update_sql() ? "TRUE" : "FALSE"));
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
bool inserting =
(
spider->wide_handler->sql_command == SQLCOM_INSERT ||
spider->wide_handler->sql_command == SQLCOM_INSERT_SELECT
);
-#endif
bool updating =
(
spider->wide_handler->sql_command == SQLCOM_UPDATE ||
@@ -7961,12 +7957,10 @@ longlong spider_split_read_param(
DBUG_PRINT("info",("spider replacing=%s", replacing ? "TRUE" : "FALSE"));
TABLE *table = spider->get_table();
if (
-#ifdef SPIDER_HAS_GROUP_BY_HANDLER
(
inserting &&
spider->use_fields
) ||
-#endif
replacing ||
(
(