| 1 | // | 
|---|---|
| 2 | // Query.cpp | 
| 3 | // | 
| 4 | // Library: JSON | 
| 5 | // Package: JSON | 
| 6 | // Module: Query | 
| 7 | // | 
| 8 | // Copyright (c) 2012, Applied Informatics Software Engineering GmbH. | 
| 9 | // and Contributors. | 
| 10 | // | 
| 11 | // SPDX-License-Identifier: BSL-1.0 | 
| 12 | // | 
| 13 | |
| 14 | |
| 15 | #include "Poco/JSON/Query.h" | 
| 16 | #include "Poco/StringTokenizer.h" | 
| 17 | #include "Poco/RegularExpression.h" | 
| 18 | #include "Poco/NumberParser.h" | 
| 19 | #include <sstream> | 
| 20 | |
| 21 | |
| 22 | using Poco::Dynamic::Var; | 
| 23 | |
| 24 | |
| 25 | namespace Poco { | 
| 26 | namespace JSON { | 
| 27 | |
| 28 | |
| 29 | Query::Query(const Var& source): _source(source) | 
| 30 | { | 
| 31 | if (!source.isEmpty() && | 
| 32 | source.type() != typeid(Object) && | 
| 33 | source.type() != typeid(Object::Ptr) && | 
| 34 | source.type() != typeid(Array) && | 
| 35 | source.type() != typeid(Array::Ptr)) | 
| 36 | 		throw InvalidArgumentException("Only JSON Object, Array or pointers thereof allowed.");  | 
| 37 | } | 
| 38 | |
| 39 | |
| 40 | Query::~Query() | 
| 41 | { | 
| 42 | } | 
| 43 | |
| 44 | |
| 45 | Object::Ptr Query::findObject(const std::string& path) const | 
| 46 | { | 
| 47 | Var result = find(path); | 
| 48 | |
| 49 | if (result.type() == typeid(Object::Ptr)) | 
| 50 | return result.extract<Object::Ptr>(); | 
| 51 | else if (result.type() == typeid(Object)) | 
| 52 | return new Object(result.extract<Object>()); | 
| 53 | |
| 54 | return 0; | 
| 55 | } | 
| 56 | |
| 57 | |
| 58 | Object& Query::findObject(const std::string& path, Object& obj) const | 
| 59 | { | 
| 60 | obj.clear(); | 
| 61 | |
| 62 | Var result = find(path); | 
| 63 | |
| 64 | if (result.type() == typeid(Object::Ptr)) | 
| 65 | obj = *result.extract<Object::Ptr>(); | 
| 66 | else if (result.type() == typeid(Object)) | 
| 67 | obj = result.extract<Object>(); | 
| 68 | |
| 69 | return obj; | 
| 70 | } | 
| 71 | |
| 72 | |
| 73 | Array::Ptr Query::findArray(const std::string& path) const | 
| 74 | { | 
| 75 | Var result = find(path); | 
| 76 | |
| 77 | if (result.type() == typeid(Array::Ptr)) | 
| 78 | return result.extract<Array::Ptr>(); | 
| 79 | else if (result.type() == typeid(Array)) | 
| 80 | return new Array(result.extract<Array>()); | 
| 81 | |
| 82 | return 0; | 
| 83 | } | 
| 84 | |
| 85 | |
| 86 | Array& Query::findArray(const std::string& path, Array& arr) const | 
| 87 | { | 
| 88 | arr.clear(); | 
| 89 | |
| 90 | Var result = find(path); | 
| 91 | |
| 92 | if (result.type() == typeid(Array::Ptr)) | 
| 93 | arr = *result.extract<Array::Ptr>(); | 
| 94 | else if (result.type() == typeid(Array)) | 
| 95 | arr = result.extract<Array>(); | 
| 96 | |
| 97 | return arr; | 
| 98 | } | 
| 99 | |
| 100 | |
| 101 | Var Query::find(const std::string& path) const | 
| 102 | { | 
| 103 | Var result = _source; | 
| 104 | 	StringTokenizer tokenizer(path, ".");  | 
| 105 | for (StringTokenizer::Iterator token = tokenizer.begin(); token != tokenizer.end(); token++) | 
| 106 | { | 
| 107 | if (!result.isEmpty()) | 
| 108 | { | 
| 109 | std::vector<int> indexes; | 
| 110 | RegularExpression::MatchVec matches; | 
| 111 | int firstOffset = -1; | 
| 112 | int offset = 0; | 
| 113 | 			RegularExpression regex("\\[([0-9]+)\\]");  | 
| 114 | while (regex.match(*token, offset, matches) > 0) | 
| 115 | { | 
| 116 | if (firstOffset == -1) | 
| 117 | { | 
| 118 | firstOffset = static_cast<int>(matches[0].offset); | 
| 119 | } | 
| 120 | std::string num = token->substr(matches[1].offset, matches[1].length); | 
| 121 | indexes.push_back(NumberParser::parse(num)); | 
| 122 | offset = static_cast<int>(matches[0].offset + matches[0].length); | 
| 123 | } | 
| 124 | |
| 125 | std::string name(*token); | 
| 126 | if (firstOffset != -1) | 
| 127 | { | 
| 128 | name = name.substr(0, firstOffset); | 
| 129 | } | 
| 130 | |
| 131 | if (name.length() > 0) | 
| 132 | { | 
| 133 | if (result.type() == typeid(Object::Ptr)) | 
| 134 | { | 
| 135 | Object::Ptr o = result.extract<Object::Ptr>(); | 
| 136 | result = o->get(name); | 
| 137 | } | 
| 138 | else if (result.type() == typeid(Object)) | 
| 139 | { | 
| 140 | Object o = result.extract<Object>(); | 
| 141 | result = o.get(name); | 
| 142 | } | 
| 143 | else | 
| 144 | result.empty(); | 
| 145 | |
| 146 | } | 
| 147 | |
| 148 | if (!result.isEmpty() && !indexes.empty()) | 
| 149 | { | 
| 150 | for (std::vector<int>::iterator it = indexes.begin(); it != indexes.end(); ++it) | 
| 151 | { | 
| 152 | if (result.type() == typeid(Array::Ptr)) | 
| 153 | { | 
| 154 | Array::Ptr array = result.extract<Array::Ptr>(); | 
| 155 | result = array->get(*it); | 
| 156 | if (result.isEmpty()) break; | 
| 157 | } | 
| 158 | else if (result.type() == typeid(Array)) | 
| 159 | { | 
| 160 | Array array = result.extract<Array>(); | 
| 161 | result = array.get(*it); | 
| 162 | if (result.isEmpty()) break; | 
| 163 | } | 
| 164 | } | 
| 165 | } | 
| 166 | } | 
| 167 | } | 
| 168 | return result; | 
| 169 | } | 
| 170 | |
| 171 | |
| 172 | } } // namespace Poco::JSON | 
| 173 |