/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/test/unittest/api/ |
H A D | documentdb_api_test.cpp | 61 GRD_DB *db = nullptr; variable 90 GRD_DB *db = nullptr; variable 108 GRD_DB *db = nullptr; variable 140 GRD_DB *db = nullptr; variable 156 GRD_DB *db = nullptr; variable 174 GRD_DB *db = nullptr; variable 189 GRD_DB *db = nullptr; variable 206 GRD_DB *db = nullptr; variable 221 GRD_DB *db = nullptr; variable 240 GRD_DB *db = nullptr; variable [all …]
|
/ohos5.0/base/security/asset/services/db_operator/src/test/ |
H A D | test_database.rs | 65 let mut db = in open_db_and_insert_data() localVariable 89 let mut db = in create_and_drop_database() localVariable 124 let mut db = in create_delete_asset_table() localVariable 142 let mut db = in insert_data_with_different_alias() localVariable 166 let mut db = open_db_and_insert_data(); in delete_data() localVariable 186 let mut db = open_db_and_insert_data(); in update_data() localVariable 216 let mut db = in query_ordered_data() localVariable 253 let mut db = in insert_error_data() localVariable 262 let db = open_db_and_insert_data(); in backup_and_restore() localVariable 273 let mut db = in backup_and_restore() localVariable [all …]
|
H A D | test_table.rs | 36 let mut db = in create_delete_table() localVariable 52 let mut db = in table_restore() localVariable 86 …let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owne… in insert_test_data() localVariable 118 let db = insert_test_data(); in execute_sql() localVariable 134 let db = insert_test_data(); in data_life_circle() localVariable 156 …let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owne… in single_data() localVariable 189 …let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owne… in multiple_data() localVariable 231 …let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owne… in insert_query_row() localVariable 261 …let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owne… in update_delete_row() localVariable 289 …let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owne… in upgrade_table() localVariable [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/native/dbm_kv_store/src/kv_store_impl_posix/ |
H A D | dbm_kv_store.c | 25 int DBM_GetKVStore(const char* storeFullPath, KVStoreHandle* db) in DBM_GetKVStore() 30 int DBM_Get(KVStoreHandle db, const char* key, void* value, unsigned int count, unsigned int* realV… in DBM_Get() 34 int DBM_Put(KVStoreHandle db, const char* key, const void* value, unsigned int len) in DBM_Put() 38 int DBM_Delete(KVStoreHandle db, const char* key) in DBM_Delete() 43 int DBM_CloseKVStore(KVStoreHandle db) in DBM_CloseKVStore() 52 void DBM_KVStoreControl(KVStoreHandle db, int cmd, void* arg) in DBM_KVStoreControl()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/document/ |
H A D | grd_document_api.cpp | 28 GRD_API int32_t GRD_CreateCollection(GRD_DB *db, const char *collectionName, const char *optionStr,… in GRD_CreateCollection() 40 GRD_API int32_t GRD_DropCollection(GRD_DB *db, const char *collectionName, uint32_t flags) in GRD_DropCollection() 52 GRD_API int32_t GRD_UpdateDoc(GRD_DB *db, const char *collectionName, const char *filter, const cha… in GRD_UpdateDoc() 65 GRD_API int32_t GRD_UpsertDoc(GRD_DB *db, const char *collectionName, const char *filter, const cha… in GRD_UpsertDoc() 78 GRD_API int32_t GRD_InsertDoc(GRD_DB *db, const char *collectionName, const char *document, uint32_… in GRD_InsertDoc() 90 GRD_API int32_t GRD_DeleteDoc(GRD_DB *db, const char *collectionName, const char *filter, uint32_t … in GRD_DeleteDoc() 102 GRD_API int32_t GRD_FindDoc(GRD_DB *db, const char *collectionName, Query query, uint32_t flags, in GRD_FindDoc()
|
H A D | grd_document_api_inner.cpp | 25 int32_t GRD_CreateCollectionInner(GRD_DB *db, const char *collectionName, const char *optionStr, ui… in GRD_CreateCollectionInner() 37 int32_t GRD_DropCollectionInner(GRD_DB *db, const char *collectionName, uint32_t flags) in GRD_DropCollectionInner() 48 int32_t GRD_UpdateDocInner(GRD_DB *db, const char *collectionName, const char *filter, const char *… in GRD_UpdateDocInner() 61 int32_t GRD_UpsertDocInner(GRD_DB *db, const char *collectionName, const char *filter, const char *… in GRD_UpsertDocInner() 75 int32_t GRD_InsertDocInner(GRD_DB *db, const char *collectionName, const char *document, uint32_t f… in GRD_InsertDocInner() 84 int32_t GRD_DeleteDocInner(GRD_DB *db, const char *collectionName, const char *filter, uint32_t fla… in GRD_DeleteDocInner() 101 int32_t GRD_FindDocInner(GRD_DB *db, const char *collectionName, Query query, uint32_t flags, GRD_R… in GRD_FindDocInner()
|
/ohos5.0/foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/ |
H A D | mock.cpp | 69 __attribute__((visibility("default"))) DBStatus UnRegisterClientObserver(sqlite3 *db) in UnRegisterClientObserver() 74 __attribute__((visibility("default"))) DBStatus RegisterStoreObserver(sqlite3 *db, in RegisterStoreObserver() 80 __attribute__((visibility("default"))) DBStatus UnregisterStoreObserver(sqlite3 *db, in UnregisterStoreObserver() 86 __attribute__((visibility("default"))) DBStatus UnregisterStoreObserver(sqlite3 *db) in UnregisterStoreObserver() 92 const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db) in Lock() 98 const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db) in UnLock() 103 __attribute__((visibility("default"))) DBStatus DropLogicDeletedData(sqlite3 *db, const std::string… in DropLogicDeletedData()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/base/ |
H A D | grd_db_api.cpp | 28 GRD_API int32_t GRD_DBOpen(const char *dbPath, const char *configStr, uint32_t flags, GRD_DB **db) in GRD_DBOpen() 41 GRD_API int32_t GRD_DBClose(GRD_DB *db, uint32_t flags) in GRD_DBClose() 53 GRD_API int32_t GRD_DBBackup(GRD_DB *db, const char *backupDbFile, uint8_t *encryptedKey, uint32_t … in GRD_DBBackup() 78 GRD_API int32_t GRD_Flush(GRD_DB *db, uint32_t flags) in GRD_Flush() 90 GRD_API int32_t GRD_IndexPreload(GRD_DB *db, const char *collectionName) in GRD_IndexPreload()
|
H A D | grd_db_api_inner.cpp | 25 int32_t GRD_DBOpenInner(const char *dbPath, const char *configStr, uint32_t flags, GRD_DB **db) in GRD_DBOpenInner() 49 int32_t GRD_DBCloseInner(GRD_DB *db, uint32_t flags) in GRD_DBCloseInner() 65 int32_t GRD_FlushInner(GRD_DB *db, uint32_t flags) in GRD_FlushInner() 76 int32_t GRD_IndexPreloadInner(GRD_DB *db, const char *collectionName) in GRD_IndexPreloadInner()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/native/dbm_kv_store/src/kv_store_impl_hal/ |
H A D | dbm_kv_store.c | 153 static void ReleaseKVDBHandle(DBHandle db) in ReleaseKVDBHandle() 168 DBHandle db = (DBHandle)malloc(sizeof(DBM)); in GetKVDBHandle() local 484 static int VacuumStore(DBHandle db) in VacuumStore() 559 static int SetSumIndex(DBHandle db) in SetSumIndex() 567 static int CheckPoint(DBHandle db) in CheckPoint() 601 static int LoadSumFileHeader(DBHandle db) in LoadSumFileHeader() 630 static int InitKVStore(DBHandle db) in InitKVStore() 688 DBHandle db = GetKVDBHandle(storeFullPath); in DBM_GetKVStore() local 1262 static int CloseKVStore(KVStoreHandle db) in CloseKVStore() 1281 int DBM_CloseKVStore(KVStoreHandle db) in DBM_CloseKVStore() [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
H A D | distributeddb_interfaces_relational_test.cpp | 118 sqlite3 *db = RelationalTestUtils::CreateDataBase(dbPath); in PrepareVirtualDeviceEnv() local 190 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); in NoramlCreateDistributedTableTest() local 279 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); variable 331 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); variable 355 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); in CreateDistributedTableOverLimitTest() local 421 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); in CreateDistributedTableInvalidArgsTest() local 498 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); in CreateDistributedTableNonPrimaryKeyTest() local 565 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); in CreateDistributedTableInvalidFieldTest() local 607 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); in CreateDistributedTableCompositePKTest() local 649 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); in CreateDistributedTableWithHistoryDataTest() local [all …]
|
H A D | distributeddb_cloud_interfaces_relational_ext_test.cpp | 189 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); variable 209 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); in PrepareData() local 257 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); in InsertTriggerTest() local 344 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); variable 397 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); in UpdateTriggerTest() local 495 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); variable 565 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); variable 598 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_dbDir + STORE_ID + DB_SUFFIX); variable 979 void InitLogicDeleteData(sqlite3 *&db, const std::string &tableName, uint64_t num) in InitLogicDeleteData() 1291 void InitDataStatus(const std::string &tableName, int count, sqlite3 *db) in InitDataStatus() [all …]
|
H A D | distributeddb_cloud_interfaces_reference_test.cpp | 62 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_storePath); in SetUp() local 311 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_storePath); variable 341 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_storePath); variable 378 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_storePath); variable 400 void CheckResult(sqlite3 *db) in CheckResult() 432 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_storePath); in NormalSetReferenceTest() local 509 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_storePath); in ReferenceChangeTest() local 604 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_storePath); variable 680 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_storePath); variable 766 sqlite3 *db = RelationalTestUtils::CreateDataBase(g_storePath); variable [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/kv/ |
H A D | grd_kv_api.cpp | 26 GRD_API int32_t GRD_KVPut(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD… in GRD_KVPut() 37 GRD_API int32_t GRD_KVGet(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD… in GRD_KVGet() 48 GRD_API int32_t GRD_KVDel(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key) in GRD_KVDel() 59 GRD_API int32_t GRD_KVScan(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, GRD_KvSc… in GRD_KVScan() 71 GRD_API int32_t GRD_KVFilter(GRD_DB *db, const char *collectionName, const GRD_FilterOptionT *scanP… in GRD_KVFilter() 139 GRD_API int32_t GRD_KVBatchPut(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) in GRD_KVBatchPut() 150 GRD_API int32_t GRD_KVBatchDel(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) in GRD_KVBatchDel()
|
H A D | grd_kv_api_inner.cpp | 23 int32_t GRD_KVPutInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KV… in GRD_KVPutInner() 28 int32_t GRD_KVGetInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, const GRD_KV… in GRD_KVGetInner() 33 int32_t GRD_KVDelInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key) in GRD_KVDelInner() 38 int32_t GRD_KVScanInner(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key, GRD_KvScanM… in GRD_KVScanInner() 44 int32_t GRD_KVFilterInner(GRD_DB *db, const char *collectionName, const GRD_FilterOptionT *scanPara… in GRD_KVFilterInner() 76 int32_t GRD_KVBatchPutInner(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) in GRD_KVBatchPutInner() 81 int32_t GRD_KVBatchDelInner(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch) in GRD_KVBatchDelInner()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_relational_remote_query_test.cpp | 52 sqlite3 *db = nullptr; in CreateDBAndTable() local 97 int ExecSql(sqlite3 *db, const std::string &sql) in ExecSql() 102 int InsertData(sqlite3 *db, size_t byteSize) in InsertData() 184 sqlite3 *db = nullptr; variable 243 sqlite3 *db = nullptr; variable 310 sqlite3 *db = nullptr; variable 357 sqlite3 *db = nullptr; variable 490 sqlite3 *db = nullptr; variable 531 sqlite3 *db = nullptr; variable 584 sqlite3 *db = nullptr; variable
|
H A D | distributeddb_relational_encrypted_db_test.cpp | 85 void ExecSqlAndAssertOK(sqlite3 *db, const std::string &sql) in ExecSqlAndAssertOK() 159 sqlite3 *db = nullptr; variable 193 sqlite3 *db = nullptr; variable 227 sqlite3 *db = nullptr; variable 285 sqlite3 *db = nullptr; variable 329 sqlite3 *db = nullptr; variable 387 sqlite3 *db = nullptr; variable 463 sqlite3 *db = nullptr; variable 523 sqlite3 *db = nullptr; variable
|
H A D | distributeddb_relational_get_data_test.cpp | 55 sqlite3 *db = nullptr; in CreateDBAndTable() local 77 sqlite3 *db = nullptr; in AddOrUpdateRecord() local 97 sqlite3 *db = nullptr; in GetLogData() local 194 sqlite3 *db = nullptr; in PutBatchData() local 469 sqlite3 *db = nullptr; variable 669 sqlite3 *db = nullptr; variable 760 sqlite3 *db = nullptr; variable 845 sqlite3 *db = nullptr; variable 911 sqlite3 *db = nullptr; variable 1018 sqlite3 *db = nullptr; variable [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
H A D | rd_utils.cpp | 118 int RdKVPut(GRD_DB *db, const char *collectionName, const Key &key, const Value &value) in RdKVPut() 133 int RdKVGet(GRD_DB *db, const char *collectionName, const Key &key, Value &value) in RdKVGet() 161 int RdKVDel(GRD_DB *db, const char *collectionName, const Key &key) in RdKVDel() 175 int RdKVScan(GRD_DB *db, const char *collectionName, const Key &key, GRD_KvScanModeE mode, in RdKVScan() 189 int RdKVRangeScan(GRD_DB *db, const char *collectionName, const Key &beginKey, const Key &endKey, in RdKVRangeScan() 216 int RdDBClose(GRD_DB *db, uint32_t flags) in RdDBClose() 247 int RdKVBatchPut(GRD_DB *db, const char *kvTableName, GRD_KVBatchT *batch) in RdKVBatchPut() 256 int RdFlush(GRD_DB *db, uint32_t flags) in RdFlush() 266 int RdKVBatchDel(GRD_DB *db, const char *kvTableName, GRD_KVBatchT *batch) in RdKVBatchDel() 280 int RdDbOpen(const char *dbPath, const char *configStr, uint32_t flags, GRD_DB *&db) in RdDbOpen() [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
H A D | native_sqlite.cpp | 22 sqlite3 *db = nullptr; in CreateDataBase() local 34 int NativeSqlite::ExecSql(sqlite3 *db, const std::string &sql) in ExecSql() 48 int NativeSqlite::ExecSql(sqlite3 *db, const std::string &sql, const std::function<int (sqlite3_stm… in ExecSql()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_utils.cpp | 425 int SQLiteUtils::CommitTransaction(sqlite3 *db) in CommitTransaction() 430 int SQLiteUtils::RollbackTransaction(sqlite3 *db) in RollbackTransaction() 640 sqlite3 *db = nullptr; in CreateMetaDatabase() local 1098 sqlite3 *db = nullptr; in SetUserVer() local 1183 sqlite3 *db = nullptr; in ExportDatabase() local 1391 int SQLiteUtils::RegisterCalcHash(sqlite3 *db) in RegisterCalcHash() 1489 int SQLiteUtils::RegisterGetSysTime(sqlite3 *db) in RegisterGetSysTime() 2221 void SQLiteUtils::ExecuteCheckPoint(sqlite3 *db) in ExecuteCheckPoint() 2254 int SQLiteUtils::SetPersistWalMode(sqlite3 *db) in SetPersistWalMode() 2267 int64_t SQLiteUtils::GetLastRowId(sqlite3 *db) in GetLastRowId() [all …]
|
H A D | sqlite_log_table_manager.cpp | 19 int SqliteLogTableManager::AddRelationalLogTableTrigger(sqlite3 *db, const TableInfo &table, in AddRelationalLogTableTrigger() 46 int SqliteLogTableManager::CreateRelationalLogTable(sqlite3 *db, const TableInfo &table) in CreateRelationalLogTable() 80 int SqliteLogTableManager::CreateKvSyncLogTable(sqlite3 *db) in CreateKvSyncLogTable() 122 int SqliteLogTableManager::UpgradeKvSyncLogTable(const std::string &tableName, sqlite3 *db) in UpgradeKvSyncLogTable() 142 int SqliteLogTableManager::CreateKvCloudFlagIndex(const std::string &tableName, sqlite3 *db) in CreateKvCloudFlagIndex()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/ |
H A D | rd_sqlite_utils.cpp | 59 int RDSQLiteUtils::CreateDataBase(const std::string &path, int flag, sqlite3 *&db) in CreateDataBase() 86 int RDSQLiteUtils::GetStatement(sqlite3 *db, const std::string &sql, sqlite3_stmt *&statement) in GetStatement() 207 int RDSQLiteUtils::BeginTransaction(sqlite3 *db, TransactType type) in BeginTransaction() 216 int RDSQLiteUtils::CommitTransaction(sqlite3 *db) in CommitTransaction() 221 int RDSQLiteUtils::RollbackTransaction(sqlite3 *db) in RollbackTransaction() 226 int RDSQLiteUtils::ExecSql(sqlite3 *db, const std::string &sql) in ExecSql() 242 int RDSQLiteUtils::ExecSql(sqlite3 *db, const std::string &sql, const std::function<int(sqlite3_stm… in ExecSql()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/ |
H A D | distributed_rdb_tools.cpp | 123 bool DistributedRdbTools::InitSqlite3Store(sqlite3 *&db, const RdbParameters ¶m) in InitSqlite3Store() 141 void SqliteExecSql(sqlite3 *db, const char *sql) in SqliteExecSql() 154 bool DistributedRdbTools::InitTableDataAndTrigger(const sqlite3 *&db) in InitTableDataAndTrigger() 178 bool DistributedRdbTools::AlterTableAttributes(const sqlite3 *&db) in AlterTableAttributes() 224 bool DistributedRdbTools::Sqlite3ExecOpration(const sqlite3 *&db, cont char *&sql_name) in Sqlite3ExecOpration() 238 void DistributedRdbTools::CloseSqlite3Store(sqlite3 *&db) in CloseSqlite3Store()
|
/ohos5.0/base/security/asset/services/db_operator/src/ |
H A D | sqlite3_wrapper.c | 26 int SqliteCloseV2(void *db) in SqliteCloseV2() 31 int SqliteExec(void *db, const char *zSql, char **pzErrMsg) in SqliteExec() 46 int SqliteChanges(void *db) in SqliteChanges() 51 int SqlitePrepareV2(void *db, const char *zSql, void **ppStmt, const char **pzTail) in SqlitePrepareV2() 66 const char *SqliteErrMsg(void *db) in SqliteErrMsg() 116 int SqliteKey(void *db, const void *pKey, int nKey) in SqliteKey()
|