Skip to content

Commit

Permalink
Another fix after the latest rebase of commits for MDEV-28883
Browse files Browse the repository at this point in the history
  • Loading branch information
igorbabaev committed Mar 16, 2023
1 parent c22f7e8 commit e2e3524
Show file tree
Hide file tree
Showing 4 changed files with 13 additions and 8 deletions.
6 changes: 2 additions & 4 deletions mysql-test/main/derived.result
Original file line number Diff line number Diff line change
Expand Up @@ -1593,8 +1593,7 @@ where a = ( select * from (select a from t1) dt where dt.a > 5)
returning pk, a;
id select_type table type possible_keys key key_len ref rows Extra
1 PRIMARY t1 ALL NULL NULL NULL NULL 3 Using where
2 SUBQUERY <derived3> ALL NULL NULL NULL NULL 3 Using where
3 DERIVED t1 ALL NULL NULL NULL NULL 3 Using where
2 SUBQUERY t1 ALL NULL NULL NULL NULL 3 Using where
delete from t1
where a = ( select * from (select a from t1) dt where dt.a > 5)
returning pk, a;
Expand Down Expand Up @@ -1633,8 +1632,7 @@ where a <> ( select * from (select a from t1) dt where dt.a > 7)
order by a limit 2;
id select_type table type possible_keys key key_len ref rows Extra
1 PRIMARY t1 ALL NULL NULL NULL NULL 4 Using where; Using filesort
2 SUBQUERY <derived3> ALL NULL NULL NULL NULL 4 Using where
3 DERIVED t1 ALL NULL NULL NULL NULL 4 Using where
2 SUBQUERY t1 ALL NULL NULL NULL NULL 4 Using where
delete from t1
where a <> ( select * from (select a from t1) dt where dt.a > 7)
order by a limit 2;
Expand Down
6 changes: 3 additions & 3 deletions sql/sql_base.cc
Original file line number Diff line number Diff line change
Expand Up @@ -1205,7 +1205,7 @@ TABLE_LIST* find_dup_table(THD *thd, TABLE_LIST *table, TABLE_LIST *table_list,
if (thd->lex->sql_command == SQLCOM_UPDATE)
{
Sql_cmd_update *cmd= (Sql_cmd_update *) (thd->lex->m_sql_cmd);
if (cmd->is_multitable())
if (cmd->is_multitable() || derived->derived->outer_select())
materialize= false;
else if (!cmd->processing_as_multitable_update_prohibited(thd))
{
Expand All @@ -1216,9 +1216,9 @@ TABLE_LIST* find_dup_table(THD *thd, TABLE_LIST *table, TABLE_LIST *table_list,
else if (thd->lex->sql_command == SQLCOM_DELETE)
{
Sql_cmd_delete *cmd= (Sql_cmd_delete *) (thd->lex->m_sql_cmd);
if (cmd->is_multitable())
if (cmd->is_multitable() || derived->derived->outer_select())
materialize= false;
if (!cmd->processing_as_multitable_delete_prohibited(thd))
else if (!cmd->processing_as_multitable_delete_prohibited(thd))
{
cmd->set_as_multitable();
materialize= false;
Expand Down
2 changes: 2 additions & 0 deletions sql/sql_delete.cc
Original file line number Diff line number Diff line change
Expand Up @@ -1507,7 +1507,9 @@ bool Sql_cmd_delete::precheck(THD *thd)
return true;
}

#ifdef WITH_WSREP
WSREP_SYNC_WAIT(thd, WSREP_SYNC_WAIT_BEFORE_UPDATE_DELETE);
#endif

return false;

Expand Down
7 changes: 6 additions & 1 deletion sql/sql_update.cc
Original file line number Diff line number Diff line change
Expand Up @@ -2827,7 +2827,10 @@ bool multi_update::send_eof()

bool Sql_cmd_update::processing_as_multitable_update_prohibited(THD *thd)
{
return false;
SELECT_LEX *const select_lex = thd->lex->first_select_lex();
return
(select_lex->order_list.elements &&
select_lex->limit_params.select_limit);
}


Expand All @@ -2851,7 +2854,9 @@ bool Sql_cmd_update::precheck(THD *thd)
return true;
}

#ifdef WITH_WSREP
WSREP_SYNC_WAIT(thd, WSREP_SYNC_WAIT_BEFORE_UPDATE_DELETE);
#endif

return false;

Expand Down

0 comments on commit e2e3524

Please sign in to comment.