Mercurial > hg > orthanc-databases
annotate Framework/Plugins/IndexBackend.cpp @ 210:a0c095a4ba7d
all the integration tests pass on SQLite
| author | Sebastien Jodogne <s.jodogne@gmail.com> |
|---|---|
| date | Mon, 22 Mar 2021 19:36:43 +0100 |
| parents | 13a3863df7fa |
| children | c2e4a909de0e |
| rev | line source |
|---|---|
| 0 | 1 /** |
| 2 * Orthanc - A Lightweight, RESTful DICOM Store | |
| 3 * Copyright (C) 2012-2016 Sebastien Jodogne, Medical Physics | |
| 4 * Department, University Hospital of Liege, Belgium | |
|
193
3236894320d6
upgrade to year 2021
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
157
diff
changeset
|
5 * Copyright (C) 2017-2021 Osimis S.A., Belgium |
| 0 | 6 * |
| 7 * This program is free software: you can redistribute it and/or | |
| 8 * modify it under the terms of the GNU Affero General Public License | |
| 9 * as published by the Free Software Foundation, either version 3 of | |
| 10 * the License, or (at your option) any later version. | |
| 11 * | |
| 12 * This program is distributed in the hope that it will be useful, but | |
| 13 * WITHOUT ANY WARRANTY; without even the implied warranty of | |
| 14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | |
| 15 * Affero General Public License for more details. | |
| 16 * | |
| 17 * You should have received a copy of the GNU Affero General Public License | |
| 18 * along with this program. If not, see <http://www.gnu.org/licenses/>. | |
| 19 **/ | |
| 20 | |
| 21 | |
| 22 #include "IndexBackend.h" | |
| 23 | |
| 152 | 24 #include "../../Resources/Orthanc/Databases/ISqlLookupFormatter.h" |
| 0 | 25 #include "../Common/BinaryStringValue.h" |
| 26 #include "../Common/Integer64Value.h" | |
| 27 #include "../Common/Utf8StringValue.h" | |
| 28 #include "GlobalProperties.h" | |
| 29 | |
|
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
30 #include <Compatibility.h> // For std::unique_ptr<> |
| 152 | 31 #include <Logging.h> |
| 32 #include <OrthancException.h> | |
| 0 | 33 |
| 34 | |
| 35 namespace OrthancDatabases | |
| 36 { | |
| 37 static std::string ConvertWildcardToLike(const std::string& query) | |
| 38 { | |
| 39 std::string s = query; | |
| 40 | |
| 41 for (size_t i = 0; i < s.size(); i++) | |
| 42 { | |
| 43 if (s[i] == '*') | |
| 44 { | |
| 45 s[i] = '%'; | |
| 46 } | |
| 47 else if (s[i] == '?') | |
| 48 { | |
| 49 s[i] = '_'; | |
| 50 } | |
| 51 } | |
| 52 | |
| 65 | 53 // TODO Escape underscores and percents |
| 54 | |
| 0 | 55 return s; |
| 56 } | |
| 57 | |
| 58 | |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
59 int64_t IndexBackend::ReadInteger64(const DatabaseManager::StatementBase& statement, |
| 0 | 60 size_t field) |
| 61 { | |
| 62 if (statement.IsDone()) | |
| 63 { | |
| 64 throw Orthanc::OrthancException(Orthanc::ErrorCode_Database); | |
| 65 } | |
| 66 | |
| 67 const IValue& value = statement.GetResultField(field); | |
| 68 | |
| 69 switch (value.GetType()) | |
| 70 { | |
| 71 case ValueType_Integer64: | |
| 72 return dynamic_cast<const Integer64Value&>(value).GetValue(); | |
| 73 | |
| 74 default: | |
| 75 //LOG(ERROR) << value.Format(); | |
| 76 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); | |
| 77 } | |
| 78 } | |
| 79 | |
| 80 | |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
81 int32_t IndexBackend::ReadInteger32(const DatabaseManager::StatementBase& statement, |
| 0 | 82 size_t field) |
| 83 { | |
| 84 if (statement.IsDone()) | |
| 85 { | |
| 86 throw Orthanc::OrthancException(Orthanc::ErrorCode_Database); | |
| 87 } | |
| 88 | |
| 89 int64_t value = ReadInteger64(statement, field); | |
| 90 | |
| 91 if (value != static_cast<int64_t>(static_cast<int32_t>(value))) | |
| 92 { | |
| 93 LOG(ERROR) << "Integer overflow"; | |
| 94 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); | |
| 95 } | |
| 96 else | |
| 97 { | |
| 98 return static_cast<int32_t>(value); | |
| 99 } | |
| 100 } | |
| 101 | |
| 102 | |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
103 std::string IndexBackend::ReadString(const DatabaseManager::StatementBase& statement, |
| 0 | 104 size_t field) |
| 105 { | |
| 106 const IValue& value = statement.GetResultField(field); | |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
107 |
| 0 | 108 switch (value.GetType()) |
| 109 { | |
| 110 case ValueType_BinaryString: | |
| 111 return dynamic_cast<const BinaryStringValue&>(value).GetContent(); | |
| 112 | |
| 113 case ValueType_Utf8String: | |
| 114 return dynamic_cast<const Utf8StringValue&>(value).GetContent(); | |
| 115 | |
| 116 default: | |
| 117 //LOG(ERROR) << value.Format(); | |
| 118 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); | |
| 119 } | |
| 120 } | |
| 121 | |
| 122 | |
| 123 template <typename T> | |
| 124 void IndexBackend::ReadListOfIntegers(std::list<T>& target, | |
| 125 DatabaseManager::CachedStatement& statement, | |
| 126 const Dictionary& args) | |
| 127 { | |
| 128 statement.Execute(args); | |
| 129 | |
| 130 target.clear(); | |
| 131 | |
| 132 if (!statement.IsDone()) | |
| 133 { | |
| 134 if (statement.GetResultFieldsCount() != 1) | |
| 135 { | |
| 136 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); | |
| 137 } | |
| 138 | |
| 139 statement.SetResultFieldType(0, ValueType_Integer64); | |
| 140 | |
| 141 while (!statement.IsDone()) | |
| 142 { | |
| 143 target.push_back(static_cast<T>(ReadInteger64(statement, 0))); | |
| 144 statement.Next(); | |
| 145 } | |
| 146 } | |
| 147 } | |
| 148 | |
| 149 | |
| 150 void IndexBackend::ReadListOfStrings(std::list<std::string>& target, | |
| 151 DatabaseManager::CachedStatement& statement, | |
| 152 const Dictionary& args) | |
| 153 { | |
| 154 statement.Execute(args); | |
| 155 | |
| 156 target.clear(); | |
| 157 | |
| 158 if (!statement.IsDone()) | |
| 159 { | |
| 160 if (statement.GetResultFieldsCount() != 1) | |
| 161 { | |
| 162 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); | |
| 163 } | |
| 164 | |
| 165 while (!statement.IsDone()) | |
| 166 { | |
| 167 target.push_back(ReadString(statement, 0)); | |
| 168 statement.Next(); | |
| 169 } | |
| 170 } | |
| 171 } | |
| 172 | |
| 173 | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
174 void IndexBackend::ReadChangesInternal(IDatabaseBackendOutput& output, |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
175 bool& done, |
| 0 | 176 DatabaseManager::CachedStatement& statement, |
| 177 const Dictionary& args, | |
| 178 uint32_t maxResults) | |
| 179 { | |
| 180 statement.Execute(args); | |
| 181 | |
| 182 uint32_t count = 0; | |
| 183 | |
| 184 while (count < maxResults && | |
| 185 !statement.IsDone()) | |
| 186 { | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
187 output.AnswerChange( |
| 0 | 188 ReadInteger64(statement, 0), |
| 189 ReadInteger32(statement, 1), | |
| 190 static_cast<OrthancPluginResourceType>(ReadInteger32(statement, 3)), | |
| 191 GetPublicId(ReadInteger64(statement, 2)), | |
| 192 ReadString(statement, 4)); | |
| 193 | |
| 194 statement.Next(); | |
| 195 count++; | |
| 196 } | |
| 197 | |
| 198 done = (count < maxResults || | |
| 199 statement.IsDone()); | |
| 200 } | |
| 201 | |
| 202 | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
203 void IndexBackend::ReadExportedResourcesInternal(IDatabaseBackendOutput& output, |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
204 bool& done, |
| 0 | 205 DatabaseManager::CachedStatement& statement, |
| 206 const Dictionary& args, | |
| 207 uint32_t maxResults) | |
| 208 { | |
| 209 statement.Execute(args); | |
| 210 | |
| 211 uint32_t count = 0; | |
| 212 | |
| 213 while (count < maxResults && | |
| 214 !statement.IsDone()) | |
| 215 { | |
| 216 int64_t seq = ReadInteger64(statement, 0); | |
| 217 OrthancPluginResourceType resourceType = | |
| 218 static_cast<OrthancPluginResourceType>(ReadInteger32(statement, 1)); | |
| 219 std::string publicId = ReadString(statement, 2); | |
| 220 | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
221 output.AnswerExportedResource(seq, |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
222 resourceType, |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
223 publicId, |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
224 ReadString(statement, 3), // modality |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
225 ReadString(statement, 8), // date |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
226 ReadString(statement, 4), // patient ID |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
227 ReadString(statement, 5), // study instance UID |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
228 ReadString(statement, 6), // series instance UID |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
229 ReadString(statement, 7)); // sop instance UID |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
230 |
| 0 | 231 statement.Next(); |
| 232 count++; | |
| 233 } | |
| 234 | |
| 235 done = (count < maxResults || | |
| 236 statement.IsDone()); | |
| 237 } | |
| 238 | |
| 239 | |
| 240 void IndexBackend::ClearDeletedFiles() | |
| 241 { | |
| 242 DatabaseManager::CachedStatement statement( | |
| 243 STATEMENT_FROM_HERE, manager_, | |
| 244 "DELETE FROM DeletedFiles"); | |
| 245 | |
| 246 statement.Execute(); | |
| 247 } | |
| 248 | |
| 249 | |
| 250 void IndexBackend::ClearDeletedResources() | |
| 251 { | |
| 252 DatabaseManager::CachedStatement statement( | |
| 253 STATEMENT_FROM_HERE, manager_, | |
| 254 "DELETE FROM DeletedResources"); | |
| 255 | |
| 256 statement.Execute(); | |
| 257 } | |
| 258 | |
| 259 | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
260 void IndexBackend::SignalDeletedFiles(IDatabaseBackendOutput& output) |
| 0 | 261 { |
| 262 DatabaseManager::CachedStatement statement( | |
| 263 STATEMENT_FROM_HERE, manager_, | |
| 264 "SELECT * FROM DeletedFiles"); | |
| 265 | |
| 266 statement.SetReadOnly(true); | |
| 267 statement.Execute(); | |
| 268 | |
| 269 while (!statement.IsDone()) | |
| 270 { | |
| 271 std::string a = ReadString(statement, 0); | |
| 272 std::string b = ReadString(statement, 5); | |
| 273 std::string c = ReadString(statement, 6); | |
| 274 | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
275 output.SignalDeletedAttachment(a.c_str(), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
276 ReadInteger32(statement, 1), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
277 ReadInteger64(statement, 3), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
278 b.c_str(), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
279 ReadInteger32(statement, 4), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
280 ReadInteger64(statement, 2), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
281 c.c_str()); |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
282 |
| 0 | 283 statement.Next(); |
| 284 } | |
| 285 } | |
| 286 | |
| 287 | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
288 void IndexBackend::SignalDeletedResources(IDatabaseBackendOutput& output) |
| 0 | 289 { |
| 290 DatabaseManager::CachedStatement statement( | |
| 291 STATEMENT_FROM_HERE, manager_, | |
| 292 "SELECT * FROM DeletedResources"); | |
| 293 | |
| 294 statement.SetReadOnly(true); | |
| 295 statement.Execute(); | |
| 296 | |
| 297 while (!statement.IsDone()) | |
| 298 { | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
299 output.SignalDeletedResource( |
| 0 | 300 ReadString(statement, 1), |
| 301 static_cast<OrthancPluginResourceType>(ReadInteger32(statement, 0))); | |
| 302 | |
| 303 statement.Next(); | |
| 304 } | |
| 305 } | |
| 306 | |
| 307 | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
308 IndexBackend::IndexBackend(OrthancPluginContext* context, |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
309 IDatabaseFactory* factory) : |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
310 context_(context), |
| 0 | 311 manager_(factory) |
| 312 { | |
| 313 } | |
| 314 | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
315 |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
316 void IndexBackend::SetOutputFactory(IDatabaseBackendOutput::IFactory* factory) |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
317 { |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
318 if (factory == NULL) |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
319 { |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
320 throw Orthanc::OrthancException(Orthanc::ErrorCode_NullPointer); |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
321 } |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
322 else if (outputFactory_.get() != NULL) |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
323 { |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
324 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
325 } |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
326 else |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
327 { |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
328 outputFactory_.reset(factory); |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
329 } |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
330 } |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
331 |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
332 |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
333 IDatabaseBackendOutput* IndexBackend::CreateOutput() |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
334 { |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
335 if (outputFactory_.get() == NULL) |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
336 { |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
337 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls); |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
338 } |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
339 else |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
340 { |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
341 return outputFactory_->CreateOutput(); |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
342 } |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
343 } |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
344 |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
345 |
| 0 | 346 void IndexBackend::AddAttachment(int64_t id, |
| 347 const OrthancPluginAttachment& attachment) | |
| 348 { | |
| 349 DatabaseManager::CachedStatement statement( | |
| 350 STATEMENT_FROM_HERE, manager_, | |
| 351 "INSERT INTO AttachedFiles VALUES(${id}, ${type}, ${uuid}, " | |
| 352 "${compressed}, ${uncompressed}, ${compression}, ${hash}, ${hash-compressed})"); | |
| 353 | |
| 354 statement.SetParameterType("id", ValueType_Integer64); | |
| 355 statement.SetParameterType("type", ValueType_Integer64); | |
| 356 statement.SetParameterType("uuid", ValueType_Utf8String); | |
| 357 statement.SetParameterType("compressed", ValueType_Integer64); | |
| 358 statement.SetParameterType("uncompressed", ValueType_Integer64); | |
| 359 statement.SetParameterType("compression", ValueType_Integer64); | |
| 360 statement.SetParameterType("hash", ValueType_Utf8String); | |
| 361 statement.SetParameterType("hash-compressed", ValueType_Utf8String); | |
| 362 | |
| 363 Dictionary args; | |
| 364 args.SetIntegerValue("id", id); | |
| 365 args.SetIntegerValue("type", attachment.contentType); | |
| 366 args.SetUtf8Value("uuid", attachment.uuid); | |
| 367 args.SetIntegerValue("compressed", attachment.compressedSize); | |
| 368 args.SetIntegerValue("uncompressed", attachment.uncompressedSize); | |
| 369 args.SetIntegerValue("compression", attachment.compressionType); | |
| 370 args.SetUtf8Value("hash", attachment.uncompressedHash); | |
| 371 args.SetUtf8Value("hash-compressed", attachment.compressedHash); | |
| 372 | |
| 373 statement.Execute(args); | |
| 374 } | |
| 375 | |
| 376 | |
| 377 void IndexBackend::AttachChild(int64_t parent, | |
| 378 int64_t child) | |
| 379 { | |
| 380 DatabaseManager::CachedStatement statement( | |
| 381 STATEMENT_FROM_HERE, manager_, | |
| 382 "UPDATE Resources SET parentId = ${parent} WHERE internalId = ${child}"); | |
| 383 | |
| 384 statement.SetParameterType("parent", ValueType_Integer64); | |
| 385 statement.SetParameterType("child", ValueType_Integer64); | |
| 386 | |
| 387 Dictionary args; | |
| 388 args.SetIntegerValue("parent", parent); | |
| 389 args.SetIntegerValue("child", child); | |
| 390 | |
| 391 statement.Execute(args); | |
| 392 } | |
| 393 | |
| 394 | |
| 395 void IndexBackend::ClearChanges() | |
| 396 { | |
| 397 DatabaseManager::CachedStatement statement( | |
| 398 STATEMENT_FROM_HERE, manager_, | |
| 399 "DELETE FROM Changes"); | |
| 400 | |
| 401 statement.Execute(); | |
| 402 } | |
| 403 | |
| 404 | |
| 405 void IndexBackend::ClearExportedResources() | |
| 406 { | |
| 407 DatabaseManager::CachedStatement statement( | |
| 408 STATEMENT_FROM_HERE, manager_, | |
| 409 "DELETE FROM ExportedResources"); | |
| 410 | |
| 411 statement.Execute(); | |
| 412 } | |
| 413 | |
| 414 | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
415 void IndexBackend::DeleteAttachment(IDatabaseBackendOutput& output, |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
416 int64_t id, |
| 0 | 417 int32_t attachment) |
| 418 { | |
| 419 ClearDeletedFiles(); | |
| 420 | |
| 421 { | |
| 422 DatabaseManager::CachedStatement statement( | |
| 423 STATEMENT_FROM_HERE, manager_, | |
| 424 "DELETE FROM AttachedFiles WHERE id=${id} AND fileType=${type}"); | |
| 425 | |
| 426 statement.SetParameterType("id", ValueType_Integer64); | |
| 427 statement.SetParameterType("type", ValueType_Integer64); | |
| 428 | |
| 429 Dictionary args; | |
| 430 args.SetIntegerValue("id", id); | |
| 431 args.SetIntegerValue("type", static_cast<int>(attachment)); | |
| 432 | |
| 433 statement.Execute(args); | |
| 434 } | |
| 435 | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
436 SignalDeletedFiles(output); |
| 0 | 437 } |
| 438 | |
| 439 | |
| 440 void IndexBackend::DeleteMetadata(int64_t id, | |
| 441 int32_t metadataType) | |
| 442 { | |
| 443 DatabaseManager::CachedStatement statement( | |
| 444 STATEMENT_FROM_HERE, manager_, | |
| 445 "DELETE FROM Metadata WHERE id=${id} and type=${type}"); | |
| 446 | |
| 447 statement.SetParameterType("id", ValueType_Integer64); | |
| 448 statement.SetParameterType("type", ValueType_Integer64); | |
| 449 | |
| 450 Dictionary args; | |
| 451 args.SetIntegerValue("id", id); | |
| 452 args.SetIntegerValue("type", static_cast<int>(metadataType)); | |
| 453 | |
| 454 statement.Execute(args); | |
| 455 } | |
| 456 | |
| 457 | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
458 void IndexBackend::DeleteResource(IDatabaseBackendOutput& output, |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
459 int64_t id) |
| 0 | 460 { |
|
1
d17b2631bb67
starting StorageBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
461 assert(manager_.GetDialect() != Dialect_MySQL); |
| 0 | 462 |
| 463 ClearDeletedFiles(); | |
| 464 ClearDeletedResources(); | |
| 465 | |
| 466 { | |
| 467 DatabaseManager::CachedStatement statement( | |
| 468 STATEMENT_FROM_HERE, GetManager(), | |
| 469 "DELETE FROM RemainingAncestor"); | |
| 470 | |
| 471 statement.Execute(); | |
| 472 } | |
| 473 | |
| 474 { | |
| 475 DatabaseManager::CachedStatement statement( | |
| 476 STATEMENT_FROM_HERE, GetManager(), | |
| 477 "DELETE FROM Resources WHERE internalId=${id}"); | |
| 478 | |
| 479 statement.SetParameterType("id", ValueType_Integer64); | |
| 480 | |
| 481 Dictionary args; | |
| 482 args.SetIntegerValue("id", id); | |
| 483 | |
| 484 statement.Execute(args); | |
| 485 } | |
| 486 | |
| 487 | |
| 488 { | |
| 489 DatabaseManager::CachedStatement statement( | |
| 490 STATEMENT_FROM_HERE, GetManager(), | |
| 491 "SELECT * FROM RemainingAncestor"); | |
| 492 | |
| 493 statement.Execute(); | |
| 494 | |
| 495 if (!statement.IsDone()) | |
| 496 { | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
497 output.SignalRemainingAncestor( |
| 0 | 498 ReadString(statement, 1), |
| 499 static_cast<OrthancPluginResourceType>(ReadInteger32(statement, 0))); | |
| 500 | |
| 501 // There is at most 1 remaining ancestor | |
| 502 assert((statement.Next(), statement.IsDone())); | |
| 503 } | |
| 504 } | |
| 505 | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
506 SignalDeletedFiles(output); |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
507 SignalDeletedResources(output); |
| 0 | 508 } |
| 509 | |
| 510 | |
| 511 void IndexBackend::GetAllInternalIds(std::list<int64_t>& target, | |
| 512 OrthancPluginResourceType resourceType) | |
| 513 { | |
| 514 DatabaseManager::CachedStatement statement( | |
| 515 STATEMENT_FROM_HERE, manager_, | |
| 516 "SELECT internalId FROM Resources WHERE resourceType=${type}"); | |
| 517 | |
| 518 statement.SetReadOnly(true); | |
| 519 statement.SetParameterType("type", ValueType_Integer64); | |
| 520 | |
| 521 Dictionary args; | |
| 522 args.SetIntegerValue("type", static_cast<int>(resourceType)); | |
| 523 | |
| 524 ReadListOfIntegers<int64_t>(target, statement, args); | |
| 525 } | |
| 526 | |
| 527 | |
| 528 void IndexBackend::GetAllPublicIds(std::list<std::string>& target, | |
| 529 OrthancPluginResourceType resourceType) | |
| 530 { | |
| 531 DatabaseManager::CachedStatement statement( | |
| 532 STATEMENT_FROM_HERE, manager_, | |
| 533 "SELECT publicId FROM Resources WHERE resourceType=${type}"); | |
| 534 | |
| 535 statement.SetReadOnly(true); | |
| 536 statement.SetParameterType("type", ValueType_Integer64); | |
| 537 | |
| 538 Dictionary args; | |
| 539 args.SetIntegerValue("type", static_cast<int>(resourceType)); | |
| 540 | |
| 541 ReadListOfStrings(target, statement, args); | |
| 542 } | |
| 543 | |
| 544 | |
| 545 void IndexBackend::GetAllPublicIds(std::list<std::string>& target, | |
| 546 OrthancPluginResourceType resourceType, | |
| 547 uint64_t since, | |
| 548 uint64_t limit) | |
| 549 { | |
| 550 DatabaseManager::CachedStatement statement( | |
| 551 STATEMENT_FROM_HERE, manager_, | |
| 552 "SELECT publicId FROM (SELECT publicId FROM Resources " | |
| 553 "WHERE resourceType=${type}) AS tmp " | |
| 554 "ORDER BY tmp.publicId LIMIT ${limit} OFFSET ${since}"); | |
| 555 | |
| 556 statement.SetReadOnly(true); | |
| 557 statement.SetParameterType("type", ValueType_Integer64); | |
| 558 statement.SetParameterType("limit", ValueType_Integer64); | |
| 559 statement.SetParameterType("since", ValueType_Integer64); | |
| 560 | |
| 561 Dictionary args; | |
| 562 args.SetIntegerValue("type", static_cast<int>(resourceType)); | |
| 563 args.SetIntegerValue("limit", limit); | |
| 564 args.SetIntegerValue("since", since); | |
| 565 | |
| 566 ReadListOfStrings(target, statement, args); | |
| 567 } | |
| 568 | |
| 569 | |
| 570 /* Use GetOutput().AnswerChange() */ | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
571 void IndexBackend::GetChanges(IDatabaseBackendOutput& output, |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
572 bool& done /*out*/, |
| 0 | 573 int64_t since, |
| 574 uint32_t maxResults) | |
| 575 { | |
| 576 DatabaseManager::CachedStatement statement( | |
| 577 STATEMENT_FROM_HERE, manager_, | |
| 578 "SELECT * FROM Changes WHERE seq>${since} ORDER BY seq LIMIT ${limit}"); | |
| 579 | |
| 580 statement.SetReadOnly(true); | |
| 581 statement.SetParameterType("limit", ValueType_Integer64); | |
| 582 statement.SetParameterType("since", ValueType_Integer64); | |
| 583 | |
| 584 Dictionary args; | |
| 585 args.SetIntegerValue("limit", maxResults + 1); | |
| 586 args.SetIntegerValue("since", since); | |
| 587 | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
588 ReadChangesInternal(output, done, statement, args, maxResults); |
| 0 | 589 } |
| 590 | |
| 591 | |
| 592 void IndexBackend::GetChildrenInternalId(std::list<int64_t>& target /*out*/, | |
| 593 int64_t id) | |
| 594 { | |
| 595 DatabaseManager::CachedStatement statement( | |
| 596 STATEMENT_FROM_HERE, manager_, | |
| 597 "SELECT a.internalId FROM Resources AS a, Resources AS b " | |
| 598 "WHERE a.parentId = b.internalId AND b.internalId = ${id}"); | |
| 599 | |
| 600 statement.SetReadOnly(true); | |
| 601 statement.SetParameterType("id", ValueType_Integer64); | |
| 602 | |
| 603 Dictionary args; | |
| 604 args.SetIntegerValue("id", id); | |
| 605 | |
| 606 ReadListOfIntegers<int64_t>(target, statement, args); | |
| 607 } | |
| 608 | |
| 609 | |
| 610 void IndexBackend::GetChildrenPublicId(std::list<std::string>& target /*out*/, | |
| 611 int64_t id) | |
| 612 { | |
| 613 DatabaseManager::CachedStatement statement( | |
| 614 STATEMENT_FROM_HERE, manager_, | |
| 615 "SELECT a.publicId FROM Resources AS a, Resources AS b " | |
| 616 "WHERE a.parentId = b.internalId AND b.internalId = ${id}"); | |
| 617 | |
| 618 statement.SetReadOnly(true); | |
| 619 statement.SetParameterType("id", ValueType_Integer64); | |
| 620 | |
| 621 Dictionary args; | |
| 622 args.SetIntegerValue("id", id); | |
| 623 | |
| 624 ReadListOfStrings(target, statement, args); | |
| 625 } | |
| 626 | |
| 627 | |
| 628 /* Use GetOutput().AnswerExportedResource() */ | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
629 void IndexBackend::GetExportedResources(IDatabaseBackendOutput& output, |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
630 bool& done /*out*/, |
| 0 | 631 int64_t since, |
| 632 uint32_t maxResults) | |
| 633 { | |
| 634 DatabaseManager::CachedStatement statement( | |
| 635 STATEMENT_FROM_HERE, manager_, | |
| 636 "SELECT * FROM ExportedResources WHERE seq>${since} ORDER BY seq LIMIT ${limit}"); | |
| 637 | |
| 638 statement.SetReadOnly(true); | |
| 639 statement.SetParameterType("limit", ValueType_Integer64); | |
| 640 statement.SetParameterType("since", ValueType_Integer64); | |
| 641 | |
| 642 Dictionary args; | |
| 643 args.SetIntegerValue("limit", maxResults + 1); | |
| 644 args.SetIntegerValue("since", since); | |
| 645 | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
646 ReadExportedResourcesInternal(output, done, statement, args, maxResults); |
| 0 | 647 } |
| 648 | |
| 649 | |
| 650 /* Use GetOutput().AnswerChange() */ | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
651 void IndexBackend::GetLastChange(IDatabaseBackendOutput& output) |
| 0 | 652 { |
| 653 DatabaseManager::CachedStatement statement( | |
| 654 STATEMENT_FROM_HERE, manager_, | |
| 655 "SELECT * FROM Changes ORDER BY seq DESC LIMIT 1"); | |
| 656 | |
| 657 statement.SetReadOnly(true); | |
| 658 | |
| 659 Dictionary args; | |
| 660 | |
| 661 bool done; // Ignored | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
662 ReadChangesInternal(output, done, statement, args, 1); |
| 0 | 663 } |
| 664 | |
| 665 | |
| 666 /* Use GetOutput().AnswerExportedResource() */ | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
667 void IndexBackend::GetLastExportedResource(IDatabaseBackendOutput& output) |
| 0 | 668 { |
| 669 DatabaseManager::CachedStatement statement( | |
| 670 STATEMENT_FROM_HERE, manager_, | |
| 671 "SELECT * FROM ExportedResources ORDER BY seq DESC LIMIT 1"); | |
| 672 | |
| 673 statement.SetReadOnly(true); | |
| 674 | |
| 675 Dictionary args; | |
| 676 | |
| 677 bool done; // Ignored | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
678 ReadExportedResourcesInternal(output, done, statement, args, 1); |
| 0 | 679 } |
| 680 | |
| 681 | |
| 682 /* Use GetOutput().AnswerDicomTag() */ | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
683 void IndexBackend::GetMainDicomTags(IDatabaseBackendOutput& output, |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
684 int64_t id) |
| 0 | 685 { |
| 686 DatabaseManager::CachedStatement statement( | |
| 687 STATEMENT_FROM_HERE, manager_, | |
| 688 "SELECT * FROM MainDicomTags WHERE id=${id}"); | |
| 689 | |
| 690 statement.SetReadOnly(true); | |
| 691 statement.SetParameterType("id", ValueType_Integer64); | |
| 692 | |
| 693 Dictionary args; | |
| 694 args.SetIntegerValue("id", id); | |
| 695 | |
| 696 statement.Execute(args); | |
| 697 | |
| 698 while (!statement.IsDone()) | |
| 699 { | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
700 output.AnswerDicomTag(static_cast<uint16_t>(ReadInteger64(statement, 1)), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
701 static_cast<uint16_t>(ReadInteger64(statement, 2)), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
702 ReadString(statement, 3)); |
| 0 | 703 statement.Next(); |
| 704 } | |
| 705 } | |
| 706 | |
| 707 | |
| 708 std::string IndexBackend::GetPublicId(int64_t resourceId) | |
| 709 { | |
| 710 DatabaseManager::CachedStatement statement( | |
| 711 STATEMENT_FROM_HERE, manager_, | |
| 712 "SELECT publicId FROM Resources WHERE internalId=${id}"); | |
| 713 | |
| 714 statement.SetReadOnly(true); | |
| 715 statement.SetParameterType("id", ValueType_Integer64); | |
| 716 | |
| 717 Dictionary args; | |
| 718 args.SetIntegerValue("id", resourceId); | |
| 719 | |
| 720 statement.Execute(args); | |
| 721 | |
| 722 if (statement.IsDone()) | |
| 723 { | |
| 724 throw Orthanc::OrthancException(Orthanc::ErrorCode_UnknownResource); | |
| 725 } | |
| 726 else | |
| 727 { | |
| 728 return ReadString(statement, 0); | |
| 729 } | |
| 730 } | |
| 731 | |
| 732 | |
| 209 | 733 uint64_t IndexBackend::GetResourcesCount(OrthancPluginResourceType resourceType) |
| 0 | 734 { |
|
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
735 std::unique_ptr<DatabaseManager::CachedStatement> statement; |
| 0 | 736 |
|
1
d17b2631bb67
starting StorageBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
737 switch (manager_.GetDialect()) |
| 0 | 738 { |
| 739 case Dialect_MySQL: | |
| 740 statement.reset(new DatabaseManager::CachedStatement( | |
| 741 STATEMENT_FROM_HERE, GetManager(), | |
| 742 "SELECT CAST(COUNT(*) AS UNSIGNED INT) FROM Resources WHERE resourceType=${type}")); | |
| 743 break; | |
| 744 | |
| 745 case Dialect_PostgreSQL: | |
| 746 statement.reset(new DatabaseManager::CachedStatement( | |
|
75
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
747 STATEMENT_FROM_HERE, GetManager(), |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
748 "SELECT CAST(COUNT(*) AS BIGINT) FROM Resources WHERE resourceType=${type}")); |
| 0 | 749 break; |
| 750 | |
| 751 case Dialect_SQLite: | |
| 752 statement.reset(new DatabaseManager::CachedStatement( | |
|
75
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
753 STATEMENT_FROM_HERE, GetManager(), |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
754 "SELECT COUNT(*) FROM Resources WHERE resourceType=${type}")); |
| 0 | 755 break; |
| 756 | |
| 757 default: | |
| 758 throw Orthanc::OrthancException(Orthanc::ErrorCode_NotImplemented); | |
| 759 } | |
| 760 | |
| 761 statement->SetReadOnly(true); | |
| 762 statement->SetParameterType("type", ValueType_Integer64); | |
| 763 | |
| 764 Dictionary args; | |
| 765 args.SetIntegerValue("type", resourceType); | |
| 766 | |
| 767 statement->Execute(args); | |
| 768 | |
| 769 return static_cast<uint64_t>(ReadInteger64(*statement, 0)); | |
| 770 } | |
| 771 | |
| 772 | |
| 773 OrthancPluginResourceType IndexBackend::GetResourceType(int64_t resourceId) | |
| 774 { | |
| 775 DatabaseManager::CachedStatement statement( | |
| 776 STATEMENT_FROM_HERE, manager_, | |
| 777 "SELECT resourceType FROM Resources WHERE internalId=${id}"); | |
| 778 | |
| 779 statement.SetReadOnly(true); | |
| 780 statement.SetParameterType("id", ValueType_Integer64); | |
| 781 | |
| 782 Dictionary args; | |
| 783 args.SetIntegerValue("id", resourceId); | |
| 784 | |
| 785 statement.Execute(args); | |
| 786 | |
| 787 if (statement.IsDone()) | |
| 788 { | |
| 789 throw Orthanc::OrthancException(Orthanc::ErrorCode_UnknownResource); | |
| 790 } | |
| 791 else | |
| 792 { | |
| 793 return static_cast<OrthancPluginResourceType>(ReadInteger32(statement, 0)); | |
| 794 } | |
| 795 } | |
| 796 | |
| 797 | |
| 798 uint64_t IndexBackend::GetTotalCompressedSize() | |
| 799 { | |
|
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
800 std::unique_ptr<DatabaseManager::CachedStatement> statement; |
| 0 | 801 |
| 802 // NB: "COALESCE" is used to replace "NULL" by "0" if the number of rows is empty | |
| 803 | |
|
1
d17b2631bb67
starting StorageBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
804 switch (manager_.GetDialect()) |
| 0 | 805 { |
| 806 case Dialect_MySQL: | |
| 807 statement.reset(new DatabaseManager::CachedStatement( | |
| 808 STATEMENT_FROM_HERE, GetManager(), | |
| 809 "SELECT CAST(COALESCE(SUM(compressedSize), 0) AS UNSIGNED INTEGER) FROM AttachedFiles")); | |
| 810 break; | |
| 811 | |
| 812 case Dialect_PostgreSQL: | |
| 813 statement.reset(new DatabaseManager::CachedStatement( | |
| 814 STATEMENT_FROM_HERE, GetManager(), | |
| 815 "SELECT CAST(COALESCE(SUM(compressedSize), 0) AS BIGINT) FROM AttachedFiles")); | |
| 816 break; | |
| 817 | |
| 818 case Dialect_SQLite: | |
| 819 statement.reset(new DatabaseManager::CachedStatement( | |
| 820 STATEMENT_FROM_HERE, GetManager(), | |
| 821 "SELECT COALESCE(SUM(compressedSize), 0) FROM AttachedFiles")); | |
| 822 break; | |
| 823 | |
| 824 default: | |
| 825 throw Orthanc::OrthancException(Orthanc::ErrorCode_NotImplemented); | |
| 826 } | |
| 827 | |
| 828 statement->SetReadOnly(true); | |
| 829 statement->Execute(); | |
| 830 | |
| 831 return static_cast<uint64_t>(ReadInteger64(*statement, 0)); | |
| 832 } | |
| 833 | |
| 834 | |
| 835 uint64_t IndexBackend::GetTotalUncompressedSize() | |
| 836 { | |
|
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
837 std::unique_ptr<DatabaseManager::CachedStatement> statement; |
| 0 | 838 |
| 839 // NB: "COALESCE" is used to replace "NULL" by "0" if the number of rows is empty | |
| 840 | |
|
1
d17b2631bb67
starting StorageBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
841 switch (manager_.GetDialect()) |
| 0 | 842 { |
| 843 case Dialect_MySQL: | |
| 844 statement.reset(new DatabaseManager::CachedStatement( | |
| 845 STATEMENT_FROM_HERE, GetManager(), | |
| 846 "SELECT CAST(COALESCE(SUM(uncompressedSize), 0) AS UNSIGNED INTEGER) FROM AttachedFiles")); | |
| 847 break; | |
| 848 | |
| 849 case Dialect_PostgreSQL: | |
| 850 statement.reset(new DatabaseManager::CachedStatement( | |
| 851 STATEMENT_FROM_HERE, GetManager(), | |
| 852 "SELECT CAST(COALESCE(SUM(uncompressedSize), 0) AS BIGINT) FROM AttachedFiles")); | |
| 853 break; | |
| 854 | |
| 855 case Dialect_SQLite: | |
| 856 statement.reset(new DatabaseManager::CachedStatement( | |
| 857 STATEMENT_FROM_HERE, GetManager(), | |
| 858 "SELECT COALESCE(SUM(uncompressedSize), 0) FROM AttachedFiles")); | |
| 859 break; | |
| 860 | |
| 861 default: | |
| 862 throw Orthanc::OrthancException(Orthanc::ErrorCode_NotImplemented); | |
| 863 } | |
| 864 | |
| 865 statement->SetReadOnly(true); | |
| 866 statement->Execute(); | |
| 867 | |
| 868 return static_cast<uint64_t>(ReadInteger64(*statement, 0)); | |
| 869 } | |
| 870 | |
| 871 | |
| 872 bool IndexBackend::IsExistingResource(int64_t internalId) | |
| 873 { | |
| 874 DatabaseManager::CachedStatement statement( | |
| 875 STATEMENT_FROM_HERE, manager_, | |
| 876 "SELECT * FROM Resources WHERE internalId=${id}"); | |
| 877 | |
| 878 statement.SetReadOnly(true); | |
| 879 statement.SetParameterType("id", ValueType_Integer64); | |
| 880 | |
| 881 Dictionary args; | |
| 882 args.SetIntegerValue("id", internalId); | |
| 883 | |
| 884 statement.Execute(args); | |
| 885 | |
| 886 return !statement.IsDone(); | |
| 887 } | |
| 888 | |
| 889 | |
| 890 bool IndexBackend::IsProtectedPatient(int64_t internalId) | |
| 891 { | |
| 892 DatabaseManager::CachedStatement statement( | |
| 893 STATEMENT_FROM_HERE, manager_, | |
| 894 "SELECT * FROM PatientRecyclingOrder WHERE patientId = ${id}"); | |
| 895 | |
| 896 statement.SetReadOnly(true); | |
| 897 statement.SetParameterType("id", ValueType_Integer64); | |
| 898 | |
| 899 Dictionary args; | |
| 900 args.SetIntegerValue("id", internalId); | |
| 901 | |
| 902 statement.Execute(args); | |
| 903 | |
| 904 return statement.IsDone(); | |
| 905 } | |
| 906 | |
| 907 | |
| 908 void IndexBackend::ListAvailableMetadata(std::list<int32_t>& target /*out*/, | |
| 909 int64_t id) | |
| 910 { | |
| 911 DatabaseManager::CachedStatement statement( | |
| 912 STATEMENT_FROM_HERE, manager_, | |
| 913 "SELECT type FROM Metadata WHERE id=${id}"); | |
| 914 | |
| 915 statement.SetReadOnly(true); | |
| 916 statement.SetParameterType("id", ValueType_Integer64); | |
| 917 | |
| 918 Dictionary args; | |
| 919 args.SetIntegerValue("id", id); | |
| 920 | |
| 921 ReadListOfIntegers<int32_t>(target, statement, args); | |
| 922 } | |
| 923 | |
| 924 | |
| 925 void IndexBackend::ListAvailableAttachments(std::list<int32_t>& target /*out*/, | |
| 926 int64_t id) | |
| 927 { | |
| 928 DatabaseManager::CachedStatement statement( | |
| 929 STATEMENT_FROM_HERE, manager_, | |
| 930 "SELECT fileType FROM AttachedFiles WHERE id=${id}"); | |
| 931 | |
| 932 statement.SetReadOnly(true); | |
| 933 statement.SetParameterType("id", ValueType_Integer64); | |
| 934 | |
| 935 Dictionary args; | |
| 936 args.SetIntegerValue("id", id); | |
| 937 | |
| 938 ReadListOfIntegers<int32_t>(target, statement, args); | |
| 939 } | |
| 940 | |
| 941 | |
| 209 | 942 void IndexBackend::LogChange(int32_t changeType, |
| 943 int64_t resourceId, | |
| 944 OrthancPluginResourceType resourceType, | |
| 945 const char* date) | |
| 0 | 946 { |
| 947 DatabaseManager::CachedStatement statement( | |
| 948 STATEMENT_FROM_HERE, manager_, | |
| 949 "INSERT INTO Changes VALUES(${}, ${changeType}, ${id}, ${resourceType}, ${date})"); | |
| 950 | |
| 951 statement.SetParameterType("changeType", ValueType_Integer64); | |
| 952 statement.SetParameterType("id", ValueType_Integer64); | |
| 953 statement.SetParameterType("resourceType", ValueType_Integer64); | |
| 954 statement.SetParameterType("date", ValueType_Utf8String); | |
| 955 | |
| 956 Dictionary args; | |
| 209 | 957 args.SetIntegerValue("changeType", changeType); |
| 958 args.SetIntegerValue("id", resourceId); | |
| 959 args.SetIntegerValue("resourceType", resourceType); | |
| 960 args.SetUtf8Value("date", date); | |
| 0 | 961 |
| 962 statement.Execute(args); | |
| 963 } | |
| 964 | |
| 965 | |
| 966 void IndexBackend::LogExportedResource(const OrthancPluginExportedResource& resource) | |
| 967 { | |
| 968 DatabaseManager::CachedStatement statement( | |
| 969 STATEMENT_FROM_HERE, manager_, | |
| 970 "INSERT INTO ExportedResources VALUES(${}, ${type}, ${publicId}, " | |
| 971 "${modality}, ${patient}, ${study}, ${series}, ${instance}, ${date})"); | |
| 972 | |
| 973 statement.SetParameterType("type", ValueType_Integer64); | |
| 974 statement.SetParameterType("publicId", ValueType_Utf8String); | |
| 975 statement.SetParameterType("modality", ValueType_Utf8String); | |
| 976 statement.SetParameterType("patient", ValueType_Utf8String); | |
| 977 statement.SetParameterType("study", ValueType_Utf8String); | |
| 978 statement.SetParameterType("series", ValueType_Utf8String); | |
| 979 statement.SetParameterType("instance", ValueType_Utf8String); | |
| 980 statement.SetParameterType("date", ValueType_Utf8String); | |
| 981 | |
| 982 Dictionary args; | |
| 983 args.SetIntegerValue("type", resource.resourceType); | |
| 984 args.SetUtf8Value("publicId", resource.publicId); | |
| 985 args.SetUtf8Value("modality", resource.modality); | |
| 986 args.SetUtf8Value("patient", resource.patientId); | |
| 987 args.SetUtf8Value("study", resource.studyInstanceUid); | |
| 988 args.SetUtf8Value("series", resource.seriesInstanceUid); | |
| 989 args.SetUtf8Value("instance", resource.sopInstanceUid); | |
| 990 args.SetUtf8Value("date", resource.date); | |
| 991 | |
| 992 statement.Execute(args); | |
| 993 } | |
| 994 | |
| 995 | |
| 996 /* Use GetOutput().AnswerAttachment() */ | |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
997 bool IndexBackend::LookupAttachment(IDatabaseBackendOutput& output, |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
998 int64_t id, |
| 0 | 999 int32_t contentType) |
| 1000 { | |
| 1001 DatabaseManager::CachedStatement statement( | |
| 1002 STATEMENT_FROM_HERE, manager_, | |
| 1003 "SELECT uuid, uncompressedSize, compressionType, compressedSize, " | |
| 1004 "uncompressedHash, compressedHash FROM AttachedFiles WHERE id=${id} AND fileType=${type}"); | |
| 1005 | |
| 1006 statement.SetReadOnly(true); | |
| 1007 statement.SetParameterType("id", ValueType_Integer64); | |
| 1008 statement.SetParameterType("type", ValueType_Integer64); | |
| 1009 | |
| 1010 Dictionary args; | |
| 1011 args.SetIntegerValue("id", id); | |
| 1012 args.SetIntegerValue("type", static_cast<int>(contentType)); | |
| 1013 | |
| 1014 statement.Execute(args); | |
| 1015 | |
| 1016 if (statement.IsDone()) | |
| 1017 { | |
| 1018 return false; | |
| 1019 } | |
| 1020 else | |
| 1021 { | |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
1022 output.AnswerAttachment(ReadString(statement, 0), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
1023 contentType, |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
1024 ReadInteger64(statement, 1), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
1025 ReadString(statement, 4), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
1026 ReadInteger32(statement, 2), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
1027 ReadInteger64(statement, 3), |
|
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
1028 ReadString(statement, 5)); |
| 0 | 1029 return true; |
| 1030 } | |
| 1031 } | |
| 1032 | |
| 1033 | |
| 1034 bool IndexBackend::LookupGlobalProperty(std::string& target /*out*/, | |
| 1035 int32_t property) | |
| 1036 { | |
| 1037 return ::OrthancDatabases::LookupGlobalProperty(target, manager_, static_cast<Orthanc::GlobalProperty>(property)); | |
| 1038 } | |
| 1039 | |
| 1040 | |
| 1041 void IndexBackend::LookupIdentifier(std::list<int64_t>& target /*out*/, | |
| 1042 OrthancPluginResourceType resourceType, | |
| 1043 uint16_t group, | |
| 1044 uint16_t element, | |
| 1045 OrthancPluginIdentifierConstraint constraint, | |
| 1046 const char* value) | |
| 1047 { | |
|
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
1048 std::unique_ptr<DatabaseManager::CachedStatement> statement; |
| 0 | 1049 |
| 1050 std::string header = | |
| 1051 "SELECT d.id FROM DicomIdentifiers AS d, Resources AS r WHERE " | |
| 1052 "d.id = r.internalId AND r.resourceType=${type} AND d.tagGroup=${group} " | |
| 1053 "AND d.tagElement=${element} AND "; | |
| 1054 | |
| 1055 switch (constraint) | |
| 1056 { | |
| 1057 case OrthancPluginIdentifierConstraint_Equal: | |
| 1058 header += "d.value = ${value}"; | |
| 1059 statement.reset(new DatabaseManager::CachedStatement( | |
| 1060 STATEMENT_FROM_HERE, manager_, header.c_str())); | |
| 1061 break; | |
| 1062 | |
| 1063 case OrthancPluginIdentifierConstraint_SmallerOrEqual: | |
| 1064 header += "d.value <= ${value}"; | |
| 1065 statement.reset(new DatabaseManager::CachedStatement( | |
| 1066 STATEMENT_FROM_HERE, manager_, header.c_str())); | |
| 1067 break; | |
| 1068 | |
| 1069 case OrthancPluginIdentifierConstraint_GreaterOrEqual: | |
| 1070 header += "d.value >= ${value}"; | |
| 1071 statement.reset(new DatabaseManager::CachedStatement( | |
| 1072 STATEMENT_FROM_HERE, manager_, header.c_str())); | |
| 1073 break; | |
| 1074 | |
| 1075 case OrthancPluginIdentifierConstraint_Wildcard: | |
| 1076 header += "d.value LIKE ${value}"; | |
| 1077 statement.reset(new DatabaseManager::CachedStatement( | |
| 1078 STATEMENT_FROM_HERE, manager_, header.c_str())); | |
| 1079 break; | |
| 1080 | |
| 1081 default: | |
| 1082 throw Orthanc::OrthancException(Orthanc::ErrorCode_Database); | |
| 1083 } | |
| 1084 | |
| 1085 statement->SetReadOnly(true); | |
| 1086 statement->SetParameterType("type", ValueType_Integer64); | |
| 1087 statement->SetParameterType("group", ValueType_Integer64); | |
| 1088 statement->SetParameterType("element", ValueType_Integer64); | |
| 1089 statement->SetParameterType("value", ValueType_Utf8String); | |
| 1090 | |
| 1091 Dictionary args; | |
| 1092 args.SetIntegerValue("type", resourceType); | |
| 1093 args.SetIntegerValue("group", group); | |
| 1094 args.SetIntegerValue("element", element); | |
| 1095 | |
| 1096 if (constraint == OrthancPluginIdentifierConstraint_Wildcard) | |
| 1097 { | |
| 1098 args.SetUtf8Value("value", ConvertWildcardToLike(value)); | |
| 1099 } | |
| 1100 else | |
| 1101 { | |
| 1102 args.SetUtf8Value("value", value); | |
| 1103 } | |
| 1104 | |
| 1105 statement->Execute(args); | |
| 1106 | |
| 1107 target.clear(); | |
| 1108 while (!statement->IsDone()) | |
| 1109 { | |
| 1110 target.push_back(ReadInteger64(*statement, 0)); | |
| 1111 statement->Next(); | |
| 1112 } | |
| 1113 } | |
| 1114 | |
| 1115 | |
| 1116 void IndexBackend::LookupIdentifierRange(std::list<int64_t>& target /*out*/, | |
| 1117 OrthancPluginResourceType resourceType, | |
| 1118 uint16_t group, | |
| 1119 uint16_t element, | |
| 1120 const char* start, | |
| 1121 const char* end) | |
| 1122 { | |
| 1123 DatabaseManager::CachedStatement statement( | |
| 1124 STATEMENT_FROM_HERE, manager_, | |
| 1125 "SELECT d.id FROM DicomIdentifiers AS d, Resources AS r WHERE " | |
| 1126 "d.id = r.internalId AND r.resourceType=${type} AND d.tagGroup=${group} " | |
| 1127 "AND d.tagElement=${element} AND d.value>=${start} AND d.value<=${end}"); | |
| 1128 | |
| 1129 statement.SetReadOnly(true); | |
| 1130 statement.SetParameterType("type", ValueType_Integer64); | |
| 1131 statement.SetParameterType("group", ValueType_Integer64); | |
| 1132 statement.SetParameterType("element", ValueType_Integer64); | |
| 1133 statement.SetParameterType("start", ValueType_Utf8String); | |
| 1134 statement.SetParameterType("end", ValueType_Utf8String); | |
| 1135 | |
| 1136 Dictionary args; | |
| 1137 args.SetIntegerValue("type", resourceType); | |
| 1138 args.SetIntegerValue("group", group); | |
| 1139 args.SetIntegerValue("element", element); | |
| 1140 args.SetUtf8Value("start", start); | |
| 1141 args.SetUtf8Value("end", end); | |
| 1142 | |
| 1143 statement.Execute(args); | |
| 1144 | |
| 1145 target.clear(); | |
| 1146 while (!statement.IsDone()) | |
| 1147 { | |
| 1148 target.push_back(ReadInteger64(statement, 0)); | |
| 1149 statement.Next(); | |
| 1150 } | |
| 1151 } | |
| 1152 | |
| 1153 | |
| 1154 bool IndexBackend::LookupMetadata(std::string& target /*out*/, | |
| 1155 int64_t id, | |
| 1156 int32_t metadataType) | |
| 1157 { | |
| 1158 DatabaseManager::CachedStatement statement( | |
| 1159 STATEMENT_FROM_HERE, manager_, | |
| 1160 "SELECT value FROM Metadata WHERE id=${id} and type=${type}"); | |
| 1161 | |
| 1162 statement.SetReadOnly(true); | |
| 1163 statement.SetParameterType("id", ValueType_Integer64); | |
| 1164 statement.SetParameterType("type", ValueType_Integer64); | |
| 1165 | |
| 1166 Dictionary args; | |
| 1167 args.SetIntegerValue("id", id); | |
| 1168 args.SetIntegerValue("type", metadataType); | |
| 1169 | |
| 1170 statement.Execute(args); | |
| 1171 | |
| 1172 if (statement.IsDone()) | |
| 1173 { | |
| 1174 return false; | |
| 1175 } | |
| 1176 else | |
| 1177 { | |
| 1178 target = ReadString(statement, 0); | |
| 1179 return true; | |
| 1180 } | |
| 1181 } | |
| 1182 | |
| 1183 | |
| 1184 bool IndexBackend::LookupParent(int64_t& parentId /*out*/, | |
| 1185 int64_t resourceId) | |
| 1186 { | |
| 1187 DatabaseManager::CachedStatement statement( | |
| 1188 STATEMENT_FROM_HERE, manager_, | |
| 1189 "SELECT parentId FROM Resources WHERE internalId=${id}"); | |
| 1190 | |
| 1191 statement.SetReadOnly(true); | |
| 1192 statement.SetParameterType("id", ValueType_Integer64); | |
| 1193 | |
| 1194 Dictionary args; | |
| 1195 args.SetIntegerValue("id", resourceId); | |
| 1196 | |
| 1197 statement.Execute(args); | |
| 1198 | |
| 1199 if (statement.IsDone() || | |
| 1200 statement.GetResultField(0).GetType() == ValueType_Null) | |
| 1201 { | |
| 1202 return false; | |
| 1203 } | |
| 1204 else | |
| 1205 { | |
| 1206 parentId = ReadInteger64(statement, 0); | |
| 1207 return true; | |
| 1208 } | |
| 1209 } | |
| 1210 | |
| 1211 | |
| 1212 bool IndexBackend::LookupResource(int64_t& id /*out*/, | |
| 1213 OrthancPluginResourceType& type /*out*/, | |
| 1214 const char* publicId) | |
| 1215 { | |
| 1216 DatabaseManager::CachedStatement statement( | |
| 1217 STATEMENT_FROM_HERE, manager_, | |
| 1218 "SELECT internalId, resourceType FROM Resources WHERE publicId=${id}"); | |
| 1219 | |
| 1220 statement.SetReadOnly(true); | |
| 1221 statement.SetParameterType("id", ValueType_Utf8String); | |
| 1222 | |
| 1223 Dictionary args; | |
| 1224 args.SetUtf8Value("id", publicId); | |
| 1225 | |
| 1226 statement.Execute(args); | |
| 1227 | |
| 1228 if (statement.IsDone()) | |
| 1229 { | |
| 1230 return false; | |
| 1231 } | |
| 1232 else | |
| 1233 { | |
| 1234 id = ReadInteger64(statement, 0); | |
| 1235 type = static_cast<OrthancPluginResourceType>(ReadInteger32(statement, 1)); | |
| 1236 return true; | |
| 1237 } | |
| 1238 } | |
| 1239 | |
| 1240 | |
| 1241 bool IndexBackend::SelectPatientToRecycle(int64_t& internalId /*out*/) | |
| 1242 { | |
| 1243 DatabaseManager::CachedStatement statement( | |
| 1244 STATEMENT_FROM_HERE, manager_, | |
| 1245 "SELECT patientId FROM PatientRecyclingOrder ORDER BY seq ASC LIMIT 1"); | |
| 1246 | |
| 1247 statement.SetReadOnly(true); | |
| 1248 statement.Execute(); | |
| 1249 | |
| 1250 if (statement.IsDone()) | |
| 1251 { | |
| 1252 return false; | |
| 1253 } | |
| 1254 else | |
| 1255 { | |
| 1256 internalId = ReadInteger64(statement, 0); | |
| 1257 return true; | |
| 1258 } | |
| 1259 } | |
| 1260 | |
| 1261 | |
| 1262 bool IndexBackend::SelectPatientToRecycle(int64_t& internalId /*out*/, | |
| 1263 int64_t patientIdToAvoid) | |
| 1264 { | |
| 1265 DatabaseManager::CachedStatement statement( | |
| 1266 STATEMENT_FROM_HERE, manager_, | |
| 1267 "SELECT patientId FROM PatientRecyclingOrder " | |
| 1268 "WHERE patientId != ${id} ORDER BY seq ASC LIMIT 1"); | |
| 1269 | |
| 1270 statement.SetReadOnly(true); | |
| 1271 statement.SetParameterType("id", ValueType_Integer64); | |
| 1272 | |
| 1273 Dictionary args; | |
| 1274 args.SetIntegerValue("id", patientIdToAvoid); | |
| 1275 | |
| 1276 statement.Execute(args); | |
| 1277 | |
| 1278 if (statement.IsDone()) | |
| 1279 { | |
| 1280 return false; | |
| 1281 } | |
| 1282 else | |
| 1283 { | |
| 1284 internalId = ReadInteger64(statement, 0); | |
| 1285 return true; | |
| 1286 } | |
| 1287 } | |
| 1288 | |
| 1289 | |
| 1290 void IndexBackend::SetGlobalProperty(int32_t property, | |
| 1291 const char* value) | |
| 1292 { | |
| 1293 return ::OrthancDatabases::SetGlobalProperty(manager_, static_cast<Orthanc::GlobalProperty>(property), value); | |
| 1294 } | |
| 1295 | |
| 1296 | |
| 1297 static void ExecuteSetTag(DatabaseManager::CachedStatement& statement, | |
| 1298 int64_t id, | |
| 1299 uint16_t group, | |
| 1300 uint16_t element, | |
| 1301 const char* value) | |
| 1302 { | |
| 1303 statement.SetParameterType("id", ValueType_Integer64); | |
| 1304 statement.SetParameterType("group", ValueType_Integer64); | |
| 1305 statement.SetParameterType("element", ValueType_Integer64); | |
| 1306 statement.SetParameterType("value", ValueType_Utf8String); | |
| 1307 | |
| 1308 Dictionary args; | |
| 1309 args.SetIntegerValue("id", id); | |
| 1310 args.SetIntegerValue("group", group); | |
| 1311 args.SetIntegerValue("element", element); | |
| 1312 args.SetUtf8Value("value", value); | |
| 1313 | |
| 1314 statement.Execute(args); | |
| 1315 } | |
| 1316 | |
| 1317 | |
| 1318 void IndexBackend::SetMainDicomTag(int64_t id, | |
| 1319 uint16_t group, | |
| 1320 uint16_t element, | |
| 1321 const char* value) | |
| 1322 { | |
| 1323 DatabaseManager::CachedStatement statement( | |
| 1324 STATEMENT_FROM_HERE, manager_, | |
| 1325 "INSERT INTO MainDicomTags VALUES(${id}, ${group}, ${element}, ${value})"); | |
| 1326 | |
| 1327 ExecuteSetTag(statement, id, group, element, value); | |
| 1328 } | |
| 1329 | |
| 1330 | |
| 1331 void IndexBackend::SetIdentifierTag(int64_t id, | |
| 1332 uint16_t group, | |
| 1333 uint16_t element, | |
| 1334 const char* value) | |
| 1335 { | |
| 1336 DatabaseManager::CachedStatement statement( | |
| 1337 STATEMENT_FROM_HERE, manager_, | |
| 1338 "INSERT INTO DicomIdentifiers VALUES(${id}, ${group}, ${element}, ${value})"); | |
| 1339 | |
| 1340 ExecuteSetTag(statement, id, group, element, value); | |
| 1341 } | |
| 1342 | |
| 1343 | |
| 1344 void IndexBackend::SetMetadata(int64_t id, | |
| 1345 int32_t metadataType, | |
| 1346 const char* value) | |
| 1347 { | |
|
1
d17b2631bb67
starting StorageBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
1348 if (manager_.GetDialect() == Dialect_SQLite) |
| 0 | 1349 { |
| 1350 DatabaseManager::CachedStatement statement( | |
| 1351 STATEMENT_FROM_HERE, manager_, | |
| 1352 "INSERT OR REPLACE INTO Metadata VALUES (${id}, ${type}, ${value})"); | |
| 1353 | |
| 1354 statement.SetParameterType("id", ValueType_Integer64); | |
| 1355 statement.SetParameterType("type", ValueType_Integer64); | |
| 1356 statement.SetParameterType("value", ValueType_Utf8String); | |
| 1357 | |
| 1358 Dictionary args; | |
| 1359 args.SetIntegerValue("id", id); | |
| 1360 args.SetIntegerValue("type", metadataType); | |
| 1361 args.SetUtf8Value("value", value); | |
| 1362 | |
| 1363 statement.Execute(args); | |
| 1364 } | |
| 1365 else | |
| 1366 { | |
| 1367 { | |
| 1368 DatabaseManager::CachedStatement statement( | |
| 1369 STATEMENT_FROM_HERE, manager_, | |
| 1370 "DELETE FROM Metadata WHERE id=${id} AND type=${type}"); | |
| 1371 | |
| 1372 statement.SetParameterType("id", ValueType_Integer64); | |
| 1373 statement.SetParameterType("type", ValueType_Integer64); | |
| 1374 | |
| 1375 Dictionary args; | |
| 1376 args.SetIntegerValue("id", id); | |
| 1377 args.SetIntegerValue("type", metadataType); | |
| 1378 | |
| 1379 statement.Execute(args); | |
| 1380 } | |
| 1381 | |
| 1382 { | |
| 1383 DatabaseManager::CachedStatement statement( | |
| 1384 STATEMENT_FROM_HERE, manager_, | |
| 1385 "INSERT INTO Metadata VALUES (${id}, ${type}, ${value})"); | |
| 1386 | |
| 1387 statement.SetParameterType("id", ValueType_Integer64); | |
| 1388 statement.SetParameterType("type", ValueType_Integer64); | |
| 1389 statement.SetParameterType("value", ValueType_Utf8String); | |
| 1390 | |
| 1391 Dictionary args; | |
| 1392 args.SetIntegerValue("id", id); | |
| 1393 args.SetIntegerValue("type", metadataType); | |
| 1394 args.SetUtf8Value("value", value); | |
| 1395 | |
| 1396 statement.Execute(args); | |
| 1397 } | |
| 1398 } | |
| 1399 } | |
| 1400 | |
| 1401 | |
| 1402 void IndexBackend::SetProtectedPatient(int64_t internalId, | |
| 1403 bool isProtected) | |
| 1404 { | |
| 1405 if (isProtected) | |
| 1406 { | |
| 1407 DatabaseManager::CachedStatement statement( | |
| 1408 STATEMENT_FROM_HERE, manager_, | |
| 1409 "DELETE FROM PatientRecyclingOrder WHERE patientId=${id}"); | |
| 1410 | |
| 1411 statement.SetParameterType("id", ValueType_Integer64); | |
| 1412 | |
| 1413 Dictionary args; | |
| 1414 args.SetIntegerValue("id", internalId); | |
| 1415 | |
| 1416 statement.Execute(args); | |
| 1417 } | |
| 1418 else if (IsProtectedPatient(internalId)) | |
| 1419 { | |
| 1420 DatabaseManager::CachedStatement statement( | |
| 1421 STATEMENT_FROM_HERE, manager_, | |
| 1422 "INSERT INTO PatientRecyclingOrder VALUES(${}, ${id})"); | |
| 1423 | |
| 1424 statement.SetParameterType("id", ValueType_Integer64); | |
| 1425 | |
| 1426 Dictionary args; | |
| 1427 args.SetIntegerValue("id", internalId); | |
| 1428 | |
| 1429 statement.Execute(args); | |
| 1430 } | |
| 1431 else | |
| 1432 { | |
| 1433 // Nothing to do: The patient is already unprotected | |
| 1434 } | |
| 1435 } | |
| 1436 | |
| 1437 | |
| 1438 uint32_t IndexBackend::GetDatabaseVersion() | |
| 1439 { | |
| 1440 std::string version = "unknown"; | |
| 1441 | |
| 1442 if (LookupGlobalProperty(version, Orthanc::GlobalProperty_DatabaseSchemaVersion)) | |
| 1443 { | |
| 1444 try | |
| 1445 { | |
| 1446 return boost::lexical_cast<unsigned int>(version); | |
| 1447 } | |
| 1448 catch (boost::bad_lexical_cast&) | |
| 1449 { | |
| 1450 } | |
| 1451 } | |
| 1452 | |
| 1453 LOG(ERROR) << "The database is corrupted. Drop it manually for Orthanc to recreate it"; | |
| 1454 throw Orthanc::OrthancException(Orthanc::ErrorCode_Database); | |
| 1455 } | |
| 1456 | |
| 1457 | |
| 1458 /** | |
| 1459 * Upgrade the database to the specified version of the database | |
| 1460 * schema. The upgrade script is allowed to make calls to | |
| 1461 * OrthancPluginReconstructMainDicomTags(). | |
| 1462 **/ | |
| 1463 void IndexBackend::UpgradeDatabase(uint32_t targetVersion, | |
| 1464 OrthancPluginStorageArea* storageArea) | |
| 1465 { | |
| 1466 LOG(ERROR) << "Upgrading database is not implemented by this plugin"; | |
| 1467 throw Orthanc::OrthancException(Orthanc::ErrorCode_NotImplemented); | |
| 1468 } | |
| 1469 | |
| 1470 | |
| 1471 void IndexBackend::ClearMainDicomTags(int64_t internalId) | |
| 1472 { | |
| 1473 { | |
| 1474 DatabaseManager::CachedStatement statement( | |
| 1475 STATEMENT_FROM_HERE, manager_, | |
| 1476 "DELETE FROM MainDicomTags WHERE id=${id}"); | |
| 1477 | |
| 1478 statement.SetParameterType("id", ValueType_Integer64); | |
| 1479 | |
| 1480 Dictionary args; | |
| 1481 args.SetIntegerValue("id", internalId); | |
| 1482 | |
| 1483 statement.Execute(args); | |
| 1484 } | |
| 1485 | |
| 1486 { | |
| 1487 DatabaseManager::CachedStatement statement( | |
| 1488 STATEMENT_FROM_HERE, manager_, | |
| 1489 "DELETE FROM DicomIdentifiers WHERE id=${id}"); | |
| 1490 | |
| 1491 statement.SetParameterType("id", ValueType_Integer64); | |
| 1492 | |
| 1493 Dictionary args; | |
| 1494 args.SetIntegerValue("id", internalId); | |
| 1495 | |
| 1496 statement.Execute(args); | |
| 1497 } | |
| 1498 } | |
| 1499 | |
| 1500 | |
| 1501 // For unit testing only! | |
| 209 | 1502 uint64_t IndexBackend::GetAllResourcesCount() |
| 0 | 1503 { |
|
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
1504 std::unique_ptr<DatabaseManager::CachedStatement> statement; |
| 0 | 1505 |
|
1
d17b2631bb67
starting StorageBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
1506 switch (manager_.GetDialect()) |
| 0 | 1507 { |
| 1508 case Dialect_MySQL: | |
| 1509 statement.reset(new DatabaseManager::CachedStatement( | |
| 1510 STATEMENT_FROM_HERE, GetManager(), | |
| 1511 "SELECT CAST(COUNT(*) AS UNSIGNED INT) FROM Resources")); | |
| 1512 break; | |
| 1513 | |
| 1514 case Dialect_PostgreSQL: | |
| 1515 statement.reset(new DatabaseManager::CachedStatement( | |
| 1516 STATEMENT_FROM_HERE, GetManager(), | |
| 1517 "SELECT CAST(COUNT(*) AS BIGINT) FROM Resources")); | |
| 1518 break; | |
| 1519 | |
| 1520 case Dialect_SQLite: | |
| 1521 statement.reset(new DatabaseManager::CachedStatement( | |
| 1522 STATEMENT_FROM_HERE, GetManager(), | |
| 1523 "SELECT COUNT(*) FROM Resources")); | |
| 1524 break; | |
| 1525 | |
| 1526 default: | |
| 1527 throw Orthanc::OrthancException(Orthanc::ErrorCode_NotImplemented); | |
| 1528 } | |
| 1529 | |
| 1530 statement->SetReadOnly(true); | |
| 1531 statement->Execute(); | |
| 1532 | |
| 1533 return static_cast<uint64_t>(ReadInteger64(*statement, 0)); | |
| 1534 } | |
| 1535 | |
| 1536 | |
| 1537 // For unit testing only! | |
| 1538 uint64_t IndexBackend::GetUnprotectedPatientsCount() | |
| 1539 { | |
|
157
275e14f57f1e
replacing deprecated std::auto_ptr by std::unique_ptr
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
152
diff
changeset
|
1540 std::unique_ptr<DatabaseManager::CachedStatement> statement; |
| 0 | 1541 |
|
1
d17b2631bb67
starting StorageBackend
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
1542 switch (manager_.GetDialect()) |
| 0 | 1543 { |
| 1544 case Dialect_MySQL: | |
| 1545 statement.reset(new DatabaseManager::CachedStatement( | |
| 1546 STATEMENT_FROM_HERE, GetManager(), | |
| 1547 "SELECT CAST(COUNT(*) AS UNSIGNED INT) FROM PatientRecyclingOrder")); | |
| 1548 break; | |
| 1549 | |
| 1550 case Dialect_PostgreSQL: | |
| 1551 statement.reset(new DatabaseManager::CachedStatement( | |
| 1552 STATEMENT_FROM_HERE, GetManager(), | |
| 1553 "SELECT CAST(COUNT(*) AS BIGINT) FROM PatientRecyclingOrder")); | |
| 1554 break; | |
| 1555 | |
| 1556 case Dialect_SQLite: | |
| 1557 statement.reset(new DatabaseManager::CachedStatement( | |
| 1558 STATEMENT_FROM_HERE, GetManager(), | |
| 1559 "SELECT COUNT(*) FROM PatientRecyclingOrder")); | |
| 1560 break; | |
| 1561 | |
| 1562 default: | |
| 1563 throw Orthanc::OrthancException(Orthanc::ErrorCode_NotImplemented); | |
| 1564 } | |
| 1565 | |
| 1566 statement->SetReadOnly(true); | |
| 1567 statement->Execute(); | |
| 1568 | |
| 1569 return static_cast<uint64_t>(ReadInteger64(*statement, 0)); | |
| 1570 } | |
| 1571 | |
| 1572 | |
| 1573 // For unit testing only! | |
| 1574 bool IndexBackend::GetParentPublicId(std::string& target, | |
| 1575 int64_t id) | |
| 1576 { | |
| 1577 DatabaseManager::CachedStatement statement( | |
| 1578 STATEMENT_FROM_HERE, GetManager(), | |
| 1579 "SELECT a.publicId FROM Resources AS a, Resources AS b " | |
| 1580 "WHERE a.internalId = b.parentId AND b.internalId = ${id}"); | |
| 1581 | |
| 1582 statement.SetReadOnly(true); | |
| 1583 statement.SetParameterType("id", ValueType_Integer64); | |
| 1584 | |
| 1585 Dictionary args; | |
| 1586 args.SetIntegerValue("id", id); | |
| 1587 | |
| 1588 statement.Execute(args); | |
| 1589 | |
| 1590 if (statement.IsDone()) | |
| 1591 { | |
| 1592 return false; | |
| 1593 } | |
| 1594 else | |
| 1595 { | |
| 1596 target = ReadString(statement, 0); | |
| 1597 return true; | |
| 1598 } | |
| 1599 } | |
| 1600 | |
| 1601 | |
| 1602 // For unit tests only! | |
| 1603 void IndexBackend::GetChildren(std::list<std::string>& childrenPublicIds, | |
| 1604 int64_t id) | |
| 1605 { | |
| 1606 DatabaseManager::CachedStatement statement( | |
| 1607 STATEMENT_FROM_HERE, GetManager(), | |
| 1608 "SELECT publicId FROM Resources WHERE parentId=${id}"); | |
| 1609 | |
| 1610 statement.SetReadOnly(true); | |
| 1611 statement.SetParameterType("id", ValueType_Integer64); | |
| 1612 | |
| 1613 Dictionary args; | |
| 1614 args.SetIntegerValue("id", id); | |
| 1615 | |
| 1616 ReadListOfStrings(childrenPublicIds, statement, args); | |
| 1617 } | |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1618 |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1619 |
| 78 | 1620 #if ORTHANC_PLUGINS_HAS_DATABASE_CONSTRAINT == 1 |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1621 class IndexBackend::LookupFormatter : public Orthanc::ISqlLookupFormatter |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1622 { |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1623 private: |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1624 Dialect dialect_; |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1625 size_t count_; |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1626 Dictionary dictionary_; |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1627 |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1628 static std::string FormatParameter(size_t index) |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1629 { |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1630 return "p" + boost::lexical_cast<std::string>(index); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1631 } |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1632 |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1633 public: |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1634 LookupFormatter(Dialect dialect) : |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1635 dialect_(dialect), |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1636 count_(0) |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1637 { |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1638 } |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1639 |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1640 virtual std::string GenerateParameter(const std::string& value) |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1641 { |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1642 const std::string key = FormatParameter(count_); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1643 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1644 count_ ++; |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1645 dictionary_.SetUtf8Value(key, value); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1646 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1647 return "${" + key + "}"; |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1648 } |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1649 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1650 virtual std::string FormatResourceType(Orthanc::ResourceType level) |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1651 { |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1652 return boost::lexical_cast<std::string>(Orthanc::Plugins::Convert(level)); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1653 } |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1654 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1655 virtual std::string FormatWildcardEscape() |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1656 { |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1657 switch (dialect_) |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1658 { |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1659 case Dialect_SQLite: |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1660 case Dialect_PostgreSQL: |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1661 return "ESCAPE '\\'"; |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1662 |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1663 case Dialect_MySQL: |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1664 return "ESCAPE '\\\\'"; |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1665 |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1666 default: |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1667 throw Orthanc::OrthancException(Orthanc::ErrorCode_NotImplemented); |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1668 } |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1669 } |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1670 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1671 void PrepareStatement(DatabaseManager::StandaloneStatement& statement) const |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1672 { |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1673 statement.SetReadOnly(true); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1674 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1675 for (size_t i = 0; i < count_; i++) |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1676 { |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1677 statement.SetParameterType(FormatParameter(i), ValueType_Utf8String); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1678 } |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1679 } |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1680 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1681 const Dictionary& GetDictionary() const |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1682 { |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1683 return dictionary_; |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1684 } |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1685 }; |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1686 #endif |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1687 |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1688 |
| 78 | 1689 #if ORTHANC_PLUGINS_HAS_DATABASE_CONSTRAINT == 1 |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1690 // New primitive since Orthanc 1.5.2 |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
1691 void IndexBackend::LookupResources(IDatabaseBackendOutput& output, |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
1692 const std::vector<Orthanc::DatabaseConstraint>& lookup, |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1693 OrthancPluginResourceType queryLevel, |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1694 uint32_t limit, |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1695 bool requestSomeInstance) |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1696 { |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1697 LookupFormatter formatter(manager_.GetDialect()); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1698 |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1699 std::string sql; |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1700 Orthanc::ISqlLookupFormatter::Apply(sql, formatter, lookup, |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1701 Orthanc::Plugins::Convert(queryLevel), limit); |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1702 |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1703 if (requestSomeInstance) |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1704 { |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1705 // Composite query to find some instance if requested |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1706 switch (queryLevel) |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1707 { |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1708 case OrthancPluginResourceType_Patient: |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1709 sql = ("SELECT patients.publicId, MIN(instances.publicId) FROM (" + sql + ") patients " |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1710 "INNER JOIN Resources studies ON studies.parentId = patients.internalId " |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1711 "INNER JOIN Resources series ON series.parentId = studies.internalId " |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1712 "INNER JOIN Resources instances ON instances.parentId = series.internalId " |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1713 "GROUP BY patients.publicId"); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1714 break; |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1715 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1716 case OrthancPluginResourceType_Study: |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1717 sql = ("SELECT studies.publicId, MIN(instances.publicId) FROM (" + sql + ") studies " |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1718 "INNER JOIN Resources series ON series.parentId = studies.internalId " |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1719 "INNER JOIN Resources instances ON instances.parentId = series.internalId " |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1720 "GROUP BY studies.publicId"); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1721 break; |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1722 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1723 case OrthancPluginResourceType_Series: |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1724 sql = ("SELECT series.publicId, MIN(instances.publicId) FROM (" + sql + ") series " |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1725 "INNER JOIN Resources instances ON instances.parentId = series.internalId " |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1726 "GROUP BY series.publicId"); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1727 break; |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1728 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1729 case OrthancPluginResourceType_Instance: |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1730 sql = ("SELECT instances.publicId, instances.publicId FROM (" + sql + ") instances"); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1731 break; |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1732 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1733 default: |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1734 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1735 } |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1736 } |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1737 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1738 DatabaseManager::StandaloneStatement statement(GetManager(), sql); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1739 formatter.PrepareStatement(statement); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1740 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1741 statement.Execute(formatter.GetDictionary()); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1742 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1743 while (!statement.IsDone()) |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1744 { |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1745 if (requestSomeInstance) |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1746 { |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
1747 output.AnswerMatchingResource(ReadString(statement, 0), ReadString(statement, 1)); |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1748 } |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1749 else |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1750 { |
|
201
42990b2dd51b
create IDatabaseBackendOutput only if needed
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
193
diff
changeset
|
1751 output.AnswerMatchingResource(ReadString(statement, 0)); |
|
70
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1752 } |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1753 |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1754 statement.Next(); |
|
e6c13ddd26d9
all integration tests passing with LookupResources extension
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
69
diff
changeset
|
1755 } |
|
69
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1756 } |
|
19764fc60ade
compatibility with Orthanc SDDK 0.9.5
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
67
diff
changeset
|
1757 #endif |
|
75
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1758 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1759 |
| 78 | 1760 #if ORTHANC_PLUGINS_HAS_DATABASE_CONSTRAINT == 1 |
|
75
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1761 static void ExecuteSetResourcesContentTags( |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1762 DatabaseManager& manager, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1763 const std::string& table, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1764 const std::string& variablePrefix, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1765 uint32_t count, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1766 const OrthancPluginResourcesContentTags* tags) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1767 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1768 std::string sql; |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1769 Dictionary args; |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1770 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1771 for (uint32_t i = 0; i < count; i++) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1772 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1773 std::string name = variablePrefix + boost::lexical_cast<std::string>(i); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1774 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1775 args.SetUtf8Value(name, tags[i].value); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1776 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1777 std::string insert = ("(" + boost::lexical_cast<std::string>(tags[i].resource) + ", " + |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
1778 boost::lexical_cast<std::string>(tags[i].group) + ", " + |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
1779 boost::lexical_cast<std::string>(tags[i].element) + ", " + |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
1780 "${" + name + "})"); |
|
75
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1781 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1782 if (sql.empty()) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1783 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1784 sql = "INSERT INTO " + table + " VALUES " + insert; |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1785 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1786 else |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1787 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1788 sql += ", " + insert; |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1789 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1790 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1791 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1792 if (!sql.empty()) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1793 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1794 DatabaseManager::StandaloneStatement statement(manager, sql); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1795 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1796 for (uint32_t i = 0; i < count; i++) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1797 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1798 statement.SetParameterType(variablePrefix + boost::lexical_cast<std::string>(i), |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1799 ValueType_Utf8String); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1800 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1801 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1802 statement.Execute(args); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1803 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1804 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1805 #endif |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1806 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1807 |
| 78 | 1808 #if ORTHANC_PLUGINS_HAS_DATABASE_CONSTRAINT == 1 |
|
75
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1809 static void ExecuteSetResourcesContentMetadata( |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1810 DatabaseManager& manager, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1811 uint32_t count, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1812 const OrthancPluginResourcesContentMetadata* metadata) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1813 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1814 std::string sqlRemove; // To overwrite |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1815 std::string sqlInsert; |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1816 Dictionary args; |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1817 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1818 for (uint32_t i = 0; i < count; i++) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1819 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1820 std::string name = "m" + boost::lexical_cast<std::string>(i); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1821 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1822 args.SetUtf8Value(name, metadata[i].value); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1823 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1824 std::string insert = ("(" + boost::lexical_cast<std::string>(metadata[i].resource) + ", " + |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1825 boost::lexical_cast<std::string>(metadata[i].metadata) + ", " + |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
1826 "${" + name + "})"); |
|
75
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1827 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1828 std::string remove = ("(id=" + boost::lexical_cast<std::string>(metadata[i].resource) + |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1829 " AND type=" + boost::lexical_cast<std::string>(metadata[i].metadata) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1830 + ")"); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1831 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1832 if (sqlInsert.empty()) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1833 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1834 sqlInsert = "INSERT INTO Metadata VALUES " + insert; |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1835 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1836 else |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1837 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1838 sqlInsert += ", " + insert; |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1839 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1840 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1841 if (sqlRemove.empty()) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1842 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1843 sqlRemove = "DELETE FROM Metadata WHERE " + remove; |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1844 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1845 else |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1846 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1847 sqlRemove += " OR " + remove; |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1848 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1849 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1850 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1851 if (!sqlRemove.empty()) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1852 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1853 DatabaseManager::StandaloneStatement statement(manager, sqlRemove); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1854 statement.Execute(); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1855 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1856 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1857 if (!sqlInsert.empty()) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1858 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1859 DatabaseManager::StandaloneStatement statement(manager, sqlInsert); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1860 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1861 for (uint32_t i = 0; i < count; i++) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1862 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1863 statement.SetParameterType("m" + boost::lexical_cast<std::string>(i), |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1864 ValueType_Utf8String); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1865 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1866 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1867 statement.Execute(args); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1868 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1869 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1870 #endif |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1871 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1872 |
| 78 | 1873 #if ORTHANC_PLUGINS_HAS_DATABASE_CONSTRAINT == 1 |
|
75
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1874 // New primitive since Orthanc 1.5.2 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1875 void IndexBackend::SetResourcesContent( |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1876 uint32_t countIdentifierTags, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1877 const OrthancPluginResourcesContentTags* identifierTags, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1878 uint32_t countMainDicomTags, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1879 const OrthancPluginResourcesContentTags* mainDicomTags, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1880 uint32_t countMetadata, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1881 const OrthancPluginResourcesContentMetadata* metadata) |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1882 { |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1883 /** |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1884 * TODO - PostgreSQL doesn't allow multiple commands in a prepared |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1885 * statement, so we execute 3 separate commands (for identifiers, |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1886 * main tags and metadata). Maybe MySQL does not suffer from the |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1887 * same limitation, to check. |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1888 **/ |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1889 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1890 ExecuteSetResourcesContentTags(GetManager(), "DicomIdentifiers", "i", |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1891 countIdentifierTags, identifierTags); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1892 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1893 ExecuteSetResourcesContentTags(GetManager(), "MainDicomTags", "t", |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1894 countMainDicomTags, mainDicomTags); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1895 |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1896 ExecuteSetResourcesContentMetadata(GetManager(), countMetadata, metadata); |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1897 } |
|
52c70007bb87
new extension implemented for PostgreSQL: SetResourcesContent
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
74
diff
changeset
|
1898 #endif |
|
76
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1899 |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1900 |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1901 // New primitive since Orthanc 1.5.2 |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1902 void IndexBackend::GetChildrenMetadata(std::list<std::string>& target, |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1903 int64_t resourceId, |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1904 int32_t metadata) |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1905 { |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1906 DatabaseManager::CachedStatement statement( |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1907 STATEMENT_FROM_HERE, manager_, |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1908 "SELECT value FROM Metadata WHERE type=${metadata} AND " |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1909 "id IN (SELECT internalId FROM Resources WHERE parentId=${id})"); |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1910 |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1911 statement.SetReadOnly(true); |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1912 statement.SetParameterType("id", ValueType_Integer64); |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1913 statement.SetParameterType("metadata", ValueType_Integer64); |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1914 |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1915 Dictionary args; |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1916 args.SetIntegerValue("id", static_cast<int>(resourceId)); |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1917 args.SetIntegerValue("metadata", static_cast<int>(metadata)); |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1918 |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1919 ReadListOfStrings(target, statement, args); |
|
a1c6238b26f8
new extension implemented for PostgreSQL: GetChildrenMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
75
diff
changeset
|
1920 } |
|
88
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1921 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1922 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1923 // New primitive since Orthanc 1.5.2 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1924 void IndexBackend::TagMostRecentPatient(int64_t patient) |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1925 { |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1926 int64_t seq; |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1927 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1928 { |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1929 DatabaseManager::CachedStatement statement( |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1930 STATEMENT_FROM_HERE, manager_, |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1931 "SELECT * FROM PatientRecyclingOrder WHERE seq >= " |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1932 "(SELECT seq FROM PatientRecyclingOrder WHERE patientid=${id}) ORDER BY seq LIMIT 2"); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1933 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1934 statement.SetReadOnly(true); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1935 statement.SetParameterType("id", ValueType_Integer64); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1936 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1937 Dictionary args; |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1938 args.SetIntegerValue("id", patient); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1939 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1940 statement.Execute(args); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1941 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1942 if (statement.IsDone()) |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1943 { |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1944 // The patient is protected, don't add it to the recycling order |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1945 return; |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1946 } |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1947 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1948 seq = ReadInteger64(statement, 0); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1949 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1950 statement.Next(); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1951 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1952 if (statement.IsDone()) |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1953 { |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1954 // The patient is already at the end of the recycling order |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1955 // (because of the "LIMIT 2" above), no need to modify the table |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1956 return; |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1957 } |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1958 } |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1959 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1960 // Delete the old position of the patient in the recycling order |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1961 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1962 { |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1963 DatabaseManager::CachedStatement statement( |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1964 STATEMENT_FROM_HERE, manager_, |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1965 "DELETE FROM PatientRecyclingOrder WHERE seq=${seq}"); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1966 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1967 statement.SetParameterType("seq", ValueType_Integer64); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1968 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1969 Dictionary args; |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1970 args.SetIntegerValue("seq", seq); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1971 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1972 statement.Execute(args); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1973 } |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1974 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1975 // Add the patient to the end of the recycling order |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1976 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1977 { |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1978 DatabaseManager::CachedStatement statement( |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1979 STATEMENT_FROM_HERE, manager_, |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1980 "INSERT INTO PatientRecyclingOrder VALUES(${}, ${id})"); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1981 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1982 statement.SetParameterType("id", ValueType_Integer64); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1983 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1984 Dictionary args; |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1985 args.SetIntegerValue("id", patient); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1986 |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1987 statement.Execute(args); |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1988 } |
|
eb08ec14fb04
new extension implemented: TagMostRecentPatient
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
85
diff
changeset
|
1989 } |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
1990 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
1991 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
1992 #if defined(ORTHANC_PLUGINS_VERSION_IS_ABOVE) // Macro introduced in 1.3.1 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
1993 # if ORTHANC_PLUGINS_VERSION_IS_ABOVE(1, 5, 4) |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
1994 // New primitive since Orthanc 1.5.4 |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
1995 bool IndexBackend::LookupResourceAndParent(int64_t& id, |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
1996 OrthancPluginResourceType& type, |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
1997 std::string& parentPublicId, |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
1998 const char* publicId) |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
1999 { |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2000 DatabaseManager::CachedStatement statement( |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2001 STATEMENT_FROM_HERE, manager_, |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2002 "SELECT resource.internalId, resource.resourceType, parent.publicId " |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2003 "FROM Resources AS resource LEFT JOIN Resources parent ON parent.internalId=resource.parentId " |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2004 "WHERE resource.publicId=${id}"); |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2005 |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2006 statement.SetParameterType("id", ValueType_Utf8String); |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2007 |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2008 Dictionary args; |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2009 args.SetUtf8Value("id", publicId); |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2010 |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2011 statement.Execute(args); |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2012 |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2013 if (statement.IsDone()) |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2014 { |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2015 return false; |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2016 } |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2017 else |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2018 { |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2019 if (statement.GetResultFieldsCount() != 3) |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2020 { |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2021 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2022 } |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2023 |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2024 statement.SetResultFieldType(0, ValueType_Integer64); |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2025 statement.SetResultFieldType(1, ValueType_Integer64); |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2026 statement.SetResultFieldType(2, ValueType_Utf8String); |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2027 |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2028 id = ReadInteger64(statement, 0); |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2029 type = static_cast<OrthancPluginResourceType>(ReadInteger32(statement, 1)); |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2030 |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2031 const IValue& value = statement.GetResultField(2); |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2032 |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2033 switch (value.GetType()) |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2034 { |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2035 case ValueType_Null: |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2036 parentPublicId.clear(); |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2037 break; |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2038 |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2039 case ValueType_Utf8String: |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2040 parentPublicId = dynamic_cast<const Utf8StringValue&>(value).GetContent(); |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2041 break; |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2042 |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2043 default: |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2044 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2045 } |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2046 |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2047 assert((statement.Next(), statement.IsDone())); |
|
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2048 return true; |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2049 } |
|
203
2089d4071408
moving classes out of OrthancPlugins namespace, to OrthancDatabases
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
201
diff
changeset
|
2050 } |
|
117
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2051 # endif |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2052 #endif |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2053 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2054 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2055 #if defined(ORTHANC_PLUGINS_VERSION_IS_ABOVE) // Macro introduced in 1.3.1 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2056 # if ORTHANC_PLUGINS_VERSION_IS_ABOVE(1, 5, 4) |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2057 // New primitive since Orthanc 1.5.4 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2058 void IndexBackend::GetAllMetadata(std::map<int32_t, std::string>& result, |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2059 int64_t id) |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2060 { |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2061 DatabaseManager::CachedStatement statement( |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2062 STATEMENT_FROM_HERE, manager_, |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2063 "SELECT type, value FROM Metadata WHERE id=${id}"); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2064 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2065 statement.SetReadOnly(true); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2066 statement.SetParameterType("id", ValueType_Integer64); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2067 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2068 Dictionary args; |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2069 args.SetIntegerValue("id", id); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2070 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2071 statement.Execute(args); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2072 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2073 result.clear(); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2074 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2075 if (!statement.IsDone()) |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2076 { |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2077 if (statement.GetResultFieldsCount() != 2) |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2078 { |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2079 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2080 } |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2081 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2082 statement.SetResultFieldType(0, ValueType_Integer64); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2083 statement.SetResultFieldType(1, ValueType_Utf8String); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2084 |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2085 while (!statement.IsDone()) |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2086 { |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2087 result[ReadInteger32(statement, 0)] = ReadString(statement, 1); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2088 statement.Next(); |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2089 } |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2090 } |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2091 } |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2092 # endif |
|
ca0ecd412988
Implementation of new extensions: LookupResourceAndParent and GetAllMetadata
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
88
diff
changeset
|
2093 #endif |
|
210
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2094 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2095 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2096 void IndexBackend::CreateInstanceGeneric(OrthancPluginCreateInstanceResult& result, |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2097 const char* hashPatient, |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2098 const char* hashStudy, |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2099 const char* hashSeries, |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2100 const char* hashInstance) |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2101 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2102 // Check out "OrthancServer/Sources/Database/Compatibility/ICreateInstance.cpp" |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2103 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2104 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2105 OrthancPluginResourceType type; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2106 int64_t tmp; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2107 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2108 if (LookupResource(tmp, type, hashInstance)) |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2109 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2110 // The instance already exists |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2111 assert(type == OrthancPluginResourceType_Instance); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2112 result.instanceId = tmp; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2113 result.isNewInstance = false; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2114 return; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2115 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2116 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2117 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2118 result.instanceId = CreateResource(hashInstance, OrthancPluginResourceType_Instance); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2119 result.isNewInstance = true; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2120 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2121 result.isNewPatient = false; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2122 result.isNewStudy = false; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2123 result.isNewSeries = false; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2124 result.patientId = -1; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2125 result.studyId = -1; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2126 result.seriesId = -1; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2127 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2128 // Detect up to which level the patient/study/series/instance |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2129 // hierarchy must be created |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2130 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2131 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2132 OrthancPluginResourceType dummy; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2133 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2134 if (LookupResource(result.seriesId, dummy, hashSeries)) |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2135 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2136 assert(dummy == OrthancPluginResourceType_Series); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2137 // The patient, the study and the series already exist |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2138 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2139 bool ok = (LookupResource(result.patientId, dummy, hashPatient) && |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2140 LookupResource(result.studyId, dummy, hashStudy)); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2141 (void) ok; // Remove warning about unused variable in release builds |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2142 assert(ok); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2143 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2144 else if (LookupResource(result.studyId, dummy, hashStudy)) |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2145 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2146 assert(dummy == OrthancPluginResourceType_Study); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2147 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2148 // New series: The patient and the study already exist |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2149 result.isNewSeries = true; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2150 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2151 bool ok = LookupResource(result.patientId, dummy, hashPatient); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2152 (void) ok; // Remove warning about unused variable in release builds |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2153 assert(ok); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2154 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2155 else if (LookupResource(result.patientId, dummy, hashPatient)) |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2156 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2157 assert(dummy == OrthancPluginResourceType_Patient); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2158 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2159 // New study and series: The patient already exist |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2160 result.isNewStudy = true; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2161 result.isNewSeries = true; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2162 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2163 else |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2164 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2165 // New patient, study and series: Nothing exists |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2166 result.isNewPatient = true; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2167 result.isNewStudy = true; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2168 result.isNewSeries = true; |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2169 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2170 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2171 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2172 // Create the series if needed |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2173 if (result.isNewSeries) |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2174 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2175 result.seriesId = CreateResource(hashSeries, OrthancPluginResourceType_Series); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2176 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2177 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2178 // Create the study if needed |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2179 if (result.isNewStudy) |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2180 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2181 result.studyId = CreateResource(hashStudy, OrthancPluginResourceType_Study); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2182 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2183 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2184 // Create the patient if needed |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2185 if (result.isNewPatient) |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2186 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2187 result.patientId = CreateResource(hashPatient, OrthancPluginResourceType_Patient); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2188 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2189 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2190 // Create the parent-to-child links |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2191 AttachChild(result.seriesId, result.instanceId); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2192 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2193 if (result.isNewSeries) |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2194 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2195 AttachChild(result.studyId, result.seriesId); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2196 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2197 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2198 if (result.isNewStudy) |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2199 { |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2200 AttachChild(result.patientId, result.studyId); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2201 } |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2202 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2203 TagMostRecentPatient(result.patientId); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2204 |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2205 // Sanity checks |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2206 assert(result.patientId != -1); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2207 assert(result.studyId != -1); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2208 assert(result.seriesId != -1); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2209 assert(result.instanceId != -1); |
|
a0c095a4ba7d
all the integration tests pass on SQLite
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
209
diff
changeset
|
2210 } |
| 0 | 2211 } |