module ActiveRecord::Import::Connection

def establish_connection(args = nil)
  conn = super(args)
  ActiveRecord::Import.load_from_connection_pool connection_pool
  conn
end