Sha256: a523d10a54e10ed15a7ddefd5ad19c85ae6f686bdf7158ab06fb50f648949701
Contents?: true
Size: 1.77 KB
Versions: 7
Compression:
Stored size: 1.77 KB
Contents
module ActiveRecord
module Locking
module Optimistic
private
def _update_record(attribute_names = @attributes.keys) #:nodoc:
return super unless locking_enabled?
return 0 if attribute_names.empty?
lock_col = self.class.locking_column
previous_lock_value = send(lock_col).to_i
increment_lock
attribute_names += [lock_col]
attribute_names.uniq!
begin
relation = self.class.unscoped
if self.composite?
affected_rows = relation.where(
relation.cpk_id_predicate(relation.table, self.class.primary_key, id_was)
).where(
lock_col => previous_lock_value
).update_all(
Hash[attributes_for_update(attribute_names).map do |name|
[name, _read_attribute(name)]
end]
)
else
affected_rows = relation.where(
self.class.primary_key => id,
lock_col => previous_lock_value,
).update_all(
Hash[attributes_for_update(attribute_names).map do |name|
[name, _read_attribute(name)]
end]
)
end
unless affected_rows == 1
raise ActiveRecord::StaleObjectError.new(self, "update")
end
affected_rows
# If something went wrong, revert the version.
rescue Exception
send(lock_col + '=', previous_lock_value)
raise
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems