calculations_test.rb 34.2 KB
Newer Older
1 2
# frozen_string_literal: true

3
require "cases/helper"
4
require "models/book"
5 6
require "models/club"
require "models/company"
7
require "models/contract"
8 9 10 11 12
require "models/edge"
require "models/organization"
require "models/possession"
require "models/topic"
require "models/reply"
13
require "models/numeric_data"
14 15 16 17 18
require "models/minivan"
require "models/speedometer"
require "models/ship_part"
require "models/treasure"
require "models/developer"
19
require "models/post"
20 21
require "models/comment"
require "models/rating"
22
require "support/stubs/strong_parameters"
23

24
class CalculationsTest < ActiveRecord::TestCase
25
  fixtures :companies, :accounts, :topics, :speedometers, :minivans, :books, :posts, :comments
26 27

  def test_should_sum_field
28
    assert_equal 318, Account.sum(:credit_limit)
29 30
  end

31 32 33 34
  def test_should_sum_arel_attribute
    assert_equal 318, Account.sum(Account.arel_table[:credit_limit])
  end

35 36
  def test_should_average_field
    value = Account.average(:credit_limit)
37
    assert_equal 53.0, value
38 39
  end

40 41 42 43 44
  def test_should_average_arel_attribute
    value = Account.average(Account.arel_table[:credit_limit])
    assert_equal 53.0, value
  end

45 46 47 48
  def test_should_resolve_aliased_attributes
    assert_equal 318, Account.sum(:available_credit)
  end

49 50 51 52 53
  def test_should_return_decimal_average_of_integer_field
    value = Account.average(:id)
    assert_equal 3.5, value
  end

54
  def test_should_return_integer_average_if_db_returns_such
A
Aaron Patterson 已提交
55
    ShipPart.delete_all
56
    ShipPart.create!(id: 3, name: "foo")
A
Aaron Patterson 已提交
57
    value = ShipPart.average(:id)
58 59 60
    assert_equal 3, value
  end

61 62
  def test_should_return_nil_as_average
    assert_nil NumericData.average(:bank_balance)
63
  end
64

65 66 67 68
  def test_should_get_maximum_of_field
    assert_equal 60, Account.maximum(:credit_limit)
  end

69 70 71 72
  def test_should_get_maximum_of_arel_attribute
    assert_equal 60, Account.maximum(Account.arel_table[:credit_limit])
  end

73
  def test_should_get_maximum_of_field_with_include
J
Jon Leighton 已提交
74
    assert_equal 55, Account.where("companies.name != 'Summit'").references(:companies).includes(:firm).maximum(:credit_limit)
75 76
  end

77 78 79 80
  def test_should_get_maximum_of_arel_attribute_with_include
    assert_equal 55, Account.where("companies.name != 'Summit'").references(:companies).includes(:firm).maximum(Account.arel_table[:credit_limit])
  end

81 82 83 84
  def test_should_get_minimum_of_field
    assert_equal 50, Account.minimum(:credit_limit)
  end

85 86 87 88
  def test_should_get_minimum_of_arel_attribute
    assert_equal 50, Account.minimum(Account.arel_table[:credit_limit])
  end

89
  def test_should_group_by_field
J
Jon Leighton 已提交
90
    c = Account.group(:firm_id).sum(:credit_limit)
91
    [1, 6, 2].each do |firm_id|
92
      assert_includes c.keys, firm_id, "Group #{c.inspect} does not contain firm_id #{firm_id}"
93
    end
94
  end
95

96
  def test_should_group_by_arel_attribute
97
    c = Account.group(Account.arel_table[:firm_id]).sum(:credit_limit)
98
    [1, 6, 2].each do |firm_id|
99
      assert_includes c.keys, firm_id, "Group #{c.inspect} does not contain firm_id #{firm_id}"
100
    end
101 102
  end

103
  def test_should_group_by_multiple_fields
104
    c = Account.group("firm_id", :credit_limit).count(:all)
105
    [ [nil, 50], [1, 50], [6, 50], [6, 55], [9, 53], [2, 60] ].each { |firm_and_limit| assert_includes c.keys, firm_and_limit }
106 107 108
  end

  def test_should_group_by_multiple_fields_having_functions
109
    c = Topic.group(:author_name, "COALESCE(type, title)").count(:all)
110 111 112 113 114
    assert_equal 1, c[["Carl", "The Third Topic of the day"]]
    assert_equal 1, c[["Mary", "Reply"]]
    assert_equal 1, c[["David", "The First Topic"]]
    assert_equal 1, c[["Carl", "Reply"]]
  end
115 116

  def test_should_group_by_summed_field
J
Jon Leighton 已提交
117
    c = Account.group(:firm_id).sum(:credit_limit)
118 119 120
    assert_equal 50,   c[1]
    assert_equal 105,  c[6]
    assert_equal 60,   c[2]
121 122
  end

123
  def test_should_generate_valid_sql_with_joins_and_group
124
    assert_nothing_raised do
125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141
      AuditLog.joins(:developer).group(:id).count
    end
  end

  def test_should_calculate_against_given_relation
    developer = Developer.create!(name: "developer")
    developer.audit_logs.create!(message: "first log")
    developer.audit_logs.create!(message: "second log")

    c = developer.audit_logs.joins(:developer).group(:id).count

    assert_equal developer.audit_logs.count, c.size
    developer.audit_logs.each do |log|
      assert_equal 1, c[log.id]
    end
  end

142
  def test_should_order_by_grouped_field
143
    c = Account.group(:firm_id).order("firm_id").sum(:credit_limit)
144
    assert_equal [1, 2, 6, 9], c.keys.compact
