Home
last modified time | relevance | path

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

12

/base/request/request/services/src/manage/scheduler/state/
H A Dsql.rs307 let db = RequestDb::get_instance(); in query_state_and_reason()
309 db.query_integer(&format!( in query_state_and_reason()
312 db.query_integer(&format!( in query_state_and_reason()
319 let db = RequestDb::get_instance(); in network()
324 db.execute(&format!( in network()
328 db.execute(sql).unwrap(); in network()
333 db.execute(&format!( in network()
337 db.execute(sql).unwrap(); in network()
342 db.execute(&format!( in network()
346 db in network()
[all...]
/base/security/asset/services/db_operator/src/test/
H A Dtest_database.rs65 let mut db = in open_db_and_insert_data() variables
68 let count = db.insert_datas(&def).unwrap(); in open_db_and_insert_data()
70 db in open_db_and_insert_data()
81 fn backup_db(db: &Database) { in backup_db()
82 fs::copy(&db.path, &db.backup_path).unwrap(); in backup_db()
89 let mut db = in create_and_drop_database() variables
92 backup_db(&db); in create_and_drop_database()
93 db.close_db(); in create_and_drop_database()
94 assert!(Database::delete(0, &db in create_and_drop_database()
124 let mut db = create_delete_asset_table() variables
142 let mut db = insert_data_with_different_alias() variables
166 let mut db = open_db_and_insert_data(); delete_data() variables
186 let mut db = open_db_and_insert_data(); update_data() variables
216 let mut db = query_ordered_data() variables
253 let mut db = insert_error_data() variables
273 let mut db = backup_and_restore() variables
286 let mut db = open_db_and_insert_data(); insert_duplicated_data() variables
303 let mut db = query_mismatch_type_data() variables
[all...]
H A Dtest_table.rs36 let mut db = in create_delete_table() variables
39 let table = Table::new("table_name", &db); in create_delete_table()
44 db.close_db(); in create_delete_table()
52 let mut db = in table_restore() variables
55 let table = Table::new("table_name", &db); in table_restore()
62 "/data/asset_test/0/Native_asset_service_8100.db", in table_restore()
63 "/data/asset_test/0/Native_asset_service_8100.db.backup", in table_restore()
66 db.close_db(); in table_restore()
68 fs::remove_file("/data/asset_test/0/Native_asset_service_8100.db").unwrap(); in table_restore()
70 "/data/asset_test/0/Native_asset_service_8100.db in table_restore()
[all...]
/base/security/asset/services/db_operator/src/
H A Dsqlite3_wrapper.c26 int SqliteCloseV2(void *db) in SqliteCloseV2() argument
28 return sqlite3_close_v2((sqlite3 *)db); in SqliteCloseV2()
31 int SqliteExec(void *db, const char *zSql, char **pzErrMsg) in SqliteExec() argument
33 return sqlite3_exec((sqlite3 *)db, zSql, NULL, NULL, pzErrMsg); in SqliteExec()
46 int SqliteChanges(void *db) in SqliteChanges() argument
48 return sqlite3_changes((sqlite3 *)db); in SqliteChanges()
51 int SqlitePrepareV2(void *db, const char *zSql, void **ppStmt, const char **pzTail) in SqlitePrepareV2() argument
53 return sqlite3_prepare_v2((sqlite3 *)db, zSql, -1, (sqlite3_stmt **)ppStmt, pzTail); in SqlitePrepareV2()
66 const char *SqliteErrMsg(void *db) in SqliteErrMsg() argument
68 return sqlite3_errmsg((sqlite3 *)db); in SqliteErrMsg()
116 SqliteKey(void *db, const void *pKey, int nKey) SqliteKey() argument
[all...]
H A Dtransaction.rs23 /// Transaction for sqlite db
26 db: &'a Database,
31 pub(crate) fn new(db: &'a Database) -> Transaction<'a> {
32 Transaction { db }
38 self.db.exec("begin transaction")
43 self.db.exec("rollback")
48 self.db.exec("commit")
H A Dstatement.rs32 fn SqlitePrepareV2(db: *mut c_void, z_sql: *const u8, pp_stmt: *mut *mut c_void, pz_tail: *mut *mut u8) -> i32; in SqlitePrepareV2()
52 db: &'b Database,
58 pub(crate) fn prepare(sql: &str, db: &'b Database) -> Result<Statement<'b>> {
62 let mut stmt = Statement { sql: sql_s, handle: 0, db };
65 db.handle as _,
74 db.print_db_msg();
84 self.db.print_db_msg();
96 self.db.print_db_msg();
111 self.db.print_db_msg();
H A Ddatabase.rs43 fn SqliteCloseV2(db: *mut c_void) -> i32; in SqliteCloseV2()
44 fn SqliteExec(db: *mut c_void, sql: *const u8, msg: *mut *mut u8) -> i32; in SqliteExec()
46 fn SqliteErrMsg(db: *mut c_void) -> *const u8; in SqliteErrMsg()
47 fn SqliteKey(db: *mut c_void, pKey: *const c_void, nKey: i32) -> i32; in SqliteKey()
104 pub type UpgradeDbCallback = fn(db: &Database, old_ver: u32, new_ver: u32) -> Result<()>;
127 format!("data/service/el2/{}/asset_service/{}.db", user_id, db_name)
132 format!("{}/{}/{}.db", DE_ROOT_PATH, user_id, db_name)
152 let mut db = Database { path, backup_path, handle: 0, db_lock: lock, db_name: db_name.to_string() }; variables
153 let _lock = db.db_lock.mtx.lock().unwrap();
154 db
227 let mut db = Database { path: path.clone(), backup_path: path, handle: 0, db_lock: lock, db_name }; check_db_accessible() variables
[all...]
/base/security/asset/services/plugin/src/
H A Dasset_plugin.rs117 // use owner and owner type calculate db file name in get_db_name()
130 /// Adds an asset to de db.
133 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; in add() variables
134 db.insert_datas(attributes).map_err(|e| e.code as u32) in add()
137 /// Adds an asset to ce db.
140 let mut db = Database::build_with_file_name(self.user_id, &db_name, true).map_err(|e| e.code as u32)?; in ce_add() variables
141 db.insert_datas(attributes).map_err(|e| e.code as u32) in ce_add()
144 /// Adds an asset with replace to de db.
147 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; in replace() variables
148 db in replace()
154 let mut db = Database::build_with_file_name(self.user_id, &db_name, true).map_err(|e| e.code as u32)?; ce_replace() variables
163 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; query() variables
174 let mut db = Database::build_with_file_name(self.user_id, &db_name, true).map_err(|e| e.code as u32)?; ce_query() variables
185 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; remove() variables
196 let mut db = Database::build_with_file_name(self.user_id, &db_name, true).map_err(|e| e.code as u32)?; ce_remove() variables
211 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; remove_with_specific_cond() variables
227 let mut db = Database::build_with_file_name(self.user_id, &db_name, true).map_err(|e| e.code as u32)?; ce_remove_with_specific_cond() variables
239 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; update() variables
250 let mut db = Database::build_with_file_name(self.user_id, &db_name, true).map_err(|e| e.code as u32)?; ce_update() variables
[all...]
/base/hiviewdfx/hiview/plugins/performance/scene_data_processor/
H A DAnimatorSceneDataProcessor.cpp106 db.insert(std::map<int32_t, AnimatorRecord*>::value_type(evt->animatorInfo.basicInfo.uniqueId, animatorRecord)); in CreateRecord()
187 if (db.find(uniqueId) != db.end()) { in GetRecord()
188 record = db[uniqueId]; in GetRecord()
195 auto iter = db.find(uniqueId); in DeleteRecord()
196 if (iter != db.end()) { in DeleteRecord()
198 db.erase(iter); in DeleteRecord()
205 for (auto it = db.begin(); it != db.end();) { in HandleTimeOutPoints()
210 it = db in HandleTimeOutPoints()
[all...]
H A DAppLaunchSceneDataProcessor.h46 AppLaunchSceneDataProcessor(IAppLaunchSceneDb* db, ITimeoutExecutor* exec,
49 AppLaunchSceneDataProcessor(IAppLaunchSceneDb* db, ITimeoutExecutor* exec, IAppTimer* timer);
56 IAppLaunchSceneDb* db; member in OHOS::HiviewDFX::AppLaunchSceneDataProcessor
H A DAppLaunchSceneDataProcessor.cpp39 AppLaunchSceneDataProcessor::AppLaunchSceneDataProcessor(IAppLaunchSceneDb* db, ITimeoutExecutor* exec, in AppLaunchSceneDataProcessor() argument
43 this->db = db; in AppLaunchSceneDataProcessor()
49 AppLaunchSceneDataProcessor::AppLaunchSceneDataProcessor(IAppLaunchSceneDb* db, ITimeoutExecutor* exec, in AppLaunchSceneDataProcessor() argument
52 this->db = db; in AppLaunchSceneDataProcessor()
202 db->UpdateRecord(record); in SaveCheckPoint()
361 return db->QueryRecord(bundleName); in GetRecord()
366 db->DeleteRecord(bundleName); in DeleteRecord()
387 db in CreateRecord()
[all...]
H A DAnimatorSceneDataProcessor.h36 std::map<int32_t, AnimatorRecord*> db; member in OHOS::HiviewDFX::AnimatorSceneDataProcessor
/base/security/asset/services/core_service/src/operations/
H A Doperation_remove.rs60 let mut db = create_db_instance(query, calling_info)?; variables
61 let results = db.query_datas(&vec![], &db_data, None, true)?;
66 let update_num = db.update_datas(&db_data, true, &update_db_data)?;
73 let remove_num = db.delete_datas(&db_data, Some(&reverse_condition), false)?;
H A Doperation_add.rs47 db: &mut Database, in resolve_conflict()
55 db.replace_datas(query, false, db_data) in resolve_conflict()
61 if db.is_data_exists(&condition, false)? { in resolve_conflict()
63 db.replace_datas(&condition, false, db_data) in resolve_conflict()
159 let mut db = create_db_instance(attributes, calling_info)?; in local_add() variables
161 if db.is_data_exists(&query, false)? { in local_add()
162 resolve_conflict(calling_info, &mut db, attributes, &query, &mut db_data)?; in local_add()
165 let _ = db.insert_datas(&db_data)?; in local_add()
H A Doperation_query.rs42 fn upgrade_version(db: &mut Database, calling_info: &CallingInfo, db_data: &mut DbMap) -> Result<()> { in upgrade_version()
55 let update_num = db.update_datas(&query_data, true, &update_data)?; in upgrade_version()
89 let mut db = create_db_instance(query, calling_info)?; in query_all() variables
90 let mut results = db.query_datas(&vec![], db_data, None, true)?; in query_all()
101 upgrade_version(&mut db, calling_info, &mut results[0])?; in query_all()
143 let mut db = create_db_instance(attrs, calling_info)?; variables
144 let mut results = db.query_datas(&vec![], db_data, Some(&get_query_options(attrs)), true)?;
H A Doperation_update.rs106 let mut db = create_db_instance(query, calling_info)?; variables
107 let results = db.query_datas(&vec![], &query_db_data, None, true)?;
113 let mut results = db.query_datas(&vec![], &query_db_data, None, true)?;
133 let update_num = db.update_datas(&query_db_data, true, &update_db_data)?;
H A Doperation_pre_query.rs51 let mut db = create_db_instance(attrs, calling_info)?; in query_key_attrs() variables
52 let results = db.query_datas(&vec![column::ACCESSIBILITY, column::REQUIRE_PASSWORD_SET], db_data, None, true)?; in query_key_attrs()
/base/startup/hvb/libhvb/src/crypto/
H A Dhvb_rsa_verify.c206 static int emsa_pss_verify_check_db(uint8_t *db, uint32_t db_len, in emsa_pss_verify_check_db() argument
213 if (db[i] != PADDING_UNIT_ZERO) { in emsa_pss_verify_check_db()
218 if (db[db_len - saltlen - PSS_DB_PADDING_LEN] != PADDING_UNIT_ONE) { in emsa_pss_verify_check_db()
238 uint8_t *db = NULL; in emsa_pss_verify() local
265 db = (uint8_t *)hvb_malloc(db_len); /* db is dbmask */ in emsa_pss_verify()
266 if (!db) { in emsa_pss_verify()
269 ret = rsa_gen_mask_mgf_v1(hash, digestlen, db, db_len); in emsa_pss_verify()
273 /* Step 7: calc db, maskedDB ^ db_mask */ in emsa_pss_verify()
275 db[ in emsa_pss_verify()
[all...]
/base/request/request/services/src/manage/
H A Dquery.rs198 let db = RequestDb::get_instance(); in ut_search_user()
201 db.execute(&format!( in ut_search_user()
218 let res = db.search_task(filter, uid); in ut_search_user()
228 let res = db.search_task(filter, uid); in ut_search_user()
238 let res = db.search_task(filter, uid); in ut_search_user()
248 let res = db.search_task(filter, uid); in ut_search_user()
258 let res = db.search_task(filter, uid); in ut_search_user()
268 let res = db.search_task(filter, uid); in ut_search_user()
275 let db = RequestDb::get_instance(); in ut_search_system()
279 db in ut_search_system()
[all...]
/base/sensors/sensor/vibration_convert/core/algorithm/intensity_processor/src/
H A Dintensity_processor.cpp125 std::vector<double> db(blockSum.size(), 0.0); in VolumeInDB()
127 db[i] = VOLUME_DB_COEF * log(blockSum[i]); in VolumeInDB()
128 if (IsLessNotEqual(db[i], 0.0)) { in VolumeInDB()
129 db[i] = 0.0; in VolumeInDB()
132 return db; in VolumeInDB()
/base/request/request/services/src/manage/events/
H A Dstop.rs22 let db = RequestDb::get_instance();
23 if let Some(info) = db.get_task_qos_info(task_id) {
H A Dremove.rs22 let db = RequestDb::get_instance();
23 if let Some(info) = db.get_task_qos_info(task_id) {
/base/accesscontrol/sandbox_manager/services/common/database/src/
H A Dstatement.cpp26 Statement::Statement(sqlite3* db, const std::string &sql) : db_(db), sql_(sql) in Statement() argument
28 if (sqlite3_prepare_v2(db, sql.c_str(), sql.size(), &statement_, nullptr) != SQLITE_OK) { in Statement()
/base/security/access_token/services/common/database/src/
H A Dstatement.cpp27 Statement::Statement(sqlite3* db, const std::string& sql) : db_(db), sql_(sql) in Statement() argument
29 if (sqlite3_prepare_v2(db, sql.c_str(), sql.size(), &statement_, nullptr) != SQLITE_OK) { in Statement()
/base/hiviewdfx/hiview/plugins/performance/context/
H A DNormalContext.cpp77 IAppLaunchSceneDb* db = new AppLaunchSceneDbAdapter(); in MakeAppStartMonitor() local
80 AppLaunchSceneDataProcessor* processor = new AppLaunchSceneDataProcessor(db, exec, nullptr, sceneTimer); in MakeAppStartMonitor()

Completed in 10 milliseconds

12