Contents

module FreshConnection
  class ConnectionManager
    def initialize
      @mutex = Mutex.new
    end

    def slave_connection
      @mutex.synchronize do
        @slave_connections ||= {}
        @slave_connections[current_thread_id] ||= new_connection
      end
    end

    def put_aside!
      @mutex.synchronize do
        if @slave_connections.present?
          @slave_connections.each_value{|c| c && c.disconnect! rescue nil}
        end
        @slave_connections = {}
      end
    end

    private

    def new_connection
      ActiveRecord::Base.send("#{spec["adapter"]}_connection", spec)
    end

    def spec
      @spec ||= get_spec
    end

    def get_spec
      ret = ActiveRecord::Base.configurations[Rails.env]
      ret.merge(ret["slave"] || {})
    end

    def current_thread_id
      Thread.current.object_id
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
fresh_connection-0.1.5	lib/fresh_connection/connection_manager.rb
fresh_connection-0.1.4	lib/fresh_connection/connection_manager.rb
fresh_connection-0.1.3	lib/fresh_connection/connection_manager.rb