Class: RDF::Repository
- Includes:
- Mutable, Transactable
- Defined in:
- vendor/bundler/ruby/3.3.0/bundler/gems/rdf-cfdeb1f47544/lib/rdf/repository.rb
Overview
An RDF repository.
Repositories support transactions with a variety of ACID semantics:
Atomicity is indicated by #supports?(:atomic_write)
. When atomicity is
supported, writes through Transactable#transaction, Mutable#apply_changeset and
#delete_insert are applied atomically.
Consistency should be guaranteed, in general. Repositories that don't support consistency, or that have specialized definitions of consistency above those declared by the RDF data model, should advertise this fact in their documentation.
Isolation may be supported at various levels, indicated by #isolation_level:
:read_uncommitted
: Inserts & deletes in an uncommitted transaction scope may be visible to other transactions (or via#each
, etc...):read_committed
: Inserts & deletes may be visible to other transactions once committed:repeatable_read
: Phantom reads may be possible:snapshot
: A transaction reads a consistent snapshot of the data. Write skew anomalies may occur (for various definitions of consistency):serializable
: A transaction reads a consistent snapshot of the data. When two or more transactions attempt conflicting writes, only one of them may succeed.
Durability is noted via Durable support and Dataset#durable? /Durable#nondurable?.
Direct Known Subclasses
DataObjects::Repository, HamsterRepo, N3::Repository, OrderedRepo, SPARQL::Client::Repository
Defined Under Namespace
Modules: Implementation
Constant Summary collapse
- DEFAULT_TX_CLASS =
RDF::Transaction
Constants inherited from Dataset
Dataset::DEFAULT_GRAPH, Dataset::ISOLATION_LEVELS
Instance Attribute Summary collapse
-
#options ⇒ Hash{Symbol => Object}
readonly
Returns the options passed to this repository when it was constructed.
-
#title ⇒ String
readonly
Returns the title of this repository.
-
#uri ⇒ URI
(also: #url)
readonly
Returns the URI of this repository.
Attributes included from Enumerable
Class Method Summary collapse
-
.load(urls, **options) {|repository| ... }
Loads one or more RDF files into a new transient in-memory repository.
Instance Method Summary collapse
-
#delete_insert(deletes, inserts) ⇒ Object
Performs a set of deletes and inserts as a combined operation within a transaction.
-
#initialize(uri: nil, title: nil, **options) {|repository| ... } ⇒ Repository
constructor
Initializes this repository instance.
- #isolation_level ⇒ Object
-
#snapshot ⇒ Dataset
A queryable snapshot of the repository for isolated reads.
-
#supports?(feature) ⇒ Boolean
Returns
true
if this respository supports the givenfeature
.
Methods included from Transactable
#commit_transaction, #rollback_transaction, #transaction
Methods included from Mutable
#<<, add_entailment, #apply_changeset, #clear, #delete, #delete_statement, #delete_statements, #entail, #entail!, #immutable?, #insert, #load, #method_missing, #mutable?, #respond_to_missing?, #update
Methods included from Util::Aliasing::LateBound
Methods included from Util::Coercions
Methods included from Writable
#<<, #insert, #insert_graph, #insert_reader, #insert_statement, #insert_statements, #writable?
Methods included from Readable
Methods inherited from Dataset
#inspect, #inspect!, #query_pattern
Methods included from Queryable
#concise_bounded_description, #first, #first_literal, #first_object, #first_predicate, #first_subject, #first_value, #lint, #query, #query_execute, #query_pattern, #query_without_sparql, #to_sparql
Methods included from Durable
Methods included from Enumerable
add_entailment, #canonicalize, #canonicalize!, #dump, #each_graph, #each_object, #each_predicate, #each_quad, #each_statement, #each_subject, #each_term, #each_triple, #entail, #enum_graph, #enum_object, #enum_predicate, #enum_quad, #enum_statement, #enum_subject, #enum_term, #enum_triple, #graph?, #graph_names, #invalid?, #method_missing, #object?, #objects, #predicate?, #predicates, #quad?, #quads, #respond_to_missing?, #statement?, #statements, #subject?, #subjects, #term?, #terms, #to_a, #to_h, #to_set, #triple?, #triples, #valid?, #validate!
Methods included from Isomorphic
#bijection_to, #isomorphic_with?
Methods included from Countable
Constructor Details
#initialize(uri: nil, title: nil, **options) {|repository| ... } ⇒ Repository
Initializes this repository instance.
151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 |
# File 'vendor/bundler/ruby/3.3.0/bundler/gems/rdf-cfdeb1f47544/lib/rdf/repository.rb', line 151 def initialize(uri: nil, title: nil, **, &block) @options = {with_graph_name: true, with_validity: true}.merge() @uri = uri @title = title # Provide a default in-memory implementation: send(:extend, Implementation) if self.class.equal?(RDF::Repository) @tx_class ||= @options.delete(:transaction_class) { DEFAULT_TX_CLASS } if block_given? case block.arity when 1 then block.call(self) else instance_eval(&block) end end end |
Dynamic Method Handling
This class handles dynamic methods through the method_missing method in the class RDF::Mutable
Instance Attribute Details
#options ⇒ Hash{Symbol => Object} (readonly)
Returns the options passed to this repository when it was constructed.
97 98 99 |
# File 'vendor/bundler/ruby/3.3.0/bundler/gems/rdf-cfdeb1f47544/lib/rdf/repository.rb', line 97 def @options end |
#title ⇒ String (readonly)
Returns the title of this repository.
110 111 112 |
# File 'vendor/bundler/ruby/3.3.0/bundler/gems/rdf-cfdeb1f47544/lib/rdf/repository.rb', line 110 def title @title end |
Class Method Details
.load(urls, **options) {|repository| ... }
This method returns an undefined value.
Loads one or more RDF files into a new transient in-memory repository.
121 122 123 124 125 126 127 128 129 130 131 132 133 134 |
# File 'vendor/bundler/ruby/3.3.0/bundler/gems/rdf-cfdeb1f47544/lib/rdf/repository.rb', line 121 def self.load(urls, **, &block) self.new(**) do |repository| Array(urls).each do |url| repository.load(url, **) end if block_given? case block.arity when 1 then block.call(repository) else repository.instance_eval(&block) end end end end |
Instance Method Details
#delete_insert(deletes, inserts) ⇒ Object
Performs a set of deletes and inserts as a combined operation within a transaction. The Repository's transaction semantics apply to updates made through this method.
200 201 202 203 204 205 206 207 |
# File 'vendor/bundler/ruby/3.3.0/bundler/gems/rdf-cfdeb1f47544/lib/rdf/repository.rb', line 200 def delete_insert(deletes, inserts) return super unless supports?(:atomic_write) transaction(mutable: true) do deletes.respond_to?(:each_statement) ? delete(deletes) : delete(*deletes) inserts.respond_to?(:each_statement) ? insert(inserts) : insert(*inserts) end end |
#isolation_level ⇒ Object
220 221 222 |
# File 'vendor/bundler/ruby/3.3.0/bundler/gems/rdf-cfdeb1f47544/lib/rdf/repository.rb', line 220 def isolation_level supports?(:snapshots) ? :repeatable_read : super end |
#snapshot ⇒ Dataset
A queryable snapshot of the repository for isolated reads.
229 230 231 |
# File 'vendor/bundler/ruby/3.3.0/bundler/gems/rdf-cfdeb1f47544/lib/rdf/repository.rb', line 229 def snapshot raise NotImplementedError.new("#{self.class}#snapshot") end |
#supports?(feature) ⇒ Boolean
Returns true
if this respository supports the given feature
.
Supported features include those from Enumerable#supports? along with the following:
:atomic_write
supports atomic write in transaction scopes:snapshots
supports creation of immutable snapshots of current contents via #snapshot.
178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 |
# File 'vendor/bundler/ruby/3.3.0/bundler/gems/rdf-cfdeb1f47544/lib/rdf/repository.rb', line 178 def supports?(feature) case feature.to_sym when :graph_name then @options[:with_graph_name] when :inference then false # forward-chaining inference when :validity then @options.fetch(:with_validity, true) when :literal_equality then true when :atomic_write then false when :rdf_full then false # FIXME: quoted triples are now deprecated when :quoted_triples then false when :base_direction then false when :snapshots then false else false end end |