# File lib/quiver/adapter/arec_low_level_updater.rb, line 91 def primary_key original_attributes[adapter_klass.primary_key_name] end
class Quiver::Adapter::ActiveRecord::ARecLowLevelUpdater
Attributes
adapter_klass[RW]
attrs[RW]
failed[RW]
mapper_klass[RW]
original_attributes[RW]
Public Class Methods
new(adapter_klass, original_attributes)
click to toggle source
# File lib/quiver/adapter/arec_low_level_updater.rb, line 5 def initialize(adapter_klass, original_attributes) self.adapter_klass = adapter_klass self.failed = false self.original_attributes = original_attributes self.attrs = {} end
Public Instance Methods
failed!()
click to toggle source
# File lib/quiver/adapter/arec_low_level_updater.rb, line 73 def failed! self.failed = true end
map(attributes, opts)
click to toggle source
# File lib/quiver/adapter/arec_low_level_updater.rb, line 12 def map(attributes, opts) record = record_class(opts[:to]) if opts[:foreign_key] record = record.where(opts[:foreign_key]) end if opts[:primary] record = record.where( adapter_klass.primary_key_name => primary_key ) end result = record.update_all(attributes) if result == 0 self.failed = true end end
map_array(h, opts)
click to toggle source
# File lib/quiver/adapter/arec_low_level_updater.rb, line 32 def map_array(h, opts) raise ArgumentError, 'map_array requires opts[foreign_key] to be set' unless opts[:foreign_key] h.each do |key, items| record = record_class(opts[:to]) query = record.where(opts[:foreign_key]) ids = record.pluck(:id) remaining_ids = items.map { |i| i[:id] }.compact remove_ids = ids - remaining_ids query.where(id: remove_ids).delete_all attrs[key] = items.map do |item| item = item.merge(opts[:foreign_key]) if item[:id] result = query.where(id: item[:id]).update_all(item) if result != 1 self.failed = true else item end else result = record.create(item) if !result.persisted? self.failed = true else result.attributes.symbolize_keys end end end end end
primary_key()
click to toggle source
result()
click to toggle source
# File lib/quiver/adapter/arec_low_level_updater.rb, line 77 def result r = original_attributes.symbolize_keys.merge(attrs.merge( adapter_klass.primary_key_name => primary_key ).symbolize_keys) if original_attributes[:__type__] r.merge!( original_attributes[:__type__][:name] => original_attributes[:__type__][:value] ) end r end
success?()
click to toggle source
# File lib/quiver/adapter/arec_low_level_updater.rb, line 69 def success? !failed end
Private Instance Methods
record_class(name)
click to toggle source
# File lib/quiver/adapter/arec_low_level_updater.rb, line 99 def record_class(name) adapter_klass.record_classes[name] end