Skip to content

M
MariaDB
Commit b3ab3105 authored by Monty's avatar Monty
Browse files
Options

Removed double calls to records_in_range from distinct and group by 

Fixed by moving testing of get_best_group_min_max() after range testing.
parent f36ca142
Hide whitespace changes
Inline Side-by-side
Showing with 140 additions and 118 deletions
mysql-test/main/opt_trace.result
View file @ b3ab3105
...@@ -1387,6 +1387,13 @@ EXPLAIN SELECT MIN(d) FROM t1 where b=2 and c=3 group by a { ...@@ -1387,6 +1387,13 @@ EXPLAIN SELECT MIN(d) FROM t1 where b=2 and c=3 group by a {
"chosen": true "chosen": true
}, },
"setup_range_conditions": [], "setup_range_conditions": [],
"analyzing_range_alternatives": {
"range_scan_alternatives": [],
"analyzing_roworder_intersect": {
"cause": "too few roworder scans"
},
"analyzing_index_merge_union": []
},
"group_index_range": { "group_index_range": {
"potential_group_range_indexes": [ "potential_group_range_indexes": [
{ {
...@@ -1411,13 +1418,6 @@ EXPLAIN SELECT MIN(d) FROM t1 where b=2 and c=3 group by a { ...@@ -1411,13 +1418,6 @@ EXPLAIN SELECT MIN(d) FROM t1 where b=2 and c=3 group by a {
"ranges": ["(2,3) <= (b,c) <= (2,3)"], "ranges": ["(2,3) <= (b,c) <= (2,3)"],
"chosen": false, "chosen": false,
"cause": "cost" "cause": "cost"
},
"analyzing_range_alternatives": {
"range_scan_alternatives": [],
"analyzing_roworder_intersect": {
"cause": "too few roworder scans"
},
"analyzing_index_merge_union": []
} }
} }
}, },
...@@ -1598,6 +1598,13 @@ EXPLAIN SELECT id,MIN(a),MAX(a) FROM t1 WHERE a>=20010104e0 GROUP BY id { ...@@ -1598,6 +1598,13 @@ EXPLAIN SELECT id,MIN(a),MAX(a) FROM t1 WHERE a>=20010104e0 GROUP BY id {
"chosen": true "chosen": true
}, },
"setup_range_conditions": [], "setup_range_conditions": [],
"analyzing_range_alternatives": {
"range_scan_alternatives": [],
"analyzing_roworder_intersect": {
"cause": "too few roworder scans"
},
"analyzing_index_merge_union": []
},
"group_index_range": { "group_index_range": {
"potential_group_range_indexes": [ "potential_group_range_indexes": [
{ {
...@@ -1622,13 +1629,6 @@ EXPLAIN SELECT id,MIN(a),MAX(a) FROM t1 WHERE a>=20010104e0 GROUP BY id { ...@@ -1622,13 +1629,6 @@ EXPLAIN SELECT id,MIN(a),MAX(a) FROM t1 WHERE a>=20010104e0 GROUP BY id {
"ranges": ["(2001-01-04) <= (a)"], "ranges": ["(2001-01-04) <= (a)"],
"chosen": false, "chosen": false,
"cause": "cost" "cause": "cost"
},
"analyzing_range_alternatives": {
"range_scan_alternatives": [],
"analyzing_roworder_intersect": {
"cause": "too few roworder scans"
},
"analyzing_index_merge_union": []
} }
} }
}, },
...@@ -1789,6 +1789,13 @@ EXPLAIN SELECT * FROM t1 WHERE a = 20010104e0 GROUP BY id { ...@@ -1789,6 +1789,13 @@ EXPLAIN SELECT * FROM t1 WHERE a = 20010104e0 GROUP BY id {
"chosen": true "chosen": true
}, },
"setup_range_conditions": [], "setup_range_conditions": [],
"analyzing_range_alternatives": {
"range_scan_alternatives": [],
"analyzing_roworder_intersect": {
"cause": "too few roworder scans"
},
"analyzing_index_merge_union": []
},
"group_index_range": { "group_index_range": {
"potential_group_range_indexes": [ "potential_group_range_indexes": [
{ {
...@@ -1813,13 +1820,6 @@ EXPLAIN SELECT * FROM t1 WHERE a = 20010104e0 GROUP BY id { ...@@ -1813,13 +1820,6 @@ EXPLAIN SELECT * FROM t1 WHERE a = 20010104e0 GROUP BY id {
"ranges": ["(2001-01-04) <= (a) <= (2001-01-04)"], "ranges": ["(2001-01-04) <= (a) <= (2001-01-04)"],
"chosen": false, "chosen": false,
"cause": "cost" "cause": "cost"
},
"analyzing_range_alternatives": {
"range_scan_alternatives": [],
"analyzing_roworder_intersect": {
"cause": "too few roworder scans"
},
"analyzing_index_merge_union": []
} }
} }
}, },
...@@ -2031,10 +2031,6 @@ explain select * from t1 where a=1 and b=2 order by c limit 1 { ...@@ -2031,10 +2031,6 @@ explain select * from t1 where a=1 and b=2 order by c limit 1 {
} }
], ],
"setup_range_conditions": [], "setup_range_conditions": [],
"group_index_range": {
"chosen": false,
"cause": "no group by or distinct"
},
"analyzing_range_alternatives": { "analyzing_range_alternatives": {
"range_scan_alternatives": [ "range_scan_alternatives": [
{ {
...@@ -2063,6 +2059,10 @@ explain select * from t1 where a=1 and b=2 order by c limit 1 { ...@@ -2063,6 +2059,10 @@ explain select * from t1 where a=1 and b=2 order by c limit 1 {
}, },
"analyzing_index_merge_union": [] "analyzing_index_merge_union": []
}, },
"group_index_range": {
"chosen": false,
"cause": "no group by or distinct"
},
"chosen_range_access_summary": { "chosen_range_access_summary": {
"range_access_plan": { "range_access_plan": {
"type": "range_scan", "type": "range_scan",
...@@ -2213,10 +2213,6 @@ explain select * from t1 where a=1 and b=2 order by c limit 1 { ...@@ -2213,10 +2213,6 @@ explain select * from t1 where a=1 and b=2 order by c limit 1 {
} }
], ],
"setup_range_conditions": [], "setup_range_conditions": [],
"group_index_range": {
"chosen": false,
"cause": "no group by or distinct"
},
"analyzing_range_alternatives": { "analyzing_range_alternatives": {
"range_scan_alternatives": [ "range_scan_alternatives": [
{ {
...@@ -2235,6 +2231,10 @@ explain select * from t1 where a=1 and b=2 order by c limit 1 { ...@@ -2235,6 +2231,10 @@ explain select * from t1 where a=1 and b=2 order by c limit 1 {
}, },
"analyzing_index_merge_union": [] "analyzing_index_merge_union": []
}, },
"group_index_range": {
"chosen": false,
"cause": "no group by or distinct"
},
"chosen_range_access_summary": { "chosen_range_access_summary": {
"range_access_plan": { "range_access_plan": {
"type": "range_scan", "type": "range_scan",
...@@ -3199,10 +3199,6 @@ explain select * from t1 where pk = 2 and a=5 and b=1 { ...@@ -3199,10 +3199,6 @@ explain select * from t1 where pk = 2 and a=5 and b=1 {
"chosen": true "chosen": true
}, },
"setup_range_conditions": [], "setup_range_conditions": [],
"group_index_range": {
"chosen": false,
"cause": "no group by or distinct"
},
"analyzing_range_alternatives": { "analyzing_range_alternatives": {
"range_scan_alternatives": [ "range_scan_alternatives": [
{ {
...@@ -3271,6 +3267,10 @@ explain select * from t1 where pk = 2 and a=5 and b=1 { ...@@ -3271,6 +3267,10 @@ explain select * from t1 where pk = 2 and a=5 and b=1 {
}, },
"analyzing_index_merge_union": [] "analyzing_index_merge_union": []
}, },
"group_index_range": {
"chosen": false,
"cause": "no group by or distinct"
},
"chosen_range_access_summary": { "chosen_range_access_summary": {
"range_access_plan": { "range_access_plan": {
"type": "range_scan", "type": "range_scan",
...@@ -3681,10 +3681,6 @@ explain delete from t0 where t0.a<3 { ...@@ -3681,10 +3681,6 @@ explain delete from t0 where t0.a<3 {
} }
], ],
"setup_range_conditions": [], "setup_range_conditions": [],
"group_index_range": {
"chosen": false,
"cause": "no join"
},
"analyzing_range_alternatives": { "analyzing_range_alternatives": {
"range_scan_alternatives": [ "range_scan_alternatives": [
{ {
...@@ -3700,6 +3696,10 @@ explain delete from t0 where t0.a<3 { ...@@ -3700,6 +3696,10 @@ explain delete from t0 where t0.a<3 {
], ],
"analyzing_index_merge_union": [] "analyzing_index_merge_union": []
}, },
"group_index_range": {
"chosen": false,
"cause": "no join"
},
"chosen_range_access_summary": { "chosen_range_access_summary": {
"range_access_plan": { "range_access_plan": {
"type": "range_scan", "type": "range_scan",
...@@ -3824,10 +3824,6 @@ explain delete t0,t1 from t0, t1 where t0.a=t1.a and t1.a<3 { ...@@ -3824,10 +3824,6 @@ explain delete t0,t1 from t0, t1 where t0.a=t1.a and t1.a<3 {
"chosen": true "chosen": true
}, },
"setup_range_conditions": [], "setup_range_conditions": [],
"group_index_range": {
"chosen": false,
"cause": "not single_table"
},
"analyzing_range_alternatives": { "analyzing_range_alternatives": {
"range_scan_alternatives": [ "range_scan_alternatives": [
{ {
...@@ -3846,6 +3842,10 @@ explain delete t0,t1 from t0, t1 where t0.a=t1.a and t1.a<3 { ...@@ -3846,6 +3842,10 @@ explain delete t0,t1 from t0, t1 where t0.a=t1.a and t1.a<3 {
}, },
"analyzing_index_merge_union": [] "analyzing_index_merge_union": []
}, },
"group_index_range": {
"chosen": false,
"cause": "not single_table"
},
"chosen_range_access_summary": { "chosen_range_access_summary": {
"range_access_plan": { "range_access_plan": {
"type": "range_scan", "type": "range_scan",
...@@ -3889,10 +3889,6 @@ explain delete t0,t1 from t0, t1 where t0.a=t1.a and t1.a<3 { ...@@ -3889,10 +3889,6 @@ explain delete t0,t1 from t0, t1 where t0.a=t1.a and t1.a<3 {
"chosen": true "chosen": true
}, },
"setup_range_conditions": [], "setup_range_conditions": [],
"group_index_range": {
"chosen": false,
"cause": "not single_table"
},
"analyzing_range_alternatives": { "analyzing_range_alternatives": {
"range_scan_alternatives": [ "range_scan_alternatives": [
{ {
...@@ -3911,6 +3907,10 @@ explain delete t0,t1 from t0, t1 where t0.a=t1.a and t1.a<3 { ...@@ -3911,6 +3907,10 @@ explain delete t0,t1 from t0, t1 where t0.a=t1.a and t1.a<3 {
}, },
"analyzing_index_merge_union": [] "analyzing_index_merge_union": []
}, },
"group_index_range": {
"chosen": false,
"cause": "not single_table"
},
"chosen_range_access_summary": { "chosen_range_access_summary": {
"range_access_plan": { "range_access_plan": {
"type": "range_scan", "type": "range_scan",
......
mysql-test/main/opt_trace_index_merge.result
View file @ b3ab3105
...@@ -93,10 +93,6 @@ explain select * from t1 where a=1 or b=1 { ...@@ -93,10 +93,6 @@ explain select * from t1 where a=1 or b=1 {
} }
], ],
"setup_range_conditions": [], "setup_range_conditions": [],
"group_index_range": {
"chosen": false,
"cause": "no group by or distinct"
},
"analyzing_range_alternatives": { "analyzing_range_alternatives": {
"range_scan_alternatives": [], "range_scan_alternatives": [],
"analyzing_roworder_intersect": { "analyzing_roworder_intersect": {
...@@ -168,6 +164,10 @@ explain select * from t1 where a=1 or b=1 { ...@@ -168,6 +164,10 @@ explain select * from t1 where a=1 or b=1 {
} }
] ]
}, },
"group_index_range": {
"chosen": false,
"cause": "no group by or distinct"
},
"chosen_range_access_summary": { "chosen_range_access_summary": {
"range_access_plan": { "range_access_plan": {
"type": "index_roworder_union", "type": "index_roworder_union",
......
mysql-test/main/opt_trace_index_merge_innodb.result
View file @ b3ab3105
...@@ -108,10 +108,6 @@ explain select * from t1 where pk1 != 0 and key1 = 1 { ...@@ -108,10 +108,6 @@ explain select * from t1 where pk1 != 0 and key1 = 1 {
} }
], ],
"setup_range_conditions": [], "setup_range_conditions": [],
"group_index_range": {
"chosen": false,
"cause": "no group by or distinct"
},
"analyzing_range_alternatives": { "analyzing_range_alternatives": {
"range_scan_alternatives": [ "range_scan_alternatives": [
{ {
...@@ -158,6 +154,10 @@ explain select * from t1 where pk1 != 0 and key1 = 1 { ...@@ -158,6 +154,10 @@ explain select * from t1 where pk1 != 0 and key1 = 1 {
}, },
"analyzing_index_merge_union": [] "analyzing_index_merge_union": []
}, },
"group_index_range": {
"chosen": false,
"cause": "no group by or distinct"
},
"chosen_range_access_summary": { "chosen_range_access_summary": {
"range_access_plan": { "range_access_plan": {
"type": "range_scan", "type": "range_scan",
......
sql/opt_range.cc
View file @ b3ab3105
...@@ -277,7 +277,6 @@ class SEL_TREE :public Sql_alloc ...@@ -277,7 +277,6 @@ class SEL_TREE :public Sql_alloc
pointer to such SEL_TREE instead of NULL) pointer to such SEL_TREE instead of NULL)
*/ */
Mem_root_array<SEL_ARG *, true> keys; Mem_root_array<SEL_ARG *, true> keys;
key_map keys_map; /* bitmask of non-NULL elements in keys */ key_map keys_map; /* bitmask of non-NULL elements in keys */
/* /*
...@@ -426,8 +425,9 @@ static bool sel_trees_must_be_ored(RANGE_OPT_PARAM* param, ...@@ -426,8 +425,9 @@ static bool sel_trees_must_be_ored(RANGE_OPT_PARAM* param,
static int and_range_trees(RANGE_OPT_PARAM *param, static int and_range_trees(RANGE_OPT_PARAM *param,
SEL_TREE *tree1, SEL_TREE *tree2, SEL_TREE *tree1, SEL_TREE *tree2,
SEL_TREE *result); SEL_TREE *result);
static bool remove_nonrange_trees(RANGE_OPT_PARAM *param, SEL_TREE *tree); static bool remove_nonrange_trees(PARAM *param, SEL_TREE *tree);
static void restore_nonrange_trees(RANGE_OPT_PARAM *param, SEL_TREE *tree,
SEL_ARG **backup);
static void print_key_value(String *out, const KEY_PART_INFO *key_part, static void print_key_value(String *out, const KEY_PART_INFO *key_part,
const uchar* key, uint length); const uchar* key, uint length);
static void print_keyparts_name(String *out, const KEY_PART_INFO *key_part, static void print_keyparts_name(String *out, const KEY_PART_INFO *key_part,
...@@ -2621,8 +2621,8 @@ static int fill_used_fields_bitmap(PARAM *param) ...@@ -2621,8 +2621,8 @@ static int fill_used_fields_bitmap(PARAM *param)
TODO TODO
* Change the value returned in quick_condition_rows from a pessimistic * Change the value returned in quick_condition_rows from a pessimistic
estimate to true E(#rows that satisfy table condition). estimate to true E(#rows that satisfy table condition).
(we can re-use some of E(#rows) calcuation code from index_merge/intersection (we can re-use some of E(#rows) calcuation code from
for this) index_merge/intersection for this)
* Check if this function really needs to modify keys_to_use, and change the * Check if this function really needs to modify keys_to_use, and change the
code to pass it by reference if it doesn't. code to pass it by reference if it doesn't.
...@@ -2647,6 +2647,8 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use, ...@@ -2647,6 +2647,8 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use,
uint idx; uint idx;
double scan_time; double scan_time;
Item *notnull_cond= NULL; Item *notnull_cond= NULL;
TABLE_READ_PLAN *best_trp= NULL;
SEL_ARG **backup_keys= 0;
DBUG_ENTER("SQL_SELECT::test_quick_select"); DBUG_ENTER("SQL_SELECT::test_quick_select");
DBUG_PRINT("enter",("keys_to_use: %lu prev_tables: %lu const_tables: %lu", DBUG_PRINT("enter",("keys_to_use: %lu prev_tables: %lu const_tables: %lu",
(ulong) keys_to_use.to_ulonglong(), (ulong) prev_tables, (ulong) keys_to_use.to_ulonglong(), (ulong) prev_tables,
...@@ -2776,7 +2778,7 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use, ...@@ -2776,7 +2778,7 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use,
Json_writer_array trace_keypart(thd, "key_parts"); Json_writer_array trace_keypart(thd, "key_parts");
for (uint part= 0 ; part < n_key_parts ; for (uint part= 0 ; part < n_key_parts ;
part++, key_parts++, key_part_info++) part++, key_parts++, key_part_info++)
{ {
key_parts->key= param.keys; key_parts->key= param.keys;
key_parts->part= part; key_parts->part= part;
key_parts->length= key_part_info->length; key_parts->length= key_part_info->length;
...@@ -2831,8 +2833,6 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use, ...@@ -2831,8 +2833,6 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use,
trace_cov.add("cause", "cost"); trace_cov.add("cause", "cost");
} }
TABLE_READ_PLAN *best_trp= NULL;
TRP_GROUP_MIN_MAX *group_trp= NULL;
double best_read_time= read_time; double best_read_time= read_time;
if (notnull_cond) if (notnull_cond)
...@@ -2869,36 +2869,6 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use, ...@@ -2869,36 +2869,6 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use,
} }
} }
/*
Try to construct a QUICK_GROUP_MIN_MAX_SELECT.
Notice that it can be constructed no matter if there is a range tree.
*/
DBUG_EXECUTE_IF("force_group_by", force_group_by = true; );
if (!only_single_index_range_scan)
group_trp= get_best_group_min_max(&param, tree, best_read_time);
if (group_trp)
{
param.table->quick_condition_rows= MY_MIN(group_trp->records,
head->stat_records());
Json_writer_object grp_summary(thd, "best_group_range_summary");
if (unlikely(thd->trace_started()))
group_trp->trace_basic_info(&param, &grp_summary);
if (group_trp->read_cost < best_read_time || force_group_by)
{
grp_summary.add("chosen", true);
best_trp= group_trp;
best_read_time= best_trp->read_cost;
if (force_group_by)
{
goto force_plan;
}
}
else
grp_summary.add("chosen", false).add("cause", "cost");
}
if (tree) if (tree)
{ {
/* /*
...@@ -2911,6 +2881,10 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use, ...@@ -2911,6 +2881,10 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use,
bool can_build_covering= FALSE; bool can_build_covering= FALSE;
Json_writer_object trace_range(thd, "analyzing_range_alternatives"); Json_writer_object trace_range(thd, "analyzing_range_alternatives");
backup_keys= (SEL_ARG**) alloca(sizeof(backup_keys[0])*param.keys);
memcpy(&backup_keys[0], &tree->keys[0],
sizeof(backup_keys[0])*param.keys);
remove_nonrange_trees(&param, tree); remove_nonrange_trees(&param, tree);
/* Get best 'range' plan and prepare data for making other plans */ /* Get best 'range' plan and prepare data for making other plans */
...@@ -3000,7 +2974,38 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use, ...@@ -3000,7 +2974,38 @@ int SQL_SELECT::test_quick_select(THD *thd, key_map keys_to_use,
} }
} }
force_plan: /*
Try to construct a QUICK_GROUP_MIN_MAX_SELECT.
Notice that it can be constructed no matter if there is a range tree.
*/
DBUG_EXECUTE_IF("force_group_by", force_group_by = true; );
if (!only_single_index_range_scan)
{
TRP_GROUP_MIN_MAX *group_trp;
if (tree)
restore_nonrange_trees(&param, tree, backup_keys);
if ((group_trp= get_best_group_min_max(&param, tree, read_time)))
{
param.table->quick_condition_rows= MY_MIN(group_trp->records,
head->stat_records());
Json_writer_object grp_summary(thd, "best_group_range_summary");
if (unlikely(thd->trace_started()))
group_trp->trace_basic_info(&param, &grp_summary);
if (group_trp->read_cost < best_read_time || force_group_by)
{
grp_summary.add("chosen", true);
best_trp= group_trp;
best_read_time= best_trp->read_cost;
}
else
grp_summary.add("chosen", false).add("cause", "cost");
}
if (tree)
remove_nonrange_trees(&param, tree);
}
thd->mem_root= param.old_root; thd->mem_root= param.old_root;
/* If we got a read plan, create a quick select from it. */ /* If we got a read plan, create a quick select from it. */
...@@ -9417,7 +9422,7 @@ bool sel_trees_must_be_ored(RANGE_OPT_PARAM* param, ...@@ -9417,7 +9422,7 @@ bool sel_trees_must_be_ored(RANGE_OPT_PARAM* param,
1 No tree->keys[] left. 1 No tree->keys[] left.
*/ */
static bool remove_nonrange_trees(RANGE_OPT_PARAM *param, SEL_TREE *tree) static bool remove_nonrange_trees(PARAM *param, SEL_TREE *tree)
{ {
bool res= FALSE; bool res= FALSE;
for (uint i=0; i < param->keys; i++) for (uint i=0; i < param->keys; i++)
...@@ -9427,6 +9432,8 @@ static bool remove_nonrange_trees(RANGE_OPT_PARAM *param, SEL_TREE *tree) ...@@ -9427,6 +9432,8 @@ static bool remove_nonrange_trees(RANGE_OPT_PARAM *param, SEL_TREE *tree)
if (tree->keys[i]->part) if (tree->keys[i]->part)
{ {
tree->keys[i]= NULL; tree->keys[i]= NULL;
/* Mark that records_in_range has not been called */
param->quick_rows[param->real_keynr[i]]= HA_POS_ERROR;
tree->keys_map.clear_bit(i); tree->keys_map.clear_bit(i);
} }
else else
...@@ -9437,6 +9444,23 @@ static bool remove_nonrange_trees(RANGE_OPT_PARAM *param, SEL_TREE *tree) ...@@ -9437,6 +9444,23 @@ static bool remove_nonrange_trees(RANGE_OPT_PARAM *param, SEL_TREE *tree)
} }
/*
Restore nonrange trees to their previous state
*/
static void restore_nonrange_trees(RANGE_OPT_PARAM *param, SEL_TREE *tree,
SEL_ARG **backup_keys)
{
for (uint i=0; i < param->keys; i++)
{
if (backup_keys[i])
{
tree->keys[i]= backup_keys[i];
tree->keys_map.set_bit(i);
}
}
}
/* /*
Build a SEL_TREE for a disjunction out of such trees for the disjuncts Build a SEL_TREE for a disjunction out of such trees for the disjuncts
...@@ -11032,7 +11056,10 @@ ha_rows check_quick_select(PARAM *param, uint idx, bool index_only, ...@@ -11032,7 +11056,10 @@ ha_rows check_quick_select(PARAM *param, uint idx, bool index_only,
ha_rows rows= HA_POS_ERROR; ha_rows rows= HA_POS_ERROR;
uint keynr= param->real_keynr[idx]; uint keynr= param->real_keynr[idx];
DBUG_ENTER("check_quick_select"); DBUG_ENTER("check_quick_select");
/* Range not calculated yet */
param->quick_rows[keynr]= HA_POS_ERROR;
/* Handle cases when we don't have a valid non-empty list of range */ /* Handle cases when we don't have a valid non-empty list of range */
if (!tree) if (!tree)
DBUG_RETURN(HA_POS_ERROR); DBUG_RETURN(HA_POS_ERROR);
...@@ -11108,6 +11135,9 @@ ha_rows check_quick_select(PARAM *param, uint idx, bool index_only, ...@@ -11108,6 +11135,9 @@ ha_rows check_quick_select(PARAM *param, uint idx, bool index_only,
param->table->quick_index_only_costs[keynr]= cost->index_only_cost(); param->table->quick_index_only_costs[keynr]= cost->index_only_cost();
} }
} }
else
param->quick_rows[keynr]= HA_POS_ERROR;
/* Figure out if the key scan is ROR (returns rows in ROWID order) or not */ /* Figure out if the key scan is ROR (returns rows in ROWID order) or not */
enum ha_key_alg key_alg= param->table->key_info[seq.real_keyno].algorithm; enum ha_key_alg key_alg= param->table->key_info[seq.real_keyno].algorithm;
if ((key_alg != HA_KEY_ALG_BTREE) && (key_alg!= HA_KEY_ALG_UNDEF)) if ((key_alg != HA_KEY_ALG_BTREE) && (key_alg!= HA_KEY_ALG_UNDEF))
...@@ -13074,7 +13104,7 @@ cost_group_min_max(TABLE* table, KEY *index_info, uint used_key_parts, ...@@ -13074,7 +13104,7 @@ cost_group_min_max(TABLE* table, KEY *index_info, uint used_key_parts,
@param param Parameter from test_quick_select @param param Parameter from test_quick_select
@param sel_tree Range tree generated by get_mm_tree @param sel_tree Range tree generated by get_mm_tree
@param read_time Best read time so far (=table/index scan time) @param read_time Best read time so far of table or index scan time
@return table read plan @return table read plan
@retval NULL Loose index scan not applicable or mem_root == NULL @retval NULL Loose index scan not applicable or mem_root == NULL
@retval !NULL Loose index scan table read plan @retval !NULL Loose index scan table read plan
...@@ -13105,7 +13135,6 @@ get_best_group_min_max(PARAM *param, SEL_TREE *tree, double read_time) ...@@ -13105,7 +13135,6 @@ get_best_group_min_max(PARAM *param, SEL_TREE *tree, double read_time)
Item_field *item_field; Item_field *item_field;
bool is_agg_distinct; bool is_agg_distinct;
List<Item_field> agg_distinct_flds; List<Item_field> agg_distinct_flds;
DBUG_ENTER("get_best_group_min_max"); DBUG_ENTER("get_best_group_min_max");
Json_writer_object trace_group(thd, "group_index_range"); Json_writer_object trace_group(thd, "group_index_range");
...@@ -13130,8 +13159,6 @@ get_best_group_min_max(PARAM *param, SEL_TREE *tree, double read_time) ...@@ -13130,8 +13159,6 @@ get_best_group_min_max(PARAM *param, SEL_TREE *tree, double read_time)
DBUG_RETURN(NULL); DBUG_RETURN(NULL);
} }
/* Check (SA1,SA4) and store the only MIN/MAX argument - the C attribute.*/
List_iterator<Item> select_items_it(join->fields_list);
is_agg_distinct = is_indexed_agg_distinct(join, &agg_distinct_flds); is_agg_distinct = is_indexed_agg_distinct(join, &agg_distinct_flds);
if ((!join->group_list) && /* Neither GROUP BY nor a DISTINCT query. */ if ((!join->group_list) && /* Neither GROUP BY nor a DISTINCT query. */
...@@ -13143,6 +13170,9 @@ get_best_group_min_max(PARAM *param, SEL_TREE *tree, double read_time) ...@@ -13143,6 +13170,9 @@ get_best_group_min_max(PARAM *param, SEL_TREE *tree, double read_time)
} }
/* Analyze the query in more detail. */ /* Analyze the query in more detail. */
/* Check (SA1,SA4) and store the only MIN/MAX argument - the C attribute.*/
List_iterator<Item> select_items_it(join->fields_list);
if (join->sum_funcs[0]) if (join->sum_funcs[0])
{ {
Item_sum *min_max_item; Item_sum *min_max_item;
...@@ -13570,25 +13600,18 @@ get_best_group_min_max(PARAM *param, SEL_TREE *tree, double read_time) ...@@ -13570,25 +13600,18 @@ get_best_group_min_max(PARAM *param, SEL_TREE *tree, double read_time)
/* Compute the cost of using this index. */ /* Compute the cost of using this index. */
if (tree) if (tree)
{ {
cur_index_tree= tree->keys[cur_param_idx]; if ((cur_index_tree= tree->keys[cur_param_idx]))
/* Check if this range tree can be used for prefix retrieval. */
Cost_estimate dummy_cost;
uint mrr_flags= HA_MRR_USE_DEFAULT_IMPL;
uint mrr_bufsize=0;
bool is_ror_scan= FALSE;
cur_quick_prefix_records= check_quick_select(param, cur_param_idx,
FALSE /*don't care*/,
cur_index_tree, TRUE,
&mrr_flags, &mrr_bufsize,
&dummy_cost, &is_ror_scan);
if (unlikely(cur_index_tree && thd->trace_started()))
{ {
Json_writer_array trace_range(thd, "ranges"); cur_quick_prefix_records= param->quick_rows[cur_index];
if (unlikely(cur_index_tree && thd->trace_started()))
const KEY_PART_INFO *key_part= cur_index_info->key_part; {
trace_ranges(&trace_range, param, cur_param_idx, Json_writer_array trace_range(thd, "ranges");
cur_index_tree, key_part); trace_ranges(&trace_range, param, cur_param_idx,
cur_index_tree, cur_index_info->key_part);
}
} }
else
cur_quick_prefix_records= HA_POS_ERROR;
} }
cost_group_min_max(table, cur_index_info, cur_used_key_parts, cost_group_min_max(table, cur_index_info, cur_used_key_parts,
cur_group_key_parts, tree, cur_index_tree, cur_group_key_parts, tree, cur_index_tree,
...@@ -13995,7 +14018,7 @@ get_sel_arg_for_keypart(Field *field, ...@@ -13995,7 +14018,7 @@ get_sel_arg_for_keypart(Field *field,
last_part [in] Last keypart of the index last_part [in] Last keypart of the index
thd [in] Current thread thd [in] Current thread
key_infix [out] Infix of constants to be used for index lookup key_infix [out] Infix of constants to be used for index lookup
key_infix_len [out] Lenghth of the infix key_infix_len [out] Length of the infix
first_non_infix_part [out] The first keypart after the infix (if any) first_non_infix_part [out] The first keypart after the infix (if any)
DESCRIPTION DESCRIPTION
...@@ -14023,7 +14046,6 @@ get_constant_key_infix(KEY *index_info, SEL_ARG *index_range_tree, ...@@ -14023,7 +14046,6 @@ get_constant_key_infix(KEY *index_info, SEL_ARG *index_range_tree,
uchar *key_infix, uint *key_infix_len, uchar *key_infix, uint *key_infix_len,
KEY_PART_INFO **first_non_infix_part) KEY_PART_INFO **first_non_infix_part)
{ {
SEL_ARG *cur_range;
KEY_PART_INFO *cur_part; KEY_PART_INFO *cur_part;
/* End part for the first loop below. */ /* End part for the first loop below. */
KEY_PART_INFO *end_part= min_max_arg_part ? min_max_arg_part : last_part; KEY_PART_INFO *end_part= min_max_arg_part ? min_max_arg_part : last_part;
...@@ -14032,7 +14054,7 @@ get_constant_key_infix(KEY *index_info, SEL_ARG *index_range_tree, ...@@ -14032,7 +14054,7 @@ get_constant_key_infix(KEY *index_info, SEL_ARG *index_range_tree,
uchar *key_ptr= key_infix; uchar *key_ptr= key_infix;
for (cur_part= first_non_group_part; cur_part != end_part; cur_part++) for (cur_part= first_non_group_part; cur_part != end_part; cur_part++)
{ {
cur_range= NULL; SEL_ARG *cur_range= NULL;
/* /*
Check NGA3: Check NGA3:
1. get_sel_arg_for_keypart gets the range tree for the 'field' and also 1. get_sel_arg_for_keypart gets the range tree for the 'field' and also
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7