Commit 653f14c2 authored by Magne Mahre's avatar Magne Mahre

Bug#56452 Assertion failed: thd->transaction.stmt.is_empty() ||

          thd->in_sub_stmt
      
In a precursor patch for Bug#52044 
(revid:bzr/kostja@stripped), a
number of reorganizations of code was made. In addition some
assertions were added to ensure the correct transactional state.
      
The reorganization had a small glitch so statements that was
active in the query cache was not followed by a
statement commit/rollback (this code was removed). A section
in the trans_commit_stmt/trans_rollback_stmt code is to
clear the thd->transaction.stmt list of affected storage
engines.  When a new statement is initiated, an assert
introduced by the 523044 patch checks if this list is cleared.
When the query cache is accessed, this list may be populated,
and since it's not committed it will not be cleared.
      
This fix adds explicit statement commit or rollback for
statements that is contained in the query cache.
parent e53e16a8
...@@ -220,3 +220,14 @@ Variable_name Value ...@@ -220,3 +220,14 @@ Variable_name Value
Qcache_hits 1 Qcache_hits 1
set GLOBAL query_cache_size=1048576; set GLOBAL query_cache_size=1048576;
drop table t2; drop table t2;
CREATE TABLE t1 (a INT) ENGINE=InnoDB;
BEGIN;
INSERT INTO t1 VALUES(1);
ROLLBACK WORK AND CHAIN NO RELEASE;
SELECT a FROM t1;
a
ROLLBACK WORK AND CHAIN NO RELEASE;
SELECT a FROM t1;
a
ROLLBACK;
DROP TABLE t1;
...@@ -14,3 +14,18 @@ let $engine_type= InnoDB; ...@@ -14,3 +14,18 @@ let $engine_type= InnoDB;
let $test_foreign_keys= 1; let $test_foreign_keys= 1;
--source include/query_cache.inc --source include/query_cache.inc
#
# Bug#56452 Assertion failed: thd->transaction.stmt.is_empty() ||
# thd->in_sub_stmt
#
CREATE TABLE t1 (a INT) ENGINE=InnoDB;
BEGIN;
INSERT INTO t1 VALUES(1);
ROLLBACK WORK AND CHAIN NO RELEASE;
SELECT a FROM t1;
ROLLBACK WORK AND CHAIN NO RELEASE;
SELECT a FROM t1;
ROLLBACK;
DROP TABLE t1;
...@@ -341,6 +341,7 @@ TODO list: ...@@ -341,6 +341,7 @@ TODO list:
#include "../storage/myisammrg/ha_myisammrg.h" #include "../storage/myisammrg/ha_myisammrg.h"
#include "../storage/myisammrg/myrg_def.h" #include "../storage/myisammrg/myrg_def.h"
#include "probes_mysql.h" #include "probes_mysql.h"
#include "transaction.h"
#ifdef EMBEDDED_LIBRARY #ifdef EMBEDDED_LIBRARY
#include "emb_qcache.h" #include "emb_qcache.h"
...@@ -1683,6 +1684,8 @@ def_week_frmt: %lu, in_trans: %d, autocommit: %d", ...@@ -1683,6 +1684,8 @@ def_week_frmt: %lu, in_trans: %d, autocommit: %d",
} }
else else
thd->lex->safe_to_cache_query= 0; // Don't try to cache this thd->lex->safe_to_cache_query= 0; // Don't try to cache this
/* End the statement transaction potentially started by engine. */
trans_rollback_stmt(thd);
goto err_unlock; // Parse query goto err_unlock; // Parse query
} }
else else
...@@ -1724,6 +1727,13 @@ def_week_frmt: %lu, in_trans: %d, autocommit: %d", ...@@ -1724,6 +1727,13 @@ def_week_frmt: %lu, in_trans: %d, autocommit: %d",
thd->limit_found_rows = query->found_rows(); thd->limit_found_rows = query->found_rows();
thd->status_var.last_query_cost= 0.0; thd->status_var.last_query_cost= 0.0;
/*
End the statement transaction potentially started by an
engine callback. We ignore the return value for now,
since as long as EOF packet is part of the query cache
response, we can't handle it anyway.
*/
(void) trans_commit_stmt(thd);
if (!thd->stmt_da->is_set()) if (!thd->stmt_da->is_set())
thd->stmt_da->disable_status(); thd->stmt_da->disable_status();
......
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