diff options
Diffstat (limited to 'sql/sql_insert.cc')
| -rw-r--r-- | sql/sql_insert.cc | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/sql/sql_insert.cc b/sql/sql_insert.cc index 7e438ac3a7c..a631a82be1e 100644 --- a/sql/sql_insert.cc +++ b/sql/sql_insert.cc @@ -3084,10 +3084,19 @@ void select_insert::send_error(uint errcode,const char *err) bool select_insert::send_eof() { +<<<<<<< gca sql/sql_insert.cc 1.146.1.105 + int error, error2; + bool changed, transactional_table= table->file->has_transactions(); +<<<<<<< local sql/sql_insert.cc 1.300 int error; bool const trans_table= table->file->has_transactions(); ulonglong id; bool changed; +<<<<<<< remote sql/sql_insert.cc 1.146.1.106 + int error, error2; + bool changed, transactional_table= table->file->has_transactions(); + THD::killed_state killed_status= thd->killed; +>>>>>>> DBUG_ENTER("select_insert::send_eof"); DBUG_PRINT("enter", ("trans_table=%d, table_type='%s'", trans_table, table->file->table_type())); @@ -3120,6 +3129,14 @@ bool select_insert::send_eof() { if (!error) thd->clear_error(); +<<<<<<< gca sql/sql_insert.cc 1.146.1.105 + Query_log_event qinfo(thd, thd->query, thd->query_length, + transactional_table, FALSE); + mysql_bin_log.write(&qinfo); + } + if ((error2=ha_autocommit_or_rollback(thd,error)) && ! error) + error=error2; +<<<<<<< local sql/sql_insert.cc 1.300 thd->binlog_query(THD::ROW_QUERY_TYPE, thd->query, thd->query_length, trans_table, FALSE); @@ -3138,6 +3155,14 @@ bool select_insert::send_eof() } table->file->ha_release_auto_increment(); +<<<<<<< remote sql/sql_insert.cc 1.146.1.106 + Query_log_event qinfo(thd, thd->query, thd->query_length, + transactional_table, FALSE, killed_status); + mysql_bin_log.write(&qinfo); + } + if ((error2=ha_autocommit_or_rollback(thd,error)) && ! error) + error=error2; +>>>>>>> if (error) { table->file->print_error(error,MYF(0)); |