Add missing COMMIT detection for non-transactional engines

Non-transactional engines will use a query event with a COMMIT in it to
signal that the transaction is over.
This commit is contained in:
Markus Mäkelä 2019-09-25 09:51:12 +03:00
parent 51d2d6c1f2
commit bcf26fba3e
No known key found for this signature in database
GPG Key ID: 72D48FCE664F7B19

View File

@ -374,6 +374,13 @@ bool Replicator::Imp::process_one_event(SQL::Event& event)
break;
case QUERY_EVENT:
if (strncasecmp(event->event.query.statement.str, "commit",
event->event.query.statement.length) == 0)
{
commit = true;
}
/* fallthrough */
case USER_VAR_EVENT:
if (m_implicit_commit)
{