Sha256: 00ef06f6508f392eff49971a99b1bac930056c496457f8c79e6225cf34c6ce73
Contents?: true
Size: 768 Bytes
Versions: 7
Compression:
Stored size: 768 Bytes
Contents
# frozen_string_literal: true
module TableSaw
module Queries
class ExecuteInsertStatement
attr_reader :statement, :row
def initialize(statement, row)
@statement = statement
@row = row
end
def call
"EXECUTE #{statement.name}(#{values});"
end
private
def values
TableSaw.schema_cache.columns(statement.table_name).zip(row)
.map { |column, value| quote_value(column, value) }
.join(', ')
end
def connection
TableSaw.schema_cache.connection
end
def quote_value(column, value)
type = connection.lookup_cast_type_from_column(column)
connection.quote(type.serialize(type.deserialize(value)))
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems