Sha256: ed87ffd489c206d00370388cb1e772f84f0d8e0a7c1281845104ee95dd92868e
Contents?: true
Size: 1.67 KB
Versions: 15
Compression:
Stored size: 1.67 KB
Contents
module SPARQL; module Algebra
##
# A SPARQL algebra Update can make modifications to it's dataset
#
# Mixin with SPARQL::Algebra::Operator to provide update-like operations on graphs
#
# @abstract
module Update
##
# Prepends an operator.
#
# @param [RDF::Query] query
# a query
# @return [void] self
def unshift(query)
@operands.unshift(query)
self
end
##
# The variables used in this update.
#
# @return [Hash{Symbol => RDF::Query::Variable}]
def variables
operands.inject({}) {|hash, o| o.executable? ? hash.merge(o.variables) : hash}
end
##
# Executes this upate on the given `queryable` graph or repository.
#
# @param [RDF::Writable] queryable
# the graph or repository to write
# @param [Hash{Symbol => Object}] options
# any additional keyword options
# @option options [Boolean] debug
# Query execution debugging
# @return [RDF::Writable]
# Returns the dataset.
# @raise [NotImplementedError]
# If an attempt is made to perform an unsupported operation
# @see https://www.w3.org/TR/sparql11-update/
def execute(queryable, **options, &block)
raise NotImplementedError, "#{self.class}#execute(#{queryable})"
end
# Add graph_name to sub-items, unless they already have a graph_name
# @param [RDF::URI, RDF::Query::Variable] value
# @return [RDF::URI, RDF::Query::Variable]
def graph_name=(value)
operands.each do |operand|
operand.graph_name = value if operand.respond_to?(:graph_name) && operand.graph_name != false
end
value
end
end # Query
end; end # SPARQL::Algebra
Version data entries
15 entries across 15 versions & 1 rubygems