generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-03-25 16:13:42 +01:00
Code Issues Projects Releases Wiki Activity

Merge pull request #4256 from pocoproject/4247-mysql-startTransaction

Browse Source 
Implement MySQL::SessionHandle::startTransaction as submitting the SQL statement 'BEGIN'
This commit is contained in:
Aleksandar Fabijanic 2023-11-10 12:52:06 +01:00 committed by GitHub
commit 940c9b48ff
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Data/MySQL/src/SessionHandle.cpp
View File

@ -153,14 +153,14 @@ void SessionHandle::close()
void SessionHandle::startTransaction() void SessionHandle::startTransaction()
{ {
int rc = mysql_autocommit(_pHandle, false); int rc = mysql_query(_pHandle, "BEGIN");
if (rc != 0) if (rc != 0)
{ {
// retry if connection lost // retry if connection lost
int err = mysql_errno(_pHandle); int err = mysql_errno(_pHandle);
if (err == 2006 /* CR_SERVER_GONE_ERROR */ || err == 2013 /* CR_SERVER_LOST */) if (err == 2006 /* CR_SERVER_GONE_ERROR */ || err == 2013 /* CR_SERVER_LOST */)
{ {
rc = mysql_autocommit(_pHandle, false); rc = mysql_query(_pHandle, "BEGIN");
} }
} }
if (rc != 0) throw TransactionException("Start transaction failed.", _pHandle); if (rc != 0) throw TransactionException("Start transaction failed.", _pHandle);