class ActiveRecord::ConnectionAdapters::SavepointTransaction
def commit
def commit connection.release_savepoint(savepoint_name) if materialized? @state.commit! @instrumenter.finish(:commit) if materialized? end
def full_rollback?; false; end
def full_rollback?; false; end
def initialize(connection, savepoint_name, parent_transaction, **options)
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
def materialize!
def materialize! connection.create_savepoint(savepoint_name) super end
def restart
def restart return unless materialized? @instrumenter.finish(:restart) @instrumenter.start connection.rollback_to_savepoint(savepoint_name) end
def rollback
def rollback unless @state.invalidated? connection.rollback_to_savepoint(savepoint_name) if materialized? && connection.active? end @state.rollback! @instrumenter.finish(:rollback) if materialized? end