145 146 147
  end

  def test_should_order_by_calculation
B
Ben Toews 已提交
148
    c = Account.group(:firm_id).order("sum_credit_limit desc, firm_id").sum(:credit_limit)
149 150
    assert_equal [105, 60, 53, 50, 50], c.keys.collect { |k| c[k] }
    assert_equal [6, 2, 9, 1], c.keys.compact
151 152
  end

153
  def test_should_limit_calculation
154
    c = Account.where("firm_id IS NOT NULL").group(:firm_id).order("firm_id").limit(2).sum(:credit_limit)
155 156 157 158
    assert_equal [1, 2], c.keys.compact
  end

  def test_should_limit_calculation_with_offset
159 160
    c = Account.where("firm_id IS NOT NULL").group(:firm_id).order("firm_id").
     limit(2).offset(1).sum(:credit_limit)
161 162 163
    assert_equal [2, 6], c.keys.compact
  end

164
  def test_limit_should_apply_before_count
165
    accounts = Account.limit(4)
166 167 168 169 170

    assert_equal 3, accounts.count(:firm_id)
    assert_equal 3, accounts.select(:firm_id).count
  end

171
  def test_limit_should_apply_before_count_arel_attribute
172
    accounts = Account.limit(4)
173 174 175 176 177 178

    firm_id_attribute = Account.arel_table[:firm_id]
    assert_equal 3, accounts.count(firm_id_attribute)
    assert_equal 3, accounts.select(firm_id_attribute).count
  end

179 180 181 182 183 184 185
  def test_count_should_shortcut_with_limit_zero
    accounts = Account.limit(0)

    assert_no_queries { assert_equal 0, accounts.count }
  end

  def test_limit_is_kept
A
Aaron Patterson 已提交
186 187
    return if current_adapter?(:OracleAdapter)

188
    queries = capture_sql { Account.limit(1).count }
189 190 191 192
    assert_equal 1, queries.length
    assert_match(/LIMIT/, queries.first)
  end

193 194 195
  def test_offset_is_kept
    return if current_adapter?(:OracleAdapter)

196
    queries = capture_sql { Account.offset(1).count }
197
    assert_equal 1, queries.length
198
    assert_match(/OFFSET/, queries.first)
199 200
  end

201 202 203
  def test_limit_with_offset_is_kept
    return if current_adapter?(:OracleAdapter)

204
    queries = capture_sql { Account.limit(1).offset(1).count }
205
    assert_equal 1, queries.length
206 207
    assert_match(/LIMIT/, queries.first)
    assert_match(/OFFSET/, queries.first)
208 209 210
  end

  def test_no_limit_no_offset
211
    queries = capture_sql { Account.count }
212 213 214 215 216
    assert_equal 1, queries.length
    assert_no_match(/LIMIT/, queries.first)
    assert_no_match(/OFFSET/, queries.first)
  end

217 218 219 220 221
  def test_count_on_invalid_columns_raises
    e = assert_raises(ActiveRecord::StatementInvalid) {
      Account.select("credit_limit, firm_name").count
    }

G
Gannon McGibbon 已提交
222 223
    assert_match %r{accounts}i, e.sql
    assert_match "credit_limit, firm_name", e.sql
224 225
  end

226
  def test_apply_distinct_in_count
227
    queries = capture_sql do
