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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
env = require('test_run')
test_run = env.new()
engine = test_run:get_cfg('engine')
--
-- gh-3443: Check that changes done to spaces marked as local
-- are not replicated, but vclock is still promoted.
--
s1 = box.schema.space.create('test1', {engine = engine})
_ = s1:create_index('pk')
s2 = box.schema.space.create('test2', {engine = engine, is_local = true})
_ = s2:create_index('pk')
s1.is_local
s2.is_local
-- Check is_local to group_id mapping.
box.space._space:get(s1.id)[6]
box.space._space:get(s2.id)[6]
-- Check that group_id is immutable.
box.space._space:update(s1.id, {{'=', 6, {group_id = 1}}}) -- error
box.space._space:update(s2.id, {{'=', 6, {group_id = 0}}}) -- error
-- Currently, there are only two replication groups:
-- 0 (global) and 1 (local)
box.space._space:insert{9000, 1, 'test', engine, 0, {group_id = 2}, {}} -- error
-- Temporary local spaces should behave in the same fashion as
-- plain temporary spaces, i.e. neither replicated nor persisted.
s3 = box.schema.space.create('test3', {is_local = true, temporary = true})
_ = s3:create_index('pk')
s3.is_local
s3.temporary
-- gh-4263 The truncation of the local & temporary space
-- should not spread among the replicas
s4 = box.schema.space.create('test4', {is_local = true})
_ = s4:create_index('pk')
s4.is_local
s4.temporary
s5 = box.schema.space.create('test5', {temporary = true})
_ = s5:create_index('pk')
s5.is_local
s5.temporary
_ = s1:insert{1}
_ = s2:insert{1}
_ = s3:insert{1}
_ = s4:insert{1}
_ = s5:insert{1}
box.snapshot()
_ = s1:insert{2}
_ = s2:insert{2}
_ = s3:insert{2}
_ = s4:insert{2}
_ = s5:insert{2}
box.schema.user.grant('guest', 'replication')
test_run:cmd("create server replica with rpl_master=default, script='replication/replica.lua'")
test_run:cmd("start server replica")
test_run:cmd("switch replica")
box.space.test1.is_local
box.space.test2.is_local
box.space.test3.is_local
box.space.test3.temporary
box.space.test4.is_local
box.space.test4.temporary
box.space.test5.is_local
box.space.test5.temporary
box.space.test1:select()
box.space.test2:select()
box.space.test3:select()
box.space.test4:select()
box.space.test5:select()
-- To check truncation fill replica's copy with 2 entries
_=box.space.test4:insert{4}
_=box.space.test4:insert{5}
_=box.space.test5:insert{4}
_=box.space.test5:insert{5}
box.space.test4:select()
box.space.test5:select()
-- truncate temp & local space on master
test_run:cmd("switch default")
s4:truncate()
s5:truncate()
-- Expect two records
box.space._truncate:count()
-- check truncation results on replica
test_run:cmd("switch replica")
-- Expect no records on replica
box.space._truncate:count()
-- the affected space must be unchanged
box.space.test4:select()
box.space.test5:select()
box.cfg{read_only = true} -- local spaces ignore read_only
for i = 1, 3 do box.space.test2:insert{i, i} end
for i = 1, 3 do box.space.test3:insert{i, i, i} end
test_run:cmd("switch default")
_ = s1:insert{3}
_ = s2:insert{3}
_ = s3:insert{3}
vclock = test_run:get_vclock('default')
-- Ignore 0-th component when waiting. They don't match.
vclock[0] = nil
_ = test_run:wait_vclock('replica', vclock)
test_run:cmd("switch replica")
box.space.test1:select()
box.space.test2:select()
box.space.test3:select()
test_run:cmd("restart server replica")
box.space.test1:select()
box.space.test2:select()
box.space.test3:select()
test_run:cmd("switch default")
test_run:cmd("stop server replica")
test_run:cmd("cleanup server replica")
test_run:cmd("delete server replica")
test_run:cleanup_cluster()
box.schema.user.revoke('guest', 'replication')
s1:select()
s2:select()
s3:select()
s1:drop()
s2:drop()
s3:drop()
s4:drop()
s5:drop()
|
