/foundation/distributedhardware/device_manager/utils/src/kvadapter/ |
H A D | kv_adapter_manager.cpp | 74 std::string prefixKey = DM_KV_STORE_PREFIX + value.appID + DB_KEY_DELIMITER + value.udidHash; in PutByAnoyDeviceId() local 75 idCacheMap_[prefixKey] = value; in PutByAnoyDeviceId() 83 if (kvAdapter_->Put(prefixKey, valueStr) != DM_OK) { in PutByAnoyDeviceId() 84 LOGE("Insert value to DB for prefixKey failed"); in PutByAnoyDeviceId() 107 std::string prefixKey = DM_KV_STORE_PREFIX + value.appID + DB_KEY_DELIMITER + value.udidHash; in Get() local 108 idCacheMap_[prefixKey] = value; in Get()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
H A D | lru_map.h | 52 void RemoveWithPrefixKey(const K &prefixKey) in RemoveWithPrefixKey() argument 58 if (key.find(prefixKey) == 0) { in RemoveWithPrefixKey()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | query_sync_object.h | 31 std::vector<uint8_t> prefixKey{}; 40 QuerySyncObject(const std::list<QueryObjNode> &queryObjNodes, const std::vector<uint8_t> &prefixKey,
|
H A D | query_sync_object.cpp | 91 QuerySyncObject::QuerySyncObject(const std::list<QueryObjNode> &queryObjNodes, const std::vector<uint8_t> &prefixKey, in QuerySyncObject() argument 93 : QueryObject(queryObjNodes, prefixKey, keys) in QuerySyncObject() 122 objContext.prefixKey.assign(prefixKey_.begin(), prefixKey_.end()); in GetObjContext() 214 (void)parcel.WriteVectorChar(context.prefixKey); in SerializeData() 311 (void)parcel.ReadVectorChar(context.prefixKey); in DeSerializeData() 341 queryObj = QuerySyncObject(context.queryObjNodes, context.prefixKey, keys); in DeSerializeData()
|
H A D | query_object.h | 32 QueryObject(const std::list<QueryObjNode> &queryObjNodes, const std::vector<uint8_t> &prefixKey,
|
H A D | sqlite_cloud_kv_store.cpp | 299 std::string prefixKey; in FilterCloudVersionPrefixKey() 300 int errCode = CloudStorageUtils::GetValueFromOneField(type, prefixKey); in FilterCloudVersionPrefixKey() 305 isFilter = !prefixKey.empty() && prefixKey.find(CloudDbConstant::CLOUD_VERSION_RECORD_PREFIX_KEY) == 0; in FilterCloudVersionPrefixKey()
|
H A D | query_object.cpp | 91 QueryObject::QueryObject(const std::list<QueryObjNode> &queryObjNodes, const std::vector<uint8_t> &prefixKey, in QueryObject() argument 94 prefixKey_(prefixKey), in QueryObject()
|
H A D | sqlite_single_ver_natural_store.cpp | 1989 Key prefixKey; in RemoveAllSubscribe() local 1996 DBCommon::StringToVector(DBConstant::SUBSCRIBE_QUERY_PREFIX, prefixKey); in RemoveAllSubscribe() 1997 errCode = handle->DeleteMetaDataByPrefixKey(prefixKey); in RemoveAllSubscribe()
|
/foundation/distributeddatamgr/kv_store/test/unittest/distributeddata/ |
H A D | SchemaJsTest.js | 64 query.prefixKey('test_key_'); 249 query.prefixKey('test_key_'); 338 query.prefixKey('test_key_'); 384 query.prefixKey('test_key_'); 430 query.prefixKey('test_key_');
|
H A D | SingleKvStoreDataCallbackJsTest.js | 2169 query.prefixKey("batch_test"); 2214 query.prefixKey("batch_test"); 2359 query.prefixKey("batch_test"); 2398 query.prefixKey("batch_test"); 2439 query.prefixKey("batch_test"); 2484 query.prefixKey("batch_test");
|
H A D | DeviceKvStoreDataCallbackJsTest.js | 2044 query.prefixKey("batch_test"); 2089 query.prefixKey("batch_test"); 2235 query.prefixKey("batch_test"); 2275 query.prefixKey("batch_test"); 2317 query.prefixKey("batch_test"); 2362 query.prefixKey("batch_test");
|
H A D | SingleKvStoreDataPromiseJsTest.js | 2371 query.prefixKey("batch_test"); 2424 query.prefixKey("batch_test"); 2573 query.prefixKey("batch_test"); 2617 query.prefixKey("batch_test"); 2659 query.prefixKey("batch_test"); 2707 query.prefixKey("batch_test");
|
H A D | DeviceKvStoreDataPromiseJsTest.js | 2254 query.prefixKey("batch_test"); 2310 query.prefixKey("batch_test"); 2460 query.prefixKey("batch_test"); 2505 query.prefixKey("batch_test"); 2548 query.prefixKey("batch_test"); 2596 query.prefixKey("batch_test");
|
/foundation/distributeddatamgr/kv_store/test/unittest/distributedKVStore/ |
H A D | SchemaJsTest.js | 113 query.prefixKey('test_key_'); 160 query.prefixKey('test_key_'); 207 query.prefixKey('test_key_'); 254 query.prefixKey('test_key_'); 301 query.prefixKey('test_key_');
|
H A D | SingleKvStoreKVCallbackJsTest.js | 1651 query.prefixKey("batch_test"); 1691 query.prefixKey("batch_test"); 2334 query.prefixKey("batch_test"); 2432 query.prefixKey("batch_test"); 2511 query.prefixKey("batch_test"); 2556 query.prefixKey("batch_test");
|
H A D | DeviceKvStoreKVCallbackJsTest.js | 1618 query.prefixKey("batch_test"); 1658 query.prefixKey("batch_test"); 2209 query.prefixKey("batch_test"); 2309 query.prefixKey("batch_test"); 2388 query.prefixKey("batch_test"); 2434 query.prefixKey("batch_test");
|
H A D | SingleKvStoreKVPromiseJsTest.js | 1418 query.prefixKey("batch_test"); 1472 query.prefixKey("batch_test"); 2184 query.prefixKey("batch_test"); 2241 query.prefixKey("batch_test"); 2283 predicates.prefixKey("name_"); 2332 predicates.prefixKey("batch_test"); 2427 query.prefixKey("batch_test"); 2512 query.prefixKey("batch_test");
|
H A D | DeviceKvStoreKVPromiseJsTest.js | 1415 query.prefixKey("batch_test"); 1469 query.prefixKey("batch_test"); 2089 query.prefixKey("batch_test"); 2146 query.prefixKey("batch_test"); 2189 predicates.prefixKey("name_"); 2238 predicates.prefixKey("batch_test"); 2333 query.prefixKey("batch_test"); 2418 query.prefixKey("batch_test");
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
H A D | query_sync_water_mark_helper.cpp | 533 Key prefixKey; in ResetRecvQueryWaterMark() local 534 DBCommon::StringToVector(prefixKeyStr, prefixKey); in ResetRecvQueryWaterMark() 535 int errCode = storage_->DeleteMetaDataByPrefixKey(prefixKey); in ResetRecvQueryWaterMark()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
H A D | distributeddb_tools_unit_test.cpp | 346 std::vector<uint8_t> DistributedDBToolsUnitTest::GetRandPrefixKey(const std::vector<uint8_t> &prefixKey, uint32_t size) in GetRandPrefixKey() argument 349 if (size <= prefixKey.size()) { in GetRandPrefixKey() 352 DistributedDBToolsUnitTest::GetRandomKeyValue(value, size - prefixKey.size()); in GetRandPrefixKey() 353 std::vector<uint8_t> res(prefixKey); in GetRandPrefixKey()
|
H A D | distributeddb_tools_unit_test.h | 216 static std::vector<uint8_t> GetRandPrefixKey(const std::vector<uint8_t> &prefixKey, uint32_t size);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_storage_sqlite_single_ver_natural_executor_test.cpp | 1218 const std::vector<uint8_t> prefixKey; in HWTEST_F() local 1220 QueryObject queryObj(queryObjNodes, prefixKey, keys); in HWTEST_F()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
H A D | cloud_storage_utils.cpp | 1454 std::string prefixKey = CloudDbConstant::CLOUD_VERSION_RECORD_PREFIX_KEY; in IsSystemRecord() local 1455 if (key.size() < prefixKey.size()) { in IsSystemRecord() 1459 return keyStr.find(prefixKey) == 0; in IsSystemRecord()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | distributeddb_single_ver_p2p_simple_sync_test.cpp | 61 std::vector<uint8_t> prefixKey = {'a', 'b', 'c'}; in CalculateDataTest() local 62 Key key = DistributedDBToolsUnitTest::GetRandPrefixKey(prefixKey, keySize); in CalculateDataTest()
|
H A D | distributeddb_single_ver_p2p_complex_sync_test.cpp | 1277 std::vector<uint8_t> prefixKey({'a', 'b'}); in HWTEST_F() 1278 Query query = Query::Select().PrefixKey(prefixKey); in HWTEST_F()
|