diff options
Diffstat (limited to 'sql/sql_select.cc')
| -rw-r--r-- | sql/sql_select.cc | 192 |
1 files changed, 121 insertions, 71 deletions
diff --git a/sql/sql_select.cc b/sql/sql_select.cc index c8420d8679c..d482de59110 100644 --- a/sql/sql_select.cc +++ b/sql/sql_select.cc @@ -539,9 +539,10 @@ static void trace_table_dependencies(THD *thd, { TABLE_LIST *table_ref= join_tabs[i].tab_list; Json_writer_object trace_one_table(thd); - trace_one_table.add_table_name(&join_tabs[i]); - trace_one_table.add("row_may_be_null", - (bool)table_ref->table->maybe_null); + trace_one_table. + add_table_name(&join_tabs[i]). + add("row_may_be_null", + (bool)table_ref->table->maybe_null); const table_map map= table_ref->get_map(); DBUG_ASSERT(map < (1ULL << table_count)); for (uint j= 0; j < table_count; j++) @@ -1735,7 +1736,7 @@ JOIN::prepare(TABLE_LIST *tables_init, COND *conds_init, uint og_num, } } - if (thd->trace_started()) + if (unlikely(thd->trace_started())) { Json_writer_object trace_wrapper(thd); opt_trace_print_expanded_query(thd, select_lex, &trace_wrapper); @@ -5478,7 +5479,7 @@ make_join_statistics(JOIN *join, List<TABLE_LIST> &tables_list, } } - if (thd->trace_started()) + if (unlikely(thd->trace_started())) trace_table_dependencies(thd, stat, join->table_count); if (join->conds || outer_join) @@ -5499,7 +5500,7 @@ make_join_statistics(JOIN *join, List<TABLE_LIST> &tables_list, skip_unprefixed_keyparts)) goto error; DBUG_EXECUTE("opt", print_keyuse_array(keyuse_array);); - if (thd->trace_started()) + if (unlikely(thd->trace_started())) print_keyuse_array_for_trace(thd, keyuse_array); } @@ -5948,13 +5949,13 @@ make_join_statistics(JOIN *join, List<TABLE_LIST> &tables_list, delete select; else { - if (thd->trace_started()) + if (unlikely(thd->trace_started())) add_table_scan_values_to_trace(thd, s); } } else { - if (thd->trace_started()) + if (unlikely(thd->trace_started())) add_table_scan_values_to_trace(thd, s); } } @@ -8073,8 +8074,10 @@ best_access_path(JOIN *join, */ records= 1.0; type= JT_FT; - trace_access_idx.add("access_type", join_type_str[type]) - .add("full-text index", keyinfo->name); + if (unlikely(trace_access_idx.trace_started())) + trace_access_idx. + add("access_type", join_type_str[type]). + add("full-text index", keyinfo->name); } else { @@ -8099,8 +8102,10 @@ best_access_path(JOIN *join, DBUG_ASSERT(join->eq_ref_tables & table->map); /* TODO: Adjust cost for covering and clustering key */ type= JT_EQ_REF; - trace_access_idx.add("access_type", join_type_str[type]) - .add("index", keyinfo->name); + if (unlikely(trace_access_idx.trace_started())) + trace_access_idx. + add("access_type", join_type_str[type]). + add("index", keyinfo->name); if (!found_ref && table->opt_range_keys.is_set(key)) tmp= adjust_quick_cost(table->opt_range[key].cost, 1); else @@ -8116,8 +8121,10 @@ best_access_path(JOIN *join, else { type= JT_REF; - trace_access_idx.add("access_type", join_type_str[type]) - .add("index", keyinfo->name); + if (unlikely(trace_access_idx.trace_started())) + trace_access_idx. + add("access_type", join_type_str[type]). + add("index", keyinfo->name); if (!found_ref) { /* We found a const key */ /* @@ -8147,8 +8154,10 @@ best_access_path(JOIN *join, } /* quick_range couldn't use key! */ records= (double) s->records/rec; - trace_access_idx.add("used_range_estimates", false) - .add("reason", "not available"); + if (unlikely(trace_access_idx.trace_started())) + trace_access_idx. + add("used_range_estimates", false). + add("reason", "not available"); } else { @@ -8183,17 +8192,13 @@ best_access_path(JOIN *join, records= (double) table->opt_range[key].rows; trace_access_idx.add("used_range_estimates", "clipped down"); } - else + else if (unlikely(trace_access_idx.trace_started())) { trace_access_idx.add("used_range_estimates", false); if (table->opt_range_keys.is_set(key)) - { trace_access_idx.add("reason", "not better than ref estimates"); - } else - { trace_access_idx.add("reason", "not available"); - } } } /* Limit the number of matched rows */ @@ -8204,8 +8209,10 @@ best_access_path(JOIN *join, else { type = ref_or_null_part ? JT_REF_OR_NULL : JT_REF; - trace_access_idx.add("access_type", join_type_str[type]) - .add("index", keyinfo->name); + if (unlikely(trace_access_idx.trace_started())) + trace_access_idx. + add("access_type", join_type_str[type]). + add("index", keyinfo->name); /* Use as much key-parts as possible and a uniq key is better than a not unique key @@ -8450,15 +8457,23 @@ best_access_path(JOIN *join, } } tmp= COST_ADD(tmp, records_after_filter/TIME_FOR_COMPARE); - trace_access_idx.add("rows", records). - add("found_matching_rows_cost",tmp). - add("startup_cost", startup_cost); + if (unlikely(trace_access_idx.trace_started())) + trace_access_idx. + add("rows", records). + add("found_matching_rows_cost",tmp). + add("startup_cost", startup_cost); tmp= COST_MULT(tmp, record_count); tmp= COST_ADD(tmp, startup_cost); + + if (unlikely(trace_access_idx.trace_started())) + trace_access_idx. + add("rows_after_filter", records_after_filter). + add("cost", tmp); + if (tmp + 0.0001 < best_cost) { - trace_access_idx.add("cost", tmp).add("chosen", true); + trace_access_idx.add("chosen", true); best_cost= tmp; best_records= records; best_key= start_key; @@ -8467,10 +8482,11 @@ best_access_path(JOIN *join, best_filter= filter; best_type= type; } - else if (thd->trace_started()) + else if (unlikely(thd->trace_started())) { - trace_access_idx.add("cost",tmp).add("chosen", false) - .add("cause", cause ? cause : "cost"); + trace_access_idx. + add("chosen", false). + add("cause", cause ? cause : "cost"); } } /* for each key */ records= best_records; @@ -8518,6 +8534,7 @@ best_access_path(JOIN *join, (!(s->table->map & join->outer_join) || join->allowed_outer_join_with_cache)) // (2) { + Json_writer_object trace_access_hash(thd); double refills, cmp_time; /* Estimate the cost of the hash join access to the table */ double rnd_records= matching_candidates_in_table(s, found_constraint, @@ -8566,12 +8583,14 @@ best_access_path(JOIN *join, best_uses_jbuf= TRUE; best_filter= 0; best_type= JT_HASH; - Json_writer_object trace_access_hash(thd); - trace_access_hash.add("type", "hash"); - trace_access_hash.add("index", "hj-key"); - trace_access_hash.add("rows", rnd_records); - trace_access_hash.add("cost", best_cost); - trace_access_hash.add("chosen", true); + if (unlikely(trace_access_hash.trace_started())) + trace_access_hash. + add("type", "hash"). + add("index", "hj-key"). + add("rows", rnd_records). + add("refills", refills). + add("cost", best_cost). + add("chosen", true); } /* @@ -8747,8 +8766,10 @@ best_access_path(JOIN *join, best_filter_cmp_gain= (best_filter ? best_filter->get_cmp_gain(record_count * records) : 0); - trace_access_scan.add("resulting_rows", rnd_records); - trace_access_scan.add("cost", tmp); + if (unlikely(trace_access_scan.trace_started())) + trace_access_scan. + add("resulting_rows", rnd_records). + add("cost", tmp); /* TODO: Document the following if */ if (best_cost == DBL_MAX || @@ -8779,9 +8800,11 @@ best_access_path(JOIN *join, } else { - trace_access_scan.add("type", "scan"); - trace_access_scan.add("chosen", false); - trace_access_scan.add("cause", "cost"); + if (unlikely(trace_access_scan.trace_started())) + trace_access_scan. + add("type", "scan"). + add("chosen", false). + add("cause", "cost"); } /* Update the cost information for the current partial plan */ @@ -10533,10 +10556,11 @@ best_extension_by_limited_search(JOIN *join, current_record_count / TIME_FOR_COMPARE)); - if (unlikely(thd->trace_started())) + if (unlikely(trace_one_table.trace_started())) { - trace_one_table.add("rows_for_plan", current_record_count); - trace_one_table.add("cost_for_plan", current_read_time); + trace_one_table. + add("rows_for_plan", current_record_count). + add("cost_for_plan", current_read_time); } optimize_semi_joins(join, remaining_tables, idx, ¤t_record_count, ¤t_read_time, loose_scan_pos); @@ -12442,8 +12466,10 @@ make_join_select(JOIN *join,SQL_SELECT *select,COND *cond) trace_const_cond.add("condition_on_constant_tables", const_cond); if (const_cond->is_expensive()) { - trace_const_cond.add("evaluated", "false") - .add("cause", "expensive cond"); + if (unlikely(trace_const_cond.trace_started())) + trace_const_cond. + add("evalualted", "false"). + add("cause", "expensive cond"); } else { @@ -12455,8 +12481,10 @@ make_join_select(JOIN *join,SQL_SELECT *select,COND *cond) if (!const_cond_result) { DBUG_PRINT("info",("Found impossible WHERE condition")); - trace_const_cond.add("evaluated", "true") - .add("found", "impossible where"); + if (unlikely(trace_const_cond.trace_started())) + trace_const_cond. + add("evalualted", "true"). + add("found", "impossible where"); join->exec_const_cond= NULL; DBUG_RETURN(1); } @@ -12559,9 +12587,13 @@ make_join_select(JOIN *join,SQL_SELECT *select,COND *cond) tab->table->intersect_keys.is_set(tab->ref.key)))) { /* Range uses longer key; Use this instead of ref on key */ - Json_writer_object ref_to_range(thd); - ref_to_range.add("ref_to_range", true); - ref_to_range.add("cause", "range uses longer key"); + if (unlikely(thd->trace_started())) + { + Json_writer_object ref_to_range(thd); + ref_to_range. + add("ref_to_range", true). + add("cause", "range uses longer key"); + } tab->type=JT_ALL; use_quick_range=1; tab->use_quick=1; @@ -13072,8 +13104,9 @@ make_join_select(JOIN *join,SQL_SELECT *select,COND *cond) continue; Item *const cond = tab->select_cond; Json_writer_object trace_one_table(thd); - trace_one_table.add_table_name(tab); - trace_one_table.add("attached", cond); + trace_one_table. + add_table_name(tab). + add("attached", cond); } } } @@ -18295,8 +18328,11 @@ optimize_cond(JOIN *join, COND *conds, Json_writer_object trace_wrapper(thd); Json_writer_object trace_cond(thd, "condition_processing"); - trace_cond.add("condition", join->conds == conds ? "WHERE" : "HAVING") - .add("original_condition", conds); + + if (unlikely(trace_cond.trace_started())) + trace_cond. + add("condition", join->conds == conds ? "WHERE" : "HAVING"). + add("original_condition", conds); Json_writer_array trace_steps(thd, "steps"); DBUG_EXECUTE("where", print_where(conds, "original", QT_ORDINARY);); @@ -18304,10 +18340,13 @@ optimize_cond(JOIN *join, COND *conds, ignore_on_conds, cond_equal, MY_TEST(flags & OPT_LINK_EQUAL_FIELDS)); DBUG_EXECUTE("where",print_where(conds,"after equal_items", QT_ORDINARY);); + + if (unlikely(thd->trace_started())) { Json_writer_object equal_prop_wrapper(thd); - equal_prop_wrapper.add("transformation", "equality_propagation") - .add("resulting_condition", conds); + equal_prop_wrapper. + add("transformation", "equality_propagation"). + add("resulting_condition", conds); } /* change field = field to field = const for each found field = const */ @@ -18317,20 +18356,24 @@ optimize_cond(JOIN *join, COND *conds, Remove all and-levels where CONST item != CONST item */ DBUG_EXECUTE("where",print_where(conds,"after const change", QT_ORDINARY);); + if (unlikely(thd->trace_started())) { Json_writer_object const_prop_wrapper(thd); - const_prop_wrapper.add("transformation", "constant_propagation") - .add("resulting_condition", conds); + const_prop_wrapper. + add("transformation", "constant_propagation"). + add("resulting_condition", conds); } conds= conds->remove_eq_conds(thd, cond_value, true); if (conds && conds->type() == Item::COND_ITEM && ((Item_cond*) conds)->functype() == Item_func::COND_AND_FUNC) *cond_equal= &((Item_cond_and*) conds)->m_cond_equal; + if (unlikely(thd->trace_started())) { Json_writer_object cond_removal_wrapper(thd); - cond_removal_wrapper.add("transformation", "trivial_condition_removal") - .add("resulting_condition", conds); + cond_removal_wrapper. + add("transformation", "trivial_condition_removal"). + add("resulting_condition", conds); } DBUG_EXECUTE("info",print_where(conds,"after remove", QT_ORDINARY);); } @@ -30008,15 +30051,19 @@ test_if_cheaper_ordering(const JOIN_TAB *tab, ORDER *order, TABLE *table, HA_POS_ERROR; if (is_best_covering && !is_covering) { - possible_key.add("chosen", false); - possible_key.add("cause", "covering index already found"); + if (unlikely(possible_key.trace_started())) + possible_key. + add("chosen", false). + add("cause", "covering index already found"); continue; } if (is_covering && refkey_select_limit < select_limit) { - possible_key.add("chosen", false); - possible_key.add("cause", "ref estimates better"); + if (unlikely(possible_key.trace_started())) + possible_key. + add("chosen", false). + add("cause", "ref estimates better"); continue; } if (table->opt_range_keys.is_set(nr)) @@ -30056,8 +30103,9 @@ test_if_cheaper_ordering(const JOIN_TAB *tab, ORDER *order, TABLE *table, } else { - possible_key.add("usable", false); - possible_key.add("cause", "cost"); + possible_key. + add("usable", false). + add("cause", "cost"); } } else @@ -30071,13 +30119,15 @@ test_if_cheaper_ordering(const JOIN_TAB *tab, ORDER *order, TABLE *table, { if (keys.is_set(nr)) { - possible_key.add("can_resolve_order", false); - possible_key.add("cause", "order can not be resolved by key"); + possible_key. + add("can_resolve_order", false). + add("cause", "order can not be resolved by key"); } else { - possible_key.add("can_resolve_order", false); - possible_key.add("cause", "not usable index for the query"); + possible_key. + add("can_resolve_order", false). + add("cause", "not usable index for the query"); } } } |