1
0
mirror of https://github.com/MariaDB/server.git synced 2025-08-01 03:47:19 +03:00

MDEV-26831 fallout: fix problems of name resolution cache

- Avoid passing real field cache as a parameter when we check for duplicates.

- Correct cache cleanup (cached field number also have to be reset).

- Name resolution cache simple test added.
This commit is contained in:
Oleksandr Byelkin
2022-11-25 12:54:24 +01:00
parent 7bdd878ae4
commit a6a906d766
3 changed files with 87 additions and 4 deletions

View File

@ -0,0 +1,25 @@
connect con1,localhost,root;
create table t1 (a int, b int);
create table t2 (c int, d int);
create view v1 as select c+1 as e, d+1 as f from t2;
SET DEBUG_SYNC= 'table_field_cached SIGNAL in_sync WAIT_FOR go';
prepare stmt1 from "select a from t1";
execute stmt1;
connection default;
SET DEBUG_SYNC= 'now WAIT_FOR in_sync';
SET DEBUG_SYNC= 'now SIGNAL go';
connection con1;
a
SET DEBUG_SYNC= 'table_field_cached SIGNAL in_sync WAIT_FOR go';
prepare stmt1 from "select e from v1";
execute stmt1;
connection default;
SET DEBUG_SYNC= 'now WAIT_FOR in_sync';
SET DEBUG_SYNC= 'now SIGNAL go';
connection con1;
e
connection default;
disconnect con1;
SET DEBUG_SYNC = 'RESET';
drop view v1;
drop table t1,t2;

View File

@ -0,0 +1,36 @@
source include/have_debug_sync.inc;
connect con1,localhost,root;
create table t1 (a int, b int);
create table t2 (c int, d int);
create view v1 as select c+1 as e, d+1 as f from t2;
SET DEBUG_SYNC= 'table_field_cached SIGNAL in_sync WAIT_FOR go';
prepare stmt1 from "select a from t1";
--send execute stmt1
connection default;
SET DEBUG_SYNC= 'now WAIT_FOR in_sync';
SET DEBUG_SYNC= 'now SIGNAL go';
connection con1;
--reap
SET DEBUG_SYNC= 'table_field_cached SIGNAL in_sync WAIT_FOR go';
prepare stmt1 from "select e from v1";
--send execute stmt1
connection default;
SET DEBUG_SYNC= 'now WAIT_FOR in_sync';
SET DEBUG_SYNC= 'now SIGNAL go';
connection con1;
--reap
connection default;
disconnect con1;
SET DEBUG_SYNC = 'RESET';
drop view v1;
drop table t1,t2;

View File

@ -6037,7 +6037,10 @@ find_field_in_table(THD *thd, TABLE *table, const char *name, size_t length,
if (cached_field_index < table->s->fields && if (cached_field_index < table->s->fields &&
!my_strcasecmp(system_charset_info, !my_strcasecmp(system_charset_info,
table->field[cached_field_index]->field_name.str, name)) table->field[cached_field_index]->field_name.str, name))
{
field= table->field[cached_field_index]; field= table->field[cached_field_index];
DEBUG_SYNC(thd, "table_field_cached");
}
else else
{ {
LEX_CSTRING fname= {name, length}; LEX_CSTRING fname= {name, length};
@ -6485,6 +6488,13 @@ find_field_in_tables(THD *thd, Item_ident *item,
if (last_table) if (last_table)
last_table= last_table->next_name_resolution_table; last_table= last_table->next_name_resolution_table;
uint fake_index_for_duplicate_search= NO_CACHED_FIELD_INDEX;
/*
For the field search it will point to field cache, but for duplicate
search it will point to fake_index_for_duplicate_search (no cache
present).
*/
uint *current_cache= &(item->cached_field_index);
for (; cur_table != last_table ; for (; cur_table != last_table ;
cur_table= cur_table->next_name_resolution_table) cur_table= cur_table->next_name_resolution_table)
{ {
@ -6494,7 +6504,7 @@ find_field_in_tables(THD *thd, Item_ident *item,
SQLCOM_SHOW_FIELDS) SQLCOM_SHOW_FIELDS)
? false : check_privileges, ? false : check_privileges,
allow_rowid, allow_rowid,
&(item->cached_field_index), current_cache,
register_tree_change, register_tree_change,
&actual_table); &actual_table);
if (cur_field) if (cur_field)
@ -6509,7 +6519,7 @@ find_field_in_tables(THD *thd, Item_ident *item,
item->name.str, db, table_name, ref, item->name.str, db, table_name, ref,
false, false,
allow_rowid, allow_rowid,
&(item->cached_field_index), current_cache,
register_tree_change, register_tree_change,
&actual_table); &actual_table);
if (cur_field) if (cur_field)
@ -6526,8 +6536,19 @@ find_field_in_tables(THD *thd, Item_ident *item,
Store the original table of the field, which may be different from Store the original table of the field, which may be different from
cur_table in the case of NATURAL/USING join. cur_table in the case of NATURAL/USING join.
*/ */
item->cached_table= (!actual_table->cacheable_table || found) ? if (actual_table->cacheable_table /*(1)*/ && !found /*(2)*/)
0 : actual_table; {
/*
We have just found a field allowed to cache (1) and
it is not dublicate search (2).
*/
item->cached_table= actual_table;
}
else
{
item->cached_table= NULL;
item->cached_field_index= NO_CACHED_FIELD_INDEX;
}
DBUG_ASSERT(thd->where); DBUG_ASSERT(thd->where);
/* /*
@ -6546,6 +6567,7 @@ find_field_in_tables(THD *thd, Item_ident *item,
return (Field*) 0; return (Field*) 0;
} }
found= cur_field; found= cur_field;
current_cache= &fake_index_for_duplicate_search;
} }
} }