Class: ROM::SQL::Commands::Create

Inherits:
Commands::Create
  • Object
show all
Includes:
ErrorWrapper, Transaction
Defined in:
lib/rom/sql/commands/create.rb

Instance Method Summary collapse

Methods included from ErrorWrapper

#call

Methods included from Transaction

#transaction

Instance Method Details

#execute(tuples) ⇒ Object 



12
13
14
15
16
17
18
19
20
 
# File 'lib/rom/sql/commands/create.rb', line 12

def execute(tuples)
  insert_tuples = Array([tuples]).flatten.map do |tuple|
    attributes = input[tuple]
    validator.call(attributes)
    attributes.to_h
  end

  insert(insert_tuples)
end

#insert(tuples) ⇒ Object 



22
23
24
25
 
# File 'lib/rom/sql/commands/create.rb', line 22

def insert(tuples)
  pks = tuples.map { |tuple| relation.insert(tuple) }
  relation.where(relation.primary_key => pks)
end