aboutsummaryrefslogtreecommitdiffstats
path: root/activerecord/lib
diff options
context:
space:
mode:
authorHongli Lai (Phusion) <hongli@phusion.nl>2008-10-09 14:31:23 +0200
committerHongli Lai (Phusion) <hongli@phusion.nl>2008-11-03 20:55:47 +0100
commit47b594cc5a2adc86e14a6a3d331583edde56a22f (patch)
tree502aa1dbc5437e05729997ed0d72f7d5096509d4 /activerecord/lib
parent3f4a8b6d0a6c1ddab417b8d19affdc1e9f9209ba (diff)
downloadrails-47b594cc5a2adc86e14a6a3d331583edde56a22f.tar.gz
rails-47b594cc5a2adc86e14a6a3d331583edde56a22f.tar.bz2
rails-47b594cc5a2adc86e14a6a3d331583edde56a22f.zip
Improve documentation for DatabaseStatements#transactions and AbstractAdapter#transactional_fixtures, especially with regard to support for nested transactions.
Diffstat (limited to 'activerecord/lib')
-rw-r--r--activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb75
-rwxr-xr-xactiverecord/lib/active_record/connection_adapters/abstract_adapter.rb3
-rw-r--r--activerecord/lib/active_record/transactions.rb2
3 files changed, 74 insertions, 6 deletions
diff --git a/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb b/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb
index f23fe5a90c..bd434f2efc 100644
--- a/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb
+++ b/activerecord/lib/active_record/connection_adapters/abstract/database_statements.rb
@@ -54,14 +54,65 @@ module ActiveRecord
delete_sql(sql, name)
end
- # Wrap a block in a transaction. Returns result of block.
+ # Runs the given block in a database transaction, and returns the result
+ # of the block.
+ #
+ # == Nested transactions support
+ #
+ # Most databases don't support true nested transactions. At the time of
+ # writing, the only database that supports true nested transactions that
+ # we're aware of, is MS-SQL.
+ #
+ # In order to get around this problem, #transaction will emulate the effect
+ # of nested transactions, by using savepoints:
+ # http://dev.mysql.com/doc/refman/5.0/en/savepoints.html
+ # Savepoints are supported by MySQL and PostgreSQL, but not SQLite3.
+ #
+ # It is safe to call this method if a database transaction is already open,
+ # i.e. if #transaction is called within another #transaction block. In case
+ # of a nested call, #transaction will behave as follows:
+ #
+ # - The block will be run without doing anything. All database statements
+ # that happen within the block are effectively appended to the already
+ # open database transaction.
+ # - However, if +start_db_transaction+ is set to true, then the block will
+ # be run inside a new database savepoint, effectively making the block
+ # a sub-transaction.
+ # - If the #transactional_fixtures attribute is set to true, then the first
+ # nested call to #transaction will create a new savepoint instead of
+ # doing nothing. This makes it possible for toplevel transactions in unit
+ # tests to behave like real transactions, even though a database
+ # transaction has already been opened.
+ #
+ # === Caveats
+ #
+ # MySQL doesn't support DDL transactions. If you perform a DDL operation,
+ # then any created savepoints will be automatically released. For example,
+ # if you've created a savepoint, then you execute a CREATE TABLE statement,
+ # then the savepoint that was created will be automatically released.
+ #
+ # This means that, on MySQL, you shouldn't execute DDL operations inside
+ # a #transaction call that you know might create a savepoint. Otherwise,
+ # #transaction will raise exceptions when it tries to release the
+ # already-automatically-released savepoints:
+ #
+ # Model.connection.transaction do # BEGIN
+ # Model.connection.transaction(true) do # CREATE SAVEPOINT rails_savepoint_1
+ # Model.connection.create_table(...)
+ # # rails_savepoint_1 now automatically released
+ # end # RELEASE savepoint rails_savepoint_1 <--- BOOM! database error!
+ # end
def transaction(start_db_transaction = false)
- start_db_transaction ||= open_transactions.zero? || (open_transactions == 1 && transactional_fixtures)
+ start_db_transaction ||= open_transactions == 0 || (open_transactions == 1 && transactional_fixtures)
transaction_open = false
begin
if block_given?
if start_db_transaction
- open_transactions.zero? ? begin_db_transaction : create_savepoint
+ if open_transactions == 0
+ begin_db_transaction
+ else
+ create_savepoint
+ end
increment_open_transactions
transaction_open = true
end
@@ -71,7 +122,11 @@ module ActiveRecord
if transaction_open
transaction_open = false
decrement_open_transactions
- open_transactions.zero? ? rollback_db_transaction : rollback_to_savepoint
+ if open_transactions == 0
+ rollback_db_transaction
+ else
+ rollback_to_savepoint
+ end
end
raise unless database_transaction_rollback.is_a? ActiveRecord::Rollback
end
@@ -79,9 +134,17 @@ module ActiveRecord
if transaction_open
decrement_open_transactions
begin
- open_transactions.zero? ? commit_db_transaction : release_savepoint
+ if open_transactions == 0
+ commit_db_transaction
+ else
+ release_savepoint
+ end
rescue Exception => database_transaction_rollback
- open_transactions.zero? ? rollback_db_transaction : rollback_to_savepoint
+ if open_transactions == 0
+ rollback_db_transaction
+ else
+ rollback_to_savepoint
+ end
raise
end
end
diff --git a/activerecord/lib/active_record/connection_adapters/abstract_adapter.rb b/activerecord/lib/active_record/connection_adapters/abstract_adapter.rb
index cb5c5740c3..45a6cff346 100755
--- a/activerecord/lib/active_record/connection_adapters/abstract_adapter.rb
+++ b/activerecord/lib/active_record/connection_adapters/abstract_adapter.rb
@@ -173,6 +173,9 @@ module ActiveRecord
"rails_savepoint_#{open_transactions}"
end
+ # Whether this AbstractAdapter is currently being used inside a unit test
+ # with transactional fixtures turned on. See DatabaseStatements#transaction
+ # for more information about the effect of this option.
attr_accessor :transactional_fixtures
def log_info(sql, name, seconds)
diff --git a/activerecord/lib/active_record/transactions.rb b/activerecord/lib/active_record/transactions.rb
index 56b62474d9..4bac7b39d9 100644
--- a/activerecord/lib/active_record/transactions.rb
+++ b/activerecord/lib/active_record/transactions.rb
@@ -125,6 +125,8 @@ module ActiveRecord
def transaction(options = {}, &block)
options.assert_valid_keys :force
+ # See the API documentation for ConnectionAdapters::DatabaseStatements#transaction
+ # for useful information.
connection.transaction(options[:force], &block)
end
end