summaryrefslogtreecommitdiff
path: root/sql/events.cc
diff options
context:
space:
mode:
authorkostja@vajra.(none) <>2007-04-13 23:53:05 -0400
committerkostja@vajra.(none) <>2007-04-13 23:53:05 -0400
commit8b10ae74cc997adc3e6ebffea9ef39071771a827 (patch)
tree80a138b97ff91b9b6181aec552a578672c0ca8c8 /sql/events.cc
parenteccd5ae20180a53813f64dd3ebd6519e9651ba65 (diff)
downloadmariadb-git-8b10ae74cc997adc3e6ebffea9ef39071771a827.tar.gz
Fix rpl_events test failure in the runtime tree.
Diffstat (limited to 'sql/events.cc')
-rw-r--r--sql/events.cc9
1 files changed, 6 insertions, 3 deletions
diff --git a/sql/events.cc b/sql/events.cc
index 200f46b7f7a..0148533a612 100644
--- a/sql/events.cc
+++ b/sql/events.cc
@@ -424,7 +424,8 @@ Events::create_event(THD *thd, Event_parse_data *parse_data,
if (event_queue)
event_queue->create_event(thd, new_element, &created);
/* Binlog the create event. */
- if (mysql_bin_log.is_open() && (thd->query_length > 0))
+ DBUG_ASSERT(thd->query && thd->query_length);
+ if (mysql_bin_log.is_open())
{
thd->clear_error();
thd->binlog_query(THD::MYSQL_QUERY_TYPE,
@@ -549,7 +550,8 @@ Events::update_event(THD *thd, Event_parse_data *parse_data,
event_queue->update_event(thd, parse_data->dbname, parse_data->name,
new_element);
/* Binlog the alter event. */
- if (mysql_bin_log.is_open() && (thd->query_length > 0))
+ DBUG_ASSERT(thd->query && thd->query_length);
+ if (mysql_bin_log.is_open())
{
thd->clear_error();
thd->binlog_query(THD::MYSQL_QUERY_TYPE,
@@ -628,7 +630,8 @@ Events::drop_event(THD *thd, LEX_STRING dbname, LEX_STRING name, bool if_exists)
if (event_queue)
event_queue->drop_event(thd, dbname, name);
/* Binlog the drop event. */
- if (mysql_bin_log.is_open() && (thd->query_length > 0))
+ DBUG_ASSERT(thd->query && thd->query_length);
+ if (mysql_bin_log.is_open())
{
thd->clear_error();
thd->binlog_query(THD::MYSQL_QUERY_TYPE,