1 /***************************************************************************
2 QgsOgrTransaction.cpp - Transaction support for OGR layers
3 -------------------
4 begin : June 13, 2018
5 copyright : (C) 2018 by Even Rouault
6 email : even.rouault @ spatialys.com
7 ***************************************************************************/
8
9 /***************************************************************************
10 * *
11 * This program is free software; you can redistribute it and/or modify *
12 * it under the terms of the GNU General Public License as published by *
13 * the Free Software Foundation; either version 2 of the License, or *
14 * (at your option) any later version. *
15 * *
16 ***************************************************************************/
17
18 #include "qgsogrtransaction.h"
19 ///@cond PRIVATE
20
21 #include "qgsogrprovider.h"
22 #include "qgslogger.h"
23 #include "qgis.h"
24
QgsOgrTransaction(const QString & connString,QgsOgrDatasetSharedPtr ds)25 QgsOgrTransaction::QgsOgrTransaction( const QString &connString, QgsOgrDatasetSharedPtr ds )
26 : QgsTransaction( connString ), mSharedDS( ds )
27
28 {
29 Q_ASSERT( mSharedDS );
30 }
31
beginTransaction(QString & error,int)32 bool QgsOgrTransaction::beginTransaction( QString &error, int /* statementTimeout */ )
33 {
34 return executeSql( QStringLiteral( "BEGIN" ), error );
35 }
36
commitTransaction(QString & error)37 bool QgsOgrTransaction::commitTransaction( QString &error )
38 {
39 return executeSql( QStringLiteral( "COMMIT" ), error );
40 }
41
rollbackTransaction(QString & error)42 bool QgsOgrTransaction::rollbackTransaction( QString &error )
43 {
44 return executeSql( QStringLiteral( "ROLLBACK" ), error );
45 }
46
executeSql(const QString & sql,QString & errorMsg,bool isDirty,const QString & name)47 bool QgsOgrTransaction::executeSql( const QString &sql, QString &errorMsg, bool isDirty, const QString &name )
48 {
49
50 QString err;
51 if ( isDirty )
52 {
53 createSavepoint( err );
54 }
55
56 QgsDebugMsg( QStringLiteral( "Transaction sql: %1" ).arg( sql ) );
57 if ( !mSharedDS->executeSQLNoReturn( sql ) )
58 {
59 errorMsg = CPLGetLastErrorMsg();
60 QgsDebugMsg( errorMsg );
61
62 if ( isDirty )
63 {
64 rollbackToSavepoint( savePoints().last(), err );
65 }
66
67 return false;
68 }
69
70 if ( isDirty )
71 {
72 dirtyLastSavePoint();
73 emit dirtied( sql, name );
74 }
75
76 QgsDebugMsg( QStringLiteral( "... ok" ) );
77 return true;
78 }
79
80 ///@endcond
81