mirror of
https://github.com/MariaDB/server.git
synced 2025-08-08 11:22:35 +03:00
Derived tables bug fix .......
This commit is contained in:
@@ -1322,10 +1322,10 @@ SELECT t2.id, t1.label FROM t2 INNER JOIN
|
|||||||
(SELECT t1.id_object as id_object FROM t1 WHERE t1.label LIKE '%test%') AS lbl
|
(SELECT t1.id_object as id_object FROM t1 WHERE t1.label LIKE '%test%') AS lbl
|
||||||
ON (t2.id = lbl.id_object) INNER JOIN t1 ON (t2.id = t1.id_object);
|
ON (t2.id = lbl.id_object) INNER JOIN t1 ON (t2.id = t1.id_object);
|
||||||
id label
|
id label
|
||||||
3382 Fournisseur Test
|
3382 Test
|
||||||
102 Fournisseur Test
|
102 Le Pekin (Test)
|
||||||
1794 Fournisseur Test
|
1794 Test de resto
|
||||||
1822 Fournisseur Test
|
1822 Test 3
|
||||||
3524 Fournisseur Test
|
3524 Societe Test
|
||||||
3525 Fournisseur Test
|
3525 Fournisseur Test
|
||||||
drop table t1,t2;
|
drop table t1,t2;
|
||||||
|
@@ -701,12 +701,20 @@ int ha_myisam::repair(THD *thd, MI_CHECK ¶m, bool optimize)
|
|||||||
void ha_myisam::deactivate_non_unique_index(ha_rows rows)
|
void ha_myisam::deactivate_non_unique_index(ha_rows rows)
|
||||||
{
|
{
|
||||||
MYISAM_SHARE* share = file->s;
|
MYISAM_SHARE* share = file->s;
|
||||||
|
bool do_warning=0;
|
||||||
if (share->state.key_map == ((ulonglong) 1L << share->base.keys)-1)
|
if (share->state.key_map == ((ulonglong) 1L << share->base.keys)-1)
|
||||||
{
|
{
|
||||||
if (!(specialflag & SPECIAL_SAFE_MODE))
|
if (!(specialflag & SPECIAL_SAFE_MODE))
|
||||||
{
|
{
|
||||||
if (rows == HA_POS_ERROR)
|
if (rows == HA_POS_ERROR)
|
||||||
|
{
|
||||||
|
uint orig_update= file->update;
|
||||||
|
file->update ^= HA_STATE_CHANGED;
|
||||||
|
uint check_update= file->update;
|
||||||
mi_extra(file, HA_EXTRA_NO_KEYS, 0);
|
mi_extra(file, HA_EXTRA_NO_KEYS, 0);
|
||||||
|
do_warning= (file->update == check_update) && file->state->records;
|
||||||
|
file->update= orig_update;
|
||||||
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
/*
|
/*
|
||||||
@@ -731,6 +739,10 @@ void ha_myisam::deactivate_non_unique_index(ha_rows rows)
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
enable_activate_all_index=0;
|
enable_activate_all_index=0;
|
||||||
|
if (do_warning)
|
||||||
|
push_warning_printf(current_thd, MYSQL_ERROR::WARN_LEVEL_WARN,
|
||||||
|
ER_ILLEGAL_HA,
|
||||||
|
ER(ER_ILLEGAL_HA), table->table_name);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@@ -789,6 +789,7 @@ TABLE *open_table(THD *thd,const char *db,const char *table_name,
|
|||||||
DBUG_RETURN(0);
|
DBUG_RETURN(0);
|
||||||
}
|
}
|
||||||
table->query_id=thd->query_id;
|
table->query_id=thd->query_id;
|
||||||
|
table->clear_query_id=1;
|
||||||
thd->tmp_table_used= 1;
|
thd->tmp_table_used= 1;
|
||||||
goto reset;
|
goto reset;
|
||||||
}
|
}
|
||||||
@@ -2050,8 +2051,9 @@ bool setup_tables(TABLE_LIST *tables)
|
|||||||
table->keys_in_use_for_query &= ~map;
|
table->keys_in_use_for_query &= ~map;
|
||||||
}
|
}
|
||||||
table->used_keys &= table->keys_in_use_for_query;
|
table->used_keys &= table->keys_in_use_for_query;
|
||||||
if (table_list->shared)
|
if (table_list->shared || table->clear_query_id)
|
||||||
{
|
{
|
||||||
|
table->clear_query_id= 0;
|
||||||
/* Clear query_id that may have been set by previous select */
|
/* Clear query_id that may have been set by previous select */
|
||||||
for (Field **ptr=table->field ; *ptr ; ptr++)
|
for (Field **ptr=table->field ; *ptr ; ptr++)
|
||||||
(*ptr)->query_id=0;
|
(*ptr)->query_id=0;
|
||||||
|
@@ -122,6 +122,16 @@ int mysql_derived(THD *thd, LEX *lex, SELECT_LEX_UNIT *unit,
|
|||||||
res= -1;
|
res= -1;
|
||||||
goto exit;
|
goto exit;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
This is done in order to redo all field optimisations when any of the
|
||||||
|
involved tables is used in the outer query
|
||||||
|
*/
|
||||||
|
if (tables)
|
||||||
|
{
|
||||||
|
for (TABLE_LIST *cursor= tables; cursor; cursor= cursor->next)
|
||||||
|
cursor->table->clear_query_id= 1;
|
||||||
|
}
|
||||||
|
|
||||||
item_list= select_cursor->item_list;
|
item_list= select_cursor->item_list;
|
||||||
select_cursor->with_wild= 0;
|
select_cursor->with_wild= 0;
|
||||||
@@ -223,8 +233,6 @@ int mysql_derived(THD *thd, LEX *lex, SELECT_LEX_UNIT *unit,
|
|||||||
/* Add new temporary table to list of open derived tables */
|
/* Add new temporary table to list of open derived tables */
|
||||||
table->next= thd->derived_tables;
|
table->next= thd->derived_tables;
|
||||||
thd->derived_tables= table;
|
thd->derived_tables= table;
|
||||||
thd->query_id++;
|
|
||||||
query_id++;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
exit:
|
exit:
|
||||||
|
@@ -1835,10 +1835,19 @@ int mysql_alter_table(THD *thd,char *new_db, char *new_name,
|
|||||||
/* COND_refresh will be signaled in close_thread_tables() */
|
/* COND_refresh will be signaled in close_thread_tables() */
|
||||||
break;
|
break;
|
||||||
case DISABLE:
|
case DISABLE:
|
||||||
VOID(pthread_mutex_lock(&LOCK_open));
|
if (table->db_type == DB_TYPE_MYISAM)
|
||||||
wait_while_table_is_used(thd, table);
|
{
|
||||||
VOID(pthread_mutex_unlock(&LOCK_open));
|
VOID(pthread_mutex_lock(&LOCK_open));
|
||||||
table->file->deactivate_non_unique_index(HA_POS_ERROR);
|
wait_while_table_is_used(thd, table);
|
||||||
|
VOID(pthread_mutex_unlock(&LOCK_open));
|
||||||
|
table->file->deactivate_non_unique_index(HA_POS_ERROR);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
push_warning_printf(current_thd, MYSQL_ERROR::WARN_LEVEL_WARN,
|
||||||
|
ER_ILLEGAL_HA,
|
||||||
|
ER(ER_ILLEGAL_HA), table->table_name);
|
||||||
|
break;
|
||||||
|
|
||||||
/* COND_refresh will be signaled in close_thread_tables() */
|
/* COND_refresh will be signaled in close_thread_tables() */
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
@@ -116,6 +116,7 @@ struct st_table {
|
|||||||
my_bool crashed;
|
my_bool crashed;
|
||||||
my_bool is_view;
|
my_bool is_view;
|
||||||
my_bool no_keyread;
|
my_bool no_keyread;
|
||||||
|
my_bool clear_query_id; /* To reset query_id for tables and cols */
|
||||||
Field *next_number_field, /* Set if next_number is activated */
|
Field *next_number_field, /* Set if next_number is activated */
|
||||||
*found_next_number_field, /* Set on open */
|
*found_next_number_field, /* Set on open */
|
||||||
*rowid_field;
|
*rowid_field;
|
||||||
|
Reference in New Issue
Block a user