IntenseFinance/gnucash
3
0
Fork 0
mirror of https://github.com/Gnucash/gnucash.git synced 2024-12-01 21:19:16 -06:00
Code Issues Packages Projects Releases Wiki Activity

Add SAVEPOINT support to enable nested gnc_dbi_transaction calls.

Browse Source
This commit is contained in:
John Ralls 2017-02-04 09:50:50 -08:00
parent db73c39bf1
commit 979e6397c1
1 changed files with 29 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/backend/dbi/gnc-backend-dbi.c
View File

@ -220,12 +220,20 @@ gnc_dbi_verify_conn( GncDbiSqlConnection* dbi_conn )
return dbi_conn->conn_ok; return dbi_conn->conn_ok;
} }
static unsigned int sql_savepoint = 0;
static gboolean static gboolean
gnc_dbi_transaction_begin(QofBackend* qbe, dbi_conn conn) gnc_dbi_transaction_begin(QofBackend* qbe, dbi_conn conn)
{ {
dbi_result result; dbi_result result;
if (sql_savepoint == 0)
result = dbi_conn_queryf(conn, "BEGIN"); result = dbi_conn_queryf(conn, "BEGIN");
else
{
char *savepoint = g_strdup_printf("savepoint_%d", sql_savepoint);
result = dbi_conn_queryf(conn, "SAVEPOINT %s", savepoint);
g_free(savepoint);
}
if (result != NULL) if (result != NULL)
{ {
if(dbi_result_free(result) != 0) if(dbi_result_free(result) != 0)
@ -233,6 +241,7 @@ gnc_dbi_transaction_begin(QofBackend* qbe, dbi_conn conn)
PERR( "Error in dbi_result_free() result\n" ); PERR( "Error in dbi_result_free() result\n" );
qof_backend_set_error(qbe, ERR_BACKEND_SERVER_ERR); qof_backend_set_error(qbe, ERR_BACKEND_SERVER_ERR);
} }
++sql_savepoint;
return TRUE; return TRUE;
} }
PERR( "BEGIN transaction failed()\n" ); PERR( "BEGIN transaction failed()\n" );
@ -244,7 +253,16 @@ static gboolean
gnc_dbi_transaction_commit(QofBackend *qbe, dbi_conn conn) gnc_dbi_transaction_commit(QofBackend *qbe, dbi_conn conn)
{ {
dbi_result result; dbi_result result;
g_return_val_if_fail(sql_savepoint > 0, FALSE);
if (sql_savepoint == 1)
result = dbi_conn_queryf(conn, "COMMIT"); result = dbi_conn_queryf(conn, "COMMIT");
else
{
char *savepoint = g_strdup_printf("savepoint_%d", sql_savepoint - 1);
result = dbi_conn_queryf(conn, "RELEASE SAVEPOINT %s",
savepoint);
g_free(savepoint);
}
if (result != NULL) if (result != NULL)
{ {
if(dbi_result_free(result) != 0) if(dbi_result_free(result) != 0)
@ -252,6 +270,7 @@ gnc_dbi_transaction_commit(QofBackend *qbe, dbi_conn conn)
PERR( "Error in dbi_result_free() result\n" ); PERR( "Error in dbi_result_free() result\n" );
qof_backend_set_error(qbe, ERR_BACKEND_SERVER_ERR); qof_backend_set_error(qbe, ERR_BACKEND_SERVER_ERR);
} }
--sql_savepoint;
return TRUE; return TRUE;
} }
PERR( "COMMIT transaction failed()\n" ); PERR( "COMMIT transaction failed()\n" );
@ -264,7 +283,16 @@ gnc_dbi_transaction_rollback(QofBackend *qbe, dbi_conn conn)
{ {
dbi_result result; dbi_result result;
DEBUG( "ROLLBACK\n" ); DEBUG( "ROLLBACK\n" );
g_return_val_if_fail(sql_savepoint > 0, FALSE);
if (sql_savepoint == 1)
result = dbi_conn_queryf(conn, "ROLLBACK"); result = dbi_conn_queryf(conn, "ROLLBACK");
else
{
char *savepoint = g_strdup_printf("savepoint_%d", sql_savepoint - 1);
result = dbi_conn_queryf(conn, "ROLLBACK TO SAVEPOINT %s",
savepoint);
g_free(savepoint);
}
if (result != NULL) if (result != NULL)
{ {
if(dbi_result_free(result) != 0) if(dbi_result_free(result) != 0)
@ -272,6 +300,7 @@ gnc_dbi_transaction_rollback(QofBackend *qbe, dbi_conn conn)
PERR( "Error in dbi_result_free() result\n" ); PERR( "Error in dbi_result_free() result\n" );
qof_backend_set_error(qbe, ERR_BACKEND_SERVER_ERR ); qof_backend_set_error(qbe, ERR_BACKEND_SERVER_ERR );
} }
--sql_savepoint;
return TRUE; return TRUE;
} }
PERR( "ROLLBACK transaction failed()\n" ); PERR( "ROLLBACK transaction failed()\n" );