Contents

# frozen_string_literal: true

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 :prepend, SQLServerTransaction

    module SQLServerRealTransaction
      attr_reader :starting_isolation_level

      def initialize(connection, options, **args)
        @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 :prepend, SQLServerRealTransaction
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
activerecord-sqlserver-adapter-6.0.3	lib/active_record/connection_adapters/sqlserver/transaction.rb
activerecord-sqlserver-adapter-6.0.2	lib/active_record/connection_adapters/sqlserver/transaction.rb
activerecord-sqlserver-adapter-6.0.1	lib/active_record/connection_adapters/sqlserver/transaction.rb
activerecord-sqlserver-adapter-6.0.0	lib/active_record/connection_adapters/sqlserver/transaction.rb
activerecord-sqlserver-adapter-6.0.0.rc2	lib/active_record/connection_adapters/sqlserver/transaction.rb