aboutsummaryrefslogtreecommitdiff
path: root/db/uobject.cpp
diff options
context:
space:
mode:
authorneodarz <neodarz@neodarz.net>2019-08-09 16:28:59 +0200
committerneodarz <neodarz@neodarz.net>2019-08-09 16:28:59 +0200
commitcf86e3de524ff247f496c34cd9e8df61cd4e6845 (patch)
treec7070f754e7d2d7f238bcc776161628f18998c21 /db/uobject.cpp
parenta6408962010c1880a54d2f0f3a1e35b0ca65531d (diff)
downloadumosapicpp-cf86e3de524ff247f496c34cd9e8df61cd4e6845.tar.xz
umosapicpp-cf86e3de524ff247f496c34cd9e8df61cd4e6845.zip
Add ability to search uobjects
Diffstat (limited to 'db/uobject.cpp')
-rw-r--r--db/uobject.cpp22
1 files changed, 22 insertions, 0 deletions
diff --git a/db/uobject.cpp b/db/uobject.cpp
index 0b76daf..bfaf7df 100644
--- a/db/uobject.cpp
+++ b/db/uobject.cpp
@@ -102,3 +102,25 @@ std::string uobject::remove(std::string collection, std::string oid, struct json
}
return json_object_to_json_string_ext(jsonObject, JSON_C_TO_STRING_SPACED | JSON_C_TO_STRING_PRETTY);
}
+
+std::string uobject::searchKeyValue(std::string collection, std::string key, std::string value, struct json_object* jsonArray) {
+ auto conn = mongo.get_connection();
+
+ auto coll = (*conn)[config["mongo_db"]][collection];
+
+ // Generate a string with the folowing format:
+ // {"datas.key":"value"}
+ std::string json_string = "{\"datas.";
+ json_string += key;
+ json_string += "\":\"";
+ json_string += value;
+ json_string += "\"}";
+
+ auto cursor = coll.find(bsoncxx::from_json(json_string));
+
+ for (auto&& doc : cursor) {
+ json_object_array_add(jsonArray, json_tokener_parse(bsoncxx::to_json(doc).c_str()));
+ }
+
+ return json_object_to_json_string_ext(jsonArray, JSON_C_TO_STRING_SPACED | JSON_C_TO_STRING_PRETTY);
+}