Sha256: 1e93f75df730673c1b8ac5fab25d1dc4658da3261904122bf01fb26456a7c49c
Contents?: true
Size: 1.24 KB
Versions: 15
Compression:
Stored size: 1.24 KB
Contents
# frozen_string_literal: true
require 'rom/commands'
module ROM
module Memory
# Memory adapter commands namespace
#
# @api public
module Commands
# In-memory create command
#
# @api public
class Create < ROM::Commands::Create
adapter :memory
use :schema
# @see ROM::Commands::Create#execute
def execute(tuples)
Array([tuples]).flatten.map { |tuple|
attributes = input[tuple]
relation.insert(attributes.to_h)
attributes
}.to_a
end
end
# In-memory update command
#
# @api public
class Update < ROM::Commands::Update
adapter :memory
use :schema
# @see ROM::Commands::Update#execute
def execute(params)
attributes = input[params]
relation.map { |tuple| tuple.update(attributes.to_h) }
end
end
# In-memory delete command
#
# @api public
class Delete < ROM::Commands::Delete
adapter :memory
# @see ROM::Commands::Delete#execute
def execute
relation.to_a.map do |tuple|
source.delete(tuple)
tuple
end
end
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems