mirror of
https://github.com/MariaDB/server.git
synced 2025-07-30 16:24:05 +03:00
fixed union rexecution bug
This commit is contained in:
@ -5,6 +5,9 @@ SELECT (SELECT 1) UNION SELECT (SELECT 2);
|
|||||||
(SELECT 1)
|
(SELECT 1)
|
||||||
1
|
1
|
||||||
2
|
2
|
||||||
|
SELECT (SELECT (SELECT 0 UNION SELECT 0));
|
||||||
|
(SELECT (SELECT 0 UNION SELECT 0))
|
||||||
|
0
|
||||||
drop table if exists t1,t2,t3,t4,t5,attend,clinic,inscrit;
|
drop table if exists t1,t2,t3,t4,t5,attend,clinic,inscrit;
|
||||||
create table t1 (a int);
|
create table t1 (a int);
|
||||||
create table t2 (a int, b int);
|
create table t2 (a int, b int);
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
|
|
||||||
select (select 2);
|
select (select 2);
|
||||||
SELECT (SELECT 1) UNION SELECT (SELECT 2);
|
SELECT (SELECT 1) UNION SELECT (SELECT 2);
|
||||||
|
SELECT (SELECT (SELECT 0 UNION SELECT 0));
|
||||||
drop table if exists t1,t2,t3,t4,t5,attend,clinic,inscrit;
|
drop table if exists t1,t2,t3,t4,t5,attend,clinic,inscrit;
|
||||||
create table t1 (a int);
|
create table t1 (a int);
|
||||||
create table t2 (a int, b int);
|
create table t2 (a int, b int);
|
||||||
|
@ -945,7 +945,7 @@ void st_select_lex_unit::init_query()
|
|||||||
select_limit_cnt= HA_POS_ERROR;
|
select_limit_cnt= HA_POS_ERROR;
|
||||||
offset_limit_cnt= 0;
|
offset_limit_cnt= 0;
|
||||||
union_option= 0;
|
union_option= 0;
|
||||||
prepared= optimized= 0;
|
prepared= optimized= executed= 0;
|
||||||
item= 0;
|
item= 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -227,8 +227,9 @@ protected:
|
|||||||
select_result *result;
|
select_result *result;
|
||||||
int res;
|
int res;
|
||||||
bool describe, found_rows_for_union,
|
bool describe, found_rows_for_union,
|
||||||
prepared, //prepare phase already performed for UNION (unit)
|
prepared, // prepare phase already performed for UNION (unit)
|
||||||
optimized; // optimize phase already performed for UNION (unit)
|
optimized, // optimize phase already performed for UNION (unit)
|
||||||
|
executed; // already executed
|
||||||
public:
|
public:
|
||||||
/*
|
/*
|
||||||
Pointer to 'last' select or pointer to unit where stored
|
Pointer to 'last' select or pointer to unit where stored
|
||||||
|
@ -199,8 +199,12 @@ int st_select_lex_unit::exec()
|
|||||||
{
|
{
|
||||||
DBUG_ENTER("st_select_lex_unit::exec");
|
DBUG_ENTER("st_select_lex_unit::exec");
|
||||||
SELECT_LEX *lex_select_save= thd->lex.select;
|
SELECT_LEX *lex_select_save= thd->lex.select;
|
||||||
|
|
||||||
if(depended || !item || !item->assigned())
|
if (executed && !depended)
|
||||||
|
DBUG_RETURN(0);
|
||||||
|
executed= 1;
|
||||||
|
|
||||||
|
if (depended || !item || !item->assigned())
|
||||||
{
|
{
|
||||||
if (optimized && item && item->assigned())
|
if (optimized && item && item->assigned())
|
||||||
item->assigned(0); // We will reinit & rexecute unit
|
item->assigned(0); // We will reinit & rexecute unit
|
||||||
|
Reference in New Issue
Block a user