Sha256: 88eb67e4e011e7b31ab296b8fe77861da585932fd58cb2fb124431bb5a6ee947
Contents?: true
Size: 1.49 KB
Versions: 15
Compression:
Stored size: 1.49 KB
Contents
require 'active_record/connection_adapters/abstract/transaction'
module ActiveRecord
module ConnectionAdapters
module SQLServerTransaction
private
def sqlserver?
connection.respond_to?(:sqlserver?) && connection.sqlserver?
end
def current_isolation_level
return unless sqlserver?
level = connection.user_options_isolation_level
# When READ_COMMITTED_SNAPSHOT is set to ON,
# user_options_isolation_level will be equal to 'read committed
# snapshot' which is not a valid isolation level
if level.blank? || level == 'read committed snapshot'
'READ COMMITTED'
else
level.upcase
end
end
end
Transaction.send :include, SQLServerTransaction
module SQLServerRealTransaction
attr_reader :starting_isolation_level
def initialize(connection, options, run_commit_callbacks: false)
@connection = connection
@starting_isolation_level = current_isolation_level if options[:isolation]
super
end
def commit
super
reset_starting_isolation_level
end
def rollback
super
reset_starting_isolation_level
end
private
def reset_starting_isolation_level
if sqlserver? && starting_isolation_level
connection.set_transaction_isolation_level(starting_isolation_level)
end
end
end
RealTransaction.send :include, SQLServerRealTransaction
end
end
Version data entries
15 entries across 15 versions & 2 rubygems