test/cetus
1
0
Fork 0
mirror of https://gitee.com/wangbin579/cetus.git synced 2024-11-29 18:37:36 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix more join problems for partition mode

Browse Source
This commit is contained in:
lazio579 2019-01-17 12:02:22 +08:00
parent d0175857eb
commit 76bc1e1692
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
plugins/shard/sharding-parser.c
View File

@ -945,6 +945,18 @@ dup_groups(sql_src_item_t *table, GPtrArray *groups)
}
}
static void
dup_groups_for_partition(sql_src_list_t *sources, GPtrArray *groups)
{
int i;
for (i = 0; i < sources->len; ++i) {
sql_src_item_t *src = g_ptr_array_index(sources, i);
if (src->groups == NULL || src->groups->len == 0) {
dup_groups(src, groups);
}
}
}
static int
routing_select(sql_context_t *context, const sql_select_t *select,
char *default_db, guint32 fixture, query_stats_t *stats, GPtrArray *groups /* out */, int partition_mode)
@ -970,7 +982,7 @@ routing_select(sql_context_t *context, const sql_select_t *select,
}
shard_conf_get_table_groups(groups, db, table);
if (partition_mode) {
dup_groups(src, groups);
dup_groups_for_partition(sources, groups);
}
g_ptr_array_free(sharding_tables, TRUE);
return USE_ALL_SHARDINGS;
@ -1081,6 +1093,9 @@ routing_select(sql_context_t *context, const sql_select_t *select,
g_ptr_array_free(sharding_tables, TRUE);
shard_conf_get_table_groups(groups, db, shard_table->table_name);
stats->com_select_bad_key += 1;
if (partition_mode) {
dup_groups_for_partition(sources, groups);
}
return USE_ALL_SHARDINGS;
}
partitions_get_group_names(partitions, groups);