4
* Copyright (C) 2009 Tim Marston <edam@waxworlds.org>
4
* Copyright (C) 2009 Tim Marston <tim@ed.am>
6
6
* This file is part of sqlite3cc (hereafter referred to as "this program").
7
* See http://www.waxworlds.org/edam/software/sqlite3cc for more information.
9
* This program is free software: you can redistribute it and/or modify
10
* it under the terms of the GNU Lesser General Public License as published
11
* by the Free Software Foundation, either version 3 of the License, or
12
* (at your option) any later version.
14
* This program is distributed in the hope that it will be useful,
15
* but WITHOUT ANY WARRANTY; without even the implied warranty of
16
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17
* GNU Lesser General Public License for more details.
7
* See http://ed.am/dev/sqlite3cc for more information.
9
* This program is free software: you can redistribute it and/or modify it under
10
* the terms of the GNU Lesser General Public License as published by the Free
11
* Software Foundation, either version 3 of the License, or (at your option) any
14
* This program is distributed in the hope that it will be useful, but WITHOUT
15
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
16
* FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
19
19
* You should have received a copy of the GNU Lesser General Public License
20
20
* along with this program. If not, see <http://www.gnu.org/licenses/>.
23
23
#include <sqlite3cc/transaction.h>
24
#include <sqlite3cc/database.h>
24
#include <sqlite3cc/connection.h>
25
25
#include <sqlite3cc/exception.h>
26
26
#include <boost/thread.hpp>
27
27
#include <boost/lexical_cast.hpp>
30
sqlite::basic_transaction::basic_transaction(
38
void sqlite::basic_transaction::begin()
40
int error_code = _database.exec( "BEGIN" );
41
if( error_code != SQLITE_OK ) throw sqlite_error( error_code );
45
void sqlite::basic_transaction::commit()
47
int error_code = _database.exec( "COMMIT" );
48
if( error_code != SQLITE_OK ) throw sqlite_error( error_code );
52
void sqlite::basic_transaction::rollback()
54
int error_code = _database.exec( "ROLLBACK" );
55
if( error_code != SQLITE_OK ) throw sqlite_error( error_code );
30
sqlite::detail::basic_transaction::basic_transaction(
31
connection &connection )
33
_connection( connection )
38
void sqlite::detail::basic_transaction::begin()
40
_connection.exec( "BEGIN" );
44
void sqlite::detail::basic_transaction::commit()
46
// we must reset any active queries when committing
47
reset_active_queries();
48
_connection.exec( "COMMIT" );
52
void sqlite::detail::basic_transaction::reset_active_queries()
54
sqlite3_stmt *old_handle = NULL;
55
while( sqlite3_stmt *handle =
56
sqlite3_next_stmt( _connection._handle, old_handle ) )
58
int code = sqlite3_reset( handle );
59
if( code != SQLITE_OK ) throw sqlite_error( _connection, code );
65
void sqlite::detail::basic_transaction::rollback()
67
// we must reset any active queries when rolling back
68
reset_active_queries();
69
_connection.exec( "ROLLBACK" );
73
sqlite::immediate_transaction::immediate_transaction(
74
connection &connection )
76
basic_transaction( connection )
81
void sqlite::immediate_transaction::begin()
83
_connection.exec( "BEGIN IMMEDIATE" );
59
87
sqlite::exclusive_transaction::exclusive_transaction(
88
connection &connection )
62
basic_transaction( database )
90
basic_transaction( connection )
67
95
void sqlite::exclusive_transaction::begin()
69
int error_code = _database.exec( "BEGIN EXCLUSIVE" );
70
if( error_code != SQLITE_OK ) throw sqlite_error( error_code );
97
_connection.exec( "BEGIN EXCLUSIVE" );
74
101
sqlite::recursive_transaction::recursive_transaction(
102
connection &connection )
77
basic_transaction( database )
104
basic_transaction( connection )
79
106
static unsigned long long i = 0;
107
static boost::mutex mutex;
80
108
unsigned long long my_i;
81
static boost::mutex mutex;
83
110
boost::lock_guard< boost::mutex > lock( mutex );
90
117
void sqlite::recursive_transaction::begin()
92
int error_code = _database.exec( "SAVEPOINT " + _sp_name );
93
if( error_code != SQLITE_OK ) throw sqlite_error( error_code );
119
_connection.exec( "SAVEPOINT " + _sp_name );
97
123
void sqlite::recursive_transaction::commit()
99
int error_code = _database.exec( "RELEASE " + _sp_name );
100
if( error_code != SQLITE_OK ) throw sqlite_error( error_code );
125
// we must reset any active queries when committing
126
reset_active_queries();
127
_connection.exec( "RELEASE " + _sp_name );
104
131
void sqlite::recursive_transaction::rollback()
106
int error_code = _database.exec( "ROLLBACK TO " + _sp_name );
107
if( error_code != SQLITE_OK ) throw sqlite_error( error_code );
133
// we must reset any active queries when rolling back
134
reset_active_queries();
135
_connection.exec( "ROLLBACK TO " + _sp_name );
109
137
// we have rolled back this transaction's savepoint, but the savepoint will
110
138
// remain on the transaction stack unless we also release it
111
error_code = _database.exec( "RELEASE " + _sp_name );
112
if( error_code != SQLITE_OK ) throw sqlite_error( error_code );
139
_connection.exec( "RELEASE " + _sp_name );
added
removed
src/transaction.cc
