To get this branch, use:
bzr branch
http://bzr.ed.am/sqlite3cc
« back to all changes in this revision
Viewing changes to include/sqlite3cc/transaction.h
- browse files at revision 41
- compare with another revision
- download diff
- download tarball
- view history from revision 41
- Committer: Tim Marston
- Date: 2014-01-03 16:40:21 UTC
- Revision ID: tim@ed.am-20140103164021-i6o99h1459xjdq5o
reverted version no. to 0.2dev
- files added:
- docs
- files removed:
- Makefile.in
- build-aux
- m4
- files renamed:
- include/sqlite3cc/database.h => include/sqlite3cc/connection.h
- src/database.cc => src/connection.cc
- files modified:
- .bzrignore
added
removed
include/sqlite3cc/transaction.h
1
1
/*
2
2
* transaction.h
3
3
*
4
* Copyright (C) 2009 Tim Marston <edam@waxworlds.org>
4
* Copyright (C) 2009 Tim Marston <tim@ed.am>
5
5
*
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.
8
*
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.
13
*
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.
8
*
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
12
* later version.
13
*
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
17
* details.
18
18
*
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/>.
32
32
{
33
33
34
34
35
class database;
36
37
38
/**
39
* A basic (default, deferred) transaction.
40
*/
41
class basic_transaction
42
:
43
private boost::noncopyable
35
class connection;
36
37
38
namespace detail
44
39
{
45
//______________________________________________________________________________
46
// instantiation
47
public:
48
49
/**
50
* Constructor that provides a database upon which to act
51
* @param database a database
52
*/
53
explicit basic_transaction(
54
database &database );
55
56
//______________________________________________________________________________
57
// public interface
58
public:
59
60
/**
61
* Begin the transaction
62
*/
63
virtual void begin();
64
65
/**
66
* Commit the transaction
67
*/
68
virtual void commit();
69
70
/**
71
* Rollback the transaction
72
*/
73
virtual void rollback();
74
75
//______________________________________________________________________________
76
// implementation
77
protected:
78
79
/* the database on which to act */
80
database &_database;
81
82
};
83
84
85
////////////////////////////////////////////////////////////////////////////////
86
87
88
/**
89
* An exclusive transaction
40
41
/**
42
* A basic (default, deferred) transaction.
43
*/
44
class basic_transaction
45
:
46
private boost::noncopyable
47
{
48
//__________________________________________________________________________
49
// instantiation
50
public:
51
52
/**
53
* Constructor that provides a connection upon which to act.
54
*
55
* @param connection a connection
56
*/
57
explicit basic_transaction(
58
connection &connection );
59
60
//__________________________________________________________________________
61
// public interface
62
public:
63
64
/**
65
* Begin the transaction
66
*/
67
virtual void begin();
68
69
/**
70
* Commit the transaction
71
*/
72
virtual void commit();
73
74
/**
75
* Rollback the transaction
76
*/
77
virtual void rollback();
78
79
//__________________________________________________________________________
80
// implementation
81
protected:
82
83
/** reset any in-progress statements */
84
void reset_active_queries();
85
86
/** the connection on which to act */
87
connection &_connection;
88
89
};
90
91
} // namespace detail
92
93
94
////////////////////////////////////////////////////////////////////////////////
95
96
97
/**
98
* A deferred transaction.
99
*/
100
typedef detail::basic_transaction deferred_transaction;
101
102
103
////////////////////////////////////////////////////////////////////////////////
104
105
106
/**
107
* An immediate transaction.
90
108
*/
91
109
class immediate_transaction
92
110
:
93
public basic_transaction
111
public detail::basic_transaction
94
112
{
95
113
//______________________________________________________________________________
96
114
// instantiation
97
115
public:
98
116
99
117
/**
100
* Constructor that provides a database upon which to act
101
* @param database a database
118
* Constructor that provides a connection upon which to act.
119
*
120
* @param connection a connection
102
121
*/
103
122
explicit immediate_transaction(
104
database &database );
123
connection &connection );
105
124
106
125
//______________________________________________________________________________
107
126
// public interface
108
127
public:
109
128
110
129
/**
111
* Begin the transaction
130
* Begin the transaction.
112
131
*/
113
132
virtual void begin();
114
133
119
138
120
139
121
140
/**
122
* An exclusive transaction
141
* An exclusive transaction.
123
142
*/
124
143
class exclusive_transaction
125
144
:
126
public basic_transaction
145
public detail::basic_transaction
127
146
{
128
147
//______________________________________________________________________________
129
148
// instantiation
130
149
public:
131
150
132
151
/**
133
* Constructor that provides a database upon which to act
134
* @param database a database
152
* Constructor that provides a connection upon which to act.
153
*
154
* @param connection a connection
135
155
*/
136
156
explicit exclusive_transaction(
137
database &database );
157
connection &connection );
138
158
139
159
//______________________________________________________________________________
140
160
// public interface
156
176
*/
157
177
class recursive_transaction
158
178
:
159
public basic_transaction
179
public detail::basic_transaction
160
180
{
161
181
//______________________________________________________________________________
162
182
// instantiation
163
183
public:
164
184
165
185
/**
166
* Constructor that provides a database upon which to act
167
* @param database a database
186
* Constructor that provides a connection upon which to act.
187
*
188
* @param connection a connection
168
189
*/
169
190
explicit recursive_transaction(
170
database &database );
191
connection &connection );
171
192
172
193
//______________________________________________________________________________
173
194
// public interface
174
195
public:
175
196
176
197
/**
177
* Begin the transaction
198
* Begin the transaction.
178
199
*/
179
200
virtual void begin();
180
201
181
202
/**
182
* Commit the transaction
203
* Commit the transaction.
183
204
*/
184
205
virtual void commit();
185
206
186
207
/**
187
* Rollback the transaction
208
* Rollback the transaction.
188
209
*/
189
210
virtual void rollback();
190
211
202
223
203
224
204
225
/**
205
* A scope guard, or sentinel for use with one of the transaction classes.
226
* A scope guard (sentinel) for use with one of the transaction classes to
227
* provide RAII-style transactions. It defaults to using deferred transactions.
206
228
*/
207
template< class T = basic_transaction >
229
template< class T = deferred_transaction >
208
230
class transaction_guard
209
231
:
210
232
private boost::noncopyable
214
236
public:
215
237
216
238
/**
217
* Constructor that provides a database upon which to act
218
* @param database a database
239
* Constructor that provides a connection upon which to act.
240
*
241
* @param connection a connection
219
242
*/
220
243
explicit transaction_guard(
221
database &database )
244
connection &connection )
222
245
:
223
_transaction( database ),
224
_released( false )
246
_transaction( connection ),
247
_released( true )
225
248
{
226
249
_transaction.begin();
250
_released = false;
227
251
}
228
252
229
253
~transaction_guard()
230
254
{
231
if( !_released ) {
232
try {
233
_transaction.rollback();
234
}
235
catch( ... ) {
236
}
237
}
255
if( !_released )
256
_transaction.rollback();
238
257
}
239
258
240
259
//______________________________________________________________________________
242
261
public:
243
262
244
263
/**
245
* Commit the transaction
264
* Begin the transaction. Note that this is done automatically in the
265
* constructor.
266
*/
267
void begin()
268
{
269
if( _released ) {
270
_transaction.begin();
271
_released = false;
272
}
273
}
274
275
/**
276
* Commit the transaction.
246
277
*/
247
278
void commit()
248
279
{
252
283
}
253
284
}
254
285
286
/**
287
* Rollback the transaction. Note that this is done automatically in the
288
* destructor if the transaction hasn't otherwise been completed.
289
*/
290
void rollback()
291
{
292
if( !_released ) {
293
_transaction.rollback();
294
_released = true;
295
}
296
}
297
255
298
//______________________________________________________________________________
256
299
// implementation
257
300
protected:
258
301
259
/* the transaction */
302
/** the transaction */
260
303
T _transaction;
261
304
262
/* have we released the transaction yet? */
305
/** have we released the transaction yet? */
263
306
bool _released;
264
307
265
308
};
Loggerhead is a web-based interface for Bazaar branches
Version: 1.18.2, Revision: 480