Home
last modified time | relevance | path

Searched refs:keyPrefix (Results 1 - 25 of 120) sorted by relevance

12345

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_natural_store_snapshot.cpp46 int MultiVerNaturalStoreSnapshot::GetEntries(const Key &keyPrefix, std::vector<Entry> &entries) const in GetEntries() argument
51 if (keyPrefix.size() > DBConstant::MAX_KEY_SIZE) { in GetEntries()
52 LOGE("[MultiSnapshot] Invalid prefix[%zu]", keyPrefix.size()); in GetEntries()
55 return static_cast<MultiVerStorageExecutor *>(databaseHandle_)->GetEntries(keyPrefix, entries); in GetEntries()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/
H A Ddistributeddb_kv_batch_crud_test.cpp673 vector<Entry> MultiSnapCheck1(vector<Entry> &entries1, vector<Entry> &entries2, DistributedDB::Key &keyPrefix, in MultiSnapCheck1() argument
677 * @tc.steps: step3. Register snap2 then getEntries with keyPrefix="k". in MultiSnapCheck1()
686 snap2->GetEntries(keyPrefix, function2); in MultiSnapCheck1()
691 * @tc.steps: step4. putBatch (k1,v1)(k2,v2) again and Register snap3 then getEntries with keyPrefix="k". in MultiSnapCheck1()
705 snap3->GetEntries(keyPrefix, function3); in MultiSnapCheck1()
709 * @tc.steps: step5. putBatch (k1,v2)(k2,v3) again, Register snap4 then getEntries with keyPrefix="k". in MultiSnapCheck1()
721 snap4->GetEntries(keyPrefix, function4); in MultiSnapCheck1()
733 void SnapWithTransactionCheck(vector<Key> keys1, DistributedDB::Key keyPrefix, in SnapWithTransactionCheck() argument
782 snap5->GetEntries(keyPrefix, function5); in SnapWithTransactionCheck()
819 * @tc.steps: step2. Register snap1 then getEntries with keyPrefix in HWTEST_F()
828 DistributedDB::Key keyPrefix = { 'k' }; HWTEST_F() local
842 RegisterSnapAgainAndCheck1(KvStoreObserverSnapImpl &observer1, KvStoreSnapshotDelegate *&snap1, vector<Entry> &entries, DistributedDB::Key &keyPrefix) RegisterSnapAgainAndCheck1() argument
864 RegisterSnapAgainAndCheck2(KvStoreObserverSnapImpl &observer2, KvStoreSnapshotDelegate *&snap2, vector<Entry> &entries, DistributedDB::Key &keyPrefix) RegisterSnapAgainAndCheck2() argument
891 RegisterSnapAgainAndCheck3(KvStoreObserverSnapImpl &observer3, KvStoreSnapshotDelegate *&snap3, vector<Entry> &entries, DistributedDB::Key &keyPrefix) RegisterSnapAgainAndCheck3() argument
917 RegisterSnapAgainAndCheck4(KvStoreObserverSnapImpl &observer4, KvStoreSnapshotDelegate *&snap4, vector<Entry> &entries, DistributedDB::Key &keyPrefix, vector<Entry> &entriesInDB) RegisterSnapAgainAndCheck4() argument
948 RegisterSnapAgainAndCheck5(KvStoreObserverSnapImpl &observer5, KvStoreSnapshotDelegate *&snap5, vector<Entry> &entries1, DistributedDB::Key &keyPrefix, vector<Entry> &entriesInDB) RegisterSnapAgainAndCheck5() argument
997 RegisterSnapAgainAndCheck6(KvStoreSnapshotDelegate *snap6, KvStoreSnapshotDelegate *snap7, KvStoreSnapshotDelegate *snap8, DistributedDB::Key &keyPrefix) RegisterSnapAgainAndCheck6() argument
1075 DistributedDB::Key keyPrefix = { 'k' }; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/
H A Dsqlite_local_kvdb_snapshot.cpp39 int SQLiteLocalKvDBSnapshot::GetEntries(const Key &keyPrefix, std::vector<Entry> &entries) const in GetEntries() argument
45 return connect_->GetEntries(option, keyPrefix, entries); in GetEntries()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/versioninfomanager/versioninfomanager/include/
H A Dversion_info_manager_test.h61 int32_t GetDataByKeyPrefix(const std::string &keyPrefix, std::vector<std::string> &values) in GetDataByKeyPrefix() argument
63 (void)keyPrefix; in GetDataByKeyPrefix()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/
H A Ddb_store_mock.cpp26 DBStatus DBStoreMock::GetEntries(const Key &keyPrefix, std::vector<Entry> &entries) const in GetEntries() argument
28 return GetEntries(entries_, keyPrefix, entries); in GetEntries()
31 DBStatus DBStoreMock::GetEntries(const Key &keyPrefix, KvStoreResultSet *&resultSet) const in GetEntries() argument
84 DBStatus DBStoreMock::GetLocalEntries(const Key &keyPrefix, std::vector<Entry> &entries) const in GetLocalEntries() argument
86 return GetEntries(localEntries_, keyPrefix, entries); in GetLocalEntries()
244 DBStatus DBStoreMock::GetKeys(const Key &keyPrefix, std::vector<Key> &keys) const in GetKeys() argument
261 DBStatus DBStoreMock::GetEntries(ConcurrentMap<Key, Value> &store, const Key &keyPrefix, in GetEntries() argument
264 store.ForEach([&entries, &keyPrefix](const Key &key, Value &value) { in GetEntries()
265 auto it = std::search(key.begin(), key.end(), keyPrefix.begin(), keyPrefix in GetEntries()
[all...]
H A Dkv_store_nb_delegate_mock.h40 DBStatus GetEntries(const Key &keyPrefix, std::vector<Entry> &entries) const;
41 DBStatus GetEntries(const Key &keyPrefix, KvStoreResultSet *&resultSet) const;
51 DBStatus GetLocalEntries(const Key &keyPrefix, std::vector<Entry> &entries) const;
91 DBStatus GetKeys(const Key &keyPrefix, std::vector<Key> &keys) const;
H A Ddb_store_mock.h53 DBStatus GetEntries(const Key &keyPrefix, std::vector<Entry> &entries) const override;
54 DBStatus GetEntries(const Key &keyPrefix, KvStoreResultSet *&resultSet) const override;
64 DBStatus GetLocalEntries(const Key &keyPrefix, std::vector<Entry> &entries) const override;
101 DBStatus GetKeys(const Key &keyPrefix, std::vector<Key> &keys) const override;
121 DBStatus GetEntries(ConcurrentMap<Key, Value> &store, const Key &keyPrefix, std::vector<Entry> &entries) const;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_natural_store_connection.h46 int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const override;
83 int GetResultSet(const IOption &option, const Key &keyPrefix, IKvDBResultSet *&resultSet) const override;
97 int GetKeys(const IOption &option, const Key &keyPrefix, std::vector<Key> &keys) const override;
115 const Key &keyPrefix, std::vector<Entry> &entries) const;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/
H A Ddistributeddb_data_generator.cpp21 std::vector<uint8_t> keyPrefix) in GenerateRecord()
24 entry.key = keyPrefix; in GenerateRecord()
111 const std::vector<uint8_t> &keyPrefix) in GenerateLongRecord()
114 entry.key = keyPrefix; in GenerateLongRecord()
134 const std::vector<uint8_t> &keyPrefix, unsigned int num) in GenerateMaxBigRecord()
137 entry.key = keyPrefix; in GenerateMaxBigRecord()
250 const std::vector<uint8_t> &keyPrefix, const std::vector<uint8_t> &val, DistributedDB::Entry &entry) in GenerateOneRecordForImage()
263 entry.key = keyPrefix; in GenerateOneRecordForImage()
264 for (unsigned int cnt = 0; cnt < (entrySize.keySize - len - keyPrefix.size()); cnt++) { in GenerateOneRecordForImage()
275 int num, std::vector<uint8_t> keyPrefix, st in GenerateRecordsForImage()
20 GenerateRecord(unsigned int keyNo, DistributedDB::Entry &entry, std::vector<uint8_t> keyPrefix) GenerateRecord() argument
110 GenerateLongRecord(unsigned int keyNo, DistributedDB::Entry &entry, const std::vector<uint8_t> &keyPrefix) GenerateLongRecord() argument
133 GenerateMaxBigRecord(unsigned int keyNo, DistributedDB::Entry &entry, const std::vector<uint8_t> &keyPrefix, unsigned int num) GenerateMaxBigRecord() argument
249 GenerateOneRecordForImage(int entryNo, const EntrySize &entrySize, const std::vector<uint8_t> &keyPrefix, const std::vector<uint8_t> &val, DistributedDB::Entry &entry) GenerateOneRecordForImage() argument
274 GenerateRecordsForImage(std::vector<DistributedDB::Entry> &entries, EntrySize &entrySize, int num, std::vector<uint8_t> keyPrefix, std::vector<uint8_t> val) GenerateRecordsForImage() argument
284 GenerateAppointPrefixAndSizeRecord(int recordNo, const EntrySize &entrySize, const std::vector<uint8_t> &keyPrefix, const std::vector<uint8_t> &valPrefix, DistributedDB::Entry &entry) GenerateAppointPrefixAndSizeRecord() argument
302 GenerateAppointPrefixAndSizeRecords(std::vector<DistributedDB::Entry> &entries, const EntrySize &entrySize, int num, const std::vector<uint8_t> &keyPrefix, const std::vector<uint8_t> &valPrefix) GenerateAppointPrefixAndSizeRecords() argument
313 GenerateAppointPrefixAndSizeRecords(std::vector<DistributedDB::Entry> &entries, int startpoint, const NumberSize param, const std::vector<uint8_t> &keyPrefix, const std::vector<uint8_t> &valPrefix) GenerateAppointPrefixAndSizeRecords() argument
364 GenerateFixedLenRandRecords(std::vector<DistributedDB::Key> &allKeys, int recordNum, const EntrySize &entrySize, const std::vector<uint8_t> &keyPrefix, const std::vector<uint8_t> &valPrefix) GenerateFixedLenRandRecords() argument
[all...]
/foundation/communication/dsoftbus/tests/core/bus_center/lnn/net_builder/src/
H A Dlnn_kv_adapter_wrapper_mock.cpp66 int32_t LnnDeleteDBDataByPrefix(int32_t dbId, const char *keyPrefix, int32_t keyPrefixLen) in LnnDeleteDBDataByPrefix() argument
68 return GetKvAdapterInterface()->LnnDeleteDBDataByPrefix(dbId, keyPrefix, keyPrefixLen); in LnnDeleteDBDataByPrefix()
/foundation/communication/dsoftbus/core/adapter/bus_center/src/
H A Dlnn_kv_adapter_wrapper_virtual.cpp62 int32_t LnnDeleteDBDataByPrefix(int32_t dbId, const char *keyPrefix, int32_t keyPrefixLen) in LnnDeleteDBDataByPrefix() argument
65 (void)keyPrefix; in LnnDeleteDBDataByPrefix()
/foundation/deviceprofile/device_info_manager/services/core/include/persistenceadapter/kvadapter/
H A Dikv_adapter.h35 virtual int32_t DeleteByPrefix(const std::string& keyPrefix) = 0;
37 virtual int32_t GetByPrefix(const std::string& keyPrefix, std::map<std::string, std::string>& values) = 0;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_snapshot_delegate_impl.cpp55 const Key &keyPrefix, const std::function<void(DBStatus, const std::vector<Entry> &)> &callback) const in GetEntries()
65 int errCode = snapShot_->GetEntries(keyPrefix, entries); in GetEntries()
54 GetEntries( const Key &keyPrefix, const std::function<void(DBStatus, const std::vector<Entry> &)> &callback) const GetEntries() argument
H A Dkv_store_nb_delegate_impl.h41 DBStatus GetEntries(const Key &keyPrefix, std::vector<Entry> &entries) const override;
43 DBStatus GetEntries(const Key &keyPrefix, KvStoreResultSet *&resultSet) const override;
64 DBStatus GetLocalEntries(const Key &keyPrefix, std::vector<Entry> &entries) const override;
161 DBStatus GetKeys(const Key &keyPrefix, std::vector<Key> &keys) const override;
197 DBStatus GetEntriesInner(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_meta_executor.cpp45 Key keyPrefix; in GetMetaKeysByKeyPrefix() local
46 DBCommon::StringToVector(keyPre + '%', keyPrefix); in GetMetaKeysByKeyPrefix()
47 errCode = SQLiteUtils::BindBlobToStatement(statement, 1, keyPrefix); // 1: bind index for prefix key in GetMetaKeysByKeyPrefix()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/schemadelegate_fuzzer/
H A Dschemadelegate_fuzzer.cpp75 Key keyPrefix = fuzz.GetSequence(fuzz.GetInt()); in SchemaFuzzCURD() local
76 delegate->GetEntries(keyPrefix, entriesGot); in SchemaFuzzCURD()
82 delegate->GetEntries(keyPrefix, readResultSet); in SchemaFuzzCURD()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_transaction_optimization_test.cpp129 Key keyPrefix; in HWTEST_F() local
131 EXPECT_EQ(g_kvNbDelegatePtr->GetEntries(keyPrefix, getSyncEntries), OK); in HWTEST_F()
135 EXPECT_EQ(g_kvNbDelegatePtr->GetLocalEntries(keyPrefix, getLocalEntries), OK); in HWTEST_F()
149 EXPECT_EQ(g_kvNbDelegatePtr->GetEntries(keyPrefix, getSyncEntries), OK); in HWTEST_F()
153 EXPECT_EQ(g_kvNbDelegatePtr->GetLocalEntries(keyPrefix, getLocalEntries), OK); in HWTEST_F()
354 Key keyPrefix; in HWTEST_F() local
356 EXPECT_EQ(g_kvNbDelegatePtr->GetEntries(keyPrefix, getSyncEntries), NOT_FOUND); in HWTEST_F()
358 EXPECT_EQ(g_kvNbDelegatePtr->GetLocalEntries(keyPrefix, getLocalEntries), NOT_FOUND); in HWTEST_F()
783 Key keyPrefix; in HWTEST_F() local
785 EXPECT_EQ(g_kvNbDelegatePtr->GetEntries(keyPrefix, entrie in HWTEST_F()
[all...]
/foundation/communication/dsoftbus/tests/core/adapter/unittest/
H A Dlnn_kv_adapter_test.cpp251 * @tc.desc: DeleteByPrefix failed, keyPrefix is empty.
257 std::string keyPrefix = ""; in HWTEST_F() local
258 EXPECT_EQ(SOFTBUS_INVALID_PARAM, kvStore->DeleteByPrefix(keyPrefix)); in HWTEST_F()
263 * @tc.desc: DeleteByPrefix failed, keyPrefix length exceeds MAX_STRING_LEN.
269 std::string keyPrefix(MAX_STRING_LEN + 1, 'a'); in HWTEST_F()
270 EXPECT_EQ(SOFTBUS_INVALID_PARAM, kvStore->DeleteByPrefix(keyPrefix)); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/kvstoreresultset_fuzzer/
H A Dkvstoreresultset_fuzzer.cpp52 Key keyPrefix; in ResultSetFuzzer() local
54 kvNbDelegatePtr->GetEntries(keyPrefix, readResultSet); in ResultSetFuzzer()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/metainfomgr_fuzzer/
H A Dmetainfomgr_fuzzer.cpp43 std::string keyPrefix(reinterpret_cast<const char*>(data), size); in GetDataByKeyPrefixFuzzTest()
45 MetaInfoManager::GetInstance()->GetDataByKeyPrefix(keyPrefix, metaCapMap); in GetDataByKeyPrefixFuzzTest()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dikvdb_connection.h62 virtual int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const = 0;
121 virtual int GetResultSet(const IOption &option, const Key &keyPrefix, IKvDBResultSet *&resultSet) const = 0;
135 virtual int GetKeys(const IOption &option, const Key &keyPrefix, std::vector<Key> &keys) const = 0;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dgeneric_kvdb_connection.h60 int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const override;
64 int GetResultSet(const IOption &option, const Key &keyPrefix, IKvDBResultSet *&resultSet) const override;
78 int GetKeys(const IOption &option, const Key &keyPrefix, std::vector<Key> &keys) const override;
H A Dgeneric_kvdb_connection.cpp227 int GenericKvDBConnection::GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const in GetEntries() argument
230 (void)keyPrefix; in GetEntries()
243 int GenericKvDBConnection::GetResultSet(const IOption &option, const Key &keyPrefix, IKvDBResultSet *&resultSet) const in GetResultSet() argument
246 (void)keyPrefix; in GetResultSet()
354 int GenericKvDBConnection::GetKeys(const IOption &option, const Key &keyPrefix, std::vector<Key> &keys) const
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/
H A Djs_single_kv_store.cpp114 std::string keyPrefix; member
122 // required 1 arguments :: <keyPrefix/query> in GetVariantArgs()
128 status = JSUtil::GetValue(env, argv[0], va.keyPrefix); in GetVariantArgs()
129 CHECK_RETURN(!va.keyPrefix.empty(), "invalid arg[0], i.e. invalid keyPrefix!", napi_invalid_arg); in GetVariantArgs()
148 * getEntries(keyPrefix:string, callback:AsyncCallback<Entry[]>):void
149 * getEntries(keyPrefix:string):Promise<Entry[]>
163 // required 1 arguments :: <keyPrefix/query> in GetEntries()
174 OHOS::DistributedKv::Key keyPrefix(ctxt->va.keyPrefix); in GetEntries()
[all...]
H A Djs_device_kv_store.cpp131 std::string keyPrefix; member
144 // number 2 means: required 2 arguments, <deviceId> <keyPrefix/query> in GetVariantArgs()
151 status = JSUtil::GetValue(env, argv[1], va.keyPrefix); in GetVariantArgs()
152 CHECK_RETURN(!va.keyPrefix.empty(), "invalid arg[1], i.e. invalid keyPrefix!", napi_invalid_arg); in GetVariantArgs()
186 * getEntries(deviceId:string, keyPrefix:string, callback:AsyncCallback<Entry[]>):void
187 * getEntries(deviceId:string, keyPrefix:string):Promise<Entry[]>
213 std::string deviceKey = GetDeviceKey(ctxt->va.deviceId, ctxt->va.keyPrefix); in GetEntries()
214 OHOS::DistributedKv::Key keyPrefix(deviceKey); in GetEntries()
215 status = kvStore->GetEntries(keyPrefix, ctx in GetEntries()
[all...]

Completed in 13 milliseconds

12345