Contents

module Tako
  module ActiveRecordExt
    module ConnectionHandling
      def connection
        return Tako::Repository.create_proxy(@force_shard).connection if force_shard?
        if Tako::ProxyStack.top
          Tako::ProxyStack.top.connection
        else
          super
        end
      end
    end
  end
end

ActiveRecord::ConnectionHandling.class_eval do
  alias_method :connection_without_tako, :connection
  prepend Tako::ActiveRecordExt::ConnectionHandling
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
tako-0.6.0	lib/tako/active_record_ext/connection_handling.rb