mirror of
https://github.com/MariaDB/server.git
synced 2025-01-17 12:32:27 +01:00
Bug#28677: SELECT on missing column gives extra error
The method select_insert::send_error does two things, it rolls back a statement being executed and outputs an error message. But when a nonexistent column is referenced, an error message has been published already and there is no need to publish another. Fixed by moving all functionality beyond publishing an error message into select_insert::abort() and calling only that function.
This commit is contained in:
parent
b50d17a9b5
commit
cc2d534ab1
5 changed files with 80 additions and 45 deletions
|
@ -41,3 +41,17 @@ SELECT a FROM t1 WHERE a IN(1, (SELECT IF(1=0,1,2/0)));
|
|||
a
|
||||
1
|
||||
DROP TABLE t1;
|
||||
CREATE TABLE t1( a INT );
|
||||
SELECT b FROM t1;
|
||||
ERROR 42S22: Unknown column 'b' in 'field list'
|
||||
SHOW ERRORS;
|
||||
Level Code Message
|
||||
Error 1054 Unknown column 'b' in 'field list'
|
||||
CREATE TABLE t2 SELECT b FROM t1;
|
||||
ERROR 42S22: Unknown column 'b' in 'field list'
|
||||
SHOW ERRORS;
|
||||
Level Code Message
|
||||
Error 1054 Unknown column 'b' in 'field list'
|
||||
INSERT INTO t1 SELECT b FROM t1;
|
||||
ERROR 42S22: Unknown column 'b' in 'field list'
|
||||
DROP TABLE t1;
|
||||
|
|
|
@ -53,4 +53,17 @@ INSERT INTO t1 VALUES(2),(3);
|
|||
SELECT a FROM t1 WHERE a IN(1, (SELECT IF(1=0,1,2/0)));
|
||||
DROP TABLE t1;
|
||||
|
||||
#
|
||||
# Bug #28677: SELECT on missing column gives extra error
|
||||
#
|
||||
CREATE TABLE t1( a INT );
|
||||
--error ER_BAD_FIELD_ERROR
|
||||
SELECT b FROM t1;
|
||||
SHOW ERRORS;
|
||||
--error ER_BAD_FIELD_ERROR
|
||||
CREATE TABLE t2 SELECT b FROM t1;
|
||||
SHOW ERRORS;
|
||||
--error ER_BAD_FIELD_ERROR
|
||||
INSERT INTO t1 SELECT b FROM t1;
|
||||
DROP TABLE t1;
|
||||
# End of 5.0 tests
|
||||
|
|
|
@ -1951,6 +1951,7 @@ class select_insert :public select_result_interceptor {
|
|||
virtual void store_values(List<Item> &values);
|
||||
void send_error(uint errcode,const char *err);
|
||||
bool send_eof();
|
||||
void abort();
|
||||
/* not implemented: select_insert is never re-used in prepared statements */
|
||||
void cleanup();
|
||||
};
|
||||
|
|
|
@ -2862,41 +2862,6 @@ void select_insert::send_error(uint errcode,const char *err)
|
|||
|
||||
my_message(errcode, err, MYF(0));
|
||||
|
||||
if (!table)
|
||||
{
|
||||
/*
|
||||
This can only happen when using CREATE ... SELECT and the table was not
|
||||
created becasue of an syntax error
|
||||
*/
|
||||
DBUG_VOID_RETURN;
|
||||
}
|
||||
if (!thd->prelocked_mode)
|
||||
table->file->end_bulk_insert();
|
||||
/*
|
||||
If at least one row has been inserted/modified and will stay in the table
|
||||
(the table doesn't have transactions) (example: we got a duplicate key
|
||||
error while inserting into a MyISAM table) we must write to the binlog (and
|
||||
the error code will make the slave stop).
|
||||
*/
|
||||
if ((info.copied || info.deleted || info.updated) &&
|
||||
!table->file->has_transactions())
|
||||
{
|
||||
if (last_insert_id)
|
||||
thd->insert_id(last_insert_id); // For binary log
|
||||
if (mysql_bin_log.is_open())
|
||||
{
|
||||
Query_log_event qinfo(thd, thd->query, thd->query_length,
|
||||
table->file->has_transactions(), FALSE);
|
||||
mysql_bin_log.write(&qinfo);
|
||||
}
|
||||
if (!table->s->tmp_table)
|
||||
thd->no_trans_update.all= TRUE;
|
||||
}
|
||||
if (info.copied || info.deleted || info.updated)
|
||||
{
|
||||
query_cache_invalidate3(thd, table, 1);
|
||||
}
|
||||
ha_rollback_stmt(thd);
|
||||
DBUG_VOID_RETURN;
|
||||
}
|
||||
|
||||
|
@ -2952,6 +2917,49 @@ bool select_insert::send_eof()
|
|||
DBUG_RETURN(0);
|
||||
}
|
||||
|
||||
void select_insert::abort()
|
||||
{
|
||||
DBUG_ENTER("select_insert::abort");
|
||||
|
||||
if (!table)
|
||||
{
|
||||
/*
|
||||
This can only happen when using CREATE ... SELECT and the table was not
|
||||
created becasue of an syntax error
|
||||
*/
|
||||
DBUG_VOID_RETURN;
|
||||
}
|
||||
if (!thd->prelocked_mode)
|
||||
table->file->end_bulk_insert();
|
||||
/*
|
||||
If at least one row has been inserted/modified and will stay in the table
|
||||
(the table doesn't have transactions) (example: we got a duplicate key
|
||||
error while inserting into a MyISAM table) we must write to the binlog (and
|
||||
the error code will make the slave stop).
|
||||
*/
|
||||
if ((info.copied || info.deleted || info.updated) &&
|
||||
!table->file->has_transactions())
|
||||
{
|
||||
if (last_insert_id)
|
||||
thd->insert_id(last_insert_id); // For binary log
|
||||
if (mysql_bin_log.is_open())
|
||||
{
|
||||
Query_log_event qinfo(thd, thd->query, thd->query_length,
|
||||
table->file->has_transactions(), FALSE);
|
||||
mysql_bin_log.write(&qinfo);
|
||||
}
|
||||
if (!table->s->tmp_table)
|
||||
thd->no_trans_update.all= TRUE;
|
||||
}
|
||||
if (info.copied || info.deleted || info.updated)
|
||||
{
|
||||
query_cache_invalidate3(thd, table, 1);
|
||||
}
|
||||
ha_rollback_stmt(thd);
|
||||
|
||||
DBUG_VOID_RETURN;
|
||||
|
||||
}
|
||||
|
||||
/***************************************************************************
|
||||
CREATE TABLE (SELECT) ...
|
||||
|
@ -3209,13 +3217,7 @@ void select_create::store_values(List<Item> &values)
|
|||
|
||||
void select_create::send_error(uint errcode,const char *err)
|
||||
{
|
||||
/*
|
||||
Disable binlog, because we "roll back" partial inserts in ::abort
|
||||
by removing the table, even for non-transactional tables.
|
||||
*/
|
||||
tmp_disable_binlog(thd);
|
||||
select_insert::send_error(errcode, err);
|
||||
reenable_binlog(thd);
|
||||
}
|
||||
|
||||
|
||||
|
@ -3240,6 +3242,14 @@ bool select_create::send_eof()
|
|||
|
||||
void select_create::abort()
|
||||
{
|
||||
/*
|
||||
Disable binlog, because we "roll back" partial inserts in ::abort
|
||||
by removing the table, even for non-transactional tables.
|
||||
*/
|
||||
tmp_disable_binlog(thd);
|
||||
select_insert::abort();
|
||||
reenable_binlog(thd);
|
||||
|
||||
if (lock)
|
||||
{
|
||||
mysql_unlock_tables(thd, lock);
|
||||
|
|
|
@ -258,11 +258,8 @@ bool handle_select(THD *thd, LEX *lex, select_result *result,
|
|||
thd->net.report_error));
|
||||
res|= thd->net.report_error;
|
||||
if (unlikely(res))
|
||||
{
|
||||
/* If we had a another error reported earlier then this will be ignored */
|
||||
result->send_error(ER_UNKNOWN_ERROR, ER(ER_UNKNOWN_ERROR));
|
||||
result->abort();
|
||||
}
|
||||
|
||||
DBUG_RETURN(res);
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in a new issue