diff options
Diffstat (limited to 'sql/rpl_injector.cc')
| -rw-r--r-- | sql/rpl_injector.cc | 56 |
1 files changed, 0 insertions, 56 deletions
diff --git a/sql/rpl_injector.cc b/sql/rpl_injector.cc index 19b193729fd..caa84d867ad 100644 --- a/sql/rpl_injector.cc +++ b/sql/rpl_injector.cc @@ -118,62 +118,6 @@ int injector::transaction::use_table(server_id_type sid, table tbl) } -int injector::transaction::write_row (server_id_type sid, table tbl, - MY_BITMAP const* cols, size_t colcnt, - record_type record) -{ - DBUG_ENTER("injector::transaction::write_row(...)"); - - int error= check_state(ROW_STATE); - if (error) - DBUG_RETURN(error); - - server_id_type save_id= m_thd->variables.server_id; - m_thd->set_server_id(sid); - error= m_thd->binlog_write_row(tbl.get_table(), tbl.is_transactional(), - cols, colcnt, record); - m_thd->set_server_id(save_id); - DBUG_RETURN(error); -} - - -int injector::transaction::delete_row(server_id_type sid, table tbl, - MY_BITMAP const* cols, size_t colcnt, - record_type record) -{ - DBUG_ENTER("injector::transaction::delete_row(...)"); - - int error= check_state(ROW_STATE); - if (error) - DBUG_RETURN(error); - - server_id_type save_id= m_thd->variables.server_id; - m_thd->set_server_id(sid); - error= m_thd->binlog_delete_row(tbl.get_table(), tbl.is_transactional(), - cols, colcnt, record); - m_thd->set_server_id(save_id); - DBUG_RETURN(error); -} - - -int injector::transaction::update_row(server_id_type sid, table tbl, - MY_BITMAP const* cols, size_t colcnt, - record_type before, record_type after) -{ - DBUG_ENTER("injector::transaction::update_row(...)"); - - int error= check_state(ROW_STATE); - if (error) - DBUG_RETURN(error); - - server_id_type save_id= m_thd->variables.server_id; - m_thd->set_server_id(sid); - error= m_thd->binlog_update_row(tbl.get_table(), tbl.is_transactional(), - cols, colcnt, before, after); - m_thd->set_server_id(save_id); - DBUG_RETURN(error); -} - injector::transaction::binlog_pos injector::transaction::start_pos() const { |