Sha256: 72121ded4520175d1e835fde868af82ae25f8af5891217ed5bbcacffd46cd2f8
Contents?: true
Size: 1.72 KB
Versions: 13
Compression:
Stored size: 1.72 KB
Contents
# frozen_string_literal: true
require 'rom/sql/commands/error_wrapper'
module ROM
module SQL
module Commands
# SQL create command
#
# @api public
class Create < ROM::Commands::Create
adapter :sql
include ErrorWrapper
use :associates
use :schema
after :finalize
# Inserts provided tuples into the database table
#
# @api public
def execute(tuples)
insert_tuples = with_input_tuples(tuples) do |tuple|
attributes = input[tuple]
attributes.to_h
end
if insert_tuples.length > 1
multi_insert(insert_tuples)
else
insert(insert_tuples)
end
end
private
# @api private
def finalize(tuples, *)
tuples.map { |t| relation.output_schema[t] }
end
# Executes insert statement and returns inserted tuples
#
# @api private
def insert(tuples)
pks = tuples.map { |tuple| relation.insert(tuple) }
relation.where(relation.primary_key => pks).to_a
end
# Executes multi_insert statement and returns inserted tuples
#
# @api private
def multi_insert(tuples)
pks = relation.multi_insert(tuples, return: :primary_key)
relation.where(relation.primary_key => pks).to_a
end
# Yields tuples for insertion or return an enumerator
#
# @api private
def with_input_tuples(tuples)
input_tuples = Array([tuples]).flatten(1).map
return input_tuples unless block_given?
input_tuples.each { |tuple| yield(tuple) }
end
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems