diff options
author | unknown <timour@askmonty.org> | 2011-07-18 23:45:38 +0300 |
---|---|---|
committer | unknown <timour@askmonty.org> | 2011-07-18 23:45:38 +0300 |
commit | c9e236828e3e00a29abf4865ec0a852d3754ec0c (patch) | |
tree | df9e07660bff4def0693352a1c7b3035d508b4a6 /sql | |
parent | cc0195d6a1e603c3ebef91af16a1e1c33dff4a2e (diff) | |
download | mariadb-git-c9e236828e3e00a29abf4865ec0a852d3754ec0c.tar.gz |
Fix bug lp:782305
Analysis:
Both the wrong result and the valgrind warning were a result
of incomplete cleanup of the MIN/MAX subquery rewrite. At the
first execution of the query, the non-aggregate subquery is
transformed into an aggregate MIN/MAX subquery. During the
fix_fields phase of the MIN/MAX function, it sets the property
st_select_lex::with_sum_func to true.
The second execution of the query finds this flag to be ON.
When optimization reaches the same MIN/MAX subquery
transformation, it tests if the subquery is an aggregate or not.
Since select_lex->with_sum_func == true from the previous
execution, the transformation executes the second branch that
handles aggregate subqueries. This substitutes the subquery
Item into a Item_maxmin_subselect. At the same time elsewhere
it is assumed that the subquery Item is of type
Item_allany_subselect. Ultimately this results in casting the
actual object to the wrong class, and calling the wrong
any_value() method from empty_underlying_subquery().
Solution:
Cleanup the st_select_lex::with_sum_func property in the case
when the MIN/MAX transformation was performed for a non-aggregate
subquery, so that the transformation can be repeated.
Diffstat (limited to 'sql')
-rw-r--r-- | sql/item_subselect.cc | 38 | ||||
-rw-r--r-- | sql/item_subselect.h | 6 | ||||
-rw-r--r-- | sql/opt_subselect.cc | 2 |
3 files changed, 37 insertions, 9 deletions
diff --git a/sql/item_subselect.cc b/sql/item_subselect.cc index 4379483a519..94172678974 100644 --- a/sql/item_subselect.cc +++ b/sql/item_subselect.cc @@ -167,6 +167,23 @@ void Item_in_subselect::cleanup() DBUG_VOID_RETURN; } + +void Item_allany_subselect::cleanup() +{ + /* + The MAX/MIN transformation through injection is reverted through the + change_item_tree() mechanism. Revert the select_lex object of the + query to its initial state. + */ + for (SELECT_LEX *sl= unit->first_select(); + sl; sl= sl->next_select()) + if (in_strategy & SUBS_MAXMIN_INJECTED) + sl->with_sum_func= false; + Item_in_subselect::cleanup(); + +} + + Item_subselect::~Item_subselect() { DBUG_ENTER("Item_subselect::~Item_subselect"); @@ -1566,7 +1583,7 @@ Item_in_subselect::single_value_transformer(JOIN *join) bool Item_allany_subselect::transform_into_max_min(JOIN *join) { DBUG_ENTER("Item_allany_subselect::transform_into_max_min"); - if (!(in_strategy & SUBS_MAXMIN)) + if (!(in_strategy & (SUBS_MAXMIN_INJECTED | SUBS_MAXMIN_ENGINE))) DBUG_RETURN(false); Item **place= optimizer->arguments() + 1; THD *thd= join->thd; @@ -1626,6 +1643,12 @@ bool Item_allany_subselect::transform_into_max_min(JOIN *join) if (join->prepare_stage2()) DBUG_RETURN(true); subs= new Item_singlerow_subselect(select_lex); + + /* + Remove other strategies if any (we already changed the query and + can't apply other strategy). + */ + in_strategy= SUBS_MAXMIN_INJECTED; } else { @@ -1633,6 +1656,11 @@ bool Item_allany_subselect::transform_into_max_min(JOIN *join) subs= item= new Item_maxmin_subselect(thd, this, select_lex, func->l_op()); if (upper_item) upper_item->set_sub_test(item); + /* + Remove other strategies if any (we already changed the query and + can't apply other strategy). + */ + in_strategy= SUBS_MAXMIN_ENGINE; } /* fix fields is already called for left expression */ subs= func->create(left_expr, subs); @@ -1643,11 +1671,6 @@ bool Item_allany_subselect::transform_into_max_min(JOIN *join) select_lex->master_unit()->uncacheable&= ~UNCACHEABLE_DEPENDENT_INJECTED; select_lex->uncacheable&= ~UNCACHEABLE_DEPENDENT_INJECTED; - /* - Remove other strategies if there was (we already changed the query and - can't apply other strategy). - */ - in_strategy= SUBS_MAXMIN; DBUG_RETURN(false); } @@ -2540,7 +2563,8 @@ bool Item_allany_subselect::select_transformer(JOIN *join) { DBUG_ENTER("Item_allany_subselect::select_transformer"); - DBUG_ASSERT((in_strategy & ~(SUBS_MAXMIN | SUBS_IN_TO_EXISTS)) == 0); + DBUG_ASSERT((in_strategy & ~(SUBS_MAXMIN_INJECTED | SUBS_MAXMIN_ENGINE | + SUBS_IN_TO_EXISTS)) == 0); in_strategy|= SUBS_IN_TO_EXISTS; if (upper_item) upper_item->show= 1; diff --git a/sql/item_subselect.h b/sql/item_subselect.h index a192bb48f5c..5eb24bd311e 100644 --- a/sql/item_subselect.h +++ b/sql/item_subselect.h @@ -366,7 +366,10 @@ TABLE_LIST * const NO_JOIN_NEST=(TABLE_LIST*)0x1; #define SUBS_PARTIAL_MATCH_ROWID_MERGE 8 #define SUBS_PARTIAL_MATCH_TABLE_SCAN 16 /* ALL/ANY will be transformed with max/min optimization */ -#define SUBS_MAXMIN 32 +/* The subquery has not aggregates, transform it into a MAX/MIN query. */ +#define SUBS_MAXMIN_INJECTED 32 +/* The subquery has aggregates, use a special max/min subselect engine. */ +#define SUBS_MAXMIN_ENGINE 64 /** @@ -555,6 +558,7 @@ public: Item_allany_subselect(Item * left_expr, chooser_compare_func_creator fc, st_select_lex *select_lex, bool all); + void cleanup(); // only ALL subquery has upper not subs_type substype() { return all?ALL_SUBS:ANY_SUBS; } bool select_transformer(JOIN *join); diff --git a/sql/opt_subselect.cc b/sql/opt_subselect.cc index d94e166b32f..5e4be21e449 100644 --- a/sql/opt_subselect.cc +++ b/sql/opt_subselect.cc @@ -466,7 +466,7 @@ int check_and_do_in_subquery_rewrites(JOIN *join) /* Check if max/min optimization applicable */ if (allany_subs) allany_subs->in_strategy|= (allany_subs->is_maxmin_applicable(join) ? - SUBS_MAXMIN : + (SUBS_MAXMIN_INJECTED | SUBS_MAXMIN_ENGINE) : SUBS_IN_TO_EXISTS); /* |