File tree Expand file tree Collapse file tree 2 files changed +6
-14
lines changed Expand file tree Collapse file tree 2 files changed +6
-14
lines changed Original file line number Diff line number Diff line change @@ -10136,14 +10136,6 @@ void init_server_psi_keys(void)
10136
10136
count= array_elements (com_statement_info);
10137
10137
mysql_statement_register (category, com_statement_info, count);
10138
10138
10139
- #ifdef WITH_WSREP /* WSREP AFTER SE */
10140
- if (wsrep_recovery)
10141
- {
10142
- select_thread_in_use= 0 ;
10143
- wsrep_recover ();
10144
- unireg_abort (0 );
10145
- }
10146
- #endif /* WITH_WSREP */
10147
10139
/*
10148
10140
When a new packet is received,
10149
10141
it is instrumented as "statement/com/".
Original file line number Diff line number Diff line change @@ -3244,6 +3244,12 @@ case SQLCOM_PREPARE:
3244
3244
/* So that CREATE TEMPORARY TABLE gets to binlog at commit/rollback */
3245
3245
if (create_info.tmp_table ())
3246
3246
thd->variables .option_bits |= OPTION_KEEP_LOG;
3247
+ #ifdef WITH_WSREP
3248
+ if (!thd->is_current_stmt_binlog_format_row () ||
3249
+ !(create_info.options & HA_LEX_CREATE_TMP_TABLE))
3250
+ WSREP_TO_ISOLATION_BEGIN (create_table->db , create_table->table_name ,
3251
+ NULL )
3252
+ #endif /* WITH_WSREP */
3247
3253
/* regular create */
3248
3254
if (create_info.options & HA_LEX_CREATE_TABLE_LIKE)
3249
3255
{
@@ -3253,12 +3259,6 @@ case SQLCOM_PREPARE:
3253
3259
}
3254
3260
else
3255
3261
{
3256
- #ifdef WITH_WSREP
3257
- if (!thd->is_current_stmt_binlog_format_row () ||
3258
- !(create_info.options & HA_LEX_CREATE_TMP_TABLE))
3259
- WSREP_TO_ISOLATION_BEGIN (create_table->db , create_table->table_name ,
3260
- NULL )
3261
- #endif /* WITH_WSREP */
3262
3262
/* Regular CREATE TABLE */
3263
3263
res= mysql_create_table (thd, create_table,
3264
3264
&create_info, &alter_info);
You can’t perform that action at this time.
0 commit comments