]>
Commit | Line | Data |
---|---|---|
7a9d65d2 MC |
1 | AT_BANNER([OVSDB -- replication]) |
2 | ||
3 | m4_divert_push([PREPARE_TESTS]) | |
4 | [ | |
5 | replication_schema () { | |
6 | cat <<'EOF' | |
7 | {"name": "mydb", | |
8 | "tables": { | |
9 | "a": { | |
10 | "columns": { | |
11 | "number": {"type": "integer"}, | |
12 | "name": {"type": "string"}}, | |
13 | "indexes": [["number"]]}, | |
14 | "b": { | |
15 | "columns": { | |
16 | "number": {"type": "integer"}, | |
17 | "name": {"type": "string"}}, | |
18 | "indexes": [["number"]]}} | |
19 | } | |
20 | EOF | |
21 | } | |
22 | ] | |
23 | m4_divert_pop([PREPARE_TESTS]) | |
24 | ||
25 | m4_define([REPLICATION_EXAMPLES], [ | |
26 | ||
27 | OVSDB_CHECK_REPLICATION([insert monitored table, insert excluded table], | |
28 | [replication_schema], | |
29 | [[[["mydb", | |
30 | {"op": "insert", | |
31 | "table": "a", | |
32 | "row": {"number": 0, "name": "zero"}}]]], | |
33 | [[["mydb", | |
34 | {"op": "insert", | |
35 | "table": "b", | |
36 | "row": {"number": 1, "name": "one"}}]]]], | |
37 | [[7,9c7,8 | |
38 | < _uuid name number | |
39 | < ------------------------------------ ---- ------ | |
40 | < <0> one 1 @&t@ | |
41 | --- | |
42 | > _uuid name number | |
43 | > ----- ---- ------]] | |
44 | ) | |
45 | ||
46 | OVSDB_CHECK_REPLICATION([insert monitored table, update excluded table], | |
47 | [replication_schema], | |
48 | [[[["mydb", | |
49 | {"op": "insert", | |
50 | "table": "a", | |
51 | "row": {"number": 0, "name": "zero"}}]]], | |
52 | [[["mydb", | |
53 | {"op": "insert", | |
54 | "table": "b", | |
55 | "row": {"number": 1, "name": "one"}}]]], | |
56 | [[["mydb", | |
57 | {"op": "update", | |
58 | "table": "b", | |
59 | "where":[["name","==","one"]], | |
60 | "row": {"number": 2, "name": "two"}}]]]], | |
61 | [[7,9c7,8 | |
62 | < _uuid name number | |
63 | < ------------------------------------ ---- ------ | |
64 | < <0> two 2 @&t@ | |
65 | --- | |
66 | > _uuid name number | |
67 | > ----- ---- ------]] | |
68 | ) | |
69 | ||
70 | OVSDB_CHECK_REPLICATION([update monitored table, insert excluded table], | |
71 | [replication_schema], | |
72 | [[[["mydb", | |
73 | {"op": "insert", | |
74 | "table": "a", | |
75 | "row": {"number": 0, "name": "zero"}}]]], | |
76 | [[["mydb", | |
77 | {"op": "update", | |
78 | "table": "a", | |
79 | "where":[["name","==","zero"]], | |
80 | "row": {"number": 1, "name": "one"}}]]], | |
81 | [[["mydb", | |
82 | {"op": "insert", | |
83 | "table": "b", | |
84 | "row": {"number": 2, "name": "two"}}]]]], | |
85 | [[7,9c7,8 | |
86 | < _uuid name number | |
87 | < ------------------------------------ ---- ------ | |
88 | < <0> two 2 @&t@ | |
89 | --- | |
90 | > _uuid name number | |
91 | > ----- ---- ------]] | |
92 | ) | |
93 | ||
94 | OVSDB_CHECK_REPLICATION([update monitored table, update excluded table], | |
95 | [replication_schema], | |
96 | [[[["mydb", | |
97 | {"op": "insert", | |
98 | "table": "a", | |
99 | "row": {"number": 0, "name": "zero"}}]]], | |
100 | [[["mydb", | |
101 | {"op": "update", | |
102 | "table": "a", | |
103 | "where":[["name","==","zero"]], | |
104 | "row": {"number": 1, "name": "one"}}]]], | |
105 | [[["mydb", | |
106 | {"op": "insert", | |
107 | "table": "b", | |
108 | "row": {"number": 2, "name": "two"}}]]], | |
109 | [[["mydb", | |
110 | {"op": "update", | |
111 | "table": "b", | |
112 | "where":[["name","==","two"]], | |
113 | "row": {"number": 3, "name": "three"}}]]]], | |
114 | [[7,9c7,8 | |
115 | < _uuid name number | |
116 | < ------------------------------------ ----- ------ | |
117 | < <0> three 3 @&t@ | |
118 | --- | |
119 | > _uuid name number | |
120 | > ----- ---- ------]] | |
121 | ) | |
122 | ||
123 | OVSDB_CHECK_REPLICATION([delete monitored table, insert excluded table], | |
124 | [replication_schema], | |
125 | [[[["mydb", | |
126 | {"op": "insert", | |
127 | "table": "a", | |
128 | "row": {"number": 0, "name": "zero"}}]]], | |
129 | [[["mydb", | |
130 | {"op": "delete", | |
131 | "table": "a", | |
132 | "where":[["name","==","zero"]]}]]], | |
133 | [[["mydb", | |
134 | {"op": "insert", | |
135 | "table": "b", | |
136 | "row": {"number": 1, "name": "one"}}]]]], | |
137 | [[6,8c6,7 | |
138 | < _uuid name number | |
139 | < ------------------------------------ ---- ------ | |
140 | < <0> one 1 @&t@ | |
141 | --- | |
142 | > _uuid name number | |
143 | > ----- ---- ------]] | |
144 | ) | |
145 | ||
146 | OVSDB_CHECK_REPLICATION([delete monitored table, update excluded table], | |
147 | [replication_schema], | |
148 | [[[["mydb", | |
149 | {"op": "insert", | |
150 | "table": "a", | |
151 | "row": {"number": 0, "name": "zero"}}]]], | |
152 | [[["mydb", | |
153 | {"op": "delete", | |
154 | "table": "a", | |
155 | "where":[["name","==","zero"]]}]]], | |
156 | [[["mydb", | |
157 | {"op": "insert", | |
158 | "table": "b", | |
159 | "row": {"number": 1, "name": "one"}}]]], | |
160 | [[["mydb", | |
161 | {"op": "update", | |
162 | "table": "b", | |
163 | "where":[["name","==","one"]], | |
164 | "row": {"number": 2, "name": "two"}}]]]], | |
165 | [[6,8c6,7 | |
166 | < _uuid name number | |
167 | < ------------------------------------ ---- ------ | |
168 | < <0> two 2 @&t@ | |
169 | --- | |
170 | > _uuid name number | |
171 | > ----- ---- ------]] | |
172 | ) | |
173 | ||
174 | ]) |