generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-04-01 09:24:55 +02:00
Code Issues Projects Releases Wiki Activity

handle MySQL connection lost/server gone when starting a transaction

Browse Source
This commit is contained in:
Guenter Obiltschnig 2016-09-15 12:01:30 +02:00
parent dcdcee5afa
commit e87a8fe962
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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