Home
last modified time | relevance | path

Searched refs:rdbStore (Results 1 - 25 of 224) sorted by relevance

123456789

/foundation/distributeddatamgr/relational_store/test/js/rdb/unittest/src/
H A DRdbstoreTransactionJsunit.test.js27 var rdbStore = undefined;
32 rdbStore = await dataRdb.getRdbStore(STORE_CONFIG, 1);
33 await rdbStore.executeSql(CREATE_TABLE_TEST, null);
43 await rdbStore.executeSql("DELETE FROM test");
48 rdbStore = null
63 rdbStore.beginTransaction()
70 await rdbStore.insert("test", valueBucket)
72 rdbStore.commit()
75 let resultSet = await rdbStore.query(predicates)
97 rdbStore
[all...]
H A DRdbstoreCreateDeleteWithFAContextJsunit.test.js54 var rdbStore = await dataRdb.getRdbStore(context, STORE_CONFIG, 1);
55 rdbStore = null
69 var rdbStore = await dataRdb.getRdbStore(context, STORE_CONFIG, 1);
70 await rdbStore.executeSql(CREATE_TABLE_TEST, null);
71 await rdbStore.executeSql("DELETE FROM test");
80 await rdbStore.insert("test", valueBucket)
89 await rdbStore.insert("test", valueBucket)
98 await rdbStore.insert("test", valueBucket)
103 let deletePromise = rdbStore.delete(predicates)
112 await rdbStore
[all...]
H A DRdbstoreDeleteJsunit.test.js25 var rdbStore = undefined;
34 rdbStore = await dataRdb.getRdbStore(STORE_CONFIG, 1);
35 await rdbStore.executeSql(CREATE_TABLE_TEST, null);
40 rdbStore = null
64 await rdbStore.insert("test", valueBucket)
73 await rdbStore.insert("test", valueBucket)
82 await rdbStore.insert("test", valueBucket)
86 let deletePromise = rdbStore.delete(predicates)
114 await rdbStore.insert("test", valueBucket)
123 await rdbStore
[all...]
H A DRdbstoreStoreExcuteSqlJsunit.test.js25 var rdbStore = undefined;
30 rdbStore = await dataRdb.getRdbStore(STORE_CONFIG, 1);
34 await rdbStore.executeSql(CREATE_TABLE_TEST, null);
40 await rdbStore.executeSql("DROP TABLE IF EXISTS test")
45 rdbStore = null
64 let ret = await rdbStore.insert("test", valueBucket)
74 let ret = await rdbStore.insert("test", valueBucket)
84 let ret = await rdbStore.insert("test", valueBucket)
87 await rdbStore.executeSql("DELETE FROM test WHERE age = ? OR age = ?", ["18", "20"])
89 let querySqlPromise = rdbStore
[all...]
H A DRdbstorePredicatesJsunit.test.js31 var rdbStore = undefined;
36 rdbStore = await dataRdb.getRdbStore(STORE_CONFIG, 1);
37 await rdbStore.executeSql(CREATE_TABLE_ALL_DATA_TYPE_SQL, null);
53 rdbStore = null
73 await rdbStore.insert("AllDataType", valueBucket)
93 await rdbStore.insert("AllDataType", valueBucket)
113 await rdbStore.insert("AllDataType", valueBucket)
129 let result = await rdbStore.query(predicates);
148 let result = await rdbStore.query(predicates);
167 let result = await rdbStore
[all...]
H A DRdbstoreInsertJsunit.test.js27 var rdbStore = undefined;
32 rdbStore = await dataRdb.getRdbStore(STORE_CONFIG, 1);
33 await rdbStore.executeSql(CREATE_TABLE_TEST, null);
38 await rdbStore.executeSql("DELETE FROM test");
47 rdbStore = null
68 await rdbStore.insert("test", valueBucket)
77 await rdbStore.insert("test", valueBucket)
86 await rdbStore.insert("test", valueBucket)
91 let resultSet = await rdbStore.query(predicates)
133 let insertPromise = rdbStore
[all...]
/foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/
H A DRdbstoreTransactionJsunit.test.js30 var rdbStore = undefined; variable
35 rdbStore = await data_relationalStore.getRdbStore(context, STORE_CONFIG);
36 await rdbStore.executeSql(CREATE_TABLE_TEST, null);
46 await rdbStore.executeSql("DELETE FROM test");
51 rdbStore = null
69 rdbStore.beginTransaction()
76 await rdbStore.insert("test", valueBucket)
78 rdbStore.commit()
81 let resultSet = await rdbStore.query(predicates)
106 rdbStore
[all...]
H A DRdbStoreDistributedJsunit.test.js23 var rdbStore = undefined; variable
34 rdbStore = await data_relationalStore.getRdbStore(context, config);
36 expect(rdbStore).assertEqual(rdbStore)
42 await rdbStore.executeSql(sqlStatement, null)
56 await rdbStore.executeSql(sqlStatement, null)
80 rdbStore = null
94 await rdbStore.setDistributedTables([])
96 expect(rdbStore).assertEqual(rdbStore)
[all...]
H A DRdbstoreDeleteJsunit.test.js28 var rdbStore = undefined
38 rdbStore = await data_relationalStore.getRdbStore(context, STORE_CONFIG);
39 await rdbStore.executeSql(CREATE_TABLE_TEST, null);
44 rdbStore = null
69 await rdbStore.insert("test", valueBucket)
78 await rdbStore.insert("test", valueBucket)
87 await rdbStore.insert("test", valueBucket)
91 let deletePromise = rdbStore.delete(predicates)
121 await rdbStore.insert("test", valueBucket)
130 await rdbStore
[all...]
H A DRdbstoreCreateDeleteWithFAContextJsunit.test.js55 var rdbStore = await data_relationalStore.getRdbStore(context, STORE_CONFIG);
56 rdbStore = null
69 var rdbStore = await data_relationalStore.getRdbStore(context, STORE_CONFIG);
70 await rdbStore.executeSql(CREATE_TABLE_TEST, null);
71 await rdbStore.executeSql("DELETE FROM test");
80 await rdbStore.insert("test", valueBucket)
89 await rdbStore.insert("test", valueBucket)
98 await rdbStore.insert("test", valueBucket)
103 let deletePromise = rdbStore.delete(predicates)
112 await rdbStore
[all...]
H A DRdbstoreDeleteSyncJsunit.test.js28 var rdbStore = undefined
38 rdbStore = await data_relationalStore.getRdbStore(context, STORE_CONFIG);
39 await rdbStore.executeSql(CREATE_TABLE_TEST, null);
44 rdbStore = null
69 await rdbStore.insert("test", valueBucket)
78 await rdbStore.insert("test", valueBucket)
87 await rdbStore.insert("test", valueBucket)
91 let ret = rdbStore.deleteSync(predicates)
116 await rdbStore.insert("test", valueBucket)
125 await rdbStore
[all...]
H A DRdbstoreStoreExcuteSqlJsunit.test.js28 var rdbStore = undefined; variable
33 rdbStore = await data_relationalStore.getRdbStore(context, STORE_CONFIG);
37 await rdbStore.executeSql(CREATE_TABLE_TEST, null);
43 await rdbStore.executeSql("DROP TABLE IF EXISTS test")
48 rdbStore = null
69 let ret = await rdbStore.insert("test", valueBucket)
79 let ret = await rdbStore.insert("test", valueBucket)
89 let ret = await rdbStore.insert("test", valueBucket)
92 await rdbStore.executeSql("DELETE FROM test WHERE age = ? OR age = ?", ["18", "20"])
94 let querySqlPromise = rdbStore
[all...]
H A DRdbstoreStoreExcuteSyncJsunit.test.js36 let rdbStore = undefined;
41 rdbStore = await relationalStore.getRdbStore(context, STORE_CONFIG);
46 await rdbStore.executeSql(CREATE_TABLE_TEST);
51 await rdbStore.executeSql("DROP TABLE IF EXISTS test");
52 await rdbStore.executeSql("DROP TABLE IF EXISTS test2");
58 rdbStore = null
70 let ret = rdbStore.executeSync("PRAGMA integrity_check");
89 let ret = rdbStore.executeSync("PRAGMA quick_check");
109 rdbStore.version = 5;
110 let ret = rdbStore
[all...]
H A DRdbstoreBackupRestoreWithFAContextJsunit.test.js24 var rdbStore
34 let rdbStore = await data_relationalStore.getRdbStore(context, STORE_CONFIG)
35 await rdbStore.executeSql(CREATE_TABLE_TEST, null)
44 await rdbStore.insert("test", valueBucket)
53 await rdbStore.insert("test", valueBucket)
62 await rdbStore.insert("test", valueBucket)
64 return rdbStore
69 let promiseRestore = rdbStore.backup(backupName)
80 rdbStore = null
85 let promiseRestore = rdbStore
[all...]
H A DRdbstoreAfterCloseJsunit.test.js31 const rdbStore = await relationalStore.getRdbStore(context, STORE_CONFIG);
32 await rdbStore.executeSql(CREATE_TABLE_TEST);
40 await rdbStore.insert('test', valueBucket);
41 return rdbStore;
69 const rdbStore = await createRdb();
71 await rdbStore.close();
78 await rdbStore.execute('SELECT * FROM test LIMIT 100');
97 const rdbStore = await createRdb();
99 await rdbStore.close();
106 await rdbStore
[all...]
H A DRdbstorePredicatesJsunit.test.js34 var rdbStore = undefined variable
89 rdbStore = await data_relationalStore.getRdbStore(context, STORE_CONFIG);
90 await rdbStore.executeSql(CREATE_TABLE_ALL_DATA_TYPE_SQL, null);
106 rdbStore = null
112 await rdbStore.insert("AllDataType", valueBucket1)
117 await rdbStore.insert("AllDataType", valueBucket2)
122 await rdbStore.insert("AllDataType", valueBucket3)
138 let result = await rdbStore.query(predicates);
158 let result = await rdbStore.query(predicates);
178 let result = await rdbStore
[all...]
H A DRdbstoreAfterCloseSyncJsunit.test.js31 const rdbStore = await relationalStore.getRdbStore(context, STORE_CONFIG);
32 await rdbStore.executeSql(CREATE_TABLE_TEST);
40 await rdbStore.insert('test', valueBucket);
41 return rdbStore;
69 const rdbStore = await createRdb();
71 await rdbStore.close();
78 rdbStore.executeSync('SELECT * FROM test LIMIT 100');
97 const rdbStore = await createRdb();
99 await rdbStore.close();
108 rdbStore
[all...]
/foundation/bundlemanager/app_domain_verify/services/src/manager/rdb/
H A Drdb_migrate_mgr.cpp28 int RdbMigrateMgr::Upgrade(NativeRdb::RdbStore& rdbStore, int currVersion, int targetVersion) in Upgrade() argument
33 int innerVersion = QueryInnerVersion(rdbStore); in Upgrade()
35 UpgradeFromV1ToV2(rdbStore); in Upgrade()
37 ret = UpgradeFromV2ToV3(rdbStore); in Upgrade()
39 ret = UpgradeFromV2ToV3(rdbStore); in Upgrade()
52 int RdbMigrateMgr::QueryInnerVersion(NativeRdb::RdbStore& rdbStore) in QueryInnerVersion() argument
56 auto absSharedResultSet = rdbStore.Query(absRdbPredicates, columns); in QueryInnerVersion()
65 APP_DOMAIN_VERIFY_HILOGI(APP_DOMAIN_VERIFY_MGR_MODULE_SERVICE, "rdbStore GetColumnCount %{public}d", count); in QueryInnerVersion()
70 APP_DOMAIN_VERIFY_HILOGI(APP_DOMAIN_VERIFY_MGR_MODULE_SERVICE, "rdbStore innerVersion %{public}d", innerVersion); in QueryInnerVersion()
74 void RdbMigrateMgr::UpgradeFromV1ToV2(NativeRdb::RdbStore& rdbStore) in UpgradeFromV1ToV2() argument
116 UpgradeFromV2ToV3(NativeRdb::RdbStore& rdbStore) UpgradeFromV2ToV3() argument
140 ExecSqlWithTrans(NativeRdb::RdbStore& rdbStore, const TransFunc& func) ExecSqlWithTrans() argument
[all...]
/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/include/
H A Dmedialibrary_rdb_utils.h41 EXPORT static void UpdateSystemAlbumInternal(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore,
43 EXPORT static void UpdateUserAlbumInternal(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore,
45 EXPORT static void UpdateSourceAlbumInternal(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore,
47 static void UpdateUserAlbumByUri(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore,
49 EXPORT static void UpdateAnalysisAlbumByUri(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore,
51 static void UpdateSourceAlbumByUri(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore,
55 EXPORT static void UpdateSysAlbumHiddenState(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore,
57 EXPORT static void UpdateAnalysisAlbumInternal(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore,
59 EXPORT static void UpdateAnalysisAlbumByFile(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore,
61 EXPORT static void UpdateAllAlbums(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore,
[all...]
/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/
H A Dmedialibrary_location_operations.cpp31 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); in InsertOperation() local
32 if (rdbStore == nullptr) { in InsertOperation()
33 MEDIA_ERR_LOG("location insert operation, rdbStore is null."); in InsertOperation()
37 int32_t errCode = rdbStore->Insert(cmd, outRowId); in InsertOperation()
47 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); in UpdateOperation() local
48 if (rdbStore == nullptr) { in UpdateOperation()
49 MEDIA_ERR_LOG("location update operation, rdbStore is null."); in UpdateOperation()
53 int32_t errCode = rdbStore->Update(cmd, updateRows); in UpdateOperation()
63 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); in DeleteOperation() local
64 if (rdbStore in DeleteOperation()
80 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); QueryOperation() local
[all...]
H A Dmedialibrary_story_operations.cpp31 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); in InsertOperation() local
32 if (rdbStore == nullptr) { in InsertOperation()
33 MEDIA_ERR_LOG("Story insert operation, rdbStore is null."); in InsertOperation()
37 int32_t errCode = rdbStore->Insert(cmd, outRowId); in InsertOperation()
47 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); in UpdateOperation() local
48 if (rdbStore == nullptr) { in UpdateOperation()
49 MEDIA_ERR_LOG("Story update operation, rdbStore is null."); in UpdateOperation()
53 int32_t errCode = rdbStore->Update(cmd, updateRows); in UpdateOperation()
63 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); in DeleteOperation() local
64 if (rdbStore in DeleteOperation()
80 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); QueryOperation() local
[all...]
H A Dmedialibrary_search_operations.cpp53 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); in InsertOperation() local
54 if (rdbStore == nullptr) { in InsertOperation()
58 int32_t errCode = rdbStore->Insert(cmd, outRowId); in InsertOperation()
68 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); in UpdateOperation() local
69 if (rdbStore == nullptr) { in UpdateOperation()
73 int32_t errCode = rdbStore->Update(cmd, updateRows); in UpdateOperation()
83 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); in DeleteOperation() local
84 if (rdbStore == nullptr) { in DeleteOperation()
88 int32_t errCode = rdbStore->Delete(cmd, deleteRows); in DeleteOperation()
99 auto rdbStore in QueryOperation() local
108 auto rdbStore = MediaLibraryUnistoreManager::GetInstance().GetRdbStore(); QueryIndexConstructProgress() local
[all...]
/foundation/multimedia/ringtone_library/services/ringtone_restore/src/
H A Dringtone_restore_db_utils.cpp31 int32_t RingtoneRestoreDbUtils::InitDb(std::shared_ptr<NativeRdb::RdbStore> &rdbStore, const std::string &dbName, in InitDb() argument
42 rdbStore = NativeRdb::RdbHelper::GetRdbStore(config, RINGTONE_RDB_VERSION, cb, err); in InitDb()
46 int32_t RingtoneRestoreDbUtils::QueryInt(std::shared_ptr<NativeRdb::RdbStore> rdbStore, const std::string &sql, in QueryInt() argument
49 if (rdbStore == nullptr) { in QueryInt()
53 auto resultSet = rdbStore->QuerySql(sql); in QueryInt()
61 int32_t RingtoneRestoreDbUtils::Update(std::shared_ptr<NativeRdb::RdbStore> &rdbStore, int32_t &changeRows, in Update() argument
64 if (rdbStore == nullptr) { in Update()
68 return rdbStore->Update(changeRows, valuesBucket, *predicates); in Update()
71 int32_t RingtoneRestoreDbUtils::QueryRingtoneCount(std::shared_ptr<NativeRdb::RdbStore> rdbStore) in QueryRingtoneCount() argument
74 return QueryInt(rdbStore, QUERY_TONEFILES_ALL_COUN in QueryRingtoneCount()
77 GetQueryResultSet( const std::shared_ptr<NativeRdb::RdbStore> &rdbStore, const std::string &querySql) GetQueryResultSet() argument
87 GetColumnInfoMap( const std::shared_ptr<NativeRdb::RdbStore> &rdbStore, const std::string &tableName) GetColumnInfoMap() argument
[all...]
/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/rdb/
H A Drdb_data_manager.cpp31 constexpr int8_t CLOSE_TIME = 20; // delay 20s stop rdbStore
119 auto rdbStore = GetRdbStore(); in BackupRdb() local
120 if (rdbStore == nullptr) { in BackupRdb()
124 auto ret = rdbStore->Backup(bmsRdbConfig_.dbPath + std::string("/") + std::string(BMS_BACK_UP_RDB_NAME)); in BackupRdb()
134 auto rdbStore = GetRdbStore(); in InsertData() local
135 if (rdbStore == nullptr) { in InsertData()
144 auto ret = rdbStore->InsertWithConflictResolution( in InsertData()
152 auto rdbStore = GetRdbStore(); in InsertData() local
153 if (rdbStore == nullptr) { in InsertData()
159 auto ret = rdbStore in InsertData()
167 auto rdbStore = GetRdbStore(); BatchInsert() local
179 auto rdbStore = GetRdbStore(); UpdateData() local
199 auto rdbStore = GetRdbStore(); UpdateData() local
217 auto rdbStore = GetRdbStore(); UpdateOrInsertData() local
240 auto rdbStore = GetRdbStore(); DeleteData() local
255 auto rdbStore = GetRdbStore(); DeleteData() local
272 auto rdbStore = GetRdbStore(); QueryData() local
309 auto rdbStore = GetRdbStore(); QueryData() local
329 auto rdbStore = GetRdbStore(); QueryAllData() local
381 auto rdbStore = GetRdbStore(); CreateTable() local
423 auto rdbStore = GetRdbStore(); QueryByStep() local
[all...]
/foundation/distributeddatamgr/relational_store/interfaces/ndk/src/
H A Drelational_store.cpp290 int OnCreate(OHOS::NativeRdb::RdbStore &rdbStore) override;
291 int OnUpgrade(OHOS::NativeRdb::RdbStore &rdbStore, int oldVersion, int newVersion) override;
294 int MainOpenCallback::OnCreate(OHOS::NativeRdb::RdbStore &rdbStore) in OnCreate() argument
299 int MainOpenCallback::OnUpgrade(OHOS::NativeRdb::RdbStore &rdbStore, int oldVersion, int newVersion) in OnUpgrade() argument
406 auto rdbStore = GetRelationalStore(store); in OH_Rdb_CloseStore() local
407 if (rdbStore == nullptr) { in OH_Rdb_CloseStore()
410 delete rdbStore; in OH_Rdb_CloseStore()
447 auto rdbStore = GetRelationalStore(store); in OH_Rdb_Insert() local
449 if (rdbStore == nullptr || table == nullptr || bucket == nullptr) { in OH_Rdb_Insert()
453 rdbStore in OH_Rdb_Insert()
459 auto rdbStore = GetRelationalStore(store); OH_Rdb_Update() local
472 auto rdbStore = GetRelationalStore(store); OH_Rdb_Delete() local
484 auto rdbStore = GetRelationalStore(store); OH_Rdb_Query() local
507 auto rdbStore = GetRelationalStore(store); OH_Rdb_ExecuteQuery() local
523 auto rdbStore = GetRelationalStore(store); OH_Rdb_Execute() local
533 auto rdbStore = GetRelationalStore(store); OH_Rdb_ExecuteByTrxId() local
543 auto rdbStore = GetRelationalStore(store); OH_Rdb_BeginTransaction() local
552 auto rdbStore = GetRelationalStore(store); OH_Rdb_RollBack() local
561 auto rdbStore = GetRelationalStore(store); OH_Rdb_Commit() local
570 auto rdbStore = GetRelationalStore(store); OH_Rdb_BeginTransWithTrxId() local
581 auto rdbStore = GetRelationalStore(store); OH_Rdb_RollBackByTrxId() local
590 auto rdbStore = GetRelationalStore(store); OH_Rdb_CommitByTrxId() local
599 auto rdbStore = GetRelationalStore(store); OH_Rdb_Backup() local
608 auto rdbStore = GetRelationalStore(store); OH_Rdb_Restore() local
617 auto rdbStore = GetRelationalStore(store); OH_Rdb_GetVersion() local
626 auto rdbStore = GetRelationalStore(store); OH_Rdb_SetVersion() local
654 auto rdbStore = GetRelationalStore(store); OH_Rdb_SetDistributedTables() local
677 auto rdbStore = GetRelationalStore(store); OH_Rdb_FindModifyTime() local
696 auto rdbStore = GetRelationalStore(store); OH_Rdb_Subscribe() local
705 auto rdbStore = GetRelationalStore(store); OH_Rdb_Unsubscribe() local
872 auto rdbStore = GetRelationalStore(store); OH_Rdb_CloudSync() local
906 auto rdbStore = GetRelationalStore(store); OH_Rdb_SubscribeAutoSyncProgress() local
915 auto rdbStore = GetRelationalStore(store); OH_Rdb_UnsubscribeAutoSyncProgress() local
924 auto rdbStore = GetRelationalStore(store); OH_Rdb_LockRow() local
934 auto rdbStore = GetRelationalStore(store); OH_Rdb_UnlockRow() local
945 auto rdbStore = GetRelationalStore(store); OH_Rdb_QueryLockedRow() local
[all...]

Completed in 10 milliseconds

123456789