Module: Tripod::Persistence

Extended by:
ActiveSupport::Concern
Included in:
Components
Defined in:
lib/tripod/persistence.rb

Overview

This module defines behaviour for persisting to the database.

Defined Under Namespace

Modules: ClassMethods Classes: Transaction

Instance Method Summary collapse

Instance Method Details

#destroy(opts = {}) ⇒ Object 



127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
 
# File 'lib/tripod/persistence.rb', line 127

def destroy(opts={})

  transaction = Tripod::Persistence::Transaction.get_transaction(opts[:transaction])

  query = "
    # delete from default graph:
    DELETE {<#{@uri.to_s}> ?p ?o} WHERE {<#{@uri.to_s}> ?p ?o};
    # delete from named graphs:
    DELETE {GRAPH ?g {<#{@uri.to_s}> ?p ?o}} WHERE {GRAPH ?g {<#{@uri.to_s}> ?p ?o}};
  "

  if transaction
    transaction.query ||= ""
    transaction.query += query
  else
    Tripod::SparqlClient::Update::update(query)
  end

  @destroyed = true
  true
end

#save(opts = {}) ⇒ true, false

Save the resource. Note: regardless of whether it’s a new_record or not, we always make the db match the contents of this resource’s statements.

Examples:

Save the resource.

resource.save

Returns:

  • (true, false) —

    True is success, false if not.

Raises:



69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
 
# File 'lib/tripod/persistence.rb', line 69

def save(opts={})

  raise Tripod::Errors::GraphUriNotSet.new() unless @graph_uri

  transaction = Tripod::Persistence::Transaction.get_transaction(opts[:transaction])

  if self.valid?

    query = "
      DELETE {GRAPH ?g {<#{@uri.to_s}> ?p ?o}} WHERE {GRAPH ?g {<#{@uri.to_s}> ?p ?o}};
      INSERT DATA {
        GRAPH <#{@graph_uri}> {
          #{ @repository.dump(:ntriples) }
        }
      };
    "

    if transaction
      transaction.query ||= ""
      transaction.query += query
    else
      Tripod::SparqlClient::Update::update(query)
    end

    @new_record = false # if running in a trans, just assume it worked. If the query is dodgy, it will throw an exception later.
    true
  else
    false
  end
end

#save!(opts = {}) ⇒ true

Save the resource, and raise an exception if it fails. Note: As with save(), regardless of whether it’s a new_record or not, we always make the db match the contents of this resource’s statements.

Examples:

Save the resource.

resource.save

Returns:

  • (true) —

    True is success.

Raises:



110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
 
# File 'lib/tripod/persistence.rb', line 110

def save!(opts={})
  # try to save
  unless self.save(opts)

    # if we get in here, save failed.

    # abort the transaction
    transaction = Tripod::Persistence::Transaction.get_transaction(opts[:transaction])
    transaction.abort() if transaction

    self.class.fail_validate!(self) # throw an exception

    # TODO: similar stuff for callbacks?
  end
  return true
end

#update_attribute(name, value) ⇒ Object 



149
150
151
152
 
# File 'lib/tripod/persistence.rb', line 149

def update_attribute(name, value)
  write_attribute(name, value)
  save
end

#update_attributes(attributes = {}) ⇒ Object 



154
155
156
157
158
159
 
# File 'lib/tripod/persistence.rb', line 154

def update_attributes(attributes={})
  attributes.each_pair do |name, value|
    send "#{name}=", value
  end
  save
end