| 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 |