Skip to content

Commit

Permalink
Call NPlusOneQuery's call_association when calling count on collectin…
Browse files Browse the repository at this point in the history
…o assocation
  • Loading branch information
flyerhzm committed Nov 5, 2023
1 parent ac58d67 commit 6beb6cb
Show file tree
Hide file tree
Showing 10 changed files with 27 additions and 2 deletions.
1 change: 1 addition & 0 deletions lib/bullet/active_record4.rb
Original file line number Diff line number Diff line change
Expand Up @@ -181,6 +181,7 @@ def has_cached_counter?(reflection = reflection())
def count(column_name = nil, options = {})
if Bullet.start?
Bullet::Detector::CounterCache.add_counter_cache(proxy_association.owner, proxy_association.reflection.name)
Bullet::Detector::NPlusOneQuery.call_association(proxy_association.owner, proxy_association.reflection.name)
end
super(column_name, options)
end
Expand Down
1 change: 1 addition & 0 deletions lib/bullet/active_record41.rb
Original file line number Diff line number Diff line change
Expand Up @@ -173,6 +173,7 @@ def count_records
def count(column_name = nil, options = {})
if Bullet.start?
Bullet::Detector::CounterCache.add_counter_cache(proxy_association.owner, proxy_association.reflection.name)
Bullet::Detector::NPlusOneQuery.call_association(proxy_association.owner, proxy_association.reflection.name)
end
super(column_name, options)
end
Expand Down
1 change: 1 addition & 0 deletions lib/bullet/active_record42.rb
Original file line number Diff line number Diff line change
Expand Up @@ -238,6 +238,7 @@ def count_records
def count(column_name = nil, options = {})
if Bullet.start?
Bullet::Detector::CounterCache.add_counter_cache(proxy_association.owner, proxy_association.reflection.name)
Bullet::Detector::NPlusOneQuery.call_association(proxy_association.owner, proxy_association.reflection.name)
end
super(column_name, options)
end
Expand Down
1 change: 1 addition & 0 deletions lib/bullet/active_record5.rb
Original file line number Diff line number Diff line change
Expand Up @@ -269,6 +269,7 @@ def count
proxy_association.owner,
proxy_association.reflection.name
)
Bullet::Detector::NPlusOneQuery.call_association(proxy_association.owner, proxy_association.reflection.name)
end
super
end
Expand Down
1 change: 1 addition & 0 deletions lib/bullet/active_record52.rb
Original file line number Diff line number Diff line change
Expand Up @@ -251,6 +251,7 @@ def count(column_name = nil)
proxy_association.owner,
proxy_association.reflection.name
)
Bullet::Detector::NPlusOneQuery.call_association(proxy_association.owner, proxy_association.reflection.name)
end
super(column_name)
end
Expand Down
1 change: 1 addition & 0 deletions lib/bullet/active_record60.rb
Original file line number Diff line number Diff line change
Expand Up @@ -278,6 +278,7 @@ def count
proxy_association.owner,
proxy_association.reflection.name
)
Bullet::Detector::NPlusOneQuery.call_association(proxy_association.owner, proxy_association.reflection.name)
end
super
end
Expand Down
1 change: 1 addition & 0 deletions lib/bullet/active_record61.rb
Original file line number Diff line number Diff line change
Expand Up @@ -278,6 +278,7 @@ def count(column_name = nil)
proxy_association.owner,
proxy_association.reflection.name
)
Bullet::Detector::NPlusOneQuery.call_association(proxy_association.owner, proxy_association.reflection.name)
end
super(column_name)
end
Expand Down
1 change: 1 addition & 0 deletions lib/bullet/active_record70.rb
Original file line number Diff line number Diff line change
Expand Up @@ -294,6 +294,7 @@ def count(column_name = nil)
proxy_association.owner,
proxy_association.reflection.name
)
Bullet::Detector::NPlusOneQuery.call_association(proxy_association.owner, proxy_association.reflection.name)
end
super(column_name)
end
Expand Down
1 change: 1 addition & 0 deletions lib/bullet/active_record71.rb
Original file line number Diff line number Diff line change
Expand Up @@ -294,6 +294,7 @@ def count(column_name = nil)
proxy_association.owner,
proxy_association.reflection.name
)
Bullet::Detector::NPlusOneQuery.call_association(proxy_association.owner, proxy_association.reflection.name)
end
super(column_name)
end
Expand Down
20 changes: 18 additions & 2 deletions spec/integration/active_record/association_spec.rb
Original file line number Diff line number Diff line change
Expand Up @@ -88,13 +88,29 @@
expect(Bullet::Detector::Association).to be_detecting_unpreloaded_association_for(Post, :comments)
end

it 'should not detect unused preload person => pets with empty?' do
Person.all.each { |person| person.pets.empty? }
it 'should not detect unused preload post => comment with empty?' do
Post.includes(:comments).each { |post| post.comments.empty? }
Bullet::Detector::UnusedEagerLoading.check_unused_preload_associations
expect(Bullet::Detector::Association).not_to be_has_unused_preload_associations

expect(Bullet::Detector::Association).to be_completely_preloading_associations
end

it 'should not detect unused preload post => comment with count' do
Post.includes(:comments).each { |post| post.comments.count }
Bullet::Detector::UnusedEagerLoading.check_unused_preload_associations
expect(Bullet::Detector::Association).not_to be_has_unused_preload_associations

expect(Bullet::Detector::Association).to be_completely_preloading_associations
end

it 'should detect non preload post => comments with count' do
Post.all.each { |post| post.comments.count }
Bullet::Detector::UnusedEagerLoading.check_unused_preload_associations
expect(Bullet::Detector::Association).not_to be_has_unused_preload_associations

expect(Bullet::Detector::Association).to be_detecting_unpreloaded_association_for(Post, :comments)
end
end

context 'category => posts => comments' do
Expand Down

0 comments on commit 6beb6cb

Please sign in to comment.