Contents

#
#
#
class ActiveRecord::Base
  class << self
    def establish_connection_with_activerecord_bulkoperation(*args)
      establish_connection_without_activerecord_bulkoperation(*args)
      ActiveSupport.run_load_hooks(:active_record_connection_established, connection_pool)
    end
    alias_method_chain :establish_connection, :activerecord_bulkoperation
  end
end

ActiveSupport.on_load(:active_record_connection_established) do |connection_pool|
  if !ActiveRecord.const_defined?(:Bulkoperation, false) || !ActiveRecord::Bulkoperation.respond_to?(:load_from_connection_pool)
    require 'activerecord_bulkoperation/base'
  end

  ActiveRecord::Bulkoperation.load_from_connection_pool connection_pool
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
activerecord_bulkoperation-0.0.8	lib/activerecord_bulkoperation.rb
activerecord_bulkoperation-0.0.7	lib/activerecord_bulkoperation.rb
activerecord_bulkoperation-0.0.6	lib/activerecord_bulkoperation.rb
activerecord_bulkoperation-0.0.5	lib/activerecord_bulkoperation.rb
activerecord_bulkoperation-0.0.4	lib/activerecord_bulkoperation.rb
activerecord_bulkoperation-0.0.3	lib/activerecord_bulkoperation.rb
activerecord_bulkoperation-0.0.2	lib/activerecord_bulkoperation.rb