Class: RDF::Repository

Inherits:

Object

• Object
• RDF::Repository

show all

Includes:

Countable, Durable, Enumerable, Mutable, Queryable

Defined in:

lib/rdf/repository.rb

Overview

repository = RDF::Repository.new

repository.readable?
repository.writable?

repository.persistent?
repository.transient?

repository.empty?

repository.count

repository.has_statement?(statement)

repository.each_statement { |statement| statement.inspect! }

repository.insert(*statements)
repository.insert(statement)
repository.insert([subject, predicate, object])
repository << statement
repository << [subject, predicate, object]

repository.delete(*statements)
repository.delete(statement)
repository.delete([subject, predicate, object])

repository.clear!

Defined Under Namespace

Modules: Implementation

Instance Attribute Summary (collapse)

• - (Hash{Symbol => Object}) options readonly

  Returns the options passed to this repository when it was constructed.

• - (String) title readonly

  Returns the title of this repository.

• - (URI) uri (also: #url) readonly

  Returns the URI of this repository.

Class Method Summary (collapse)

• + load(filenames, options = {}) {|repository| ... }

  Loads one or more RDF files into a new transient in-memory repository.

Instance Method Summary (collapse)

• - (RDF::Transaction) begin_transaction(context) protected

  Begins a new transaction.

• - commit_transaction(tx) protected

  Commits the given transaction.

• - (Repository) initialize(options = {}) {|repository| ... } constructor

  Initializes this repository instance.

• - (String) inspect

  Returns a developer-friendly representation of this object.

• - inspect!

  Outputs a developer-friendly representation of this object to stderr.

• - rollback_transaction(tx) protected

  Rolls back the given transaction.

• - (Boolean) supports?(feature)

  Returns true if this repository supports the given feature.

• - transaction(context = nil) {|tx| ... } (also: #transact)

  Executes the given block in a transaction.

Methods included from Durable

#durable?, #nondurable?

Methods included from Util::Aliasing::LateBound

#alias_method

Methods included from Mutable

#<<, #clear, #delete, #delete_statement, #delete_statements, #immutable?, #insert, #load, #mutable?, #update

Methods included from Writable

#<<, #insert, #insert_graph, #insert_reader, #insert_statement, #insert_statements, #writable?

Methods included from Readable

#readable?

Methods included from Queryable

#first, #first_literal, #first_object, #first_predicate, #first_subject, #first_value, #query, #query_execute, #query_pattern

Methods included from Enumerable

#contexts, #dump, #each_context, #each_graph, #each_object, #each_predicate, #each_quad, #each_statement, #each_subject, #each_triple, #enum_context, #enum_graph, #enum_object, #enum_predicate, #enum_quad, #enum_statement, #enum_subject, #enum_triple, #has_context?, #has_object?, #has_predicate?, #has_quad?, #has_statement?, #has_subject?, #has_triple?, #objects, #predicates, #quads, #statements, #subjects, #to_a, #to_hash, #to_set, #triples

Methods included from Countable

#count, #empty?

99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

# File 'lib/rdf/repository.rb', line 99

def initialize(options = {}, &block)
  @options = options.dup
  @uri     = @options.delete(:uri)
  @title   = @options.delete(:title)

  # Provide a default in-memory implementation:
  send(:extend, Implementation) if self.class.equal?(RDF::Repository)

  if block_given?
    case block.arity
      when 1 then block.call(self)
      else instance_eval(&block)
    end
  end
end

54
55
56

# File 'lib/rdf/repository.rb', line 54

def options
  @options
end

67
68
69

# File 'lib/rdf/repository.rb', line 67

def title
  @title
end

60
61
62

# File 'lib/rdf/repository.rb', line 60

def uri
  @uri
end

76
77
78
79
80
81
82
83
84
85
86
87
88
89

# File 'lib/rdf/repository.rb', line 76

def self.load(filenames, options = {}, &block)
  self.new(options) do |repository|
    [filenames].flatten.each do |filename|
      repository.load(filename, options)
    end

    if block_given?
      case block.arity
        when 1 then block.call(repository)
        else repository.instance_eval(&block)
      end
    end
  end
end

186
187
188

# File 'lib/rdf/repository.rb', line 186

def begin_transaction(context)
  RDF::Transaction.new(:context => context)
end

214
215
216

# File 'lib/rdf/repository.rb', line 214

def commit_transaction(tx)
  tx.execute(self)
end

129
130
131

# File 'lib/rdf/repository.rb', line 129

def inspect
  sprintf("#<%s:%#0x(%s)>", self.class.name, __id__, uri.to_s)
end

138
139
140
141

# File 'lib/rdf/repository.rb', line 138

def inspect!
  each_statement { |statement| statement.inspect! }
  nil
end

200
201
202

# File 'lib/rdf/repository.rb', line 200

def rollback_transaction(tx)
  # nothing to do
end

121
122
123

# File 'lib/rdf/repository.rb', line 121

def supports?(feature)
  false
end

repository.transaction do |tx|
  tx.insert [RDF::URI("http://rdf.rubyforge.org/"), RDF::DC.title, "RDF.rb"]
end

158
159
160
161
162
163
164
165
166
167
168
169
170
171

# File 'lib/rdf/repository.rb', line 158

def transaction(context = nil, &block)
  tx = begin_transaction(context)
  begin
    case block.arity
      when 1 then block.call(tx)
      else tx.instance_eval(&block)
    end
  rescue => error
    rollback_transaction(tx)
    raise error
  end
  commit_transaction(tx)
  self
end