228 229 230 231 232 233 234 235 236
      Account.distinct.count
      Account.group(:firm_id).distinct.count
    end

    queries.each do |query|
      assert_match %r{\ASELECT(?! DISTINCT) COUNT\(DISTINCT\b}, query
    end
  end

237 238 239 240 241 242
  def test_count_with_eager_loading_and_custom_order
    posts = Post.includes(:comments).order("comments.id")
    assert_queries(1) { assert_equal 11, posts.count }
    assert_queries(1) { assert_equal 11, posts.count(:all) }
  end

243 244 245 246 247 248
  def test_count_with_eager_loading_and_custom_select_and_order
    posts = Post.includes(:comments).order("comments.id").select(:type)
    assert_queries(1) { assert_equal 11, posts.count }
    assert_queries(1) { assert_equal 11, posts.count(:all) }
  end

249 250 251 252 253 254
  def test_count_with_eager_loading_and_custom_order_and_distinct
    posts = Post.includes(:comments).order("comments.id").distinct
    assert_queries(1) { assert_equal 11, posts.count }
    assert_queries(1) { assert_equal 11, posts.count(:all) }
  end

255 256 257 258 259 260
  def test_distinct_count_all_with_custom_select_and_order
    accounts = Account.distinct.select("credit_limit % 10").order(Arel.sql("credit_limit % 10"))
    assert_queries(1) { assert_equal 3, accounts.count(:all) }
    assert_queries(1) { assert_equal 3, accounts.load.size }
  end

261 262 263 264 265 266 267 268 269 270 271 272
  def test_distinct_count_with_order_and_limit
    assert_equal 4, Account.distinct.order(:firm_id).limit(4).count
  end

  def test_distinct_count_with_order_and_offset
    assert_equal 4, Account.distinct.order(:firm_id).offset(2).count
  end

  def test_distinct_count_with_order_and_limit_and_offset
    assert_equal 4, Account.distinct.order(:firm_id).limit(4).offset(2).count
  end

273 274 275 276 277 278 279 280 281 282 283 284
  def test_distinct_joins_count_with_order_and_limit
    assert_equal 3, Account.joins(:firm).distinct.order(:firm_id).limit(3).count
  end

  def test_distinct_joins_count_with_order_and_offset
    assert_equal 3, Account.joins(:firm).distinct.order(:firm_id).offset(2).count
  end

  def test_distinct_joins_count_with_order_and_limit_and_offset
    assert_equal 3, Account.joins(:firm).distinct.order(:firm_id).limit(3).offset(2).count
  end

285 286 287 288 289 290 291 292 293 294 295 296
  def test_distinct_joins_count_with_group_by
    expected = { nil => 4, 1 => 1, 2 => 1, 4 => 1, 5 => 1, 7 => 1 }
    assert_equal expected, Post.left_joins(:comments).group(:post_id).distinct.count(:author_id)
    assert_equal expected, Post.left_joins(:comments).group(:post_id).distinct.select(:author_id).count
    assert_equal expected, Post.left_joins(:comments).group(:post_id).count("DISTINCT posts.author_id")
    assert_equal expected, Post.left_joins(:comments).group(:post_id).select("DISTINCT posts.author_id").count

    expected = { nil => 6, 1 => 1, 2 => 1, 4 => 1, 5 => 1, 7 => 1 }
    assert_equal expected, Post.left_joins(:comments).group(:post_id).distinct.count(:all)
    assert_equal expected, Post.left_joins(:comments).group(:post_id).distinct.select(:author_id).count(:all)
  end

297 298 299 300
  def test_distinct_count_with_group_by_and_order_and_limit
    assert_equal({ 6 => 2 }, Account.group(:firm_id).distinct.order("1 DESC").limit(1).count)
  end

301
  def test_should_group_by_summed_field_having_condition
302
    c = Account.group(:firm_id).having("sum(credit_limit) > 50").sum(:credit_limit)
303 304 305 306 307
    assert_nil        c[1]
    assert_equal 105, c[6]
    assert_equal 60,  c[2]
  end

308
  def test_should_group_by_summed_field_having_condition_from_select
309
    skip unless current_adapter?(:Mysql2Adapter, :SQLite3Adapter)
310
    c = Account.select("MIN(credit_limit) AS min_credit_limit").group(:firm_id).having("min_credit_limit > 50").sum(:credit_limit)
311 312 313 314 315
    assert_nil       c[1]
    assert_equal 60, c[2]
    assert_equal 53, c[9]
  end

316
  def test_should_group_by_summed_association
J
Jon Leighton 已提交
317
    c = Account.group(:firm).sum(:credit_limit)
318 319 320 321
    assert_equal 50,   c[companies(:first_firm)]
    assert_equal 105,  c[companies(:rails_core)]
    assert_equal 60,   c[companies(:first_client)]
  end
J
Jeremy Kemper 已提交
322

323
  def test_should_sum_field_with_conditions
324
    assert_equal 105, Account.where("firm_id = 6").sum(:credit_limit)
325 326
  end

327
  def test_should_return_zero_if_sum_conditions_return_nothing
328 329
    assert_equal 0, Account.where("1 = 2").sum(:credit_limit)
    assert_equal 0, companies(:rails_core).companies.where("1 = 2").sum(:id)
330 331
  end

332
  def test_sum_should_return_valid_values_for_decimals
333
    NumericData.create(bank_balance: 19.83)
334 335 336
    assert_equal 19.83, NumericData.sum(:bank_balance)
  end

337
  def test_should_return_type_casted_values_with_group_and_expression
338
    assert_equal 0.5, Account.group(:firm_name).sum("0.01 * credit_limit")["37signals"]
339 340
  end

341
  def test_should_group_by_summed_field_with_conditions
342
    c = Account.where("firm_id > 1").group(:firm_id).sum(:credit_limit)
343 344 345
    assert_nil        c[1]
    assert_equal 105, c[6]
    assert_equal 60,  c[2]
346
  end
J
Jeremy Kemper 已提交
347

348
  def test_should_group_by_summed_field_with_conditions_and_having
349 350
    c = Account.where("firm_id > 1").group(:firm_id).
     having("sum(credit_limit) > 60").sum(:credit_limit)
351 352 353
    assert_nil        c[1]
    assert_equal 105, c[6]
    assert_nil        c[2]
354 355 356
  end

  def test_should_group_by_fields_with_table_alias
357
    c = Account.group("accounts.firm_id").sum(:credit_limit)
358 359 360
    assert_equal 50,  c[1]
    assert_equal 105, c[6]
    assert_equal 60,  c[2]
361
  end
J
Jeremy Kemper 已提交
362

363 364 365 366 367 368 369 370 371 372 373
  def test_should_calculate_grouped_with_longer_field
    field = "a" * Account.connection.max_identifier_length

    Account.update_all("#{field} = credit_limit")

    c = Account.group(:firm_id).sum(field)
    assert_equal 50,  c[1]
    assert_equal 105, c[6]
    assert_equal 60,  c[2]
  end

374
  def test_should_calculate_with_invalid_field
375
    assert_equal 6, Account.calculate(:count, "*")
376
    assert_equal 6, Account.calculate(:count, :all)
377
  end
J
Jeremy Kemper 已提交
378

379
  def test_should_calculate_grouped_with_invalid_field
380
    c = Account.group("accounts.firm_id").count(:all)
381 382 383
    assert_equal 1, c[1]
    assert_equal 2, c[6]
    assert_equal 1, c[2]
384
  end
J
Jeremy Kemper 已提交
385

386
  def test_should_calculate_grouped_association_with_invalid_field
J
Jon Leighton 已提交
387
    c = Account.group(:firm).count(:all)
388 389 390 391
    assert_equal 1, c[companies(:first_firm)]
    assert_equal 2, c[companies(:rails_core)]
    assert_equal 1, c[companies(:first_client)]
  end
392

393
  def test_should_group_by_association_with_non_numeric_foreign_key
394 395
    Speedometer.create! id: "ABC"
    Minivan.create! id: "OMG", speedometer_id: "ABC"
396

397
    c = Minivan.group(:speedometer).count(:all)
398
    first_key = c.keys.first
399
    assert_equal Speedometer, first_key.class
400
    assert_equal 1, c[first_key]
401
  end
J
Jeremy Kemper 已提交
402

403
  def test_should_calculate_grouped_association_with_foreign_key_option
404
    Account.belongs_to :another_firm, class_name: "Firm", foreign_key: "firm_id"
J
Jon Leighton 已提交
405
    c = Account.group(:another_firm).count(:all)
406 407 408 409 410
    assert_equal 1, c[companies(:first_firm)]
    assert_equal 2, c[companies(:rails_core)]
    assert_equal 1, c[companies(:first_client)]
  end

411
  def test_should_calculate_grouped_by_function
J
Jon Leighton 已提交
412
    c = Company.group("UPPER(#{QUOTED_TYPE})").count(:all)
413
    assert_equal 2, c[nil]
414 415 416
    assert_equal 1, c["DEPENDENTFIRM"]
    assert_equal 5, c["CLIENT"]
    assert_equal 2, c["FIRM"]
417
  end
J
Jeremy Kemper 已提交
418

419
  def test_should_calculate_grouped_by_function_with_table_alias
J
Jon Leighton 已提交
420
    c = Company.group("UPPER(companies.#{QUOTED_TYPE})").count(:all)
421
    assert_equal 2, c[nil]
422 423 424
    assert_equal 1, c["DEPENDENTFIRM"]
    assert_equal 5, c["CLIENT"]
    assert_equal 2, c["FIRM"]
425
  end
J
Jeremy Kemper 已提交
426

427 428 429
  def test_should_not_overshadow_enumerable_sum
    assert_equal 6, [1, 2, 3].sum(&:abs)
  end
430 431 432 433 434

  def test_should_sum_scoped_field
    assert_equal 15, companies(:rails_core).companies.sum(:id)
  end

435 436 437 438
  def test_should_sum_scoped_field_with_from
    assert_equal Club.count, Organization.clubs.count
  end

439
  def test_should_sum_scoped_field_with_conditions
440
    assert_equal 8,  companies(:rails_core).companies.where("id > 7").sum(:id)
441 442 443
  end

  def test_should_group_by_scoped_field
J
Jon Leighton 已提交
444
    c = companies(:rails_core).companies.group(:name).sum(:id)
445 446
    assert_equal 7, c["Leetsoft"]
    assert_equal 8, c["Jadedpixel"]
447 448
  end

E
Emilio Tagua 已提交
449
  def test_should_group_by_summed_field_through_association_and_having
450 451 452
    c = companies(:rails_core).companies.group(:name).having("sum(id) > 7").sum(:id)
    assert_nil      c["Leetsoft"]
    assert_equal 8, c["Jadedpixel"]
453
  end
454

455
  def test_should_count_selected_field_with_include
456 457
    assert_equal 6, Account.includes(:firm).distinct.count
    assert_equal 4, Account.includes(:firm).distinct.select(:credit_limit).count
458 459
    assert_equal 4, Account.includes(:firm).distinct.count("DISTINCT credit_limit")
    assert_equal 4, Account.includes(:firm).distinct.count("DISTINCT(credit_limit)")
460
  end
J
Jeremy Kemper 已提交
461

462 463
  def test_should_not_perform_joined_include_by_default
    assert_equal Account.count, Account.includes(:firm).count
464
    queries = capture_sql { Account.includes(:firm).count }
465 466 467 468
    assert_no_match(/join/i, queries.last)
  end

  def test_should_perform_joined_include_when_referencing_included_tables
469
    joined_count = Account.includes(:firm).where(companies: { name: "37signals" }).count
470 471 472
    assert_equal 1, joined_count
  end

473
  def test_should_count_scoped_select
474
    Account.update_all("credit_limit = NULL")
475
    assert_equal 0, Account.select("credit_limit").count
476 477 478
  end

  def test_should_count_scoped_select_with_options
479
    Account.update_all("credit_limit = NULL")
480 481
    Account.last.update_columns("credit_limit" => 49)
    Account.first.update_columns("credit_limit" => 51)
482

483
    assert_equal 1, Account.select("credit_limit").where("credit_limit >= 50").count
484 485
  end

486
  def test_should_count_manual_select_with_include
487
    assert_equal 6, Account.select("DISTINCT accounts.id").includes(:firm).count
488 489
  end

490 491 492 493 494
  def test_should_count_manual_select_with_count_all
    assert_equal 5, Account.select("DISTINCT accounts.firm_id").count(:all)
  end

  def test_should_count_with_manual_distinct_select_and_distinct
495
    assert_equal 4, Account.select("DISTINCT accounts.firm_id").distinct(true).count
496 497 498 499 500 501 502 503 504 505 506 507
  end

  def test_should_count_manual_select_with_group_with_count_all
    expected = { nil => 1, 1 => 1, 2 => 1, 6 => 2, 9 => 1 }
    actual = Account.select("DISTINCT accounts.firm_id").group("accounts.firm_id").count(:all)
    assert_equal expected, actual
  end

  def test_should_count_manual_with_count_all
    assert_equal 6, Account.count(:all)
  end

508 509 510 511 512
  def test_count_selected_arel_attribute
    assert_equal 5, Account.select(Account.arel_table[:firm_id]).count
    assert_equal 4, Account.distinct.select(Account.arel_table[:firm_id]).count
  end

513 514 515
  def test_count_with_column_parameter
    assert_equal 5, Account.count(:firm_id)
  end
J
Jeremy Kemper 已提交
516

517 518 519 520 521 522 523 524
  def test_count_with_arel_attribute
    assert_equal 5, Account.count(Account.arel_table[:firm_id])
  end

  def test_count_with_arel_star
    assert_equal 6, Account.count(Arel.star)
  end

525 526
  def test_count_with_distinct
    assert_equal 4, Account.select(:credit_limit).distinct.count
527 528
  end

529 530 531 532
  def test_count_with_aliased_attribute
    assert_equal 6, Account.count(:available_credit)
  end

533
  def test_count_with_column_and_options_parameter
J
Jon Leighton 已提交
534
    assert_equal 2, Account.where("credit_limit = 50 AND firm_id IS NOT NULL").count(:firm_id)
535
  end
J
Jeremy Kemper 已提交
536

O
oleg dashevskii 已提交
537
  def test_should_count_field_in_joined_table
538 539
    assert_equal 5, Account.joins(:firm).count("companies.id")
    assert_equal 4, Account.joins(:firm).distinct.count("companies.id")
O
oleg dashevskii 已提交
540 541
  end

542 543 544 545 546 547 548 549 550 551
  def test_count_arel_attribute_in_joined_table_with
    assert_equal 5, Account.joins(:firm).count(Company.arel_table[:id])
    assert_equal 4, Account.joins(:firm).distinct.count(Company.arel_table[:id])
  end

  def test_count_selected_arel_attribute_in_joined_table
    assert_equal 5, Account.joins(:firm).select(Company.arel_table[:id]).count
    assert_equal 4, Account.joins(:firm).distinct.select(Company.arel_table[:id]).count
  end

O
oleg dashevskii 已提交
552
  def test_should_count_field_in_joined_table_with_group_by
553
    c = Account.group("accounts.firm_id").joins(:firm).count("companies.id")
O
oleg dashevskii 已提交
554

555
    [1, 6, 2, 9].each { |firm_id| assert_includes c.keys, firm_id }
O
oleg dashevskii 已提交
556 557
  end

558
  def test_should_count_field_of_root_table_with_conflicting_group_by_column
559 560 561 562
    expected = { 1 => 2, 2 => 1, 4 => 5, 5 => 2, 7 => 1 }
    assert_equal expected, Post.joins(:comments).group(:post_id).count
    assert_equal expected, Post.joins(:comments).group("comments.post_id").count
    assert_equal expected, Post.joins(:comments).group(:post_id).select("DISTINCT posts.author_id").count(:all)
563 564
  end

565 566 567 568 569 570 571
  def test_count_with_no_parameters_isnt_deprecated
    assert_not_deprecated { Account.count }
  end

  def test_count_with_too_many_parameters_raises
    assert_raise(ArgumentError) { Account.count(1, 2, 3) }
  end
572

L
Lauro Caetano 已提交
573 574 575 576 577 578 579 580 581
  def test_count_with_order
    assert_equal 6, Account.order(:credit_limit).count
  end

  def test_count_with_reverse_order
    assert_equal 6, Account.order(:credit_limit).reverse_order.count
  end

  def test_count_with_where_and_order
582 583 584
    assert_equal 1, Account.where(firm_name: "37signals").count
    assert_equal 1, Account.where(firm_name: "37signals").order(:firm_name).count
    assert_equal 1, Account.where(firm_name: "37signals").order(:firm_name).reverse_order.count
L
Lauro Caetano 已提交
585 586
  end

587 588 589 590
  def test_count_with_block
    assert_equal 4, Account.count { |account| account.credit_limit.modulo(10).zero? }
  end

591
  def test_should_sum_expression
592
    if current_adapter?(:SQLite3Adapter, :Mysql2Adapter, :PostgreSQLAdapter, :OracleAdapter)
593 594
      assert_equal 636, Account.sum("2 * credit_limit")
    else
595
      assert_equal 636, Account.sum("2 * credit_limit").to_i
596
    end
597
  end
598

599
  def test_sum_expression_returns_zero_when_no_records_to_sum
600
    assert_equal 0, Account.where("1 = 2").sum("2 * credit_limit")
601 602
  end

603
  def test_count_with_from_option
604
    assert_equal Company.count(:all), Company.from("companies").count(:all)
J
Jon Leighton 已提交
605
    assert_equal Account.where("credit_limit = 50").count(:all),
606
        Account.from("accounts").where("credit_limit = 50").count(:all)
607 608
    assert_equal Company.where(type: "Firm").count(:type),
        Company.where(type: "Firm").from("companies").count(:type)
609 610 611
  end

  def test_sum_with_from_option
612
    assert_equal Account.sum(:credit_limit), Account.from("accounts").sum(:credit_limit)
J
Jon Leighton 已提交
613
    assert_equal Account.where("credit_limit > 50").sum(:credit_limit),
614
        Account.where("credit_limit > 50").from("accounts").sum(:credit_limit)
615 616 617
  end

  def test_average_with_from_option
618
    assert_equal Account.average(:credit_limit), Account.from("accounts").average(:credit_limit)
J
Jon Leighton 已提交
619
    assert_equal Account.where("credit_limit > 50").average(:credit_limit),
620
        Account.where("credit_limit > 50").from("accounts").average(:credit_limit)
621 622 623
  end

  def test_minimum_with_from_option
624
    assert_equal Account.minimum(:credit_limit), Account.from("accounts").minimum(:credit_limit)
J
Jon Leighton 已提交
625
    assert_equal Account.where("credit_limit > 50").minimum(:credit_limit),
626
        Account.where("credit_limit > 50").from("accounts").minimum(:credit_limit)
627 628 629
  end

  def test_maximum_with_from_option
630
    assert_equal Account.maximum(:credit_limit), Account.from("accounts").maximum(:credit_limit)
J
Jon Leighton 已提交
631
    assert_equal Account.where("credit_limit > 50").maximum(:credit_limit),
632
        Account.where("credit_limit > 50").from("accounts").maximum(:credit_limit)
633 634
  end

635
  def test_maximum_with_not_auto_table_name_prefix_if_column_included
636
    Company.create!(name: "test", contracts: [Contract.new(developer_id: 7)])
637

A
Aaron Patterson 已提交
638
    assert_equal 7, Company.includes(:contracts).maximum(:developer_id)
639 640 641
  end

  def test_minimum_with_not_auto_table_name_prefix_if_column_included
642
    Company.create!(name: "test", contracts: [Contract.new(developer_id: 7)])
643

A
Aaron Patterson 已提交
644
    assert_equal 7, Company.includes(:contracts).minimum(:developer_id)
645 646 647
  end

  def test_sum_with_not_auto_table_name_prefix_if_column_included
648
    Company.create!(name: "test", contracts: [Contract.new(developer_id: 7)])
649

A
Aaron Patterson 已提交
650
    assert_equal 7, Company.includes(:contracts).sum(:developer_id)
651 652
  end

R
Ryuta Kamizono 已提交
653 654
  if current_adapter?(:Mysql2Adapter)
    def test_from_option_with_specified_index
655 656 657
      assert_equal Edge.count(:all), Edge.from("edges USE INDEX(unique_edge_index)").count(:all)
      assert_equal Edge.where("sink_id < 5").count(:all),
          Edge.from("edges USE INDEX(unique_edge_index)").where("sink_id < 5").count(:all)
658 659 660 661
    end
  end

  def test_from_option_with_table_different_than_class
662
    assert_equal Account.count(:all), Company.from("accounts").count(:all)
663
  end
664 665 666 667

  def test_distinct_is_honored_when_used_with_count_operation_after_group
    # Count the number of authors for approved topics
    approved_topics_count = Topic.group(:approved).count(:author_name)[true]
668
    assert_equal approved_topics_count, 4
669
    # Count the number of distinct authors for approved Topics
670
    distinct_authors_for_approved_count = Topic.group(:approved).distinct.count(:author_name)[true]
671
    assert_equal distinct_authors_for_approved_count, 3
672
  end
673 674

  def test_pluck
675
    assert_equal [1, 2, 3, 4, 5], Topic.order(:id).pluck(:id)
676 677
  end

678
  def test_pluck_without_column_names
679 680 681 682 683
    if current_adapter?(:OracleAdapter)
      assert_equal [[1, "Firm", 1, nil, "37signals", nil, 1, nil, nil]], Company.order(:id).limit(1).pluck
    else
      assert_equal [[1, "Firm", 1, nil, "37signals", nil, 1, nil, ""]], Company.order(:id).limit(1).pluck
    end
684 685
  end

686 687
  def test_pluck_type_cast
    topic = topics(:first)
688
    relation = Topic.where(id: topic.id)
689 690 691 692 693
    assert_equal [ topic.approved ], relation.pluck(:approved)
    assert_equal [ topic.last_read ], relation.pluck(:last_read)
    assert_equal [ topic.written_on ], relation.pluck(:written_on)
  end

694 695 696 697 698 699 700 701 702 703 704 705
  def test_pluck_with_type_cast_does_not_corrupt_the_query_cache
    topic = topics(:first)
    relation = Topic.where(id: topic.id)
    assert_queries 1 do
      Topic.cache do
        kind = relation.select(:written_on).load.first.read_attribute_before_type_cast(:written_on).class
        relation.pluck(:written_on)
        assert_kind_of kind, relation.select(:written_on).load.first.read_attribute_before_type_cast(:written_on)
      end
    end
  end

706 707
  def test_pluck_and_distinct
    assert_equal [50, 53, 55, 60], Account.order(:credit_limit).distinct.pluck(:credit_limit)
708 709 710 711 712 713 714 715
  end

  def test_pluck_in_relation
    company = Company.first
    contract = company.contracts.create!
    assert_equal [contract.id], company.contracts.pluck(:id)
  end

716
  def test_pluck_on_aliased_attribute
717
    assert_equal "The First Topic", Topic.order(:id).pluck(:heading).first
718 719
  end

720
  def test_pluck_with_serialization
721
    t = Topic.create!(content: { foo: :bar })
722
    assert_equal [{ foo: :bar }], Topic.where(id: t.id).pluck(:content)
723 724 725
  end

  def test_pluck_with_qualified_column_name
B
Ben Toews 已提交
726
    assert_equal [1, 2, 3, 4, 5], Topic.order(:id).pluck("topics.id")
727
  end
728 729

  def test_pluck_auto_table_name_prefix
730
    c = Company.create!(name: "test", contracts: [Contract.new])
731 732 733
    assert_equal [c.id], Company.joins(:contracts).pluck(:id)
  end

734
  def test_pluck_if_table_included
735
    c = Company.create!(name: "test", contracts: [Contract.new(developer_id: 7)])
736 737 738
    assert_equal [c.id], Company.includes(:contracts).where("contracts.id" => c.contracts.first).pluck(:id)
  end

739
  def test_pluck_not_auto_table_name_prefix_if_column_joined
740 741 742
    company = Company.create!(name: "test", contracts: [Contract.new(developer_id: 7)])
    metadata = company.contracts.first.metadata
    assert_equal [metadata], Company.joins(:contracts).pluck(:metadata)
743
  end
T
twinturbo 已提交
744

745
  def test_pluck_with_selection_clause
B
Ben Toews 已提交
746 747 748
    assert_equal [50, 53, 55, 60], Account.pluck(Arel.sql("DISTINCT credit_limit")).sort
    assert_equal [50, 53, 55, 60], Account.pluck(Arel.sql("DISTINCT accounts.credit_limit")).sort
    assert_equal [50, 53, 55, 60], Account.pluck(Arel.sql("DISTINCT(credit_limit)")).sort
749 750 751 752

    # MySQL returns "SUM(DISTINCT(credit_limit))" as the column name unless
    # an alias is provided.  Without the alias, the column cannot be found
    # and properly typecast.
B
Ben Toews 已提交
753
    assert_equal [50 + 53 + 55 + 60], Account.pluck(Arel.sql("SUM(DISTINCT(credit_limit)) as credit_limit"))
754 755
  end

T
twinturbo 已提交
756
  def test_plucks_with_ids
J
Jon Leighton 已提交
757
    assert_equal Company.all.map(&:id).sort, Company.ids.sort
T
twinturbo 已提交
758
  end
759

760 761
  def test_pluck_with_includes_limit_and_empty_result
    assert_equal [], Topic.includes(:replies).limit(0).pluck(:id)
762
    assert_equal [], Topic.includes(:replies).limit(1).where("0 = 1").pluck(:id)
763 764
  end

765 766 767 768 769
  def test_pluck_with_includes_offset
    assert_equal [5], Topic.includes(:replies).order(:id).offset(4).pluck(:id)
    assert_equal [], Topic.includes(:replies).order(:id).offset(5).pluck(:id)
  end

770 771 772 773
  def test_pluck_with_join
    assert_equal [[2, 2], [4, 4]], Reply.includes(:topic).pluck(:id, :"topics.id")
  end

774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791
  def test_group_by_with_limit
    expected = { "Post" => 8, "SpecialPost" => 1 }
    actual = Post.includes(:comments).group(:type).order(:type).limit(2).count("comments.id")
    assert_equal expected, actual
  end

  def test_group_by_with_offset
    expected = { "SpecialPost" => 1, "StiPost" => 2 }
    actual = Post.includes(:comments).group(:type).order(:type).offset(1).count("comments.id")
    assert_equal expected, actual
  end

  def test_group_by_with_limit_and_offset
    expected = { "SpecialPost" => 1 }
    actual = Post.includes(:comments).group(:type).order(:type).offset(1).limit(1).count("comments.id")
    assert_equal expected, actual
  end

792
  def test_pluck_not_auto_table_name_prefix_if_column_included
793
    Company.create!(name: "test", contracts: [Contract.new(developer_id: 7)])
B
Ben Toews 已提交
794
    ids = Company.includes(:contracts).pluck(:developer_id)
795 796 797
    assert_equal Company.count, ids.length
    assert_equal [7], ids.compact
  end
798 799 800 801

  def test_pluck_multiple_columns
    assert_equal [
      [1, "The First Topic"], [2, "The Second Topic of the day"],
802 803
      [3, "The Third Topic of the day"], [4, "The Fourth Topic of the day"],
      [5, "The Fifth Topic of the day"]
804
    ], Topic.order(:id).pluck(:id, :title)
805 806
    assert_equal [
      [1, "The First Topic", "David"], [2, "The Second Topic of the day", "Mary"],
807 808
      [3, "The Third Topic of the day", "Carl"], [4, "The Fourth Topic of the day", "Carl"],
      [5, "The Fifth Topic of the day", "Jason"]
809 810 811 812 813
    ], Topic.order(:id).pluck(:id, :title, :author_name)
  end

  def test_pluck_with_multiple_columns_and_selection_clause
    assert_equal [[1, 50], [2, 50], [3, 50], [4, 60], [5, 55], [6, 53]],
B
Ben Toews 已提交
814
      Account.pluck("id, credit_limit")
815 816 817
  end

  def test_pluck_with_multiple_columns_and_includes
818
    Company.create!(name: "test", contracts: [Contract.new(developer_id: 7)])
B
Ben Toews 已提交
819
    companies_and_developers = Company.order("companies.id").includes(:contracts).pluck(:name, :developer_id)
820 821 822 823

    assert_equal Company.count, companies_and_developers.length
    assert_equal ["37signals", nil], companies_and_developers.first
    assert_equal ["test", 7], companies_and_developers.last
824
  end
825 826

  def test_pluck_with_reserved_words
827
    Possession.create!(where: "Over There")
828 829 830

    assert_equal ["Over There"], Possession.pluck(:where)
  end
831 832 833

  def test_pluck_replaces_select_clause
    taks_relation = Topic.select(:approved, :id).order(:id)
834
    assert_equal [1, 2, 3, 4, 5], taks_relation.pluck(:id)
835
    assert_equal [false, true, true, true, true], taks_relation.pluck(:approved)
836
  end
837 838 839 840

  def test_pluck_columns_with_same_name
    expected = [["The First Topic", "The Second Topic of the day"], ["The Third Topic of the day", "The Fourth Topic of the day"]]
    actual = Topic.joins(:replies)
B
Ben Toews 已提交
841
      .pluck("topics.title", "replies_topics.title")
842 843
    assert_equal expected, actual
  end
844 845

  def test_calculation_with_polymorphic_relation
846 847 848 849
    part = ShipPart.create!(name: "has trinket")
    part.trinkets.create!

    assert_equal part.id, ShipPart.joins(:trinkets).sum(:id)
850 851
  end

S
Sean Griffin 已提交
852 853 854 855 856 857 858
  def test_pluck_joined_with_polymorphic_relation
    part = ShipPart.create!(name: "has trinket")
    part.trinkets.create!

    assert_equal [part.id], ShipPart.joins(:trinkets).pluck(:id)
  end

859 860
  def test_pluck_loaded_relation
    companies = Company.order(:id).limit(3).load
Y
yuuji.yaginuma 已提交
861

862
    assert_queries(0) do
863
      assert_equal ["37signals", "Summit", "Microsoft"], companies.pluck(:name)
864 865 866 867 868
    end
  end

  def test_pluck_loaded_relation_multiple_columns
    companies = Company.order(:id).limit(3).load
Y
yuuji.yaginuma 已提交
869

870
    assert_queries(0) do
871
      assert_equal [[1, "37signals"], [2, "Summit"], [3, "Microsoft"]], companies.pluck(:id, :name)
872 873 874 875
    end
  end

  def test_pluck_loaded_relation_sql_fragment
876
    companies = Company.order(:name).limit(3).load
Y
yuuji.yaginuma 已提交
877

878
    assert_queries(1) do
B
Ben Toews 已提交
879
      assert_equal ["37signals", "Apex", "Ex Nihilo"], companies.pluck(Arel.sql("DISTINCT name"))
880 881 882
    end
  end

883 884
  def test_pick_one
    assert_equal "The First Topic", Topic.order(:id).pick(:heading)
885
    assert_nil Topic.none.pick(:heading)
886
    assert_nil Topic.where(id: 9999999999999999999).pick(:heading)
887 888 889 890
  end

  def test_pick_two
    assert_equal ["David", "david@loudthinking.com"], Topic.order(:id).pick(:author_name, :author_email_address)
891
    assert_nil Topic.none.pick(:author_name, :author_email_address)
892
    assert_nil Topic.where(id: 9999999999999999999).pick(:author_name, :author_email_address)
893 894
  end

Y
Yuji Hanamura 已提交
895 896 897 898 899
  def test_pick_delegate_to_all
    cool_first = minivans(:cool_first)
    assert_equal cool_first.color, Minivan.pick(:color)
  end

900 901 902 903 904 905
  def test_grouped_calculation_with_polymorphic_relation
    part = ShipPart.create!(name: "has trinket")
    part.trinkets.create!

    assert_equal({ "has trinket" => part.id }, ShipPart.joins(:trinkets).group("ship_parts.name").sum(:id))
  end
906 907 908 909 910

  def test_calculation_grouped_by_association_doesnt_error_when_no_records_have_association
    Client.update_all(client_of: nil)
    assert_equal({ nil => Client.count }, Client.group(:firm).count)
  end
911 912

  def test_should_reference_correct_aliases_while_joining_tables_of_has_many_through_association
913
    assert_nothing_raised do
914
      developer = Developer.create!(name: "developer")
915 916 917
      developer.ratings.includes(comment: :post).where(posts: { id: 1 }).count
    end
  end
918 919 920 921 922 923 924 925 926 927

  def test_sum_uses_enumerable_version_when_block_is_given
    block_called = false
    relation = Client.all.load

    assert_no_queries do
      assert_equal 0, relation.sum { block_called = true; 0 }
    end
    assert block_called
  end
928 929

  def test_having_with_strong_parameters
930
    params = ProtectedParams.new(credit_limit: "50")
931 932 933 934 935 936 937 938 939 940

    assert_raises(ActiveModel::ForbiddenAttributesError) do
      Account.group(:id).having(params)
    end

    result = Account.group(:id).having(params.permit!)
    assert_equal 50, result[0].credit_limit
    assert_equal 50, result[1].credit_limit
    assert_equal 50, result[2].credit_limit
  end
941 942

  def test_group_by_attribute_with_custom_type
R
Ryuta Kamizono 已提交
943
    assert_equal({ "proposed" => 2, "published" => 2 }, Book.group(:status).count)
944
  end
945

946 947 948
  def test_count_with_block_and_column_name_raises_an_error
    assert_raises(ArgumentError) do
      Account.count(:firm_id) { true }
949 950 951
    end
  end

952 953 954
  def test_sum_with_block_and_column_name_raises_an_error
    assert_raises(ArgumentError) do
      Account.sum(:firm_id) { 1 }
955 956
    end
  end
957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998

  test "#skip_query_cache! for #pluck" do
    Account.cache do
      assert_queries(1) do
        Account.pluck(:credit_limit)
        Account.pluck(:credit_limit)
      end

      assert_queries(2) do
        Account.all.skip_query_cache!.pluck(:credit_limit)
        Account.all.skip_query_cache!.pluck(:credit_limit)
      end
    end
  end

  test "#skip_query_cache! for a simple calculation" do
    Account.cache do
      assert_queries(1) do
        Account.calculate(:sum, :credit_limit)
        Account.calculate(:sum, :credit_limit)
      end

      assert_queries(2) do
        Account.all.skip_query_cache!.calculate(:sum, :credit_limit)
        Account.all.skip_query_cache!.calculate(:sum, :credit_limit)
      end
    end
  end

  test "#skip_query_cache! for a grouped calculation" do
    Account.cache do
      assert_queries(1) do
        Account.group(:firm_id).calculate(:sum, :credit_limit)
        Account.group(:firm_id).calculate(:sum, :credit_limit)
      end

      assert_queries(2) do
        Account.all.skip_query_cache!.group(:firm_id).calculate(:sum, :credit_limit)
        Account.all.skip_query_cache!.group(:firm_id).calculate(:sum, :credit_limit)
      end
    end
  end
999
end