Home
last modified time | relevance | path

Searched refs:collectionName (Results 1 - 25 of 35) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/document/
H A Dgrd_document_api_inner.cpp25 int32_t GRD_CreateCollectionInner(GRD_DB *db, const char *collectionName, const char *optionStr, uint32_t flags) in GRD_CreateCollectionInner() argument
31 std::string name = (collectionName == nullptr ? "" : collectionName); in GRD_CreateCollectionInner()
37 int32_t GRD_DropCollectionInner(GRD_DB *db, const char *collectionName, uint32_t flags) in GRD_DropCollectionInner() argument
43 std::string name = (collectionName == nullptr ? "" : collectionName); in GRD_DropCollectionInner()
48 int32_t GRD_UpdateDocInner(GRD_DB *db, const char *collectionName, const char *filter, const char *update, in GRD_UpdateDocInner() argument
51 if (db == nullptr || db->store_ == nullptr || collectionName == nullptr || filter == nullptr || update == nullptr) { in GRD_UpdateDocInner()
54 int ret = db->store_->UpdateDocument(collectionName, filter, update, flags); in GRD_UpdateDocInner()
61 int32_t GRD_UpsertDocInner(GRD_DB *db, const char *collectionName, cons argument
75 GRD_InsertDocInner(GRD_DB *db, const char *collectionName, const char *document, uint32_t flags) GRD_InsertDocInner() argument
84 GRD_DeleteDocInner(GRD_DB *db, const char *collectionName, const char *filter, uint32_t flags) GRD_DeleteDocInner() argument
101 GRD_FindDocInner(GRD_DB *db, const char *collectionName, Query query, uint32_t flags, GRD_ResultSet **resultSet) GRD_FindDocInner() argument
[all...]
H A Dgrd_document_api.cpp28 GRD_API int32_t GRD_CreateCollection(GRD_DB *db, const char *collectionName, const char *optionStr, uint32_t flags) in GRD_CreateCollection() argument
37 return GRD_DocApiInfo.CreateCollectionApi(db, collectionName, optionStr, flags); in GRD_CreateCollection()
40 GRD_API int32_t GRD_DropCollection(GRD_DB *db, const char *collectionName, uint32_t flags) in GRD_DropCollection() argument
49 return GRD_DocApiInfo.DropCollectionApi(db, collectionName, flags); in GRD_DropCollection()
52 GRD_API int32_t GRD_UpdateDoc(GRD_DB *db, const char *collectionName, const char *filter, const char *update, in GRD_UpdateDoc() argument
62 return GRD_DocApiInfo.UpdateDocApi(db, collectionName, filter, update, flags); in GRD_UpdateDoc()
65 GRD_API int32_t GRD_UpsertDoc(GRD_DB *db, const char *collectionName, const char *filter, const char *document, in GRD_UpsertDoc() argument
75 return GRD_DocApiInfo.UpsertDocApi(db, collectionName, filter, document, flags); in GRD_UpsertDoc()
78 GRD_API int32_t GRD_InsertDoc(GRD_DB *db, const char *collectionName, const char *document, uint32_t flags) in GRD_InsertDoc() argument
87 return GRD_DocApiInfo.InsertDocApi(db, collectionName, documen in GRD_InsertDoc()
90 GRD_DeleteDoc(GRD_DB *db, const char *collectionName, const char *filter, uint32_t flags) GRD_DeleteDoc() argument
102 GRD_FindDoc(GRD_DB *db, const char *collectionName, Query query, uint32_t flags, GRD_ResultSet **resultSet) GRD_FindDoc() argument
[all...]
H A Dcheck_common.cpp54 bool CheckCommon::CheckCollectionName(const std::string &collectionName, std::string &formattedName, int &errCode) in CheckCollectionName() argument
56 if (collectionName.empty()) { in CheckCollectionName()
60 if (collectionName.length() + 1 > MAX_COLLECTION_NAME) { // with '\0' in CheckCollectionName()
64 if (CheckCollectionNamePrefix(collectionName, COLLECTION_PREFIX_GRD) || in CheckCollectionName()
65 CheckCollectionNamePrefix(collectionName, COLLECTION_PREFIX_GM_SYS)) { in CheckCollectionName()
71 formattedName = collectionName; in CheckCollectionName()
H A Dcheck_common.h31 static bool CheckCollectionName(const std::string &collectionName, std::string &formattedName, int &errCode);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/common/include/
H A Dgrd_api_manager.h27 typedef int32_t (*IndexPreload)(GRD_DB *db, const char *collectionName);
28 typedef int32_t (*CreateCollection)(GRD_DB *db, const char *collectionName, const char *optionStr, uint32_t flags);
29 typedef int32_t (*DropCollection)(GRD_DB *db, const char *collectionName, uint32_t flags);
30 typedef int32_t (*InsertDoc)(GRD_DB *db, const char *collectionName, const char *document, uint32_t flags);
31 typedef int32_t (*FindDoc)(GRD_DB *db, const char *collectionName, Query query,
33 typedef int32_t (*UpdateDoc)(GRD_DB *db, const char *collectionName, const char *filter,
35 typedef int32_t (*UpsertDoc)(GRD_DB *db, const char *collectionName, const char *filter,
37 typedef int32_t (*DeleteDoc)(GRD_DB *db, const char *collectionName, const char *filter, uint32_t flags);
44 typedef int32_t (*KVPut)(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KVItemT *value);
45 typedef int32_t (*KVGet)(GRD_DB *db, const char *collectionName, cons
[all...]
H A Ddocument_type.h25 std::string collectionName; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/include/grd_document/
H A Dgrd_document_api.h28 GRD_API int32_t GRD_CreateCollection(GRD_DB *db, const char *collectionName, const char *optionStr, uint32_t flags);
30 GRD_API int32_t GRD_DropCollection(GRD_DB *db, const char *collectionName, uint32_t flags);
32 GRD_API int32_t GRD_InsertDoc(GRD_DB *db, const char *collectionName, const char *document, uint32_t flags);
34 GRD_API int32_t GRD_FindDoc(GRD_DB *db, const char *collectionName, Query query, uint32_t flags,
37 GRD_API int32_t GRD_UpdateDoc(GRD_DB *db, const char *collectionName, const char *filter, const char *update,
40 GRD_API int32_t GRD_UpsertDoc(GRD_DB *db, const char *collectionName, const char *filter, const char *document,
43 GRD_API int32_t GRD_DeleteDoc(GRD_DB *db, const char *collectionName, const char *filter, uint32_t flags);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/include/
H A Dgrd_document_api_inner.h25 int32_t GRD_CreateCollectionInner(GRD_DB *db, const char *collectionName, const char *optionStr, uint32_t flags);
27 int32_t GRD_DropCollectionInner(GRD_DB *db, const char *collectionName, uint32_t flags);
29 int32_t GRD_InsertDocInner(GRD_DB *db, const char *collectionName, const char *document, uint32_t flags);
31 int32_t GRD_FindDocInner(GRD_DB *db, const char *collectionName, Query query, uint32_t flags,
34 int32_t GRD_UpdateDocInner(GRD_DB *db, const char *collectionName, const char *filter, const char *update,
37 int32_t GRD_UpsertDocInner(GRD_DB *db, const char *collectionName, const char *filter, const char *document,
40 int32_t GRD_DeleteDocInner(GRD_DB *db, const char *collectionName, const char *filter, uint32_t flags);
H A Dgrd_kv_api_inner.h25 int32_t GRD_KVPutInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KVItemT *value);
27 int32_t GRD_KVGetInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KVItemT *value);
29 int32_t GRD_KVDelInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key);
31 int32_t GRD_KVScanInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, GRD_KvScanModeE mode,
34 int32_t GRD_KVFilterInner(GRD_DB *db, const char *collectionName, const GRD_FilterOptionT *scanParams,
48 int32_t GRD_KVBatchPutInner(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
50 int32_t GRD_KVBatchDelInner(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
H A Dgrd_db_api_inner.h25 int32_t GRD_IndexPreloadInner(GRD_DB *db, const char *collectionName);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Dkv_delegate.cpp130 int64_t KvDelegate::Upsert(const std::string &collectionName, const std::string &filter, const std::string &value) in Upsert() argument
134 ZLOGE("init failed, %{public}s", collectionName.c_str()); in Upsert()
137 int count = GRD_UpsertDoc(db_, collectionName.c_str(), filter.c_str(), value.c_str(), 0); in Upsert()
147 int32_t KvDelegate::Delete(const std::string &collectionName, const std::string &filter) in Delete() argument
151 ZLOGE("init failed, %{public}s", collectionName.c_str()); in Delete()
156 int32_t status = GetBatch(collectionName, filter, "{\"id_\": true}", queryResults); in Delete()
163 auto count = GRD_DeleteDoc(db_, collectionName.c_str(), result.c_str(), 0); in Delete()
174 ZLOGI("Delete, %{public}s, count %{public}zu", collectionName.c_str(), queryResults.size()); in Delete()
234 int32_t KvDelegate::Upsert(const std::string &collectionName, const KvData &value) in Upsert() argument
239 if (GetVersion(collectionName, i in Upsert()
250 Get(const std::string &collectionName, const Id &id, std::string &value) Get() argument
260 GetVersion(const std::string &collectionName, const std::string &filter, int &version) GetVersion() argument
276 Get( const std::string &collectionName, const std::string &filter, const std::string &projection, std::string &result) Get() argument
324 GetBatch(const std::string &collectionName, const std::string &filter, const std::string &projection, std::vector<std::string> &result) GetBatch() argument
[all...]
H A Dkv_delegate.h31 int32_t Upsert(const std::string &collectionName, const KvData &value) override;
32 int32_t Delete(const std::string &collectionName, const std::string &filter) override;
33 int32_t Get(const std::string &collectionName, const Id &id, std::string &value) override;
35 int32_t Get(const std::string &collectionName, const std::string &filter, const std::string &projection,
37 int32_t GetBatch(const std::string &collectionName, const std::string &filter, const std::string &projection,
43 bool GetVersion(const std::string &collectionName, const std::string &filter, int &version);
44 int64_t Upsert(const std::string &collectionName, const std::string &filter, const std::string &value);
H A Ddb_delegate.h121 virtual int32_t Upsert(const std::string &collectionName, const KvData &value) = 0;
122 virtual int32_t Delete(const std::string &collectionName, const std::string &filter) = 0;
123 virtual int32_t Get(const std::string &collectionName, const Id &id, std::string &value) = 0;
124 virtual int32_t Get(const std::string &collectionName, const std::string &filter, const std::string &projection,
126 virtual int32_t GetBatch(const std::string &collectionName, const std::string &filter,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/kv/
H A Dgrd_kv_api.cpp26 GRD_API int32_t GRD_KVPut(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KVItemT *value) in GRD_KVPut() argument
34 return GRD_KVApiInfo.KVPutApi(db, collectionName, key, value); in GRD_KVPut()
37 GRD_API int32_t GRD_KVGet(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KVItemT *value) in GRD_KVGet() argument
45 return GRD_KVApiInfo.KVGetApi(db, collectionName, key, value); in GRD_KVGet()
48 GRD_API int32_t GRD_KVDel(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key) in GRD_KVDel() argument
56 return GRD_KVApiInfo.KVDelApi(db, collectionName, key); in GRD_KVDel()
59 GRD_API int32_t GRD_KVScan(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, GRD_KvScanModeE mode, in GRD_KVScan() argument
68 return GRD_KVApiInfo.KVScanApi(db, collectionName, key, mode, resultSet); in GRD_KVScan()
71 GRD_API int32_t GRD_KVFilter(GRD_DB *db, const char *collectionName, const GRD_FilterOptionT *scanParams, in GRD_KVFilter() argument
80 return GRD_KVApiInfo.KVFilterApi(db, collectionName, scanParam in GRD_KVFilter()
139 GRD_KVBatchPut(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) GRD_KVBatchPut() argument
150 GRD_KVBatchDel(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) GRD_KVBatchDel() argument
[all...]
H A Dgrd_kv_api_inner.cpp23 int32_t GRD_KVPutInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KVItemT *value) in GRD_KVPutInner() argument
28 int32_t GRD_KVGetInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KVItemT *value) in GRD_KVGetInner() argument
33 int32_t GRD_KVDelInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key) in GRD_KVDelInner() argument
38 int32_t GRD_KVScanInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, GRD_KvScanModeE mode, in GRD_KVScanInner() argument
44 int32_t GRD_KVFilterInner(GRD_DB *db, const char *collectionName, const GRD_FilterOptionT *scanParams, in GRD_KVFilterInner() argument
76 int32_t GRD_KVBatchPutInner(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) in GRD_KVBatchPutInner() argument
81 int32_t GRD_KVBatchDelInner(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) in GRD_KVBatchDelInner() argument
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/test/unittest/api/
H A Ddocumentdb_insert_test.cpp35 static void TestInsertDocIntoCertainColl(const char *collectionName, const char *projection, int expectedResult) in TestInsertDocIntoCertainColl() argument
41 EXPECT_EQ(GRD_CreateCollection(g_db, collectionName, "", 0), expectedResult); in TestInsertDocIntoCertainColl()
46 EXPECT_EQ(GRD_InsertDoc(g_db, collectionName, projection, 0), expectedResult); in TestInsertDocIntoCertainColl()
51 EXPECT_EQ(GRD_DropCollection(g_db, collectionName, 0), expectedResult); in TestInsertDocIntoCertainColl()
181 * @tc.desc: Test insert with null parameter. parameter collectionName is NULL.
189 * @tc.steps:step1.Parameter collectionName is NULL in HWTEST_F()
195 * @tc.steps:step2.Parameter collectionName is empty string in HWTEST_F()
255 * @tc.desc: parameter collectionName and document is NULL or invalid
263 * @tc.steps:step1.parameter collectionName and document is NULL; in HWTEST_F()
268 * @tc.steps:step2.parameter collectionName i in HWTEST_F()
289 const char *collectionName = "collction@!#"; HWTEST_F() local
453 string collectionName = string(256, 'k'); HWTEST_F() local
474 string collectionName = "Aads_sd__23Asb_"; HWTEST_F() local
493 string collectionName = "GRD_collectionName"; HWTEST_F() local
[all...]
H A Ddocumentdb_delete_test.cpp42 void InsertDoc(const char *collectionName, const char *document);
125 void DocumentDBDeleteTest::InsertDoc(const char *collectionName, const char *document) in InsertDoc() argument
127 EXPECT_EQ(GRD_InsertDoc(g_db, collectionName, document, 0), GRD_OK); in InsertDoc()
261 * @tc.desc: Test delete with too long collectionName.
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_utils.h42 int RdKVPut(GRD_DB *db, const char *collectionName, const Key &key, const Value &value);
44 int RdKVGet(GRD_DB *db, const char *collectionName, const Key &key, Value &value);
51 int RdKVDel(GRD_DB *db, const char *collectionName, const Key &key);
53 int RdKVScan(GRD_DB *db, const char *collectionName, const Key &key, GRD_KvScanModeE mode,
56 int RdKVRangeScan(GRD_DB *db, const char *collectionName, const Key &beginKey, const Key &endKey,
80 int RdIndexPreload(GRD_DB *&db, const char *collectionName);
82 int RdCreateCollection(GRD_DB *db, const char *collectionName, const char *optionStr, uint32_t flags);
H A Drd_utils.cpp118 int RdKVPut(GRD_DB *db, const char *collectionName, const Key &key, const Value &value) in RdKVPut() argument
126 int ret = TransferGrdErrno(GRD_KVPut(db, collectionName, &innerKey, &innerVal)); in RdKVPut()
133 int RdKVGet(GRD_DB *db, const char *collectionName, const Key &key, Value &value) in RdKVGet() argument
141 int ret = TransferGrdErrno(GRD_KVGet(db, collectionName, &innerKey, &innerVal)); in RdKVGet()
161 int RdKVDel(GRD_DB *db, const char *collectionName, const Key &key) in RdKVDel() argument
168 int ret = TransferGrdErrno(GRD_KVDel(db, collectionName, &innerKey)); in RdKVDel()
175 int RdKVScan(GRD_DB *db, const char *collectionName, const Key &key, GRD_KvScanModeE mode, in RdKVScan() argument
183 return TransferGrdErrno(GRD_KVScan(db, collectionName, NULL, mode, resultSet)); in RdKVScan()
186 return TransferGrdErrno(GRD_KVScan(db, collectionName, &innerKey, mode, resultSet)); in RdKVScan()
189 int RdKVRangeScan(GRD_DB *db, const char *collectionName, cons argument
285 RdIndexPreload(GRD_DB *&db, const char *collectionName) RdIndexPreload() argument
294 RdCreateCollection(GRD_DB *db, const char *collectionName, const char *optionStr, uint32_t flags) RdCreateCollection() argument
[all...]
H A Drd_single_ver_storage_engine.h55 int IndexPreLoad(GRD_DB *&db, const char *collectionName);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/include/grd_kv/
H A Dgrd_kv_api.h27 GRD_API int32_t GRD_KVPut(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KVItemT *value);
29 GRD_API int32_t GRD_KVGet(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KVItemT *value);
31 GRD_API int32_t GRD_KVDel(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key);
33 GRD_API int32_t GRD_KVScan(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, GRD_KvScanModeE mode,
36 GRD_API int32_t GRD_KVFilter(GRD_DB *db, const char *collectionName, const GRD_FilterOptionT *scanParams,
50 GRD_API int32_t GRD_KVBatchPut(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
52 GRD_API int32_t GRD_KVBatchDel(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/interface/src/
H A Ddocument_store.cpp222 auto coll = Collection(context->collectionName, executor_); in UpdateDataIntoDB()
278 context->collectionName = collection; in UpdateDocument()
393 Collection coll = Collection(context->collectionName, executor_); in UpsertDataIntoDB()
476 context->collectionName = collection; in UpsertDocument()
568 Collection coll = Collection(context->collectionName, executor_); in DeleteDataFromDB()
615 context->collectionName = collection; in DeleteDocument()
618 Collection DocumentStore::GetCollection(std::string &collectionName) in GetCollection() argument
620 return Collection(collectionName, executor_); in GetCollection()
770 Collection coll = Collection(context->collectionName, executor_); in InitFindResultSet()
771 if (IsExistResultSet(context->collectionName)) { in InitFindResultSet()
846 EraseCollection(const std::string &collectionName) EraseCollection() argument
898 IsCollectionExists(const std::string &collectionName, int &errCode) IsCollectionExists() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/interface/include/
H A Ddocument_store.h51 Collection GetCollection(std::string &collectionName);
55 int EraseCollection(const std::string &collectionName);
65 bool IsCollectionExists(const std::string &collectionName, int &errCode);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/base/
H A Dgrd_db_api.cpp92 GRD_API int32_t GRD_IndexPreload(GRD_DB *db, const char *collectionName) in GRD_IndexPreload() argument
101 return GRD_DBApiInfo.IndexPreloadApi(db, collectionName); in GRD_IndexPreload()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/include/grd_base/
H A Dgrd_db_api.h34 GRD_API int32_t GRD_IndexPreload(GRD_DB *db, const char *collectionName);

Completed in 10 milliseconds

12