Contents

module Slaver
  class PoolsHandler
    include Singleton

    def pools
      @pools ||= {}
    end

    def for_config(klass, config_name)
      @klass = klass

      initialize_pool(config_name) unless pools[config_name]

      self
    end

    private

    def initialize_pool(config_name)
      if config_name == Rails.env
        pools[config_name] = @klass.connection_pool_without_proxy
      else
        pools[config_name] = create_connection_pool(config_name)
      end
    end

    def create_connection_pool(config_name)
      config = ::ActiveRecord::Base.configurations[config_name]
      config.symbolize_keys!
      if ActiveRecord::VERSION::MAJOR < 4
        spec = ActiveRecord::Base::ConnectionSpecification.new(config, "#{config[:adapter]}_connection")
      else
        spec = ActiveRecord::ConnectionAdapters::ConnectionSpecification.new(config, "#{config[:adapter]}_connection")
      end

      ActiveRecord::ConnectionAdapters::ConnectionPool.new(spec)
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
slaver-0.2.3	lib/slaver/pools_handler.rb
slaver-0.2.2	lib/slaver/pools_handler.rb
slaver-0.2.0	lib/slaver/pools_handler.rb