Contents

module ActiveRecord
  class Relation
    private

    def exec_queries_with_slave_connection
      return @records if loaded?

      FreshConnection::SlaveConnection.manage_access(@klass, go_slave?) do
        exec_queries_without_slave_connection
      end
    end
    alias_method_chain :exec_queries, :slave_connection

    if Rails.version.to_f > 3
      def go_slave?
        connection.open_transactions == 0 && (readonly_value.nil? || readonly_value)
      end
    else
      def go_slave?
        connection.open_transactions == 0 && (@readonly_value.nil? || @readonly_value)
      end
    end
  end

  module Calculations
    def calculate_with_slave_connection(operation, column_name, options = {})
      FreshConnection::SlaveConnection.manage_access(@klass, (go_slave? && options[:readonly] != false)) do
        calculate_without_slave_connection(operation, column_name, options)
      end
    end
    alias_method_chain :calculate, :slave_connection
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
fresh_connection-0.1.8	lib/fresh_connection/active_record/relation.rb
fresh_connection-0.1.7	lib/fresh_connection/active_record/relation.rb
fresh_connection-0.1.6	lib/fresh_connection/active_record/relation.rb
fresh_connection-0.1.5	lib/fresh_connection/active_record/relation.rb