1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
require 'test_helper'
# Test Models:
#
# Answer - :scope => :question_id
# Comment - :scope => :question_id (with an AR default scope)
# Invoice - :scope => :account_id, :start_at => 1000
# Product - :scope => :account_id, :start_at => lambda { |r| r.computed_start_value }
# Order - :scope => :non_existent_column
# User - :scope => :account_id, :column => :custom_sequential_id
# Address - :scope => :account_id ('sequential_id' does not exist)
# Email - :scope => [:emailable_id, :emailable_type]
# Subscription - no options
# Rating - :scope => :comment_id, skip: { |r| r.score == 0 }
# Monster - no options
# Zombie - STI, inherits from Monster
# Werewolf - STI, inherits from Monster
# ConcurrentBadger - scope: :concurrent_burrow_id,
# NOT NULL constraint on sequential_id,
# UNIQUE constraint on sequential_id within concurrent_burrow_id scope
if ENV['DB'] == 'postgresql'
class ConcurrencyTest < ActiveSupport::TestCase
self.use_transactional_fixtures = false
def setup
ConcurrentBadger.delete_all
end
def teardown
ConcurrentBadger.delete_all
end
test "creates records concurrently without data races" do
Thread.abort_on_exception = true
range = (1..50)
threads = []
range.each do
threads << Thread.new do
ConcurrentBadger.create!(burrow_id: 1)
end
end
threads.each(&:join)
sequential_ids = ConcurrentBadger.pluck(:sequential_id)
assert_equal range.to_a, sequential_ids
end
test "does not affect saving multiple records within a transaction" do
range = (1..10)
ConcurrentBadger.transaction do
range.each do
ConcurrentBadger.create!(burrow_id: 1)
end
end
sequential_ids = ConcurrentBadger.pluck(:sequential_id)
assert_equal range.to_a, sequential_ids
end
test "does not affect saving multiple records within nested transactons" do
range = (1..10)
ConcurrentBadger.transaction do
ConcurrentBadger.transaction do
ConcurrentBadger.transaction do
range.each do
ConcurrentBadger.create!(burrow_id: 1)
end
end
end
end
sequential_ids = ConcurrentBadger.pluck(:sequential_id)
assert_equal range.to_a, sequential_ids
end
end
end
|
