Sha256: ed92e4bb9f216deafaed20d8dabee76837ac8373f561070c1f95eaedd2baa2a4
Contents?: true
Size: 1.39 KB
Versions: 11
Compression:
Stored size: 1.39 KB
Contents
class Upsert
class MergeFunction
# @private
module Sqlite3
attr_reader :quoted_setter_names
attr_reader :quoted_update_names
attr_reader :quoted_selector_names
def initialize(*)
super
@quoted_setter_names = setter_keys.map { |k| connection.quote_ident k }
@quoted_update_names = setter_keys.select { |k| k !~ CREATED_COL_REGEX }.map { |k| connection.quote_ident k }
@quoted_selector_names = selector_keys.map { |k| connection.quote_ident k }
end
def create!
# not necessary
end
def execute(row)
bind_setter_values = row.setter.values.map { |v| connection.bind_value v }
bind_selector_values = row.selector.values.map { |v| connection.bind_value v }
bind_update_values = row.setter.select{ |k,v| k !~ CREATED_COL_REGEX }.map { |k,v| connection.bind_value v }
insert_or_ignore_sql = %{INSERT OR IGNORE INTO #{quoted_table_name} (#{quoted_setter_names.join(',')}) VALUES (#{Array.new(bind_setter_values.length, '?').join(',')})}
connection.execute insert_or_ignore_sql, bind_setter_values
update_sql = %{UPDATE #{quoted_table_name} SET #{quoted_update_names.map { |qk| "#{qk}=?" }.join(',')} WHERE #{quoted_selector_names.map { |qk| "#{qk}=?" }.join(' AND ')}}
connection.execute update_sql, (bind_update_values + bind_selector_values)
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems