Public Member Functions | |
bool | create () |
bool | setInitialMaxCommitId (uint64_t value) |
void | markInErrorState () |
void | clearErrorState () |
const std::string & | getErrorMessage () |
bool | executeSQL (std::vector< std::string > &sql) |
Protected Attributes | |
drizzled::Session::shared_ptr | _session |
Definition at line 28 of file replication_schema.h.
bool slave::SQLExecutor::executeSQL | ( | std::vector< std::string > & | sql | ) | [inherited] |
Execute a batch of SQL statements.
sql | Batch of SQL statements to execute. |
true | Success |
false | Failure |
Definition at line 49 of file sql_executor.cc.
bool slave::ReplicationSchema::setInitialMaxCommitId | ( | uint64_t | value | ) |
Set initial value of the last applied COMMIT_ID value in applier_state.
This is used when the server is started with --slave.max-commit-id to begin reading from the master transaction log at a given point. This method will persist the value to the applier_state table. If it wasn't permanently stored immediately, we risk the possibility of losing the value if the server is again restarted without ever having received another event from the master (which causes persistence of the value). An edge case, but still possible.
[in] | value | The initial value. |
Definition at line 135 of file replication_schema.cc.
Referenced by slave::ReplicationSlave::initWithConfig().