Sha256: 21b978d0adf20f2ddf513c22efb7c61605f318639f0e67783c18f3ee554c748a
Contents?: true
Size: 500 Bytes
Versions: 19
Compression:
Stored size: 500 Bytes
Contents
class Baza::SqlQueries::NonAtomicUpsert
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
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
end
Version data entries
19 entries across 19 versions & 1 rubygems