Contents

module FreshConnection
  module Extend
    module ArBase
      def self.extended(base)
        base.class_attribute :slave_connection_handler, :instance_writer => false
        base.slave_connection_handler = FreshConnection::SlaveConnectionHandler.new
      end

      def manage_access(slave_access, &block)
        if master_db_only?
          FreshConnection::AccessControl.force_master_access(&block)
        else
          FreshConnection::AccessControl.access(slave_access, &block)
        end
      end

      def establish_fresh_connection(slave_group = nil)
        slave_connection_handler.establish_connection(name, slave_group)
      end

      def slave_connection
        slave_connection_handler.connection(self)
      end

      def master_db_only!
        @_fresh_connection_master_only = true
      end

      def master_db_only?
        @_fresh_connection_master_only ||
          (self != ActiveRecord::Base && superclass.master_db_only?)
      end

      def put_aside!
        slave_connection_handler.put_aside!
      end

      def recovery(failure_connection, exception)
        slave_connection_handler.recovery(self, failure_connection, exception)
      end

      def slave_group
        slave_connection_handler.slave_group(self)
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
fresh_connection-0.2.6	lib/fresh_connection/extend/ar_base.rb
fresh_connection-0.2.5	lib/fresh_connection/extend/ar_base.rb
fresh_connection-0.2.4	lib/fresh_connection/extend/ar_base.rb
fresh_connection-0.2.3	lib/fresh_connection/extend/ar_base.rb
fresh_connection-0.2.2	lib/fresh_connection/extend/ar_base.rb
fresh_connection-0.2.1	lib/fresh_connection/extend/ar_base.rb
fresh_connection-0.2.0	lib/fresh_connection/extend/ar_base.rb