Active Record Savepoint Transaction
Methods
- C
-
- F
-
- M
-
- N
-
- R
-
Class Public methods
new(connection, savepoint_name, parent_transaction, **options)
Link
Source:
show
|
on GitHub
def initialize(connection, savepoint_name, parent_transaction, **options)
super(connection, **options)
parent_transaction.state.add_child(@state)
if isolation_level
raise ActiveRecord::TransactionIsolationError, "cannot set transaction isolation in a nested transaction"
end
@savepoint_name = savepoint_name
end
Instance Public methods
commit()
Link
Source:
show
|
on GitHub
def commit
connection.release_savepoint(savepoint_name) if materialized?
@state.commit!
@instrumenter.finish(:commit) if materialized?
end
materialize!()
Link
Source:
show
|
on GitHub
def materialize!
connection.create_savepoint(savepoint_name)
super
end
restart()
Link
Source:
show
|
on GitHub
def restart
return unless materialized?
@instrumenter.finish(:restart)
@instrumenter.start
connection.rollback_to_savepoint(savepoint_name)
end
rollback()
Link
Source:
show
|
on GitHub
def rollback
unless @state.invalidated?
connection.rollback_to_savepoint(savepoint_name) if materialized?
end
@state.rollback!
@instrumenter.finish(:rollback) if materialized?
end