Home
last modified time | relevance | path

Searched refs:db (Results 1 – 25 of 355) sorted by relevance

12345678910>>...15

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/native/dbm_kv_store/src/kv_store_impl_hal/
H A Ddbm_kv_store.c67 if (((DBHandle)(db))->lock != NULL) ((DBHandle)(db))->lock((DBHandle)(db)); \
72 if (((DBHandle)(db))->unlock != NULL) ((DBHandle)(db))->unlock((DBHandle)(db)); \
163 free(db); in ReleaseKVDBHandle()
198 return db; in GetKVDBHandle()
265 if (!db) { in GetSumFilePath()
564 return SetSumIndexToFile(db, db->kvItemSum); in SetSumIndex()
632 db->sumFileFd = OpenSumFile(db, O_RDWR_FS | O_CREAT_FS); in InitKVStore()
1268 int ret = SetSumIndexToFile(db, db->kvItemSum); in CloseKVStore()
1367 db->sumFileFd = OpenSumFile(db, O_RDWR_FS); in DBM_DeleteKVStore()
1402 db->lock = (void (*)(KVStoreHandle db))arg; in DBM_KVStoreControl()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/test/unittest/api/
H A Ddocumentdb_api_test.cpp72 db = nullptr;
363 db = nullptr;
496 db = nullptr;
658 db = nullptr;
665 db = nullptr;
672 db = nullptr;
679 db = nullptr;
699 db = nullptr;
719 db = nullptr;
741 db = nullptr;
[all …]
/ohos5.0/base/request/request/services/src/manage/scheduler/state/
H A Dsql.rs342 db.execute(&format!( in network()
351 db.execute(&format!( in network()
360 db.execute(&format!( in network()
369 db.execute(&format!( in network()
378 db.execute(&format!( in network()
388 db.execute(&format!( in network()
399 db.execute(&format!( in network()
410 db.execute(&format!( in network()
421 db.execute(&format!( in network()
432 db.execute(&format!( in network()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_relational_ext_test.cpp190 EXPECT_NE(db, nullptr);
210 EXPECT_NE(db, nullptr); in PrepareData()
258 EXPECT_NE(db, nullptr); in InsertTriggerTest()
345 EXPECT_NE(db, nullptr);
398 EXPECT_NE(db, nullptr); in UpdateTriggerTest()
496 EXPECT_NE(db, nullptr);
566 EXPECT_NE(db, nullptr);
599 EXPECT_NE(db, nullptr);
714 EXPECT_NE(db, nullptr);
777 EXPECT_NE(db, nullptr);
[all …]
H A Ddistributeddb_interfaces_relational_test.cpp119 ASSERT_NE(db, nullptr); in PrepareVirtualDeviceEnv()
191 ASSERT_NE(db, nullptr); in NoramlCreateDistributedTableTest()
226 ASSERT_NE(db, nullptr); in NoramlCreateDistributedTableTest()
280 ASSERT_NE(db, nullptr);
332 ASSERT_NE(db, nullptr);
356 ASSERT_NE(db, nullptr); in CreateDistributedTableOverLimitTest()
422 ASSERT_NE(db, nullptr); in CreateDistributedTableInvalidArgsTest()
499 ASSERT_NE(db, nullptr); in CreateDistributedTableNonPrimaryKeyTest()
566 ASSERT_NE(db, nullptr); in CreateDistributedTableInvalidFieldTest()
608 ASSERT_NE(db, nullptr); in CreateDistributedTableCompositePKTest()
[all …]
H A Ddistributeddb_cloud_interfaces_relational_remove_device_data_test.cpp133 void CreateUserDBAndTable(sqlite3 *&db) in CreateUserDBAndTable() argument
565 sqlite3 *db = nullptr; member in __anonca7e63500110::DistributedDBCloudInterfacesRelationalRemoveDeviceDataTest
587 ASSERT_NE(db, nullptr); in SetUp()
588 CreateUserDBAndTable(db); in SetUp()
651 CheckCleanLogNum(db, g_tables, 0);
743 CheckCleanLogNum(db, g_tables, 20);
1174 UpdateUserTableRecord(db, 5, 10);
1175 DeleteUserTableRecord(db, 10, 15);
1226 UpdateUserTableRecord(db, 5, 10);
1227 DeleteUserTableRecord(db, 10, 15);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_utils.h85 static int CommitTransaction(sqlite3 *db);
87 static int RollbackTransaction(sqlite3 *db);
113 static int SetUserVer(sqlite3 *db, int version);
129 static int RegisterJsonFunctions(sqlite3 *db);
147 static int RegisterCalcHash(sqlite3 *db);
149 static int RegisterGetSysTime(sqlite3 *db);
151 static int RegisterGetLastTime(sqlite3 *db);
153 static int RegisterGetRawSysTime(sqlite3 *db);
177 static void ExecuteCheckPoint(sqlite3 *db);
181 static int SetPersistWalMode(sqlite3 *db);
[all …]
H A Dsqlite_utils.cpp234 db = dbTemp; in OpenDatabase()
240 if (db == nullptr) { in GetStatement()
437 if (db == nullptr) { in ExecuteRawSQL()
466 if (db == nullptr) { in SetKey()
647 db = nullptr; in CreateMetaDatabase()
913 if (db == nullptr) { in AnalysisSchema()
948 if (db == nullptr) { in ExportDatabase()
990 (void)db; in ExportDatabase()
999 (void)db; in Rekey()
1114 db = nullptr; in SetUserVer()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/document/
H A Dgrd_document_api_inner.cpp27 if (db == nullptr || db->store_ == nullptr) { in GRD_CreateCollectionInner()
33 int ret = db->store_->CreateCollection(name, option, flags); in GRD_CreateCollectionInner()
39 if (db == nullptr || db->store_ == nullptr) { in GRD_DropCollectionInner()
44 int ret = db->store_->DropCollection(name, flags); in GRD_DropCollectionInner()
51 …if (db == nullptr || db->store_ == nullptr || collectionName == nullptr || filter == nullptr || up… in GRD_UpdateDocInner()
64 if (db == nullptr || db->store_ == nullptr || collectionName == nullptr || filter == nullptr || in GRD_UpsertDocInner()
77 … if (db == nullptr || db->store_ == nullptr || collectionName == nullptr || document == nullptr) { in GRD_InsertDocInner()
80 int ret = db->store_->InsertDocument(collectionName, document, flags); in GRD_InsertDocInner()
86 if (db == nullptr || db->store_ == nullptr || filter == nullptr || collectionName == nullptr) { in GRD_DeleteDocInner()
89 int ret = db->store_->DeleteDocument(collectionName, filter, flags); in GRD_DeleteDocInner()
[all …]
/ohos5.0/base/security/asset/services/db_operator/src/test/
H A Dtest_database.rs65 let mut db = in open_db_and_insert_data() localVariable
70 db in open_db_and_insert_data()
82 fs::copy(&db.path, &db.backup_path).unwrap(); in backup_db()
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
152 let ret = db in insert_data_with_different_alias()
264 drop(db); in backup_and_restore()
280 drop(db); in backup_and_restore()
292 drop(db); in insert_duplicated_data()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_data_operation_test.cpp718 sqlite3_close_v2(db);
719 db = nullptr;
728 sqlite3_close_v2(db);
756 sqlite3_close_v2(db);
757 db = nullptr;
804 db = nullptr;
847 db = nullptr;
855 db = nullptr;
903 db = nullptr;
938 db = nullptr;
[all …]
H A Ddistributeddb_storage_single_ver_upgrade_test.cpp354 sqlite3 *db = nullptr; variable
367 CheckVersionV3(db);
399 sqlite3 *db = nullptr; variable
410 CheckVersionV3(db);
462 sqlite3 *db = nullptr; variable
472 CheckVersionV3(db);
510 sqlite3 *db = nullptr; variable
520 CheckVersionV3(db);
546 sqlite3 *db = nullptr; variable
557 CheckVersionV3(db);
[all …]
H A Ddistributeddb_relational_encrypted_db_test.cpp159 sqlite3 *db = nullptr; variable
177 sqlite3_close(db);
193 sqlite3 *db = nullptr; variable
211 sqlite3_close(db);
227 sqlite3 *db = nullptr; variable
268 sqlite3_close(db);
313 sqlite3_close(db);
370 sqlite3_close(db);
446 sqlite3_close(db);
507 sqlite3_close(db);
[all …]
H A Ddistributeddb_relational_remote_query_test.cpp52 sqlite3 *db = nullptr; in CreateDBAndTable() local
56 sqlite3_close(db); in CreateDBAndTable()
69 sqlite3_close(db); in CreateDBAndTable()
184 sqlite3 *db = nullptr; variable
189 sqlite3_close(db);
250 sqlite3_close(db);
315 sqlite3_close(db);
362 sqlite3_close(db);
497 sqlite3_close(db);
544 sqlite3_close(db);
[all …]
H A Ddistributeddb_relational_get_data_test.cpp55 sqlite3 *db = nullptr; in CreateDBAndTable() local
59 sqlite3_close(db); in CreateDBAndTable()
72 sqlite3_close(db); in CreateDBAndTable()
77 sqlite3 *db = nullptr; in AddOrUpdateRecord() local
85 sqlite3_close(db); in AddOrUpdateRecord()
124 sqlite3_close(db); in GetLogData()
227 sqlite3_close(db); in PutBatchData()
536 sqlite3_close(db);
734 ExpectCount(db,
737 sqlite3_close(db);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/
H A Ddistributed_rdb_tools.cpp127 int errCode = sqlite3_open(dbName, &db); in InitSqlite3Store()
156 if (db == nullptr) { in InitTableDataAndTrigger()
160 SqliteExecSql(db, SQL_CREATE_NORMAL_TABLE); in InitTableDataAndTrigger()
162 SqliteExecSql(db, SQL_CREATE_TRIGGER); in InitTableDataAndTrigger()
163 SqliteExecSql(db, SQL_INSERT_NORMAL_TABLE); in InitTableDataAndTrigger()
172 SqliteExecSql(db, sql.c_str()); in InitTableDataAndTrigger()
180 if (db == nullptr) { in AlterTableAttributes()
226 if (db == nullptr) { in Sqlite3ExecOpration()
240 if (db != nullptr) { in CloseSqlite3Store()
241 sqlite3_close(db); in CloseSqlite3Store()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/
H A Dstorage_fuzzer.cpp117 sqlite3 *db = nullptr; in CreateDB() local
121 sqlite3_close(db); in CreateDB()
130 sqlite3_close(db); in CreateDB()
263 RdbTestUtils::ExecSql(db, sql); in CreateTableForStoreObserver()
318 UnRegisterClientObserver(db); in ClientObserverFuzz()
319 sqlite3_close_v2(db); in ClientObserverFuzz()
329 UnregisterStoreObserver(db); in StoreObserverFuzz()
333 sqlite3_close_v2(db); in StoreObserverFuzz()
341 sqlite3_close_v2(db); in DropLogicDeletedDataFuzz()
350 Lock(tableName, hashKey, db); in LockAndUnLockFuzz()
[all …]
/ohos5.0/foundation/ability/ability_base/test/unittest/base/
H A Ddouble_wrapper_test.cpp46 Double db(value);
47 ErrCode result = db.GetValue(value);
59 Double db(value);
60 EXPECT_EQ("1000.000000", db.ToString());
71 Double db(value);
72 double result = db.Unbox(db.Box(value));
84 Double db(value);
85 double result = db.Unbox(db.Parse(db.ToString()));
97 Double db(value);
98 double result = db.Unbox(db.Parse(db.ToString()));
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_utils.cpp120 if (db == nullptr) { in RdKVPut()
135 if (db == nullptr) { in RdKVGet()
163 if (db == nullptr) { in RdKVDel()
178 if (db == nullptr) { in RdKVScan()
192 if (db == nullptr) { in RdKVRangeScan()
216 int RdDBClose(GRD_DB *db, uint32_t flags) in RdDBClose() argument
249 if (db == nullptr) { in RdKVBatchPut()
256 int RdFlush(GRD_DB *db, uint32_t flags) in RdFlush() argument
258 if (db == nullptr) { in RdFlush()
268 if (db == nullptr) { in RdKVBatchDel()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/base/
H A Dgrd_db_api_inner.cpp27 if (db == nullptr) { in GRD_DBOpenInner()
38 *db = new (std::nothrow) GRD_DB(); in GRD_DBOpenInner()
39 if (*db == nullptr) { in GRD_DBOpenInner()
45 (*db)->store_ = store; in GRD_DBOpenInner()
49 int32_t GRD_DBCloseInner(GRD_DB *db, uint32_t flags) in GRD_DBCloseInner() argument
51 if (db == nullptr || db->store_ == nullptr) { in GRD_DBCloseInner()
60 db->store_ = nullptr; in GRD_DBCloseInner()
61 delete db; in GRD_DBCloseInner()
65 int32_t GRD_FlushInner(GRD_DB *db, uint32_t flags) in GRD_FlushInner() argument
67 if (db == nullptr || db->store_ == nullptr) { in GRD_FlushInner()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_sqlite_ext.cpp406 if (db == nullptr) { in RegisterFunction()
499 if (db == nullptr) { in GetLocalTimeOffsetFromMeta()
552 if (db == nullptr) { in GetSysTime()
599 if (db == nullptr) { in GetLastTime()
625 if (db == nullptr) { in GetDbFileName()
1020 return RegisterFunction(db, "get_sys_time", 1, db, func); in RegisterGetSysTime()
1027 return RegisterFunction(db, "get_last_time", 0, db, func); in RegisterGetLastTime()
1054 sqlite3_wal_hook(db, LogCommitHookCallback, db); in RegisterCommitAndRollbackHook()
1055 sqlite3_rollback_hook(db, RollbackHookCallback, db); in RegisterCommitAndRollbackHook()
1752 sqlite3 *db) in Lock() argument
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_syncer_download_assets_test.cpp118 void InitDatabase(sqlite3 *&db) in InitDatabase() argument
225 ASSERT_NE(db, nullptr); in DeleteLocalRecord()
429 sqlite3 *db = nullptr; member in __anon32d7e6600110::DistributedDBCloudSyncerDownloadAssetsTest
452 ASSERT_NE(db, nullptr); in SetUp()
453 InitDatabase(db); in SetUp()
1444 CheckDownloadFailedForTest002(db);
1486 CheckDownloadFailedForTest002(db);
1867 CheckConsistentCount(db, cloudCount);
1875 CheckConsistentCount(db, 0L);
1877 CheckConsistentCount(db, cloudCount);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_store_instance.cpp78 auto *db = iter->second; in GetFromCache() local
79 if (db == nullptr) { in GetFromCache()
84 db->IncObjRef(db); in GetFromCache()
85 return db; in GetFromCache()
108 if (db == nullptr) { in OpenDatabase()
125 db->WakeUpSyncer(); in OpenDatabase()
128 return db; in OpenDatabase()
140 } else if (db != nullptr) { in GetDataBase()
142 return db; in GetDataBase()
156 return db; in GetDataBase()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/common/include/
H A Dgrd_api_manager.h22 typedef int32_t (*DBOpen)(const char *dbPath, const char *configStr, uint32_t flags, GRD_DB **db);
23 typedef int32_t (*DBClose)(GRD_DB *db, uint32_t flags);
27 typedef int32_t (*DBFlush)(GRD_DB *db, uint32_t flags);
28 typedef int32_t (*IndexPreload)(GRD_DB *db, const char *collectionName);
30 typedef int32_t (*DropCollection)(GRD_DB *db, const char *collectionName, uint32_t flags);
32 typedef int32_t (*FindDoc)(GRD_DB *db, const char *collectionName, Query query,
34 typedef int32_t (*UpdateDoc)(GRD_DB *db, const char *collectionName, const char *filter,
36 typedef int32_t (*UpsertDoc)(GRD_DB *db, const char *collectionName, const char *filter,
47 typedef int32_t (*KVDel)(GRD_DB *db, const char *collectionName, const GRD_KVItemT *key);
58 typedef int32_t (*KVBatchPut)(GRD_DB *db, const char *collectionName, GRD_KVBatchT *batch);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/
H A Drd_sqlite_utils.cpp72 if (db != nullptr) { in CreateDataBase()
73 (void)sqlite3_close_v2(db); in CreateDataBase()
74 db = nullptr; in CreateDataBase()
88 if (db == nullptr) { in GetStatement()
210 return ExecSql(db, BEGIN_IMMEDIATE_SQL); in BeginTransaction()
213 return ExecSql(db, BEGIN_SQL); in BeginTransaction()
216 int RDSQLiteUtils::CommitTransaction(sqlite3 *db) in CommitTransaction() argument
218 return ExecSql(db, COMMIT_SQL); in CommitTransaction()
223 return ExecSql(db, ROLLBACK_SQL); in RollbackTransaction()
228 if (db == nullptr || sql.empty()) { in ExecSql()
[all …]

12345678910>>...15