Home
last modified time | relevance | path

Searched refs:queryNode (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_query_helper.cpp646 …std::string sql = RELATIONAL_SYMBOL_TO_SQL.at(queryNode.operFlag) + MapValueToSql(queryNode, place… in MapRelationalSymbolToSql()
664 switch (queryNode.operFlag) { in MapKeywordSymbolToSql()
670 sql += GetFieldShape(queryNode); in MapKeywordSymbolToSql()
698 … resultSql += placeholder ? "? " : FieldValue2String(queryNode.fieldValue[i], queryNode.type); in MapValueToSql()
705 …return (queryNode.operFlag == QueryObjType::IS_NULL || queryNode.operFlag == QueryObjType::IS_NOT_… in IsNeedCastWitEmptyValue()
706 queryNode.operFlag == QueryObjType::IN || queryNode.operFlag == QueryObjType::NOT_IN); in IsNeedCastWitEmptyValue()
712 if (queryNode.fieldValue.empty() && !IsNeedCastWitEmptyValue(queryNode)) { in MapCastFuncSql()
763 return "a.'" + queryNode.fieldName + "' "; in GetFieldShape()
765 return MapCastFuncSql(queryNode, accessStr); in GetFieldShape()
782 querySql += MapLogicSymbolToSql(queryNode); in ParseQueryExpression()
[all …]
H A Dsqlite_query_helper.h138 int ParseQueryExpression(const QueryObjNode &queryNode, std::string &querySql,
140 …std::string MapRelationalSymbolToSql(const QueryObjNode &queryNode, bool placeholder = false) cons…
141 std::string MapKeywordSymbolToSql(const QueryObjNode &queryNode);
142 std::string MapLogicSymbolToSql(const QueryObjNode &queryNode) const;
143 std::string MapValueToSql(const QueryObjNode &queryNode, bool placeholder) const;
144 std::string MapCastFuncSql(const QueryObjNode &queryNode, const std::string &accessStr = "");
146 int BindFieldValue(sqlite3_stmt *statement, const QueryObjNode &queryNode, int &index) const;
160 std::string GetFieldShape(const QueryObjNode &queryNode, const std::string &accessStr = "");
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dvirtual_cloud_db.cpp344 for (const auto &queryNode : queryNodes) { in IsPrimaryKeyMatching() local
345 if ((queryNode.type == QueryNodeType::IN) && (queryNode.fieldName != g_gidField)) { in IsPrimaryKeyMatching()
346 if (IsPrimaryKeyMatchingInner(queryNode, record)) { in IsPrimaryKeyMatching()
354 bool VirtualCloudDb::IsPrimaryKeyMatchingInner(const QueryNode &queryNode, VBucket &record) in IsPrimaryKeyMatchingInner() argument
356 for (const auto &value : queryNode.fieldValue) { in IsPrimaryKeyMatchingInner()
357 size_t type = record[queryNode.fieldName].index(); in IsPrimaryKeyMatchingInner()
386 for (const auto &queryNode : queryNodes) { in IsCloudGidMatching() local
387 if ((queryNode.type == QueryNodeType::IN) && (queryNode.fieldName == g_gidField)) { in IsCloudGidMatching()
388 if (IsCloudGidMatchingInner(queryNode, extend)) { in IsCloudGidMatching()
396 bool VirtualCloudDb::IsCloudGidMatchingInner(const QueryNode &queryNode, VBucket &extend) in IsCloudGidMatchingInner() argument
[all …]
H A Dvirtual_cloud_db.h120 bool IsCloudGidMatchingInner(const QueryNode &queryNode, VBucket &extend);
124 bool IsPrimaryKeyMatchingInner(const QueryNode &queryNode, VBucket &record);
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_cloud.cpp238 QueryNode queryNode; in ConvertQuery() local
239 queryNode.fieldName = std::move(node.fieldName); in ConvertQuery()
240 queryNode.fieldValue = ValueProxy::Convert(std::move(node.fieldValue)); in ConvertQuery()
243 queryNode.op = QueryOperation::IN; in ConvertQuery()
246 queryNode.op = QueryOperation::OR; in ConvertQuery()
249 queryNode.op = QueryOperation::AND; in ConvertQuery()
252 queryNode.op = QueryOperation::EQUAL_TO; in ConvertQuery()
255 queryNode.op = QueryOperation::BEGIN_GROUP; in ConvertQuery()
258 queryNode.op = QueryOperation::END_GROUP; in ConvertQuery()
264 queryNodes.emplace_back(std::move(queryNode)); in ConvertQuery()