test/cetus
1
0
Fork 0
mirror of https://gitee.com/wangbin579/cetus.git synced 2024-12-02 03:47:41 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix xa for partition

Browse Source
This commit is contained in:
lazio579 2019-01-25 18:17:57 +08:00
parent c47251c25c
commit a6e2da4b8a
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/shard/shard-plugin.c
View File

@ -1605,11 +1605,13 @@ proxy_add_server_connection_array(network_mysqld_con *con, int *server_unavailab
GString *super_group; GString *super_group;
if (con->srv->is_partition_mode) { if (con->srv->is_partition_mode) {
shard_plugin_con_t *st = con->plugin_con_state;
sql_context_t *context = st->sql_context;
super_group = partition_get_super_group(); super_group = partition_get_super_group();
last_group = NULL; last_group = NULL;
groups = 0; groups = 0;
if (plan->groups->len > 1) { if (plan->groups->len > 1) {
if (!con->is_read_ro_server_allowed) { if (context->stmt_type != STMT_SELECT) {
con->partition_dist_tran = 1; con->partition_dist_tran = 1;
} }
} }