Module: ActiveRecord::ConnectionAdapters::Trilogy::DatabaseStatements

Included in:
ActiveRecord::ConnectionAdapters::TrilogyAdapter
Defined in:
activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb

Instance Method Summary collapse

Instance Method Details

#_exec_insert(intent, pk = nil, sequence_name = nil, returning: nil) ⇒ Object

:nodoc:



7
8
9
10
11
12
13
14
15
16
# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 7

def _exec_insert(intent, pk = nil, sequence_name = nil, returning: nil) # :nodoc:
  sql, binds = sql_for_insert(intent.raw_sql, pk, intent.binds, returning)
  intent.raw_sql = sql
  intent.binds = binds

  # AbstractAdapter calls cast_result (returning an AR::Result), but
  # our last_inserted_id needs the raw Trilogy result object
  intent.execute!
  intent.raw_result
end

#execute_batch(statements, name = nil, **kwargs) ⇒ Object

:nodoc:



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
# File 'activerecord/lib/active_record/connection_adapters/trilogy/database_statements.rb', line 18

def execute_batch(statements, name = nil, **kwargs) # :nodoc:
  combine_multi_statements(statements).each do |statement|
    intent = QueryIntent.new(
      adapter: self,
      processed_sql: statement,
      name: name,
      batch: true,
      binds: kwargs[:binds] || [],
      prepare: kwargs[:prepare] || false,
      allow_async: kwargs[:async] || false,
      allow_retry: kwargs[:allow_retry] || false,
      materialize_transactions: kwargs[:materialize_transactions] != false
    )
    intent.execute!
    intent.finish
  end
end