Mercurial > hg > orthanc-databases
annotate Framework/Plugins/DatabaseBackendAdapterV3.cpp @ 580:35d2df9572b1 find-refactoring tip
count-resources
author | Alain Mazy <am@orthanc.team> |
---|---|
date | Tue, 15 Oct 2024 15:52:39 +0200 |
parents | 1a23f1ce3b98 |
children | f18e46d7dbf8 |
rev | line source |
---|---|
212 | 1 /** |
2 * Orthanc - A Lightweight, RESTful DICOM Store | |
3 * Copyright (C) 2012-2016 Sebastien Jodogne, Medical Physics | |
4 * Department, University Hospital of Liege, Belgium | |
507
54d518dcd74a
updated copyright, as Orthanc Team now replaces Osimis
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
459
diff
changeset
|
5 * Copyright (C) 2017-2023 Osimis S.A., Belgium |
54d518dcd74a
updated copyright, as Orthanc Team now replaces Osimis
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
459
diff
changeset
|
6 * Copyright (C) 2024-2024 Orthanc Team SRL, Belgium |
459
ecd0b719cff5
update year to 2024
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
403
diff
changeset
|
7 * Copyright (C) 2021-2024 Sebastien Jodogne, ICTEAM UCLouvain, Belgium |
212 | 8 * |
9 * This program is free software: you can redistribute it and/or | |
10 * modify it under the terms of the GNU Affero General Public License | |
11 * as published by the Free Software Foundation, either version 3 of | |
12 * the License, or (at your option) any later version. | |
13 * | |
14 * This program is distributed in the hope that it will be useful, but | |
15 * WITHOUT ANY WARRANTY; without even the implied warranty of | |
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | |
17 * Affero General Public License for more details. | |
18 * | |
19 * You should have received a copy of the GNU Affero General Public License | |
20 * along with this program. If not, see <http://www.gnu.org/licenses/>. | |
21 **/ | |
22 | |
23 | |
24 #include "DatabaseBackendAdapterV3.h" | |
25 | |
26 #if defined(ORTHANC_PLUGINS_VERSION_IS_ABOVE) // Macro introduced in Orthanc 1.3.1 | |
27 # if ORTHANC_PLUGINS_VERSION_IS_ABOVE(1, 9, 2) | |
28 | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
29 #include "IndexConnectionsPool.h" |
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
30 |
260
793bbbe11287
IDatabaseBackend::HasRevisionsSupport()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
256
diff
changeset
|
31 #include <Logging.h> |
212 | 32 #include <OrthancException.h> |
33 | |
34 #include <stdexcept> | |
35 #include <list> | |
36 #include <string> | |
37 #include <cassert> | |
38 | |
39 | |
40 #define ORTHANC_PLUGINS_DATABASE_CATCH(context) \ | |
41 catch (::Orthanc::OrthancException& e) \ | |
42 { \ | |
43 return static_cast<OrthancPluginErrorCode>(e.GetErrorCode()); \ | |
44 } \ | |
45 catch (::std::runtime_error& e) \ | |
46 { \ | |
47 const std::string message = "Exception in database back-end: " + std::string(e.what()); \ | |
48 OrthancPluginLogError(context, message.c_str()); \ | |
49 return OrthancPluginErrorCode_DatabasePlugin; \ | |
50 } \ | |
51 catch (...) \ | |
52 { \ | |
53 OrthancPluginLogError(context, "Native exception"); \ | |
54 return OrthancPluginErrorCode_DatabasePlugin; \ | |
55 } | |
56 | |
57 | |
58 namespace OrthancDatabases | |
59 { | |
223
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
60 static bool isBackendInUse_ = false; // Only for sanity checks |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
61 |
235
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
62 |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
63 template <typename T> |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
64 static void CopyListToVector(std::vector<T>& target, |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
65 const std::list<T>& source) |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
66 { |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
67 /** |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
68 * This has the the same effect as: |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
69 * |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
70 * target.reserve(source.size()); |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
71 * std::copy(std::begin(source), std::end(source), std::back_inserter(target)); |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
72 * |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
73 * However, this implementation is compatible with C++03 (Linux |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
74 * Standard Base), whereas "std::back_inserter" requires C++11. |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
75 **/ |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
76 |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
77 target.clear(); |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
78 target.reserve(source.size()); |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
79 |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
80 for (typename std::list<T>::const_iterator it = source.begin(); it != source.end(); ++it) |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
81 { |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
82 target.push_back(*it); |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
83 } |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
84 } |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
85 |
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
86 |
212 | 87 class DatabaseBackendAdapterV3::Output : public IDatabaseBackendOutput |
88 { | |
89 private: | |
90 struct Metadata | |
91 { | |
92 int32_t metadata; | |
93 const char* value; | |
94 }; | |
95 | |
96 _OrthancPluginDatabaseAnswerType answerType_; | |
97 std::list<std::string> stringsStore_; | |
98 | |
99 std::vector<OrthancPluginAttachment> attachments_; | |
100 std::vector<OrthancPluginChange> changes_; | |
101 std::vector<OrthancPluginDicomTag> tags_; | |
102 std::vector<OrthancPluginExportedResource> exported_; | |
103 std::vector<OrthancPluginDatabaseEvent> events_; | |
104 std::vector<int32_t> integers32_; | |
105 std::vector<int64_t> integers64_; | |
106 std::vector<OrthancPluginMatchingResource> matches_; | |
107 std::vector<Metadata> metadata_; | |
108 std::vector<std::string> stringAnswers_; | |
109 | |
110 const char* StoreString(const std::string& s) | |
111 { | |
112 stringsStore_.push_back(s); | |
113 return stringsStore_.back().c_str(); | |
114 } | |
115 | |
116 void SetupAnswerType(_OrthancPluginDatabaseAnswerType type) | |
117 { | |
118 if (answerType_ == _OrthancPluginDatabaseAnswerType_None) | |
119 { | |
120 answerType_ = type; | |
121 } | |
122 else if (answerType_ != type) | |
123 { | |
124 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
125 } | |
126 } | |
127 | |
128 public: | |
129 Output() : | |
130 answerType_(_OrthancPluginDatabaseAnswerType_None) | |
131 { | |
132 } | |
133 | |
134 void Clear() | |
135 { | |
136 // We don't systematically clear all the vectors, in order to | |
137 // avoid spending unnecessary time | |
138 | |
139 switch (answerType_) | |
140 { | |
141 case _OrthancPluginDatabaseAnswerType_None: | |
142 break; | |
143 | |
144 case _OrthancPluginDatabaseAnswerType_Attachment: | |
145 attachments_.clear(); | |
146 break; | |
147 | |
148 case _OrthancPluginDatabaseAnswerType_Change: | |
149 changes_.clear(); | |
150 break; | |
151 | |
152 case _OrthancPluginDatabaseAnswerType_DicomTag: | |
153 tags_.clear(); | |
154 break; | |
155 | |
156 case _OrthancPluginDatabaseAnswerType_ExportedResource: | |
157 exported_.clear(); | |
158 break; | |
159 | |
160 case _OrthancPluginDatabaseAnswerType_Int32: | |
161 integers32_.clear(); | |
162 break; | |
163 | |
164 case _OrthancPluginDatabaseAnswerType_Int64: | |
165 integers64_.clear(); | |
166 break; | |
167 | |
168 case _OrthancPluginDatabaseAnswerType_MatchingResource: | |
169 matches_.clear(); | |
170 break; | |
171 | |
172 case _OrthancPluginDatabaseAnswerType_Metadata: | |
173 metadata_.clear(); | |
174 break; | |
175 | |
176 case _OrthancPluginDatabaseAnswerType_String: | |
177 stringAnswers_.clear(); | |
178 break; | |
179 | |
180 default: | |
181 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); | |
182 } | |
183 | |
184 answerType_ = _OrthancPluginDatabaseAnswerType_None; | |
185 stringsStore_.clear(); | |
186 events_.clear(); | |
187 | |
188 assert(attachments_.empty()); | |
189 assert(changes_.empty()); | |
190 assert(tags_.empty()); | |
191 assert(exported_.empty()); | |
192 assert(events_.empty()); | |
193 assert(integers32_.empty()); | |
194 assert(integers64_.empty()); | |
195 assert(matches_.empty()); | |
196 assert(metadata_.empty()); | |
197 assert(stringAnswers_.empty()); | |
198 } | |
199 | |
200 | |
201 OrthancPluginErrorCode ReadAnswersCount(uint32_t& target) const | |
202 { | |
203 switch (answerType_) | |
204 { | |
205 case _OrthancPluginDatabaseAnswerType_None: | |
206 target = static_cast<uint32_t>(0); | |
207 break; | |
208 | |
209 case _OrthancPluginDatabaseAnswerType_Attachment: | |
210 target = static_cast<uint32_t>(attachments_.size()); | |
211 break; | |
212 | |
213 case _OrthancPluginDatabaseAnswerType_Change: | |
214 target = static_cast<uint32_t>(changes_.size()); | |
215 break; | |
216 | |
217 case _OrthancPluginDatabaseAnswerType_DicomTag: | |
218 target = static_cast<uint32_t>(tags_.size()); | |
219 break; | |
220 | |
221 case _OrthancPluginDatabaseAnswerType_ExportedResource: | |
222 target = static_cast<uint32_t>(exported_.size()); | |
223 break; | |
224 | |
225 case _OrthancPluginDatabaseAnswerType_Int32: | |
226 target = static_cast<uint32_t>(integers32_.size()); | |
227 break; | |
228 | |
229 case _OrthancPluginDatabaseAnswerType_Int64: | |
230 target = static_cast<uint32_t>(integers64_.size()); | |
231 break; | |
232 | |
233 case _OrthancPluginDatabaseAnswerType_MatchingResource: | |
234 target = static_cast<uint32_t>(matches_.size()); | |
235 break; | |
236 | |
237 case _OrthancPluginDatabaseAnswerType_Metadata: | |
238 target = static_cast<uint32_t>(metadata_.size()); | |
239 break; | |
240 | |
241 case _OrthancPluginDatabaseAnswerType_String: | |
242 target = static_cast<uint32_t>(stringAnswers_.size()); | |
243 break; | |
244 | |
245 default: | |
246 return OrthancPluginErrorCode_InternalError; | |
247 } | |
248 | |
249 return OrthancPluginErrorCode_Success; | |
250 } | |
251 | |
252 | |
253 OrthancPluginErrorCode ReadAnswerAttachment(OrthancPluginAttachment& target /* out */, | |
254 uint32_t index) const | |
255 { | |
256 if (index < attachments_.size()) | |
257 { | |
258 target = attachments_[index]; | |
259 return OrthancPluginErrorCode_Success; | |
260 } | |
261 else | |
262 { | |
263 return OrthancPluginErrorCode_ParameterOutOfRange; | |
264 } | |
265 } | |
266 | |
267 | |
268 OrthancPluginErrorCode ReadAnswerChange(OrthancPluginChange& target /* out */, | |
269 uint32_t index) const | |
270 { | |
271 if (index < changes_.size()) | |
272 { | |
273 target = changes_[index]; | |
274 return OrthancPluginErrorCode_Success; | |
275 } | |
276 else | |
277 { | |
278 return OrthancPluginErrorCode_ParameterOutOfRange; | |
279 } | |
280 } | |
281 | |
282 | |
283 OrthancPluginErrorCode ReadAnswerDicomTag(uint16_t& group, | |
284 uint16_t& element, | |
285 const char*& value, | |
286 uint32_t index) const | |
287 { | |
288 if (index < tags_.size()) | |
289 { | |
290 const OrthancPluginDicomTag& tag = tags_[index]; | |
291 group = tag.group; | |
292 element = tag.element; | |
293 value = tag.value; | |
294 return OrthancPluginErrorCode_Success; | |
295 } | |
296 else | |
297 { | |
298 return OrthancPluginErrorCode_ParameterOutOfRange; | |
299 } | |
300 } | |
301 | |
302 | |
303 OrthancPluginErrorCode ReadAnswerExportedResource(OrthancPluginExportedResource& target /* out */, | |
304 uint32_t index) const | |
305 { | |
306 if (index < exported_.size()) | |
307 { | |
308 target = exported_[index]; | |
309 return OrthancPluginErrorCode_Success; | |
310 } | |
311 else | |
312 { | |
313 return OrthancPluginErrorCode_ParameterOutOfRange; | |
314 } | |
315 } | |
316 | |
317 | |
318 OrthancPluginErrorCode ReadAnswerInt32(int32_t& target, | |
319 uint32_t index) const | |
320 { | |
321 if (index < integers32_.size()) | |
322 { | |
323 target = integers32_[index]; | |
324 return OrthancPluginErrorCode_Success; | |
325 } | |
326 else | |
327 { | |
328 return OrthancPluginErrorCode_ParameterOutOfRange; | |
329 } | |
330 } | |
331 | |
332 | |
333 OrthancPluginErrorCode ReadAnswerInt64(int64_t& target, | |
334 uint32_t index) const | |
335 { | |
336 if (index < integers64_.size()) | |
337 { | |
338 target = integers64_[index]; | |
339 return OrthancPluginErrorCode_Success; | |
340 } | |
341 else | |
342 { | |
343 return OrthancPluginErrorCode_ParameterOutOfRange; | |
344 } | |
345 } | |
346 | |
347 | |
348 OrthancPluginErrorCode ReadAnswerMatchingResource(OrthancPluginMatchingResource& target, | |
349 uint32_t index) const | |
350 { | |
351 if (index < matches_.size()) | |
352 { | |
353 target = matches_[index]; | |
354 return OrthancPluginErrorCode_Success; | |
355 } | |
356 else | |
357 { | |
358 return OrthancPluginErrorCode_ParameterOutOfRange; | |
359 } | |
360 } | |
361 | |
362 | |
363 OrthancPluginErrorCode ReadAnswerMetadata(int32_t& metadata, | |
364 const char*& value, | |
365 uint32_t index) const | |
366 { | |
367 if (index < metadata_.size()) | |
368 { | |
369 const Metadata& tmp = metadata_[index]; | |
370 metadata = tmp.metadata; | |
371 value = tmp.value; | |
372 return OrthancPluginErrorCode_Success; | |
373 } | |
374 else | |
375 { | |
376 return OrthancPluginErrorCode_ParameterOutOfRange; | |
377 } | |
378 } | |
379 | |
380 | |
381 OrthancPluginErrorCode ReadAnswerString(const char*& target, | |
382 uint32_t index) const | |
383 { | |
384 if (index < stringAnswers_.size()) | |
385 { | |
386 target = stringAnswers_[index].c_str(); | |
387 return OrthancPluginErrorCode_Success; | |
388 } | |
389 else | |
390 { | |
391 return OrthancPluginErrorCode_ParameterOutOfRange; | |
392 } | |
393 } | |
394 | |
395 | |
396 OrthancPluginErrorCode ReadEventsCount(uint32_t& target /* out */) const | |
397 { | |
398 target = static_cast<uint32_t>(events_.size()); | |
399 return OrthancPluginErrorCode_Success; | |
400 } | |
401 | |
402 | |
403 OrthancPluginErrorCode ReadEvent(OrthancPluginDatabaseEvent& event /* out */, | |
404 uint32_t index) const | |
405 { | |
406 if (index < events_.size()) | |
407 { | |
408 event = events_[index]; | |
409 return OrthancPluginErrorCode_Success; | |
410 } | |
411 else | |
412 { | |
413 return OrthancPluginErrorCode_ParameterOutOfRange; | |
414 } | |
415 } | |
416 | |
417 | |
418 virtual void SignalDeletedAttachment(const std::string& uuid, | |
419 int32_t contentType, | |
420 uint64_t uncompressedSize, | |
421 const std::string& uncompressedHash, | |
422 int32_t compressionType, | |
423 uint64_t compressedSize, | |
424 const std::string& compressedHash) ORTHANC_OVERRIDE | |
425 { | |
426 OrthancPluginDatabaseEvent event; | |
427 event.type = OrthancPluginDatabaseEventType_DeletedAttachment; | |
428 event.content.attachment.uuid = StoreString(uuid); | |
429 event.content.attachment.contentType = contentType; | |
430 event.content.attachment.uncompressedSize = uncompressedSize; | |
431 event.content.attachment.uncompressedHash = StoreString(uncompressedHash); | |
432 event.content.attachment.compressionType = compressionType; | |
433 event.content.attachment.compressedSize = compressedSize; | |
434 event.content.attachment.compressedHash = StoreString(compressedHash); | |
435 | |
436 events_.push_back(event); | |
437 } | |
438 | |
439 | |
440 virtual void SignalDeletedResource(const std::string& publicId, | |
441 OrthancPluginResourceType resourceType) ORTHANC_OVERRIDE | |
442 { | |
443 OrthancPluginDatabaseEvent event; | |
444 event.type = OrthancPluginDatabaseEventType_DeletedResource; | |
445 event.content.resource.level = resourceType; | |
446 event.content.resource.publicId = StoreString(publicId); | |
447 | |
448 events_.push_back(event); | |
449 } | |
450 | |
451 | |
452 virtual void SignalRemainingAncestor(const std::string& ancestorId, | |
453 OrthancPluginResourceType ancestorType) ORTHANC_OVERRIDE | |
454 { | |
455 OrthancPluginDatabaseEvent event; | |
456 event.type = OrthancPluginDatabaseEventType_RemainingAncestor; | |
457 event.content.resource.level = ancestorType; | |
458 event.content.resource.publicId = StoreString(ancestorId); | |
459 | |
460 events_.push_back(event); | |
461 } | |
462 | |
463 | |
464 virtual void AnswerAttachment(const std::string& uuid, | |
465 int32_t contentType, | |
466 uint64_t uncompressedSize, | |
467 const std::string& uncompressedHash, | |
468 int32_t compressionType, | |
469 uint64_t compressedSize, | |
470 const std::string& compressedHash) ORTHANC_OVERRIDE | |
471 { | |
472 SetupAnswerType(_OrthancPluginDatabaseAnswerType_Attachment); | |
473 | |
474 OrthancPluginAttachment attachment; | |
475 attachment.uuid = StoreString(uuid); | |
476 attachment.contentType = contentType; | |
477 attachment.uncompressedSize = uncompressedSize; | |
478 attachment.uncompressedHash = StoreString(uncompressedHash); | |
479 attachment.compressionType = compressionType; | |
480 attachment.compressedSize = compressedSize; | |
481 attachment.compressedHash = StoreString(compressedHash); | |
482 | |
483 attachments_.push_back(attachment); | |
484 } | |
485 | |
486 | |
487 virtual void AnswerChange(int64_t seq, | |
488 int32_t changeType, | |
489 OrthancPluginResourceType resourceType, | |
490 const std::string& publicId, | |
491 const std::string& date) ORTHANC_OVERRIDE | |
492 { | |
493 SetupAnswerType(_OrthancPluginDatabaseAnswerType_Change); | |
494 | |
495 OrthancPluginChange change; | |
496 change.seq = seq; | |
497 change.changeType = changeType; | |
498 change.resourceType = resourceType; | |
499 change.publicId = StoreString(publicId); | |
500 change.date = StoreString(date); | |
501 | |
502 changes_.push_back(change); | |
503 } | |
504 | |
505 | |
506 virtual void AnswerDicomTag(uint16_t group, | |
507 uint16_t element, | |
508 const std::string& value) ORTHANC_OVERRIDE | |
509 { | |
510 SetupAnswerType(_OrthancPluginDatabaseAnswerType_DicomTag); | |
511 | |
512 OrthancPluginDicomTag tag; | |
513 tag.group = group; | |
514 tag.element = element; | |
515 tag.value = StoreString(value); | |
516 | |
517 tags_.push_back(tag); | |
518 } | |
519 | |
520 | |
521 virtual void AnswerExportedResource(int64_t seq, | |
522 OrthancPluginResourceType resourceType, | |
523 const std::string& publicId, | |
524 const std::string& modality, | |
525 const std::string& date, | |
526 const std::string& patientId, | |
527 const std::string& studyInstanceUid, | |
528 const std::string& seriesInstanceUid, | |
529 const std::string& sopInstanceUid) ORTHANC_OVERRIDE | |
530 { | |
531 SetupAnswerType(_OrthancPluginDatabaseAnswerType_ExportedResource); | |
532 | |
533 OrthancPluginExportedResource exported; | |
534 exported.seq = seq; | |
535 exported.resourceType = resourceType; | |
536 exported.publicId = StoreString(publicId); | |
537 exported.modality = StoreString(modality); | |
538 exported.date = StoreString(date); | |
539 exported.patientId = StoreString(patientId); | |
540 exported.studyInstanceUid = StoreString(studyInstanceUid); | |
541 exported.seriesInstanceUid = StoreString(seriesInstanceUid); | |
542 exported.sopInstanceUid = StoreString(sopInstanceUid); | |
543 | |
544 exported_.push_back(exported); | |
545 } | |
546 | |
547 | |
548 virtual void AnswerMatchingResource(const std::string& resourceId) ORTHANC_OVERRIDE | |
549 { | |
550 SetupAnswerType(_OrthancPluginDatabaseAnswerType_MatchingResource); | |
551 | |
552 OrthancPluginMatchingResource match; | |
553 match.resourceId = StoreString(resourceId); | |
554 match.someInstanceId = NULL; | |
555 | |
556 matches_.push_back(match); | |
557 } | |
558 | |
559 | |
560 virtual void AnswerMatchingResource(const std::string& resourceId, | |
561 const std::string& someInstanceId) ORTHANC_OVERRIDE | |
562 { | |
563 SetupAnswerType(_OrthancPluginDatabaseAnswerType_MatchingResource); | |
564 | |
565 OrthancPluginMatchingResource match; | |
566 match.resourceId = StoreString(resourceId); | |
567 match.someInstanceId = StoreString(someInstanceId); | |
568 | |
569 matches_.push_back(match); | |
570 } | |
571 | |
235
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
572 |
212 | 573 void AnswerIntegers32(const std::list<int32_t>& values) |
574 { | |
575 SetupAnswerType(_OrthancPluginDatabaseAnswerType_Int32); | |
235
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
576 CopyListToVector(integers32_, values); |
212 | 577 } |
578 | |
579 | |
580 void AnswerIntegers64(const std::list<int64_t>& values) | |
581 { | |
582 SetupAnswerType(_OrthancPluginDatabaseAnswerType_Int64); | |
235
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
583 CopyListToVector(integers64_, values); |
212 | 584 } |
585 | |
586 | |
587 void AnswerInteger64(int64_t value) | |
588 { | |
589 SetupAnswerType(_OrthancPluginDatabaseAnswerType_Int64); | |
590 | |
591 integers64_.resize(1); | |
592 integers64_[0] = value; | |
593 } | |
594 | |
595 | |
596 void AnswerMetadata(int32_t metadata, | |
597 const std::string& value) | |
598 { | |
599 SetupAnswerType(_OrthancPluginDatabaseAnswerType_Metadata); | |
600 | |
601 Metadata tmp; | |
602 tmp.metadata = metadata; | |
603 tmp.value = StoreString(value); | |
604 | |
605 metadata_.push_back(tmp); | |
606 } | |
607 | |
608 | |
609 void AnswerStrings(const std::list<std::string>& values) | |
610 { | |
611 SetupAnswerType(_OrthancPluginDatabaseAnswerType_String); | |
235
f2b32d31fc99
fix lsb build, fix backward compatibility with SDK <= 1.9.1
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
234
diff
changeset
|
612 CopyListToVector(stringAnswers_, values); |
212 | 613 } |
614 | |
615 | |
616 void AnswerString(const std::string& value) | |
617 { | |
618 SetupAnswerType(_OrthancPluginDatabaseAnswerType_String); | |
619 | |
620 if (stringAnswers_.empty()) | |
621 { | |
622 stringAnswers_.push_back(value); | |
623 } | |
624 else | |
625 { | |
626 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); | |
627 } | |
628 } | |
629 }; | |
630 | |
631 | |
632 IDatabaseBackendOutput* DatabaseBackendAdapterV3::Factory::CreateOutput() | |
633 { | |
634 return new DatabaseBackendAdapterV3::Output; | |
635 } | |
636 | |
637 | |
638 class DatabaseBackendAdapterV3::Transaction : public boost::noncopyable | |
639 { | |
640 private: | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
641 IndexConnectionsPool& pool_; |
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
642 std::unique_ptr<IndexConnectionsPool::Accessor> accessor_; |
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
643 std::unique_ptr<Output> output_; |
232
4e15eace9b90
reorganization in DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
644 |
212 | 645 public: |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
646 Transaction(IndexConnectionsPool& pool) : |
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
647 pool_(pool), |
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
648 accessor_(new IndexConnectionsPool::Accessor(pool)), |
212 | 649 output_(new Output) |
650 { | |
651 } | |
652 | |
653 ~Transaction() | |
654 { | |
655 } | |
656 | |
657 IndexBackend& GetBackend() const | |
658 { | |
232
4e15eace9b90
reorganization in DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
226
diff
changeset
|
659 return accessor_->GetBackend(); |
212 | 660 } |
661 | |
662 Output& GetOutput() const | |
663 { | |
664 return *output_; | |
665 } | |
666 | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
667 DatabaseManager& GetManager() const |
212 | 668 { |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
669 return accessor_->GetManager(); |
212 | 670 } |
671 }; | |
672 | |
673 | |
674 static OrthancPluginErrorCode ReadAnswersCount(OrthancPluginDatabaseTransaction* transaction, | |
675 uint32_t* target /* out */) | |
676 { | |
677 assert(target != NULL); | |
678 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
679 return that.GetOutput().ReadAnswersCount(*target); | |
680 } | |
681 | |
682 | |
683 static OrthancPluginErrorCode ReadAnswerAttachment(OrthancPluginDatabaseTransaction* transaction, | |
684 OrthancPluginAttachment* target /* out */, | |
685 uint32_t index) | |
686 { | |
687 assert(target != NULL); | |
688 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
689 return that.GetOutput().ReadAnswerAttachment(*target, index); | |
690 } | |
691 | |
692 | |
693 static OrthancPluginErrorCode ReadAnswerChange(OrthancPluginDatabaseTransaction* transaction, | |
694 OrthancPluginChange* target /* out */, | |
695 uint32_t index) | |
696 { | |
697 assert(target != NULL); | |
698 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
699 return that.GetOutput().ReadAnswerChange(*target, index); | |
700 } | |
701 | |
702 | |
703 static OrthancPluginErrorCode ReadAnswerDicomTag(OrthancPluginDatabaseTransaction* transaction, | |
704 uint16_t* group, | |
705 uint16_t* element, | |
706 const char** value, | |
707 uint32_t index) | |
708 { | |
709 assert(group != NULL); | |
710 assert(element != NULL); | |
711 assert(value != NULL); | |
712 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
713 return that.GetOutput().ReadAnswerDicomTag(*group, *element, *value, index); | |
714 } | |
715 | |
716 | |
717 static OrthancPluginErrorCode ReadAnswerExportedResource(OrthancPluginDatabaseTransaction* transaction, | |
718 OrthancPluginExportedResource* target /* out */, | |
719 uint32_t index) | |
720 { | |
721 assert(target != NULL); | |
722 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
723 return that.GetOutput().ReadAnswerExportedResource(*target, index); | |
724 } | |
725 | |
726 | |
727 static OrthancPluginErrorCode ReadAnswerInt32(OrthancPluginDatabaseTransaction* transaction, | |
728 int32_t* target, | |
729 uint32_t index) | |
730 { | |
731 assert(target != NULL); | |
732 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
733 return that.GetOutput().ReadAnswerInt32(*target, index); | |
734 } | |
735 | |
736 | |
737 static OrthancPluginErrorCode ReadAnswerInt64(OrthancPluginDatabaseTransaction* transaction, | |
738 int64_t* target, | |
739 uint32_t index) | |
740 { | |
741 assert(target != NULL); | |
742 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
743 return that.GetOutput().ReadAnswerInt64(*target, index); | |
744 } | |
745 | |
746 | |
747 static OrthancPluginErrorCode ReadAnswerMatchingResource(OrthancPluginDatabaseTransaction* transaction, | |
748 OrthancPluginMatchingResource* target, | |
749 uint32_t index) | |
750 { | |
751 assert(target != NULL); | |
752 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
753 return that.GetOutput().ReadAnswerMatchingResource(*target, index); | |
754 } | |
755 | |
756 | |
757 static OrthancPluginErrorCode ReadAnswerMetadata(OrthancPluginDatabaseTransaction* transaction, | |
758 int32_t* metadata, | |
759 const char** value, | |
760 uint32_t index) | |
761 { | |
762 assert(metadata != NULL); | |
763 assert(value != NULL); | |
764 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
765 return that.GetOutput().ReadAnswerMetadata(*metadata, *value, index); | |
766 } | |
767 | |
768 | |
769 static OrthancPluginErrorCode ReadAnswerString(OrthancPluginDatabaseTransaction* transaction, | |
770 const char** target, | |
771 uint32_t index) | |
772 { | |
773 assert(target != NULL); | |
774 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
775 return that.GetOutput().ReadAnswerString(*target, index); | |
776 } | |
777 | |
778 | |
779 static OrthancPluginErrorCode ReadEventsCount(OrthancPluginDatabaseTransaction* transaction, | |
780 uint32_t* target /* out */) | |
781 { | |
782 assert(target != NULL); | |
783 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
784 return that.GetOutput().ReadEventsCount(*target); | |
785 } | |
786 | |
787 | |
788 static OrthancPluginErrorCode ReadEvent(OrthancPluginDatabaseTransaction* transaction, | |
789 OrthancPluginDatabaseEvent* event /* out */, | |
790 uint32_t index) | |
791 { | |
792 assert(event != NULL); | |
793 const DatabaseBackendAdapterV3::Transaction& that = *reinterpret_cast<const DatabaseBackendAdapterV3::Transaction*>(transaction); | |
794 return that.GetOutput().ReadEvent(*event, index); | |
795 } | |
796 | |
797 | |
798 static OrthancPluginErrorCode Open(void* database) | |
799 { | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
800 IndexConnectionsPool* pool = reinterpret_cast<IndexConnectionsPool*>(database); |
212 | 801 |
802 try | |
803 { | |
403
91124cc8a8c7
database plugins are informed about the identifier tags
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
401
diff
changeset
|
804 std::list<IdentifierTag> identifierTags; |
91124cc8a8c7
database plugins are informed about the identifier tags
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
401
diff
changeset
|
805 pool->OpenConnections(false, identifierTags); |
212 | 806 return OrthancPluginErrorCode_Success; |
807 } | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
808 ORTHANC_PLUGINS_DATABASE_CATCH(pool->GetContext()); |
212 | 809 } |
810 | |
811 | |
812 static OrthancPluginErrorCode Close(void* database) | |
813 { | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
814 IndexConnectionsPool* pool = reinterpret_cast<IndexConnectionsPool*>(database); |
212 | 815 |
816 try | |
817 { | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
818 pool->CloseConnections(); |
212 | 819 return OrthancPluginErrorCode_Success; |
820 } | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
821 ORTHANC_PLUGINS_DATABASE_CATCH(pool->GetContext()); |
212 | 822 } |
823 | |
824 | |
825 static OrthancPluginErrorCode DestructDatabase(void* database) | |
826 { | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
827 IndexConnectionsPool* pool = reinterpret_cast<IndexConnectionsPool*>(database); |
223
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
828 |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
829 if (pool == NULL) |
212 | 830 { |
831 return OrthancPluginErrorCode_InternalError; | |
832 } | |
833 else | |
834 { | |
223
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
835 if (isBackendInUse_) |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
836 { |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
837 isBackendInUse_ = false; |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
838 } |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
839 else |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
840 { |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
841 OrthancPluginLogError(pool->GetContext(), "More than one index backend was registered, internal error"); |
223
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
842 } |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
843 |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
844 delete pool; |
223
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
845 |
212 | 846 return OrthancPluginErrorCode_Success; |
847 } | |
848 } | |
849 | |
850 | |
851 static OrthancPluginErrorCode GetDatabaseVersion(void* database, | |
852 uint32_t* version) | |
853 { | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
854 IndexConnectionsPool* pool = reinterpret_cast<IndexConnectionsPool*>(database); |
212 | 855 |
856 try | |
857 { | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
858 IndexConnectionsPool::Accessor accessor(*pool); |
233 | 859 *version = accessor.GetBackend().GetDatabaseVersion(accessor.GetManager()); |
212 | 860 return OrthancPluginErrorCode_Success; |
861 } | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
862 ORTHANC_PLUGINS_DATABASE_CATCH(pool->GetContext()); |
212 | 863 } |
864 | |
865 | |
866 static OrthancPluginErrorCode UpgradeDatabase(void* database, | |
867 OrthancPluginStorageArea* storageArea, | |
868 uint32_t targetVersion) | |
869 { | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
870 IndexConnectionsPool* pool = reinterpret_cast<IndexConnectionsPool*>(database); |
212 | 871 |
872 try | |
873 { | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
874 IndexConnectionsPool::Accessor accessor(*pool); |
233 | 875 accessor.GetBackend().UpgradeDatabase(accessor.GetManager(), targetVersion, storageArea); |
212 | 876 return OrthancPluginErrorCode_Success; |
877 } | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
878 ORTHANC_PLUGINS_DATABASE_CATCH(pool->GetContext()); |
212 | 879 } |
880 | |
881 | |
264
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
882 static OrthancPluginErrorCode HasRevisionsSupport(void* database, |
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
883 uint8_t* target) |
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
884 { |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
885 IndexConnectionsPool* pool = reinterpret_cast<IndexConnectionsPool*>(database); |
264
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
886 |
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
887 try |
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
888 { |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
889 IndexConnectionsPool::Accessor accessor(*pool); |
264
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
890 *target = (accessor.GetBackend().HasRevisionsSupport() ? 1 : 0); |
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
891 return OrthancPluginErrorCode_Success; |
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
892 } |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
893 ORTHANC_PLUGINS_DATABASE_CATCH(pool->GetContext()); |
264
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
894 } |
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
895 |
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
896 |
212 | 897 static OrthancPluginErrorCode StartTransaction(void* database, |
898 OrthancPluginDatabaseTransaction** target /* out */, | |
899 OrthancPluginDatabaseTransactionType type) | |
900 { | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
901 IndexConnectionsPool* pool = reinterpret_cast<IndexConnectionsPool*>(database); |
212 | 902 |
903 try | |
904 { | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
905 std::unique_ptr<DatabaseBackendAdapterV3::Transaction> transaction(new DatabaseBackendAdapterV3::Transaction(*pool)); |
212 | 906 |
907 switch (type) | |
908 { | |
909 case OrthancPluginDatabaseTransactionType_ReadOnly: | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
910 transaction->GetManager().StartTransaction(TransactionType_ReadOnly); |
212 | 911 break; |
912 | |
913 case OrthancPluginDatabaseTransactionType_ReadWrite: | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
914 transaction->GetManager().StartTransaction(TransactionType_ReadWrite); |
212 | 915 break; |
916 | |
917 default: | |
918 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange); | |
919 } | |
920 | |
921 *target = reinterpret_cast<OrthancPluginDatabaseTransaction*>(transaction.release()); | |
922 | |
923 return OrthancPluginErrorCode_Success; | |
924 } | |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
925 ORTHANC_PLUGINS_DATABASE_CATCH(pool->GetContext()); |
212 | 926 } |
927 | |
928 | |
929 static OrthancPluginErrorCode DestructTransaction(OrthancPluginDatabaseTransaction* transaction) | |
930 { | |
931 if (transaction == NULL) | |
932 { | |
933 return OrthancPluginErrorCode_NullPointer; | |
934 } | |
935 else | |
936 { | |
937 delete reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
938 return OrthancPluginErrorCode_Success; | |
939 } | |
940 } | |
941 | |
942 | |
943 static OrthancPluginErrorCode Rollback(OrthancPluginDatabaseTransaction* transaction) | |
944 { | |
945 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
946 | |
947 try | |
948 { | |
949 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
950 t->GetManager().RollbackTransaction(); |
212 | 951 return OrthancPluginErrorCode_Success; |
952 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
953 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 954 } |
955 | |
956 | |
957 static OrthancPluginErrorCode Commit(OrthancPluginDatabaseTransaction* transaction, | |
958 int64_t fileSizeDelta /* TODO - not used? */) | |
959 { | |
960 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
961 | |
962 try | |
963 { | |
964 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
965 t->GetManager().CommitTransaction(); |
212 | 966 return OrthancPluginErrorCode_Success; |
967 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
968 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 969 } |
970 | |
971 | |
972 static OrthancPluginErrorCode AddAttachment(OrthancPluginDatabaseTransaction* transaction, | |
973 int64_t id, | |
261
34e2b93a7ac1
implementing interface for revisions in attachments
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
260
diff
changeset
|
974 const OrthancPluginAttachment* attachment, |
34e2b93a7ac1
implementing interface for revisions in attachments
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
260
diff
changeset
|
975 int64_t revision) |
212 | 976 { |
977 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
978 | |
979 try | |
980 { | |
981 t->GetOutput().Clear(); | |
261
34e2b93a7ac1
implementing interface for revisions in attachments
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
260
diff
changeset
|
982 t->GetBackend().AddAttachment(t->GetManager(), id, *attachment, revision); |
212 | 983 return OrthancPluginErrorCode_Success; |
984 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
985 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 986 } |
987 | |
988 | |
989 static OrthancPluginErrorCode ClearChanges(OrthancPluginDatabaseTransaction* transaction) | |
990 { | |
991 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
992 | |
993 try | |
994 { | |
995 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
996 t->GetBackend().ClearChanges(t->GetManager()); |
212 | 997 return OrthancPluginErrorCode_Success; |
998 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
999 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1000 } |
1001 | |
1002 | |
1003 static OrthancPluginErrorCode ClearExportedResources(OrthancPluginDatabaseTransaction* transaction) | |
1004 { | |
1005 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1006 | |
1007 try | |
1008 { | |
1009 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1010 t->GetBackend().ClearExportedResources(t->GetManager()); |
212 | 1011 return OrthancPluginErrorCode_Success; |
1012 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1013 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1014 } |
1015 | |
1016 | |
1017 static OrthancPluginErrorCode ClearMainDicomTags(OrthancPluginDatabaseTransaction* transaction, | |
1018 int64_t resourceId) | |
1019 { | |
1020 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1021 | |
1022 try | |
1023 { | |
1024 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1025 t->GetBackend().ClearMainDicomTags(t->GetManager(), resourceId); |
212 | 1026 return OrthancPluginErrorCode_Success; |
1027 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1028 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1029 } |
1030 | |
1031 | |
1032 static OrthancPluginErrorCode CreateInstance(OrthancPluginDatabaseTransaction* transaction, | |
1033 OrthancPluginCreateInstanceResult* target /* out */, | |
1034 const char* hashPatient, | |
1035 const char* hashStudy, | |
1036 const char* hashSeries, | |
1037 const char* hashInstance) | |
1038 { | |
1039 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1040 | |
1041 try | |
1042 { | |
1043 t->GetOutput().Clear(); | |
1044 | |
1045 if (t->GetBackend().HasCreateInstance()) | |
1046 { | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1047 t->GetBackend().CreateInstance(*target, t->GetManager(), hashPatient, hashStudy, hashSeries, hashInstance); |
212 | 1048 } |
1049 else | |
1050 { | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1051 t->GetBackend().CreateInstanceGeneric(*target, t->GetManager(), hashPatient, hashStudy, hashSeries, hashInstance); |
212 | 1052 } |
1053 | |
1054 return OrthancPluginErrorCode_Success; | |
1055 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1056 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1057 } |
1058 | |
1059 | |
1060 static OrthancPluginErrorCode DeleteAttachment(OrthancPluginDatabaseTransaction* transaction, | |
1061 int64_t id, | |
1062 int32_t contentType) | |
1063 { | |
1064 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1065 | |
1066 try | |
1067 { | |
1068 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1069 t->GetBackend().DeleteAttachment(t->GetOutput(), t->GetManager(), id, contentType); |
212 | 1070 return OrthancPluginErrorCode_Success; |
1071 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1072 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1073 } |
1074 | |
1075 | |
1076 static OrthancPluginErrorCode DeleteMetadata(OrthancPluginDatabaseTransaction* transaction, | |
1077 int64_t id, | |
1078 int32_t metadataType) | |
1079 { | |
1080 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1081 | |
1082 try | |
1083 { | |
1084 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1085 t->GetBackend().DeleteMetadata(t->GetManager(), id, metadataType); |
212 | 1086 return OrthancPluginErrorCode_Success; |
1087 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1088 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1089 } |
1090 | |
1091 | |
1092 static OrthancPluginErrorCode DeleteResource(OrthancPluginDatabaseTransaction* transaction, | |
1093 int64_t id) | |
1094 { | |
1095 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1096 | |
1097 try | |
1098 { | |
1099 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1100 t->GetBackend().DeleteResource(t->GetOutput(), t->GetManager(), id); |
212 | 1101 return OrthancPluginErrorCode_Success; |
1102 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1103 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1104 } |
1105 | |
1106 | |
1107 static OrthancPluginErrorCode GetAllMetadata(OrthancPluginDatabaseTransaction* transaction, | |
1108 int64_t id) | |
1109 { | |
1110 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1111 | |
1112 try | |
1113 { | |
1114 t->GetOutput().Clear(); | |
1115 | |
1116 std::map<int32_t, std::string> values; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1117 t->GetBackend().GetAllMetadata(values, t->GetManager(), id); |
212 | 1118 |
1119 for (std::map<int32_t, std::string>::const_iterator it = values.begin(); it != values.end(); ++it) | |
1120 { | |
1121 t->GetOutput().AnswerMetadata(it->first, it->second); | |
1122 } | |
1123 | |
1124 return OrthancPluginErrorCode_Success; | |
1125 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1126 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1127 } |
1128 | |
1129 | |
1130 static OrthancPluginErrorCode GetAllPublicIds(OrthancPluginDatabaseTransaction* transaction, | |
1131 OrthancPluginResourceType resourceType) | |
1132 { | |
1133 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1134 | |
1135 try | |
1136 { | |
1137 t->GetOutput().Clear(); | |
1138 | |
1139 std::list<std::string> values; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1140 t->GetBackend().GetAllPublicIds(values, t->GetManager(), resourceType); |
212 | 1141 t->GetOutput().AnswerStrings(values); |
1142 | |
1143 return OrthancPluginErrorCode_Success; | |
1144 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1145 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1146 } |
1147 | |
1148 | |
1149 static OrthancPluginErrorCode GetAllPublicIdsWithLimit(OrthancPluginDatabaseTransaction* transaction, | |
1150 OrthancPluginResourceType resourceType, | |
1151 uint64_t since, | |
1152 uint64_t limit) | |
1153 { | |
1154 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1155 | |
1156 try | |
1157 { | |
1158 t->GetOutput().Clear(); | |
1159 | |
1160 std::list<std::string> values; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1161 t->GetBackend().GetAllPublicIds(values, t->GetManager(), resourceType, since, limit); |
212 | 1162 t->GetOutput().AnswerStrings(values); |
1163 | |
1164 return OrthancPluginErrorCode_Success; | |
1165 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1166 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1167 } |
1168 | |
1169 | |
1170 static OrthancPluginErrorCode GetChanges(OrthancPluginDatabaseTransaction* transaction, | |
1171 uint8_t* targetDone /* out */, | |
1172 int64_t since, | |
1173 uint32_t maxResults) | |
1174 { | |
1175 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1176 | |
1177 try | |
1178 { | |
1179 t->GetOutput().Clear(); | |
1180 | |
1181 bool done; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1182 t->GetBackend().GetChanges(t->GetOutput(), done, t->GetManager(), since, maxResults); |
212 | 1183 *targetDone = (done ? 1 : 0); |
1184 | |
1185 return OrthancPluginErrorCode_Success; | |
1186 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1187 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1188 } |
1189 | |
1190 | |
1191 static OrthancPluginErrorCode GetChildrenInternalId(OrthancPluginDatabaseTransaction* transaction, | |
1192 int64_t id) | |
1193 { | |
1194 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1195 | |
1196 try | |
1197 { | |
1198 t->GetOutput().Clear(); | |
1199 | |
1200 std::list<int64_t> values; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1201 t->GetBackend().GetChildrenInternalId(values, t->GetManager(), id); |
212 | 1202 t->GetOutput().AnswerIntegers64(values); |
1203 | |
1204 return OrthancPluginErrorCode_Success; | |
1205 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1206 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1207 } |
1208 | |
1209 | |
1210 static OrthancPluginErrorCode GetChildrenMetadata(OrthancPluginDatabaseTransaction* transaction, | |
1211 int64_t resourceId, | |
1212 int32_t metadata) | |
1213 { | |
1214 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1215 | |
1216 try | |
1217 { | |
1218 t->GetOutput().Clear(); | |
1219 | |
1220 std::list<std::string> values; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1221 t->GetBackend().GetChildrenMetadata(values, t->GetManager(), resourceId, metadata); |
212 | 1222 t->GetOutput().AnswerStrings(values); |
1223 | |
1224 return OrthancPluginErrorCode_Success; | |
1225 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1226 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1227 } |
1228 | |
1229 | |
1230 static OrthancPluginErrorCode GetChildrenPublicId(OrthancPluginDatabaseTransaction* transaction, | |
1231 int64_t id) | |
1232 { | |
1233 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1234 | |
1235 try | |
1236 { | |
1237 t->GetOutput().Clear(); | |
1238 | |
1239 std::list<std::string> values; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1240 t->GetBackend().GetChildrenPublicId(values, t->GetManager(), id); |
212 | 1241 t->GetOutput().AnswerStrings(values); |
1242 | |
1243 return OrthancPluginErrorCode_Success; | |
1244 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1245 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1246 } |
1247 | |
1248 | |
1249 static OrthancPluginErrorCode GetExportedResources(OrthancPluginDatabaseTransaction* transaction, | |
1250 uint8_t* targetDone /* out */, | |
1251 int64_t since, | |
1252 uint32_t maxResults) | |
1253 { | |
1254 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1255 | |
1256 try | |
1257 { | |
1258 t->GetOutput().Clear(); | |
1259 | |
1260 bool done; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1261 t->GetBackend().GetExportedResources(t->GetOutput(), done, t->GetManager(), since, maxResults); |
212 | 1262 *targetDone = (done ? 1 : 0); |
1263 | |
1264 return OrthancPluginErrorCode_Success; | |
1265 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1266 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1267 } |
1268 | |
1269 | |
1270 static OrthancPluginErrorCode GetLastChange(OrthancPluginDatabaseTransaction* transaction) | |
1271 { | |
1272 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1273 | |
1274 try | |
1275 { | |
1276 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1277 t->GetBackend().GetLastChange(t->GetOutput(), t->GetManager()); |
212 | 1278 return OrthancPluginErrorCode_Success; |
1279 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1280 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1281 } |
1282 | |
1283 | |
1284 static OrthancPluginErrorCode GetLastChangeIndex(OrthancPluginDatabaseTransaction* transaction, | |
1285 int64_t* target) | |
1286 { | |
1287 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1288 | |
1289 try | |
1290 { | |
1291 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1292 *target = t->GetBackend().GetLastChangeIndex(t->GetManager()); |
212 | 1293 return OrthancPluginErrorCode_Success; |
1294 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1295 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1296 } |
1297 | |
1298 | |
1299 static OrthancPluginErrorCode GetLastExportedResource(OrthancPluginDatabaseTransaction* transaction) | |
1300 { | |
1301 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1302 | |
1303 try | |
1304 { | |
1305 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1306 t->GetBackend().GetLastExportedResource(t->GetOutput(), t->GetManager()); |
212 | 1307 return OrthancPluginErrorCode_Success; |
1308 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1309 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1310 } |
1311 | |
1312 | |
1313 static OrthancPluginErrorCode GetMainDicomTags(OrthancPluginDatabaseTransaction* transaction, | |
1314 int64_t id) | |
1315 { | |
1316 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1317 | |
1318 try | |
1319 { | |
1320 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1321 t->GetBackend().GetMainDicomTags(t->GetOutput(), t->GetManager(), id); |
212 | 1322 return OrthancPluginErrorCode_Success; |
1323 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1324 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1325 } |
1326 | |
1327 | |
1328 static OrthancPluginErrorCode GetPublicId(OrthancPluginDatabaseTransaction* transaction, | |
1329 int64_t id) | |
1330 { | |
1331 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1332 | |
1333 try | |
1334 { | |
1335 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1336 t->GetOutput().AnswerString(t->GetBackend().GetPublicId(t->GetManager(), id)); |
212 | 1337 return OrthancPluginErrorCode_Success; |
1338 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1339 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1340 } |
1341 | |
1342 | |
1343 static OrthancPluginErrorCode GetResourcesCount(OrthancPluginDatabaseTransaction* transaction, | |
1344 uint64_t* target /* out */, | |
1345 OrthancPluginResourceType resourceType) | |
1346 { | |
1347 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1348 | |
1349 try | |
1350 { | |
1351 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1352 *target = t->GetBackend().GetResourcesCount(t->GetManager(), resourceType); |
212 | 1353 return OrthancPluginErrorCode_Success; |
1354 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1355 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1356 } |
1357 | |
1358 | |
1359 static OrthancPluginErrorCode GetResourceType(OrthancPluginDatabaseTransaction* transaction, | |
1360 OrthancPluginResourceType* target /* out */, | |
1361 uint64_t resourceId) | |
1362 { | |
1363 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1364 | |
1365 try | |
1366 { | |
1367 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1368 *target = t->GetBackend().GetResourceType(t->GetManager(), resourceId); |
212 | 1369 return OrthancPluginErrorCode_Success; |
1370 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1371 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1372 } |
1373 | |
1374 | |
1375 static OrthancPluginErrorCode GetTotalCompressedSize(OrthancPluginDatabaseTransaction* transaction, | |
1376 uint64_t* target /* out */) | |
1377 { | |
1378 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1379 | |
1380 try | |
1381 { | |
1382 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1383 *target = t->GetBackend().GetTotalCompressedSize(t->GetManager()); |
212 | 1384 return OrthancPluginErrorCode_Success; |
1385 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1386 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1387 } |
1388 | |
1389 | |
1390 static OrthancPluginErrorCode GetTotalUncompressedSize(OrthancPluginDatabaseTransaction* transaction, | |
1391 uint64_t* target /* out */) | |
1392 { | |
1393 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1394 | |
1395 try | |
1396 { | |
1397 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1398 *target = t->GetBackend().GetTotalUncompressedSize(t->GetManager()); |
212 | 1399 return OrthancPluginErrorCode_Success; |
1400 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1401 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1402 } |
1403 | |
1404 | |
1405 static OrthancPluginErrorCode IsDiskSizeAbove(OrthancPluginDatabaseTransaction* transaction, | |
1406 uint8_t* target, | |
1407 uint64_t threshold) | |
1408 { | |
1409 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1410 | |
1411 try | |
1412 { | |
1413 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1414 bool above = (t->GetBackend().GetTotalCompressedSize(t->GetManager()) >= threshold); |
212 | 1415 *target = (above ? 1 : 0); |
1416 return OrthancPluginErrorCode_Success; | |
1417 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1418 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1419 } |
1420 | |
1421 | |
1422 static OrthancPluginErrorCode IsExistingResource(OrthancPluginDatabaseTransaction* transaction, | |
1423 uint8_t* target, | |
1424 int64_t resourceId) | |
1425 { | |
1426 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1427 | |
1428 try | |
1429 { | |
1430 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1431 bool exists = t->GetBackend().IsExistingResource(t->GetManager(), resourceId); |
212 | 1432 *target = (exists ? 1 : 0); |
1433 return OrthancPluginErrorCode_Success; | |
1434 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1435 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1436 } |
1437 | |
1438 | |
1439 static OrthancPluginErrorCode IsProtectedPatient(OrthancPluginDatabaseTransaction* transaction, | |
1440 uint8_t* target, | |
1441 int64_t resourceId) | |
1442 { | |
1443 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1444 | |
1445 try | |
1446 { | |
1447 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1448 bool isProtected = t->GetBackend().IsProtectedPatient(t->GetManager(), resourceId); |
212 | 1449 *target = (isProtected ? 1 : 0); |
1450 return OrthancPluginErrorCode_Success; | |
1451 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1452 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1453 } |
1454 | |
1455 | |
1456 static OrthancPluginErrorCode ListAvailableAttachments(OrthancPluginDatabaseTransaction* transaction, | |
1457 int64_t resourceId) | |
1458 { | |
1459 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1460 | |
1461 try | |
1462 { | |
1463 t->GetOutput().Clear(); | |
1464 | |
1465 std::list<int32_t> values; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1466 t->GetBackend().ListAvailableAttachments(values, t->GetManager(), resourceId); |
212 | 1467 t->GetOutput().AnswerIntegers32(values); |
1468 return OrthancPluginErrorCode_Success; | |
1469 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1470 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1471 } |
1472 | |
1473 | |
1474 static OrthancPluginErrorCode LogChange(OrthancPluginDatabaseTransaction* transaction, | |
1475 int32_t changeType, | |
1476 int64_t resourceId, | |
1477 OrthancPluginResourceType resourceType, | |
1478 const char* date) | |
1479 { | |
1480 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1481 | |
1482 try | |
1483 { | |
1484 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1485 t->GetBackend().LogChange(t->GetManager(), changeType, resourceId, resourceType, date); |
212 | 1486 return OrthancPluginErrorCode_Success; |
1487 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1488 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1489 } |
1490 | |
1491 | |
1492 static OrthancPluginErrorCode LogExportedResource(OrthancPluginDatabaseTransaction* transaction, | |
1493 OrthancPluginResourceType resourceType, | |
1494 const char* publicId, | |
1495 const char* modality, | |
1496 const char* date, | |
1497 const char* patientId, | |
1498 const char* studyInstanceUid, | |
1499 const char* seriesInstanceUid, | |
1500 const char* sopInstanceUid) | |
1501 { | |
1502 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1503 | |
1504 try | |
1505 { | |
1506 t->GetOutput().Clear(); | |
378
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
374
diff
changeset
|
1507 t->GetBackend().LogExportedResource(t->GetManager(), resourceType, publicId, modality, date, |
9db9e0275ec0
refactoring IndexBackend::LogExportedResource()
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
374
diff
changeset
|
1508 patientId, studyInstanceUid, seriesInstanceUid, sopInstanceUid); |
212 | 1509 return OrthancPluginErrorCode_Success; |
1510 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1511 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1512 } |
1513 | |
1514 | |
1515 static OrthancPluginErrorCode LookupAttachment(OrthancPluginDatabaseTransaction* transaction, | |
261
34e2b93a7ac1
implementing interface for revisions in attachments
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
260
diff
changeset
|
1516 int64_t* revision /* out */, |
212 | 1517 int64_t resourceId, |
1518 int32_t contentType) | |
1519 { | |
1520 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1521 | |
1522 try | |
1523 { | |
1524 t->GetOutput().Clear(); | |
261
34e2b93a7ac1
implementing interface for revisions in attachments
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
260
diff
changeset
|
1525 t->GetBackend().LookupAttachment(t->GetOutput(), *revision, t->GetManager(), resourceId, contentType); |
212 | 1526 return OrthancPluginErrorCode_Success; |
1527 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1528 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1529 } |
1530 | |
1531 | |
1532 static OrthancPluginErrorCode LookupGlobalProperty(OrthancPluginDatabaseTransaction* transaction, | |
221
73cc85f3d9c1
implementation of the "serverIdentifier" information for global properties
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
212
diff
changeset
|
1533 const char* serverIdentifier, |
212 | 1534 int32_t property) |
1535 { | |
1536 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1537 | |
1538 try | |
1539 { | |
1540 t->GetOutput().Clear(); | |
1541 | |
1542 std::string s; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1543 if (t->GetBackend().LookupGlobalProperty(s, t->GetManager(), serverIdentifier, property)) |
212 | 1544 { |
1545 t->GetOutput().AnswerString(s); | |
1546 } | |
1547 | |
1548 return OrthancPluginErrorCode_Success; | |
1549 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1550 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1551 } |
1552 | |
1553 | |
1554 static OrthancPluginErrorCode LookupMetadata(OrthancPluginDatabaseTransaction* transaction, | |
256
e184dcadf163
handling of revisions in metadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
255
diff
changeset
|
1555 int64_t* revision /* out */, |
212 | 1556 int64_t id, |
1557 int32_t metadata) | |
1558 { | |
1559 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1560 | |
1561 try | |
1562 { | |
1563 t->GetOutput().Clear(); | |
1564 | |
1565 std::string s; | |
256
e184dcadf163
handling of revisions in metadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
255
diff
changeset
|
1566 if (t->GetBackend().LookupMetadata(s, *revision, t->GetManager(), id, metadata)) |
212 | 1567 { |
1568 t->GetOutput().AnswerString(s); | |
1569 } | |
1570 | |
1571 return OrthancPluginErrorCode_Success; | |
1572 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1573 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1574 } |
1575 | |
1576 | |
1577 static OrthancPluginErrorCode LookupParent(OrthancPluginDatabaseTransaction* transaction, | |
251
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1578 uint8_t* existing /* out */, |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1579 int64_t* parentId /* out */, |
212 | 1580 int64_t id) |
1581 { | |
1582 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1583 | |
1584 try | |
1585 { | |
1586 t->GetOutput().Clear(); | |
1587 | |
251
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1588 if (t->GetBackend().LookupParent(*parentId, t->GetManager(), id)) |
212 | 1589 { |
251
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1590 *existing = 1; |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1591 } |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1592 else |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1593 { |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1594 *existing = 0; |
212 | 1595 } |
1596 | |
1597 return OrthancPluginErrorCode_Success; | |
1598 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1599 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1600 } |
1601 | |
1602 | |
1603 static OrthancPluginErrorCode LookupResource(OrthancPluginDatabaseTransaction* transaction, | |
1604 uint8_t* isExisting /* out */, | |
1605 int64_t* id /* out */, | |
1606 OrthancPluginResourceType* type /* out */, | |
1607 const char* publicId) | |
1608 { | |
1609 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1610 | |
1611 try | |
1612 { | |
1613 t->GetOutput().Clear(); | |
1614 | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1615 if (t->GetBackend().LookupResource(*id, *type, t->GetManager(), publicId)) |
212 | 1616 { |
1617 *isExisting = 1; | |
1618 } | |
1619 else | |
1620 { | |
1621 *isExisting = 0; | |
1622 } | |
1623 | |
1624 return OrthancPluginErrorCode_Success; | |
1625 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1626 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1627 } |
1628 | |
1629 | |
1630 static OrthancPluginErrorCode LookupResources(OrthancPluginDatabaseTransaction* transaction, | |
1631 uint32_t constraintsCount, | |
1632 const OrthancPluginDatabaseConstraint* constraints, | |
1633 OrthancPluginResourceType queryLevel, | |
1634 uint32_t limit, | |
1635 uint8_t requestSomeInstanceId) | |
1636 { | |
1637 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1638 | |
1639 try | |
1640 { | |
1641 t->GetOutput().Clear(); | |
1642 | |
551
1a23f1ce3b98
move classes DatabaseConstraint and ISqlLookupFormatter into namespace OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
538
diff
changeset
|
1643 DatabaseConstraints lookup; |
212 | 1644 |
1645 for (uint32_t i = 0; i < constraintsCount; i++) | |
1646 { | |
551
1a23f1ce3b98
move classes DatabaseConstraint and ISqlLookupFormatter into namespace OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
538
diff
changeset
|
1647 lookup.AddConstraint(new DatabaseConstraint(constraints[i])); |
212 | 1648 } |
1649 | |
401
a8774581adfc
replaced "WithLabels" and "WithoutLabels", by "Labels" and "LabelsConstraint"
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
391
diff
changeset
|
1650 std::set<std::string> noLabel; |
a8774581adfc
replaced "WithLabels" and "WithoutLabels", by "Labels" and "LabelsConstraint"
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
391
diff
changeset
|
1651 t->GetBackend().LookupResources(t->GetOutput(), t->GetManager(), lookup, queryLevel, noLabel, |
551
1a23f1ce3b98
move classes DatabaseConstraint and ISqlLookupFormatter into namespace OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
538
diff
changeset
|
1652 LabelsConstraint_All, limit, (requestSomeInstanceId != 0)); |
212 | 1653 return OrthancPluginErrorCode_Success; |
1654 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1655 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1656 } |
1657 | |
1658 | |
1659 static OrthancPluginErrorCode LookupResourceAndParent(OrthancPluginDatabaseTransaction* transaction, | |
1660 uint8_t* isExisting /* out */, | |
1661 int64_t* id /* out */, | |
1662 OrthancPluginResourceType* type /* out */, | |
1663 const char* publicId) | |
1664 { | |
1665 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1666 | |
1667 try | |
1668 { | |
1669 t->GetOutput().Clear(); | |
1670 | |
1671 std::string parent; | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1672 if (t->GetBackend().LookupResourceAndParent(*id, *type, parent, t->GetManager(), publicId)) |
212 | 1673 { |
1674 *isExisting = 1; | |
1675 | |
1676 if (!parent.empty()) | |
1677 { | |
1678 t->GetOutput().AnswerString(parent); | |
1679 } | |
1680 } | |
1681 else | |
1682 { | |
1683 *isExisting = 0; | |
1684 } | |
1685 | |
1686 return OrthancPluginErrorCode_Success; | |
1687 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1688 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1689 } |
1690 | |
1691 | |
251
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1692 static OrthancPluginErrorCode SelectPatientToRecycle(OrthancPluginDatabaseTransaction* transaction, |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1693 uint8_t* patientAvailable, |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1694 int64_t* patientId) |
212 | 1695 { |
1696 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1697 | |
1698 try | |
1699 { | |
1700 t->GetOutput().Clear(); | |
1701 | |
251
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1702 if (t->GetBackend().SelectPatientToRecycle(*patientId, t->GetManager())) |
212 | 1703 { |
251
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1704 *patientAvailable = 1; |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1705 } |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1706 else |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1707 { |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1708 *patientAvailable = 0; |
212 | 1709 } |
1710 | |
1711 return OrthancPluginErrorCode_Success; | |
1712 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1713 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1714 } |
1715 | |
1716 | |
1717 static OrthancPluginErrorCode SelectPatientToRecycle2(OrthancPluginDatabaseTransaction* transaction, | |
251
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1718 uint8_t* patientAvailable, |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1719 int64_t* patientId, |
212 | 1720 int64_t patientIdToAvoid) |
1721 { | |
1722 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1723 | |
1724 try | |
1725 { | |
1726 t->GetOutput().Clear(); | |
1727 | |
251
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1728 if (t->GetBackend().SelectPatientToRecycle(*patientId, t->GetManager(), patientIdToAvoid)) |
212 | 1729 { |
251
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1730 *patientAvailable = 1; |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1731 } |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1732 else |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1733 { |
ed12248ad791
implementation of minor api improvements in OrthancCDatabasePlugin.h
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
237
diff
changeset
|
1734 *patientAvailable = 0; |
212 | 1735 } |
1736 | |
1737 return OrthancPluginErrorCode_Success; | |
1738 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1739 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1740 } |
1741 | |
1742 | |
1743 static OrthancPluginErrorCode SetGlobalProperty(OrthancPluginDatabaseTransaction* transaction, | |
221
73cc85f3d9c1
implementation of the "serverIdentifier" information for global properties
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
212
diff
changeset
|
1744 const char* serverIdentifier, |
212 | 1745 int32_t property, |
1746 const char* value) | |
1747 { | |
1748 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1749 | |
1750 try | |
1751 { | |
1752 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1753 t->GetBackend().SetGlobalProperty(t->GetManager(), serverIdentifier, property, value); |
212 | 1754 return OrthancPluginErrorCode_Success; |
1755 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1756 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1757 } |
1758 | |
1759 | |
1760 static OrthancPluginErrorCode SetMetadata(OrthancPluginDatabaseTransaction* transaction, | |
1761 int64_t id, | |
1762 int32_t metadata, | |
256
e184dcadf163
handling of revisions in metadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
255
diff
changeset
|
1763 const char* value, |
e184dcadf163
handling of revisions in metadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
255
diff
changeset
|
1764 int64_t revision) |
212 | 1765 { |
1766 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1767 | |
1768 try | |
1769 { | |
1770 t->GetOutput().Clear(); | |
256
e184dcadf163
handling of revisions in metadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
255
diff
changeset
|
1771 t->GetBackend().SetMetadata(t->GetManager(), id, metadata, value, revision); |
212 | 1772 return OrthancPluginErrorCode_Success; |
1773 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1774 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1775 } |
1776 | |
1777 | |
1778 static OrthancPluginErrorCode SetProtectedPatient(OrthancPluginDatabaseTransaction* transaction, | |
1779 int64_t id, | |
1780 uint8_t isProtected) | |
1781 { | |
1782 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1783 | |
1784 try | |
1785 { | |
1786 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1787 t->GetBackend().SetProtectedPatient(t->GetManager(), id, (isProtected != 0)); |
212 | 1788 return OrthancPluginErrorCode_Success; |
1789 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1790 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1791 } |
1792 | |
1793 | |
1794 static OrthancPluginErrorCode SetResourcesContent(OrthancPluginDatabaseTransaction* transaction, | |
1795 uint32_t countIdentifierTags, | |
1796 const OrthancPluginResourcesContentTags* identifierTags, | |
1797 uint32_t countMainDicomTags, | |
1798 const OrthancPluginResourcesContentTags* mainDicomTags, | |
1799 uint32_t countMetadata, | |
1800 const OrthancPluginResourcesContentMetadata* metadata) | |
1801 { | |
1802 DatabaseBackendAdapterV3::Transaction* t = reinterpret_cast<DatabaseBackendAdapterV3::Transaction*>(transaction); | |
1803 | |
1804 try | |
1805 { | |
1806 t->GetOutput().Clear(); | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1807 t->GetBackend().SetResourcesContent(t->GetManager(), countIdentifierTags, identifierTags, |
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1808 countMainDicomTags, mainDicomTags, countMetadata, metadata); |
212 | 1809 return OrthancPluginErrorCode_Success; |
1810 } | |
225
94c9908e6aca
removed DatabaseManager member out of class IndexBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
223
diff
changeset
|
1811 ORTHANC_PLUGINS_DATABASE_CATCH(t->GetBackend().GetContext()); |
212 | 1812 } |
1813 | |
1814 | |
234
d1b124d116c1
PostgreSQL index plugin handles retries for collisions between multiple writers
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
233
diff
changeset
|
1815 void DatabaseBackendAdapterV3::Register(IndexBackend* backend, |
d1b124d116c1
PostgreSQL index plugin handles retries for collisions between multiple writers
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
233
diff
changeset
|
1816 size_t countConnections, |
d1b124d116c1
PostgreSQL index plugin handles retries for collisions between multiple writers
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
233
diff
changeset
|
1817 unsigned int maxDatabaseRetries) |
212 | 1818 { |
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
359
diff
changeset
|
1819 std::unique_ptr<IndexBackend> protection(backend); |
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
359
diff
changeset
|
1820 |
223
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1821 if (isBackendInUse_) |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1822 { |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1823 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1824 } |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1825 |
222
c8e06b41feec
refactoring registration/finalization of index backend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
1826 if (backend == NULL) |
c8e06b41feec
refactoring registration/finalization of index backend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
1827 { |
c8e06b41feec
refactoring registration/finalization of index backend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
1828 throw Orthanc::OrthancException(Orthanc::ErrorCode_NullPointer); |
c8e06b41feec
refactoring registration/finalization of index backend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
1829 } |
c8e06b41feec
refactoring registration/finalization of index backend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
1830 |
212 | 1831 OrthancPluginDatabaseBackendV3 params; |
1832 memset(¶ms, 0, sizeof(params)); | |
1833 | |
1834 params.readAnswersCount = ReadAnswersCount; | |
1835 params.readAnswerAttachment = ReadAnswerAttachment; | |
1836 params.readAnswerChange = ReadAnswerChange; | |
1837 params.readAnswerDicomTag = ReadAnswerDicomTag; | |
1838 params.readAnswerExportedResource = ReadAnswerExportedResource; | |
1839 params.readAnswerInt32 = ReadAnswerInt32; | |
1840 params.readAnswerInt64 = ReadAnswerInt64; | |
1841 params.readAnswerMatchingResource = ReadAnswerMatchingResource; | |
1842 params.readAnswerMetadata = ReadAnswerMetadata; | |
1843 params.readAnswerString = ReadAnswerString; | |
1844 | |
1845 params.readEventsCount = ReadEventsCount; | |
1846 params.readEvent = ReadEvent; | |
1847 | |
1848 params.open = Open; | |
1849 params.close = Close; | |
1850 params.destructDatabase = DestructDatabase; | |
1851 params.getDatabaseVersion = GetDatabaseVersion; | |
1852 params.upgradeDatabase = UpgradeDatabase; | |
264
7ec412af11cb
implementation of "hasRevisionsSupport" primitive in database SDK
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
262
diff
changeset
|
1853 params.hasRevisionsSupport = HasRevisionsSupport; |
212 | 1854 params.startTransaction = StartTransaction; |
1855 params.destructTransaction = DestructTransaction; | |
1856 params.rollback = Rollback; | |
1857 params.commit = Commit; | |
1858 | |
262
b0c65094b299
adding support for revisions in attachments
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
261
diff
changeset
|
1859 params.addAttachment = AddAttachment; |
212 | 1860 params.clearChanges = ClearChanges; |
1861 params.clearExportedResources = ClearExportedResources; | |
1862 params.clearMainDicomTags = ClearMainDicomTags; | |
1863 params.createInstance = CreateInstance; | |
1864 params.deleteAttachment = DeleteAttachment; | |
1865 params.deleteMetadata = DeleteMetadata; | |
1866 params.deleteResource = DeleteResource; | |
1867 params.getAllMetadata = GetAllMetadata; | |
1868 params.getAllPublicIds = GetAllPublicIds; | |
1869 params.getAllPublicIdsWithLimit = GetAllPublicIdsWithLimit; | |
1870 params.getChanges = GetChanges; | |
1871 params.getChildrenInternalId = GetChildrenInternalId; | |
1872 params.getChildrenMetadata = GetChildrenMetadata; | |
1873 params.getChildrenPublicId = GetChildrenPublicId; | |
1874 params.getExportedResources = GetExportedResources; | |
1875 params.getLastChange = GetLastChange; | |
1876 params.getLastChangeIndex = GetLastChangeIndex; | |
1877 params.getLastExportedResource = GetLastExportedResource; | |
1878 params.getMainDicomTags = GetMainDicomTags; | |
1879 params.getPublicId = GetPublicId; | |
261
34e2b93a7ac1
implementing interface for revisions in attachments
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
260
diff
changeset
|
1880 params.getResourceType = GetResourceType; |
212 | 1881 params.getResourcesCount = GetResourcesCount; |
1882 params.getTotalCompressedSize = GetTotalCompressedSize; | |
1883 params.getTotalUncompressedSize = GetTotalUncompressedSize; | |
1884 params.isDiskSizeAbove = IsDiskSizeAbove; | |
1885 params.isExistingResource = IsExistingResource; | |
1886 params.isProtectedPatient = IsProtectedPatient; | |
1887 params.listAvailableAttachments = ListAvailableAttachments; | |
1888 params.logChange = LogChange; | |
1889 params.logExportedResource = LogExportedResource; | |
1890 params.lookupAttachment = LookupAttachment; | |
1891 params.lookupGlobalProperty = LookupGlobalProperty; | |
1892 params.lookupMetadata = LookupMetadata; | |
1893 params.lookupParent = LookupParent; | |
1894 params.lookupResource = LookupResource; | |
261
34e2b93a7ac1
implementing interface for revisions in attachments
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
260
diff
changeset
|
1895 params.lookupResourceAndParent = LookupResourceAndParent; |
212 | 1896 params.lookupResources = LookupResources; |
1897 params.selectPatientToRecycle = SelectPatientToRecycle; | |
1898 params.selectPatientToRecycle2 = SelectPatientToRecycle2; | |
1899 params.setGlobalProperty = SetGlobalProperty; | |
1900 params.setMetadata = SetMetadata; | |
1901 params.setProtectedPatient = SetProtectedPatient; | |
1902 params.setResourcesContent = SetResourcesContent; | |
1903 | |
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
359
diff
changeset
|
1904 OrthancPluginContext* context = protection->GetContext(); |
212 | 1905 |
234
d1b124d116c1
PostgreSQL index plugin handles retries for collisions between multiple writers
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
233
diff
changeset
|
1906 if (OrthancPluginRegisterDatabaseBackendV3( |
d1b124d116c1
PostgreSQL index plugin handles retries for collisions between multiple writers
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
233
diff
changeset
|
1907 context, ¶ms, sizeof(params), maxDatabaseRetries, |
374
4a3985088723
moved class IndexConnectionsPool out of DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
373
diff
changeset
|
1908 new IndexConnectionsPool(protection.release(), countConnections)) != OrthancPluginErrorCode_Success) |
212 | 1909 { |
373
be7de633695c
started DatabaseBackendAdapterV4
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
359
diff
changeset
|
1910 delete backend; |
212 | 1911 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError, "Unable to register the database backend"); |
1912 } | |
1913 | |
223
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1914 backend->SetOutputFactory(new Factory); |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1915 |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1916 isBackendInUse_ = true; |
222
c8e06b41feec
refactoring registration/finalization of index backend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
1917 } |
c8e06b41feec
refactoring registration/finalization of index backend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
1918 |
c8e06b41feec
refactoring registration/finalization of index backend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
1919 |
c8e06b41feec
refactoring registration/finalization of index backend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
1920 void DatabaseBackendAdapterV3::Finalize() |
c8e06b41feec
refactoring registration/finalization of index backend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
221
diff
changeset
|
1921 { |
223
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1922 if (isBackendInUse_) |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1923 { |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1924 fprintf(stderr, "The Orthanc core has not destructed the index backend, internal error\n"); |
af049cd66661
removed singleton from DatabaseBackendAdapterV3
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
222
diff
changeset
|
1925 } |
212 | 1926 } |
1927 } | |
1928 | |
1929 # endif | |
1930 #endif |