class Baza::SqlQueries::NonAtomicUpsert

Public Class Methods

new(args) click to toggle source
# File lib/baza/sql_queries/non_atomic_upsert.rb, line 2
def initialize(args)
  @db = args.fetch(:db)
  @table_name = args.fetch(:table_name)
  @updates = args.fetch(:updates)
  @terms = args.fetch(:terms)
  @buffer = args[:buffer]
end

Public Instance Methods

execute() click to toggle source
# File lib/baza/sql_queries/non_atomic_upsert.rb, line 10
def execute
  row = @db.single(@table_name, @terms)

  if @buffer
    obj = @buffer
  else
    obj = @db
  end

  if row
    obj.update(@table_name, @updates, @terms)
  else
    obj.insert(@table_name, @terms.merge(@updates))
  end
end