Mercurial > hg > orthanc-databases
annotate PostgreSQL/UnitTests/PostgreSQLTests.cpp @ 240:c82c2cf84ae8
added handling of CR_COMMANDS_OUT_OF_SYNC
author | Sebastien Jodogne <s.jodogne@gmail.com> |
---|---|
date | Mon, 12 Apr 2021 17:07:06 +0200 |
parents | 35598014f140 |
children | b97a537f4613 |
rev | line source |
---|---|
0 | 1 /** |
2 * Orthanc - A Lightweight, RESTful DICOM Store | |
3 * Copyright (C) 2012-2016 Sebastien Jodogne, Medical Physics | |
4 * Department, University Hospital of Liege, Belgium | |
193
3236894320d6
upgrade to year 2021
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
157
diff
changeset
|
5 * Copyright (C) 2017-2021 Osimis S.A., Belgium |
0 | 6 * |
7 * This program is free software: you can redistribute it and/or | |
8 * modify it under the terms of the GNU Affero General Public License | |
9 * as published by the Free Software Foundation, either version 3 of | |
10 * the License, or (at your option) any later version. | |
11 * | |
12 * This program is distributed in the hope that it will be useful, but | |
13 * WITHOUT ANY WARRANTY; without even the implied warranty of | |
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | |
15 * Affero General Public License for more details. | |
16 * | |
17 * You should have received a copy of the GNU Affero General Public License | |
18 * along with this program. If not, see <http://www.gnu.org/licenses/>. | |
19 **/ | |
20 | |
21 | |
22 #include <gtest/gtest.h> | |
23 | |
24 #if defined(_WIN32) | |
25 // Fix redefinition of symbols on MinGW (these symbols are manually | |
26 // defined both by PostgreSQL and Google Test) | |
27 # undef S_IRGRP | |
28 # undef S_IROTH | |
29 # undef S_IRWXG | |
30 # undef S_IRWXO | |
31 # undef S_IWGRP | |
32 # undef S_IWOTH | |
33 # undef S_IXGRP | |
34 # undef S_IXOTH | |
35 #endif | |
36 | |
152 | 37 #include "../../Framework/Plugins/GlobalProperties.h" |
38 #include "../../Framework/PostgreSQL/PostgreSQLLargeObject.h" | |
39 #include "../../Framework/PostgreSQL/PostgreSQLResult.h" | |
40 #include "../../Framework/PostgreSQL/PostgreSQLTransaction.h" | |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
41 #include "../Plugins/PostgreSQLIndex.h" |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
42 #include "../Plugins/PostgreSQLStorageArea.h" |
0 | 43 |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
44 #include <Compatibility.h> // For std::unique_ptr<> |
152 | 45 #include <OrthancException.h> |
0 | 46 |
47 #include <boost/lexical_cast.hpp> | |
48 | |
49 using namespace OrthancDatabases; | |
50 | |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
51 extern PostgreSQLParameters globalParameters_; |
0 | 52 |
53 | |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
54 static PostgreSQLDatabase* CreateTestDatabase() |
0 | 55 { |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
56 std::unique_ptr<PostgreSQLDatabase> pg |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
57 (new PostgreSQLDatabase(globalParameters_)); |
0 | 58 |
59 pg->Open(); | |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
60 pg->ClearAll(); |
0 | 61 |
62 return pg.release(); | |
63 } | |
64 | |
65 | |
66 static int64_t CountLargeObjects(PostgreSQLDatabase& db) | |
67 { | |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
68 PostgreSQLTransaction transaction(db, TransactionType_ReadOnly); |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
69 |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
70 int64_t count; |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
71 |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
72 { |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
73 // Count the number of large objects in the DB |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
74 PostgreSQLStatement s(db, "SELECT COUNT(*) FROM pg_catalog.pg_largeobject"); |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
75 PostgreSQLResult r(s); |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
76 count = r.GetInteger64(0); |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
77 } |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
78 |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
79 transaction.Commit(); |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
80 return count; |
0 | 81 } |
82 | |
83 | |
84 TEST(PostgreSQL, Basic) | |
85 { | |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
86 std::unique_ptr<PostgreSQLDatabase> pg(CreateTestDatabase()); |
0 | 87 |
88 ASSERT_FALSE(pg->DoesTableExist("Test")); | |
237
35598014f140
refactoring to remove GlobalProperties.cpp
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
230
diff
changeset
|
89 pg->ExecuteMultiLines("CREATE TABLE Test(name INTEGER, value BIGINT)"); |
0 | 90 ASSERT_TRUE(pg->DoesTableExist("Test")); |
91 | |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
92 PostgreSQLStatement s(*pg, "INSERT INTO Test VALUES ($1,$2)"); |
0 | 93 s.DeclareInputInteger(0); |
94 s.DeclareInputInteger64(1); | |
95 | |
96 s.BindInteger(0, 43); | |
97 s.BindNull(0); | |
98 s.BindInteger(0, 42); | |
99 s.BindInteger64(1, -4242); | |
100 s.Run(); | |
101 | |
102 s.BindInteger(0, 43); | |
103 s.BindNull(1); | |
104 s.Run(); | |
105 | |
106 s.BindNull(0); | |
107 s.BindInteger64(1, 4444); | |
108 s.Run(); | |
109 | |
110 { | |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
111 PostgreSQLStatement t(*pg, "SELECT name, value FROM Test ORDER BY name"); |
0 | 112 PostgreSQLResult r(t); |
113 | |
114 ASSERT_FALSE(r.IsDone()); | |
115 ASSERT_FALSE(r.IsNull(0)); ASSERT_EQ(42, r.GetInteger(0)); | |
116 ASSERT_FALSE(r.IsNull(1)); ASSERT_EQ(-4242, r.GetInteger64(1)); | |
117 | |
118 r.Next(); | |
119 ASSERT_FALSE(r.IsDone()); | |
120 ASSERT_FALSE(r.IsNull(0)); ASSERT_EQ(43, r.GetInteger(0)); | |
121 ASSERT_TRUE(r.IsNull(1)); | |
122 | |
123 r.Next(); | |
124 ASSERT_FALSE(r.IsDone()); | |
125 ASSERT_TRUE(r.IsNull(0)); | |
126 ASSERT_FALSE(r.IsNull(1)); ASSERT_EQ(4444, r.GetInteger64(1)); | |
127 | |
128 r.Next(); | |
129 ASSERT_TRUE(r.IsDone()); | |
130 } | |
131 | |
132 { | |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
133 PostgreSQLStatement t(*pg, "SELECT name, value FROM Test WHERE name=$1"); |
0 | 134 t.DeclareInputInteger(0); |
135 | |
136 { | |
137 t.BindInteger(0, 42); | |
138 PostgreSQLResult r(t); | |
139 ASSERT_FALSE(r.IsDone()); | |
140 ASSERT_FALSE(r.IsNull(0)); ASSERT_EQ(42, r.GetInteger(0)); | |
141 ASSERT_FALSE(r.IsNull(1)); ASSERT_EQ(-4242, r.GetInteger64(1)); | |
142 | |
143 r.Next(); | |
144 ASSERT_TRUE(r.IsDone()); | |
145 } | |
146 | |
147 { | |
148 t.BindInteger(0, 40); | |
149 PostgreSQLResult r(t); | |
150 ASSERT_TRUE(r.IsDone()); | |
151 } | |
152 } | |
153 | |
154 } | |
155 | |
156 | |
157 TEST(PostgreSQL, String) | |
158 { | |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
159 std::unique_ptr<PostgreSQLDatabase> pg(CreateTestDatabase()); |
0 | 160 |
237
35598014f140
refactoring to remove GlobalProperties.cpp
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
230
diff
changeset
|
161 pg->ExecuteMultiLines("CREATE TABLE Test(name INTEGER, value VARCHAR(40))"); |
0 | 162 |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
163 PostgreSQLStatement s(*pg, "INSERT INTO Test VALUES ($1,$2)"); |
0 | 164 s.DeclareInputInteger(0); |
165 s.DeclareInputString(1); | |
166 | |
167 s.BindInteger(0, 42); | |
168 s.BindString(1, "Hello"); | |
169 s.Run(); | |
170 | |
171 s.BindInteger(0, 43); | |
172 s.BindNull(1); | |
173 s.Run(); | |
174 | |
175 s.BindNull(0); | |
176 s.BindString(1, ""); | |
177 s.Run(); | |
178 | |
179 { | |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
180 PostgreSQLStatement t(*pg, "SELECT name, value FROM Test ORDER BY name"); |
0 | 181 PostgreSQLResult r(t); |
182 | |
183 ASSERT_FALSE(r.IsDone()); | |
184 ASSERT_FALSE(r.IsNull(0)); ASSERT_EQ(42, r.GetInteger(0)); | |
185 ASSERT_FALSE(r.IsNull(1)); ASSERT_EQ("Hello", r.GetString(1)); | |
186 | |
187 r.Next(); | |
188 ASSERT_FALSE(r.IsDone()); | |
189 ASSERT_FALSE(r.IsNull(0)); ASSERT_EQ(43, r.GetInteger(0)); | |
190 ASSERT_TRUE(r.IsNull(1)); | |
191 | |
192 r.Next(); | |
193 ASSERT_FALSE(r.IsDone()); | |
194 ASSERT_TRUE(r.IsNull(0)); | |
195 ASSERT_FALSE(r.IsNull(1)); ASSERT_EQ("", r.GetString(1)); | |
196 | |
197 r.Next(); | |
198 ASSERT_TRUE(r.IsDone()); | |
199 } | |
200 } | |
201 | |
202 | |
203 TEST(PostgreSQL, Transaction) | |
204 { | |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
205 std::unique_ptr<PostgreSQLDatabase> pg(CreateTestDatabase()); |
0 | 206 |
237
35598014f140
refactoring to remove GlobalProperties.cpp
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
230
diff
changeset
|
207 pg->ExecuteMultiLines("CREATE TABLE Test(name INTEGER, value INTEGER)"); |
0 | 208 |
209 { | |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
210 PostgreSQLStatement s(*pg, "INSERT INTO Test VALUES ($1,$2)"); |
0 | 211 s.DeclareInputInteger(0); |
212 s.DeclareInputInteger(1); | |
213 s.BindInteger(0, 42); | |
214 s.BindInteger(1, 4242); | |
215 s.Run(); | |
216 | |
217 { | |
216
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
218 PostgreSQLTransaction t(*pg, TransactionType_ReadOnly); |
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
219 s.BindInteger(0, 0); |
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
220 s.BindInteger(1, 1); |
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
221 // Failure, as INSERT in a read-only transaction |
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
222 ASSERT_THROW(s.Run(), Orthanc::OrthancException); |
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
223 } |
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
224 |
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
225 { |
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
226 PostgreSQLTransaction t(*pg, TransactionType_ReadWrite); |
0 | 227 s.BindInteger(0, 43); |
228 s.BindInteger(1, 4343); | |
229 s.Run(); | |
230 s.BindInteger(0, 44); | |
231 s.BindInteger(1, 4444); | |
232 s.Run(); | |
233 | |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
234 PostgreSQLStatement u(*pg, "SELECT COUNT(*) FROM Test"); |
0 | 235 PostgreSQLResult r(u); |
236 ASSERT_EQ(3, r.GetInteger64(0)); | |
237 | |
238 // No commit | |
239 } | |
240 | |
241 { | |
216
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
242 // Implicit transaction |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
243 PostgreSQLStatement u(*pg, "SELECT COUNT(*) FROM Test"); |
0 | 244 PostgreSQLResult r(u); |
245 ASSERT_EQ(1, r.GetInteger64(0)); // Just "1" because of implicit rollback | |
246 } | |
247 | |
248 { | |
216
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
249 PostgreSQLTransaction t(*pg, TransactionType_ReadWrite); |
0 | 250 s.BindInteger(0, 43); |
251 s.BindInteger(1, 4343); | |
252 s.Run(); | |
253 s.BindInteger(0, 44); | |
254 s.BindInteger(1, 4444); | |
255 s.Run(); | |
256 | |
257 { | |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
258 PostgreSQLStatement u(*pg, "SELECT COUNT(*) FROM Test"); |
0 | 259 PostgreSQLResult r(u); |
260 ASSERT_EQ(3, r.GetInteger64(0)); | |
261 | |
262 t.Commit(); | |
263 ASSERT_THROW(t.Rollback(), Orthanc::OrthancException); | |
264 ASSERT_THROW(t.Commit(), Orthanc::OrthancException); | |
265 } | |
266 } | |
267 | |
268 { | |
216
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
269 PostgreSQLTransaction t(*pg, TransactionType_ReadOnly); |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
270 PostgreSQLStatement u(*pg, "SELECT COUNT(*) FROM Test"); |
0 | 271 PostgreSQLResult r(u); |
272 ASSERT_EQ(3, r.GetInteger64(0)); | |
273 } | |
274 } | |
275 } | |
276 | |
277 | |
278 | |
279 | |
280 | |
281 TEST(PostgreSQL, LargeObject) | |
282 { | |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
283 std::unique_ptr<PostgreSQLDatabase> pg(CreateTestDatabase()); |
0 | 284 ASSERT_EQ(0, CountLargeObjects(*pg)); |
285 | |
237
35598014f140
refactoring to remove GlobalProperties.cpp
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
230
diff
changeset
|
286 pg->ExecuteMultiLines("CREATE TABLE Test(name VARCHAR, value OID)"); |
0 | 287 |
288 // Automatically remove the large objects associated with the table | |
237
35598014f140
refactoring to remove GlobalProperties.cpp
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
230
diff
changeset
|
289 pg->ExecuteMultiLines("CREATE RULE TestDelete AS ON DELETE TO Test DO SELECT lo_unlink(old.value);"); |
0 | 290 |
291 { | |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
292 PostgreSQLStatement s(*pg, "INSERT INTO Test VALUES ($1,$2)"); |
0 | 293 s.DeclareInputString(0); |
294 s.DeclareInputLargeObject(1); | |
295 | |
296 for (int i = 0; i < 10; i++) | |
297 { | |
216
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
298 PostgreSQLTransaction t(*pg, TransactionType_ReadWrite); |
0 | 299 |
300 std::string value = "Value " + boost::lexical_cast<std::string>(i * 2); | |
301 PostgreSQLLargeObject obj(*pg, value); | |
302 | |
303 s.BindString(0, "Index " + boost::lexical_cast<std::string>(i)); | |
304 s.BindLargeObject(1, obj); | |
305 s.Run(); | |
306 | |
307 std::string tmp; | |
308 PostgreSQLLargeObject::Read(tmp, *pg, obj.GetOid()); | |
309 ASSERT_EQ(value, tmp); | |
310 | |
311 t.Commit(); | |
312 } | |
313 } | |
314 | |
315 | |
316 ASSERT_EQ(10, CountLargeObjects(*pg)); | |
317 | |
318 { | |
216
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
319 PostgreSQLTransaction t(*pg, TransactionType_ReadOnly); |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
320 PostgreSQLStatement s(*pg, "SELECT * FROM Test ORDER BY name DESC"); |
0 | 321 PostgreSQLResult r(s); |
322 | |
323 ASSERT_FALSE(r.IsDone()); | |
324 | |
325 ASSERT_FALSE(r.IsNull(0)); | |
326 ASSERT_EQ("Index 9", r.GetString(0)); | |
327 | |
328 std::string data; | |
329 r.GetLargeObject(data, 1); | |
330 ASSERT_EQ("Value 18", data); | |
331 | |
332 r.Next(); | |
333 ASSERT_FALSE(r.IsDone()); | |
334 | |
335 //ASSERT_TRUE(r.IsString(0)); | |
336 } | |
337 | |
338 | |
339 { | |
216
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
340 PostgreSQLTransaction t(*pg, TransactionType_ReadWrite); |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
341 PostgreSQLStatement s(*pg, "DELETE FROM Test WHERE name='Index 9'"); |
0 | 342 s.Run(); |
343 t.Commit(); | |
344 } | |
345 | |
346 | |
347 { | |
348 // Count the number of items in the DB | |
216
fbb52129158a
TransactionType given to PostgreSQLTransaction constructor
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
215
diff
changeset
|
349 PostgreSQLTransaction t(*pg, TransactionType_ReadOnly); |
214
ab96698c73a3
removed useless information about read-only in ITransaction and IPrecompiledStatement
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
207
diff
changeset
|
350 PostgreSQLStatement s(*pg, "SELECT COUNT(*) FROM Test"); |
0 | 351 PostgreSQLResult r(s); |
352 ASSERT_EQ(9, r.GetInteger64(0)); | |
353 } | |
354 | |
355 ASSERT_EQ(9, CountLargeObjects(*pg)); | |
356 } | |
357 | |
358 | |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
359 TEST(PostgreSQL, StorageArea) |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
360 { |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
361 std::unique_ptr<PostgreSQLDatabase> database(PostgreSQLDatabase::OpenDatabaseConnection(globalParameters_)); |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
362 |
226
a4918d57435c
DatabaseManager doesn't IDatabaseFactory anymore
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
225
diff
changeset
|
363 PostgreSQLStorageArea storageArea(globalParameters_, true /* clear database */); |
0 | 364 |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
365 { |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
366 PostgreSQLStorageArea::Accessor accessor(storageArea); |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
367 |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
368 ASSERT_EQ(0, CountLargeObjects(*database)); |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
369 |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
370 for (int i = 0; i < 10; i++) |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
371 { |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
372 std::string uuid = boost::lexical_cast<std::string>(i); |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
373 std::string value = "Value " + boost::lexical_cast<std::string>(i * 2); |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
374 accessor.Create(uuid, value.c_str(), value.size(), OrthancPluginContentType_Unknown); |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
375 } |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
376 |
219
dd6cfc250747
removed useless class StorageAreaBuffer
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
216
diff
changeset
|
377 std::string buffer; |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
378 ASSERT_THROW(accessor.ReadToString(buffer, "nope", OrthancPluginContentType_Unknown), |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
379 Orthanc::OrthancException); |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
380 |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
381 ASSERT_EQ(10, CountLargeObjects(*database)); |
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
382 accessor.Remove("5", OrthancPluginContentType_Unknown); |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
383 |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
384 ASSERT_EQ(9, CountLargeObjects(*database)); |
0 | 385 |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
386 for (int i = 0; i < 10; i++) |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
387 { |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
388 std::string uuid = boost::lexical_cast<std::string>(i); |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
389 std::string expected = "Value " + boost::lexical_cast<std::string>(i * 2); |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
390 |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
391 if (i == 5) |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
392 { |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
393 ASSERT_THROW(accessor.ReadToString(buffer, uuid, OrthancPluginContentType_Unknown), |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
394 Orthanc::OrthancException); |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
395 } |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
396 else |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
397 { |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
398 accessor.ReadToString(buffer, uuid, OrthancPluginContentType_Unknown); |
219
dd6cfc250747
removed useless class StorageAreaBuffer
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
216
diff
changeset
|
399 ASSERT_EQ(expected, buffer); |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
400 } |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
401 } |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
402 |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
403 for (int i = 0; i < 10; i++) |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
404 { |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
405 accessor.Remove(boost::lexical_cast<std::string>(i), OrthancPluginContentType_Unknown); |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
406 } |
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
407 |
230
675f8322eb7c
refactored StorageBackend by introducing an accessor class
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
408 ASSERT_EQ(0, CountLargeObjects(*database)); |
14
9774802fd05f
PostgreSQLStorageArea working
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
409 } |
0 | 410 } |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
411 |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
412 |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
413 TEST(PostgreSQL, ImplicitTransaction) |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
414 { |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
415 std::unique_ptr<PostgreSQLDatabase> db(CreateTestDatabase()); |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
416 |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
417 ASSERT_FALSE(db->DoesTableExist("test")); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
418 ASSERT_FALSE(db->DoesTableExist("test2")); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
419 |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
420 { |
215
b40b30075c51
added TransactionType_Implicit
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
214
diff
changeset
|
421 std::unique_ptr<OrthancDatabases::ITransaction> t(db->CreateTransaction(TransactionType_ReadWrite)); |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
422 ASSERT_FALSE(t->IsImplicit()); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
423 } |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
424 |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
425 { |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
426 Query query("CREATE TABLE test(id INT)", false); |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
427 std::unique_ptr<IPrecompiledStatement> s(db->Compile(query)); |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
428 |
215
b40b30075c51
added TransactionType_Implicit
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
214
diff
changeset
|
429 std::unique_ptr<ITransaction> t(db->CreateTransaction(TransactionType_Implicit)); |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
430 ASSERT_TRUE(t->IsImplicit()); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
431 ASSERT_THROW(t->Commit(), Orthanc::OrthancException); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
432 ASSERT_THROW(t->Rollback(), Orthanc::OrthancException); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
433 |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
434 Dictionary args; |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
435 t->ExecuteWithoutResult(*s, args); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
436 ASSERT_THROW(t->Rollback(), Orthanc::OrthancException); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
437 t->Commit(); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
438 |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
439 ASSERT_THROW(t->Commit(), Orthanc::OrthancException); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
440 } |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
441 |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
442 { |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
443 // An implicit transaction does not need to be explicitely committed |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
444 Query query("CREATE TABLE test2(id INT)", false); |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
445 std::unique_ptr<IPrecompiledStatement> s(db->Compile(query)); |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
446 |
215
b40b30075c51
added TransactionType_Implicit
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
214
diff
changeset
|
447 std::unique_ptr<ITransaction> t(db->CreateTransaction(TransactionType_Implicit)); |
23
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
448 |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
449 Dictionary args; |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
450 t->ExecuteWithoutResult(*s, args); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
451 } |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
452 |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
453 ASSERT_TRUE(db->DoesTableExist("test")); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
454 ASSERT_TRUE(db->DoesTableExist("test2")); |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
455 } |
b2ff1cd2907a
handling of implicit transactions in DatabaseManager
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
14
diff
changeset
|
456 |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
457 |
78 | 458 #if ORTHANC_PLUGINS_HAS_DATABASE_CONSTRAINT == 1 |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
459 TEST(PostgreSQLIndex, CreateInstance) |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
460 { |
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
195
diff
changeset
|
461 OrthancDatabases::PostgreSQLIndex db(NULL, globalParameters_); |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
462 db.SetClearAll(true); |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
463 |
226
a4918d57435c
DatabaseManager doesn't IDatabaseFactory anymore
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
225
diff
changeset
|
464 std::unique_ptr<OrthancDatabases::DatabaseManager> manager(OrthancDatabases::IndexBackend::CreateSingleDatabaseManager(db)); |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
465 |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
466 std::string s; |
226
a4918d57435c
DatabaseManager doesn't IDatabaseFactory anymore
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
225
diff
changeset
|
467 ASSERT_TRUE(db.LookupGlobalProperty(s, *manager, MISSING_SERVER_IDENTIFIER, Orthanc::GlobalProperty_DatabaseInternal1)); |
95 | 468 ASSERT_EQ("2", s); |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
469 |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
470 OrthancPluginCreateInstanceResult r1, r2; |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
471 |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
472 memset(&r1, 0, sizeof(r1)); |
226
a4918d57435c
DatabaseManager doesn't IDatabaseFactory anymore
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
225
diff
changeset
|
473 db.CreateInstance(r1, *manager, "a", "b", "c", "d"); |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
474 ASSERT_TRUE(r1.isNewInstance); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
475 ASSERT_TRUE(r1.isNewSeries); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
476 ASSERT_TRUE(r1.isNewStudy); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
477 ASSERT_TRUE(r1.isNewPatient); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
478 |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
479 memset(&r2, 0, sizeof(r2)); |
226
a4918d57435c
DatabaseManager doesn't IDatabaseFactory anymore
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
225
diff
changeset
|
480 db.CreateInstance(r2, *manager, "a", "b", "c", "d"); |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
481 ASSERT_FALSE(r2.isNewInstance); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
482 ASSERT_EQ(r1.instanceId, r2.instanceId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
483 |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
484 // Breaking the hierarchy |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
485 memset(&r2, 0, sizeof(r2)); |
226
a4918d57435c
DatabaseManager doesn't IDatabaseFactory anymore
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
225
diff
changeset
|
486 ASSERT_THROW(db.CreateInstance(r2, *manager, "a", "e", "c", "f"), Orthanc::OrthancException); |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
487 |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
488 memset(&r2, 0, sizeof(r2)); |
226
a4918d57435c
DatabaseManager doesn't IDatabaseFactory anymore
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
225
diff
changeset
|
489 db.CreateInstance(r2, *manager, "a", "b", "c", "e"); |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
490 ASSERT_TRUE(r2.isNewInstance); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
491 ASSERT_FALSE(r2.isNewSeries); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
492 ASSERT_FALSE(r2.isNewStudy); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
493 ASSERT_FALSE(r2.isNewPatient); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
494 ASSERT_EQ(r1.patientId, r2.patientId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
495 ASSERT_EQ(r1.studyId, r2.studyId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
496 ASSERT_EQ(r1.seriesId, r2.seriesId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
497 ASSERT_NE(r1.instanceId, r2.instanceId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
498 |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
499 memset(&r2, 0, sizeof(r2)); |
226
a4918d57435c
DatabaseManager doesn't IDatabaseFactory anymore
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
225
diff
changeset
|
500 db.CreateInstance(r2, *manager, "a", "b", "f", "g"); |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
501 ASSERT_TRUE(r2.isNewInstance); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
502 ASSERT_TRUE(r2.isNewSeries); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
503 ASSERT_FALSE(r2.isNewStudy); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
504 ASSERT_FALSE(r2.isNewPatient); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
505 ASSERT_EQ(r1.patientId, r2.patientId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
506 ASSERT_EQ(r1.studyId, r2.studyId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
507 ASSERT_NE(r1.seriesId, r2.seriesId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
508 ASSERT_NE(r1.instanceId, r2.instanceId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
509 |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
510 memset(&r2, 0, sizeof(r2)); |
226
a4918d57435c
DatabaseManager doesn't IDatabaseFactory anymore
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
225
diff
changeset
|
511 db.CreateInstance(r2, *manager, "a", "h", "i", "j"); |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
512 ASSERT_TRUE(r2.isNewInstance); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
513 ASSERT_TRUE(r2.isNewSeries); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
514 ASSERT_TRUE(r2.isNewStudy); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
515 ASSERT_FALSE(r2.isNewPatient); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
516 ASSERT_EQ(r1.patientId, r2.patientId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
517 ASSERT_NE(r1.studyId, r2.studyId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
518 ASSERT_NE(r1.seriesId, r2.seriesId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
519 ASSERT_NE(r1.instanceId, r2.instanceId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
520 |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
521 memset(&r2, 0, sizeof(r2)); |
226
a4918d57435c
DatabaseManager doesn't IDatabaseFactory anymore
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
225
diff
changeset
|
522 db.CreateInstance(r2, *manager, "k", "l", "m", "n"); |
71
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
523 ASSERT_TRUE(r2.isNewInstance); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
524 ASSERT_TRUE(r2.isNewSeries); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
525 ASSERT_TRUE(r2.isNewStudy); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
526 ASSERT_TRUE(r2.isNewPatient); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
527 ASSERT_NE(r1.patientId, r2.patientId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
528 ASSERT_NE(r1.studyId, r2.studyId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
529 ASSERT_NE(r1.seriesId, r2.seriesId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
530 ASSERT_NE(r1.instanceId, r2.instanceId); |
d40c5fecd160
new extension implemented for PostgreSQL: CreateInstance
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
531 } |
73
aa81c1c80c75
fix compatibility with older sdk
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
71
diff
changeset
|
532 #endif |
134
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
533 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
534 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
535 TEST(PostgreSQL, Lock2) |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
536 { |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
537 std::unique_ptr<PostgreSQLDatabase> db1(CreateTestDatabase()); |
134
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
538 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
539 ASSERT_FALSE(db1->ReleaseAdvisoryLock(43)); // lock counter = 0 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
540 ASSERT_TRUE(db1->AcquireAdvisoryLock(43)); // lock counter = 1 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
541 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
542 // OK, as this is the same connection |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
543 ASSERT_TRUE(db1->AcquireAdvisoryLock(43)); // lock counter = 2 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
544 ASSERT_TRUE(db1->ReleaseAdvisoryLock(43)); // lock counter = 1 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
545 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
546 // Try and release twice the lock |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
547 ASSERT_TRUE(db1->ReleaseAdvisoryLock(43)); // lock counter = 0 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
548 ASSERT_FALSE(db1->ReleaseAdvisoryLock(43)); // cannot unlock |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
549 ASSERT_TRUE(db1->AcquireAdvisoryLock(43)); // lock counter = 1 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
550 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
551 { |
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
552 std::unique_ptr<PostgreSQLDatabase> db2(CreateTestDatabase()); |
134
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
553 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
554 // The "db1" is still actively locking |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
555 ASSERT_FALSE(db2->AcquireAdvisoryLock(43)); |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
556 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
557 // Release the "db1" lock |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
558 ASSERT_TRUE(db1->ReleaseAdvisoryLock(43)); |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
559 ASSERT_FALSE(db1->ReleaseAdvisoryLock(43)); |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
560 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
561 // "db2" can now acquire the lock, but not "db1" |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
562 ASSERT_TRUE(db2->AcquireAdvisoryLock(43)); |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
563 ASSERT_FALSE(db1->AcquireAdvisoryLock(43)); |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
564 } |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
565 |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
566 // "db2" is closed, "db1" can now acquire the lock |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
567 ASSERT_TRUE(db1->AcquireAdvisoryLock(43)); |
cc3dc759c989
Added an advisory lock to avoid race conditions during database setup
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
95
diff
changeset
|
568 } |