Skip to content

Commit

Permalink
Allow ActiveRecord::Relation merges to maintain context of joined ass…
Browse files Browse the repository at this point in the history
…ociations
  • Loading branch information
armstrjare committed May 4, 2012
1 parent 5f62c86 commit 0d8cf53
Show file tree
Hide file tree
Showing 4 changed files with 43 additions and 6 deletions.
Expand Up @@ -109,7 +109,7 @@ def build(associations, parent = nil, join_type = Arel::InnerJoin)
case associations
when Symbol, String
reflection = parent.reflections[associations.to_s.intern] or
raise ConfigurationError, "Association named '#{ associations }' was not found; perhaps you misspelled it?"
raise ConfigurationError, "Association named '#{ associations }' was not found on #{parent.active_record.name}; perhaps you misspelled it?"
unless join_association = find_join_association(reflection, parent)
@reflections << reflection
join_association = build_join_association(reflection, parent)
Expand Down
Expand Up @@ -55,7 +55,12 @@ def ==(other)

def find_parent_in(other_join_dependency)
other_join_dependency.join_parts.detect do |join_part|
parent == join_part
case parent
when JoinBase
parent.active_record == join_part.active_record
else
parent == join_part
end
end
end

Expand Down
31 changes: 28 additions & 3 deletions activerecord/lib/active_record/relation/merger.rb
Expand Up @@ -29,21 +29,25 @@ def other
end

class Merger
attr_reader :relation, :values
attr_reader :relation, :other

def initialize(relation, other)
if other.default_scoped? && other.klass != relation.klass
other = other.with_default_scope
end

@relation = relation
@values = other.values
@other = other
end

def values
@other.values
end

def normal_values
Relation::SINGLE_VALUE_METHODS +
Relation::MULTI_VALUE_METHODS -
[:where, :order, :bind, :reverse_order, :lock, :create_with, :reordering]
[:where, :joins, :order, :bind, :reverse_order, :lock, :create_with, :reordering]
end

def merge
Expand All @@ -54,6 +58,7 @@ def merge

merge_multi_values
merge_single_values
merge_joins

relation
end
Expand Down Expand Up @@ -84,6 +89,26 @@ def merge_single_values
end
end

def merge_joins
return if values[:joins].blank?

if other.klass == relation.klass
relation.joins!(values[:joins])
else
joins_to_stash, other_joins = values[:joins].partition { |join|
case join
when Hash, Symbol, Array
true
else
false
end
}

join_dependency = ActiveRecord::Associations::JoinDependency.new(other.klass, joins_to_stash, [])
relation.joins!(join_dependency.join_associations + other_joins)
end
end

def merged_binds
if values[:bind]
(relation.bind_values + values[:bind]).uniq(&:first)
Expand Down
9 changes: 8 additions & 1 deletion activerecord/test/cases/relations_test.rb
Expand Up @@ -6,6 +6,7 @@
require 'models/comment'
require 'models/author'
require 'models/comment'
require 'models/rating'
require 'models/entrant'
require 'models/developer'
require 'models/reply'
Expand All @@ -19,7 +20,7 @@

class RelationTest < ActiveRecord::TestCase
fixtures :authors, :topics, :entrants, :developers, :companies, :developers_projects, :accounts, :categories, :categorizations, :posts, :comments,
:tags, :taggings, :cars, :minivans
:ratings, :tags, :taggings, :cars, :minivans

def test_do_not_double_quote_string_id
van = Minivan.last
Expand Down Expand Up @@ -731,6 +732,12 @@ def test_relation_merging_with_joins
assert_equal 1, comments.count
end

def test_relation_merging_with_merged_joins
special_comments_with_ratings = SpecialComment.joins(:ratings)
posts_with_special_comments_with_ratings = Post.group("posts.id").joins(:special_comments).merge(special_comments_with_ratings)
assert_equal 1, authors(:david).posts.merge(posts_with_special_comments_with_ratings).to_a.length
end

def test_count
posts = Post.scoped

Expand Down

0 comments on commit 0d8cf53

Please sign in to comment.