Sha256: 98fe169e1ef06063487b49a4e79514494398b6d21cd5979830dc4acf5113f31a
Contents?: true
Size: 1.98 KB
Versions: 16
Compression:
Stored size: 1.98 KB
Contents
module LD::Patch::Algebra
##
# The LD Patch `add` operator.
#
# The Add operation is used to add triples to the target graph with or without allowing duplicates.
#
# @example
# (add ((<a> <b> <c>)))
#
class Add < SPARQL::Algebra::Operator::Unary
include SPARQL::Algebra::Update
include SPARQL::Algebra::Evaluatable
NAME = :add
##
# Executes this upate on the given `writable` graph or repository.
#
# @param [RDF::Queryable] queryable
# the graph or repository to write
# @param [Hash{Symbol => Object}] options
# any additional options
# @option options [Boolean] :new
# Specifies that triples may not already exist in the target graph
# @return [RDF::Query::Solutions] A single solution including passed bindings with `var` bound to the solution.
# @raise [Error]
# If the :new option is specified and any triples already exist in queryable or if unbound variables are used
# @see http://www.w3.org/TR/sparql11-update/
def execute(queryable, options = {})
debug(options) {"Add"}
bindings = options.fetch(:bindings)
solution = bindings.first
# Bind variables to triples
triples = operand(0).dup.replace_vars! do |var|
case var
when RDF::Query::Pattern
s = var.bind(solution)
raise LD::Patch::Error.new("Operand uses unbound pattern #{var.inspect}", code: 400) if s.variable?
s
when RDF::Query::Variable
raise LD::Patch::Error.new("Operand uses unbound variable #{var.inspect}", code: 400) unless solution.bound?(var)
solution[var]
end
end
# If `:new` is specified, verify that no triple in triples exists in queryable
if @options[:new]
triples.each do |triple|
raise LD::Patch::Error, "Target graph contains added triple #{triple.to_ntriples}" if queryable.has_statement?(triple)
end
end
queryable.insert(*triples)
bindings
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems