aboutsummaryrefslogtreecommitdiffstats
path: root/activerecord/lib/active_record/associations/has_one_through_association.rb
diff options
context:
space:
mode:
Diffstat (limited to 'activerecord/lib/active_record/associations/has_one_through_association.rb')
-rw-r--r--activerecord/lib/active_record/associations/has_one_through_association.rb29
1 files changed, 14 insertions, 15 deletions
diff --git a/activerecord/lib/active_record/associations/has_one_through_association.rb b/activerecord/lib/active_record/associations/has_one_through_association.rb
index eb17935d6a..c9ae930e93 100644
--- a/activerecord/lib/active_record/associations/has_one_through_association.rb
+++ b/activerecord/lib/active_record/associations/has_one_through_association.rb
@@ -1,10 +1,8 @@
-require "active_record/associations/through_association_scope"
-
module ActiveRecord
# = Active Record Has One Through Association
module Associations
class HasOneThroughAssociation < HasOneAssociation
- include ThroughAssociationScope
+ include ThroughAssociation
def replace(new_value)
create_through_record(new_value)
@@ -13,25 +11,26 @@ module ActiveRecord
private
- def create_through_record(new_value) #nodoc:
- klass = @reflection.through_reflection.klass
-
- current_object = @owner.send(@reflection.through_reflection.name)
+ def create_through_record(new_value)
+ proxy = @owner.send(@reflection.through_reflection.name) ||
+ @owner.send(:association_instance_get, @reflection.through_reflection.name)
+ record = proxy.target
- if current_object
- new_value ? current_object.update_attributes(construct_join_attributes(new_value)) : current_object.destroy
+ if record && !new_value
+ record.destroy
elsif new_value
- if @owner.new_record?
- self.target = new_value
- through_association = @owner.send(:association_instance_get, @reflection.through_reflection.name)
- through_association.build(construct_join_attributes(new_value))
+ attributes = construct_join_attributes(new_value)
+
+ if record
+ record.update_attributes(attributes)
+ elsif @owner.new_record?
+ proxy.build(attributes)
else
- @owner.send(@reflection.through_reflection.name, klass.create(construct_join_attributes(new_value)))
+ proxy.create(attributes)
end
end
end
- private
def find_target
update_stale_state
scoped.first