class Upsert::MergeFunction::PG_Connection

@private

Constants

ERROR_CLASS

Public Instance Methods

execute_parameterized(query, args = []) click to toggle source
# File lib/upsert/merge_function/PG_Connection.rb, line 10
def execute_parameterized(query, args = [])
  controller.connection.execute(query, args)
end
unique_index_on_selector?() click to toggle source
# File lib/upsert/merge_function/PG_Connection.rb, line 14
def unique_index_on_selector?
  return @unique_index_on_selector if defined?(@unique_index_on_selector)

  type_map = PG::TypeMapByColumn.new([PG::TextDecoder::Array.new])
  res = unique_index_columns.tap { |r| r.type_map = type_map }

  @unique_index_on_selector = res.values.any? do |row|
    row.first.sort == selector_keys.sort
  end
end