Skip to content

Commit

Permalink
Fixed AssociationsPreload such that it doesnt require foreign keys to…
Browse files Browse the repository at this point in the history
… be integers (fcheung) [#33 state:resolved]
  • Loading branch information
dhh committed May 1, 2008
1 parent 1eb686a commit 6f20efd
Show file tree
Hide file tree
Showing 4 changed files with 44 additions and 12 deletions.
26 changes: 15 additions & 11 deletions activerecord/lib/active_record/association_preload.rb
Original file line number Diff line number Diff line change
Expand Up @@ -59,14 +59,14 @@ def add_preloaded_record_to_collection(parent_records, reflection_name, associat

def set_association_collection_records(id_to_record_map, reflection_name, associated_records, key)
associated_records.each do |associated_record|
mapped_records = id_to_record_map[associated_record[key].to_i]
mapped_records = id_to_record_map[associated_record[key].to_s]
add_preloaded_records_to_collection(mapped_records, reflection_name, associated_record)
end
end

def set_association_single_records(id_to_record_map, reflection_name, associated_records, key)
associated_records.each do |associated_record|
mapped_records = id_to_record_map[associated_record[key].to_i]
mapped_records = id_to_record_map[associated_record[key].to_s]
mapped_records.each do |mapped_record|
mapped_record.send("set_#{reflection_name}_target", associated_record)
end
Expand All @@ -78,7 +78,7 @@ def construct_id_map(records)
ids = []
records.each do |record|
ids << record.id
mapped_records = (id_to_record_map[record.id] ||= [])
mapped_records = (id_to_record_map[record.id.to_s] ||= [])
mapped_records << record
end
ids.uniq!
Expand Down Expand Up @@ -115,7 +115,7 @@ def preload_has_one_association(records, reflection, preload_options={})
source = reflection.source_reflection.name
through_records.first.class.preload_associations(through_records, source)
through_records.each do |through_record|
add_preloaded_record_to_collection(id_to_record_map[through_record[through_primary_key].to_i],
add_preloaded_record_to_collection(id_to_record_map[through_record[through_primary_key].to_s],
reflection.name, through_record.send(source))
end
end
Expand All @@ -140,7 +140,7 @@ def preload_has_many_association(records, reflection, preload_options={})
source = reflection.source_reflection.name
through_records.first.class.preload_associations(through_records, source)
through_records.each do |through_record|
add_preloaded_records_to_collection(id_to_record_map[through_record[through_primary_key].to_i],
add_preloaded_records_to_collection(id_to_record_map[through_record[through_primary_key].to_s],
reflection.name, through_record.send(source))
end
end
Expand Down Expand Up @@ -195,18 +195,22 @@ def preload_belongs_to_association(records, reflection, preload_options={})
records.each do |record|
if klass = record.send(polymorph_type)
klass_id = record.send(primary_key_name)

id_map = klasses_and_ids[klass] ||= {}
id_list_for_klass_id = (id_map[klass_id] ||= [])
id_list_for_klass_id << record
if klass_id
id_map = klasses_and_ids[klass] ||= {}
id_list_for_klass_id = (id_map[klass_id.to_s] ||= [])
id_list_for_klass_id << record
end
end
end
klasses_and_ids = klasses_and_ids.to_a
else
id_map = {}
records.each do |record|
mapped_records = (id_map[record.send(primary_key_name)] ||= [])
mapped_records << record
key = record.send(primary_key_name)
if key
mapped_records = (id_map[key.to_s] ||= [])
mapped_records << record
end
end
klasses_and_ids = [[reflection.klass.name, id_map]]
end
Expand Down
23 changes: 22 additions & 1 deletion activerecord/test/cases/associations/eager_test.rb
Original file line number Diff line number Diff line change
Expand Up @@ -11,11 +11,14 @@
require 'models/pet'
require 'models/reference'
require 'models/job'
require 'models/subscriber'
require 'models/subscription'
require 'models/book'

class EagerAssociationTest < ActiveRecord::TestCase
fixtures :posts, :comments, :authors, :categories, :categories_posts,
:companies, :accounts, :tags, :taggings, :people, :readers,
:owners, :pets, :author_favorites, :jobs, :references
:owners, :pets, :author_favorites, :jobs, :references, :subscribers, :subscriptions, :books

def test_loading_with_one_association
posts = Post.find(:all, :include => :comments)
Expand Down Expand Up @@ -220,6 +223,24 @@ def test_eager_load_has_many_through_quotes_table_and_column_names
assert_no_queries{ assert_equal jobs(:unicyclist, :magician), michael.jobs.sort_by(&:id) }
end

def test_eager_load_has_many_with_string_keys
subscriptions = subscriptions(:webster_awdr, :webster_rfr)
subscriber =Subscriber.find(subscribers(:second).id, :include => :subscriptions)
assert_equal subscriptions, subscriber.subscriptions.sort_by(&:id)
end

def test_eager_load_has_many_through_with_string_keys
books = books(:awdr, :rfr)
subscriber = Subscriber.find(subscribers(:second).id, :include => :books)
assert_equal books, subscriber.books.sort_by(&:id)
end

def test_eager_load_belongs_to_with_string_keys
subscriber = subscribers(:second)
subscription = Subscription.find(subscriptions(:webster_awdr).id, :include => :subscriber)
assert_equal subscriber, subscription.subscriber
end

def test_eager_association_loading_with_explicit_join
posts = Post.find(:all, :include => :comments, :joins => "INNER JOIN authors ON posts.author_id = authors.id AND authors.name = 'Mary'", :limit => 1, :order => 'author_id')
assert_equal 1, posts.length
Expand Down
2 changes: 2 additions & 0 deletions activerecord/test/models/subscriber.rb
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
class Subscriber < ActiveRecord::Base
set_primary_key 'nick'
has_many :subscriptions
has_many :books, :through => :subscriptions
end

class SpecialSubscriber < Subscriber
Expand Down
5 changes: 5 additions & 0 deletions activerecord/test/schema/schema.rb
Original file line number Diff line number Diff line change
Expand Up @@ -349,6 +349,11 @@ def create_table(*args, &block)
end
add_index :subscribers, :nick, :unique => true

create_table :subscriptions, :force => true do |t|
t.string :subscriber_id
t.integer :book_id
end

create_table :tasks, :force => true do |t|
t.datetime :starting
t.datetime :ending
Expand Down

0 comments on commit 6f20efd

Please sign in to comment.