[email protected] | f0a54b2 | 2011-07-19 18:40:21 | [diff] [blame] | 1 | // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
[email protected] | e5ffd0e4 | 2009-09-11 21:30:56 | [diff] [blame] | 2 | // Use of this source code is governed by a BSD-style license that can be |
3 | // found in the LICENSE file. | ||||
4 | |||||
[email protected] | f0a54b2 | 2011-07-19 18:40:21 | [diff] [blame] | 5 | #include "sql/transaction.h" |
[email protected] | e5ffd0e4 | 2009-09-11 21:30:56 | [diff] [blame] | 6 | |
[email protected] | e5ffd0e4 | 2009-09-11 21:30:56 | [diff] [blame] | 7 | #include "base/logging.h" |
[email protected] | f0a54b2 | 2011-07-19 18:40:21 | [diff] [blame] | 8 | #include "sql/connection.h" |
[email protected] | e5ffd0e4 | 2009-09-11 21:30:56 | [diff] [blame] | 9 | |
10 | namespace sql { | ||||
11 | |||||
12 | Transaction::Transaction(Connection* connection) | ||||
13 | : connection_(connection), | ||||
14 | is_open_(false) { | ||||
15 | } | ||||
16 | |||||
17 | Transaction::~Transaction() { | ||||
18 | if (is_open_) | ||||
19 | connection_->RollbackTransaction(); | ||||
20 | } | ||||
21 | |||||
22 | bool Transaction::Begin() { | ||||
23 | if (is_open_) { | ||||
24 | NOTREACHED() << "Beginning a transaction twice!"; | ||||
25 | return false; | ||||
26 | } | ||||
27 | is_open_ = connection_->BeginTransaction(); | ||||
28 | return is_open_; | ||||
29 | } | ||||
30 | |||||
31 | void Transaction::Rollback() { | ||||
32 | if (!is_open_) { | ||||
[email protected] | e7afe245 | 2010-08-22 16:19:13 | [diff] [blame] | 33 | NOTREACHED() << "Attempting to roll back a nonexistent transaction. " |
[email protected] | e5ffd0e4 | 2009-09-11 21:30:56 | [diff] [blame] | 34 | << "Did you remember to call Begin() and check its return?"; |
35 | return; | ||||
36 | } | ||||
37 | is_open_ = false; | ||||
38 | connection_->RollbackTransaction(); | ||||
39 | } | ||||
40 | |||||
41 | bool Transaction::Commit() { | ||||
42 | if (!is_open_) { | ||||
[email protected] | e7afe245 | 2010-08-22 16:19:13 | [diff] [blame] | 43 | NOTREACHED() << "Attempting to commit a nonexistent transaction. " |
[email protected] | e5ffd0e4 | 2009-09-11 21:30:56 | [diff] [blame] | 44 | << "Did you remember to call Begin() and check its return?"; |
45 | return false; | ||||
46 | } | ||||
47 | is_open_ = false; | ||||
48 | return connection_->CommitTransaction(); | ||||
49 | } | ||||
50 | |||||
51 | } // namespace sql |