Module: RDF::Repository::Implementation
- Defined in:
- lib/rdf/repository.rb
Overview
A default Repository implementation supporting atomic writes and serializable transactions.
Constant Summary collapse
- DEFAULT_GRAPH =
false
- SerializedTransaction =
Deprecated.
moved to Transaction::SerializedTransaction
RDF::Transaction::SerializedTransaction
Class Method Summary collapse
Instance Method Summary collapse
- #apply_changeset(changeset) ⇒ Object
- #count ⇒ Object
- #each_graph(&block) ⇒ Object
- #each_statement(&block) ⇒ Object (also: #each)
- #graph?(*args) ⇒ Object (also: #has_graph?)
- #graph_names(options = nil, &block) ⇒ Object
- #isolation_level ⇒ Object
-
#snapshot ⇒ Dataset
A readable & queryable snapshot of the repository for isolated reads.
- #statement?(*args) ⇒ Object (also: #has_statement?)
- #supports?(feature) ⇒ Boolean
Class Method Details
.extend_object(obj) ⇒ Object
254 255 256 257 258 259 260 261 |
# File 'lib/rdf/repository.rb', line 254 def self.extend_object(obj) obj.instance_variable_set(:@data, obj..delete(:data) || Hash.new) obj.instance_variable_set(:@tx_class, obj..delete(:transaction_class) || RDF::Transaction::SerializedTransaction) super end |
Instance Method Details
#apply_changeset(changeset) ⇒ Object
369 370 371 372 373 374 375 376 377 378 379 380 381 |
# File 'lib/rdf/repository.rb', line 369 def apply_changeset(changeset) data = @data changeset.deletes.each do |del| if del.constant? data = delete_from(data, del) else # we need this condition to handle wildcard statements query_pattern(del) { |stmt| data = delete_from(data, stmt) } end end changeset.inserts.each { |ins| data = insert_to(data, ins) } @data = data end |
#count ⇒ Object
281 282 283 284 285 286 287 288 289 |
# File 'lib/rdf/repository.rb', line 281 def count count = 0 @data.each do |_, ss| ss.each do |_, ps| ps.each { |_, os| count += os.size } end end count end |
#each_graph(&block) ⇒ Object
321 322 323 324 325 326 327 328 |
# File 'lib/rdf/repository.rb', line 321 def each_graph(&block) if block_given? @data.each_key do |gn| yield RDF::Graph.new(graph_name: (gn == DEFAULT_GRAPH ? nil : gn), data: self) end end enum_graph end |
#each_statement(&block) ⇒ Object Also known as: each
351 352 353 354 355 356 357 358 359 360 361 362 363 364 |
# File 'lib/rdf/repository.rb', line 351 def each_statement(&block) if block_given? @data.each do |g, ss| ss.each do |s, ps| ps.each do |p, os| os.each do |o, | yield RDF::Statement.new(s, p, o, .merge(graph_name: g.equal?(DEFAULT_GRAPH) ? nil : g)) end end end end end enum_statement end |
#graph? ⇒ Boolean #graph?(name) ⇒ Boolean Also known as: has_graph?
302 303 304 305 306 307 308 |
# File 'lib/rdf/repository.rb', line 302 def graph?(*args) case args.length when 0 then false when 1 then @data.key?(args.first) else raise ArgumentError("wrong number of arguments (given #{args.length}, expected 0 or 1)") end end |
#graph_names(options = nil, &block) ⇒ Object
314 315 316 |
# File 'lib/rdf/repository.rb', line 314 def graph_names( = nil, &block) @data.keys.reject { |g| g == DEFAULT_GRAPH }.to_a end |
#isolation_level ⇒ Object
385 386 387 |
# File 'lib/rdf/repository.rb', line 385 def isolation_level :snapshot end |
#snapshot ⇒ Dataset
A readable & queryable snapshot of the repository for isolated reads.
396 397 398 |
# File 'lib/rdf/repository.rb', line 396 def snapshot self.class.new(data: @data).freeze end |
#statement? ⇒ Boolean #statement?(statement) ⇒ Object Also known as: has_statement?
339 340 341 342 343 344 345 |
# File 'lib/rdf/repository.rb', line 339 def statement?(*args) case args.length when 0 then false when 1 then args.first && statement_in?(@data, args.first) else raise ArgumentError("wrong number of arguments (given #{args.length}, expected 0 or 1)") end end |
#supports?(feature) ⇒ Boolean
266 267 268 269 270 271 272 273 274 275 276 |
# File 'lib/rdf/repository.rb', line 266 def supports?(feature) case feature.to_sym when :graph_name then @options[:with_graph_name] when :validity then @options.fetch(:with_validity, true) when :literal_equality then true when :atomic_write then true when :rdfstar then true when :snapshots then true else false end end |