Module: ActiveRecord::Import::ActiveRecordProxyAdapter

Included in:
Mysql2ProxyAdapter, PostgreSQLProxyAdapter, SQLite3ProxyAdapter, TrilogyProxyAdapter
Defined in:
lib/activerecord-import/adapters/active_record_proxy_adapter.rb

Instance Method Summary collapse

Instance Method Details

#insert(*args, **kwargs, &block) ⇒ Object 



8
9
10
 
# File 'lib/activerecord-import/adapters/active_record_proxy_adapter.rb', line 8

def insert(*args, **kwargs, &block)
  sticking_to_primary { super(*args, **kwargs, &block) }
end

#insert_many(*args, **kwargs, &block) ⇒ Object 



4
5
6
 
# File 'lib/activerecord-import/adapters/active_record_proxy_adapter.rb', line 4

def insert_many(*args, **kwargs, &block)
  sticking_to_primary { super(*args, **kwargs, &block) }
end

#sticking_to_primary(&block) ⇒ Object 



12
13
14
 
# File 'lib/activerecord-import/adapters/active_record_proxy_adapter.rb', line 12

def sticking_to_primary(&block)
  ActiveRecord::Base.connected_to(role: writing_role, &block)
end

#writing_role ⇒ Object 



16
17
18
 
# File 'lib/activerecord-import/adapters/active_record_proxy_adapter.rb', line 16

def writing_role
  ActiveRecord.try(:writing_role) || ActiveRecord::Base.try(:writing_role) || :writing
end