/base/security/security_guard/test/fuzztest/data_collect/datacollect_fuzzer/ |
H A D | database_mock.cpp | 27 void Database::CreateRdbStore(const NativeRdb::RdbStoreConfig &config, int version, in CreateRdbStore() 33 int Database::Insert(int64_t &outRowId, const std::string &table, const NativeRdb::ValuesBucket &initialValues) in Insert() 38 int Database::BatchInsert(int64_t &outInsertNum, const std::string &table, in BatchInsert() 44 int Database::Update(int &changedRows, const NativeRdb::ValuesBucket &values, in Update() 50 int Database::Delete(int &deletedRows, const NativeRdb::AbsRdbPredicates &predicates) in Delete() 55 std::shared_ptr<NativeRdb::ResultSet> Database::Query( in Query() 61 int Database::ExecuteSql(const std::string &sql) in ExecuteSql() 66 int Database::ExecuteAndGetLong(int64_t &outValue, const std::string &sql, in ExecuteAndGetLong() 72 int Database::Count(int64_t &outValue, const NativeRdb::AbsRdbPredicates &predicates) in Count() 77 int Database [all...] |
H A D | data_collect_fuzzer.cpp | 247 Database database{}; in DatabaseFuzzTest()
|
/base/security/security_guard/services/data_collect/store/src/ |
H A D | database.cpp | 32 void Database::CreateRdbStore(const NativeRdb::RdbStoreConfig &config, int version, in CreateRdbStore() 39 int Database::Insert(int64_t &outRowId, const std::string &table, const NativeRdb::ValuesBucket &initialValues) in Insert() 48 int Database::BatchInsert(int64_t &outInsertNum, const std::string &table, in BatchInsert() 58 int Database::Update(int &changedRows, const NativeRdb::ValuesBucket &values, in Update() 68 int Database::Delete(int &deletedRows, const NativeRdb::AbsRdbPredicates &predicates) in Delete() 77 std::shared_ptr<NativeRdb::ResultSet> Database::Query( in Query() 87 int Database::ExecuteSql(const std::string &sql) in ExecuteSql() 96 int Database::ExecuteAndGetLong(int64_t &outValue, const std::string &sql, in ExecuteAndGetLong() 106 int Database::Count(int64_t &outValue, const NativeRdb::AbsRdbPredicates &predicates) in Count() 115 int Database [all...] |
/base/security/asset/services/db_operator/src/ |
H A D | transaction.rs | 21 use crate::database::Database; 26 db: &'a Database, 31 pub(crate) fn new(db: &'a Database) -> Transaction<'a> {
|
H A D | database_file_upgrade.rs | 28 fmt_backup_path, fmt_de_db_path_with_name, get_db, get_normal_db, get_split_db_lock_by_user_id, Database, 76 fn get_db_before_split(user_id: i32) -> Result<Database> { in get_db_before_split() 98 fn get_new_db(user_id: i32, info_map: &DbMap) -> Result<Database> { in get_new_db() 132 fn calculate_batch_split_times(old_data_query_condition: &DbMap, old_db: &mut Database) -> Result<u32> { in calculate_batch_split_times() 138 old_db: &mut Database, in migrate_data() 139 new_db: &mut Database, in migrate_data()
|
H A D | table.rs | 26 database::Database, 39 pub(crate) db: &'a Database, 197 log_throw_error!(ErrCode::DataCorrupted, "Database is corrupted.") in get_column_info() 201 pub(crate) fn new(table_name: &str, db: &'a Database) -> Table<'a> {
|
H A D | database.rs | 50 /// each user have a Database file 95 pub struct Database { structure names 104 pub type UpgradeDbCallback = fn(db: &Database, old_ver: u32, new_ver: u32) -> Result<()>; 144 pub(crate) fn get_db(user_id: i32, db_name: &str, upgrade_db_version: u32, db_key: Option<&DbKey>) -> Result<Database> { 152 let mut db = Database { path, backup_path, handle: 0, db_lock: lock, db_name: db_name.to_string() }; 160 pub(crate) fn get_normal_db(user_id: i32, db_name: &str, is_ce: bool) -> Result<Database> { 185 pub fn create_db_instance(attributes: &AssetMap, calling_info: &CallingInfo) -> Result<Database> { in create_db_instance() 188 let db = Database::build( in create_db_instance() 197 let db = Database::build( in create_db_instance() 208 impl Database { impls [all...] |
H A D | statement.rs | 25 database::Database, 52 db: &'b Database, 58 pub(crate) fn prepare(sql: &str, db: &'b Database) -> Result<Statement<'b>> {
|
/base/security/asset/services/db_operator/src/test/ |
H A D | test_database.rs | 27 database::Database, 60 fn open_db_and_insert_data() -> Database { in open_db_and_insert_data() 66 Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in open_db_and_insert_data() 81 fn backup_db(db: &Database) { in backup_db() 90 Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in create_and_drop_database() 94 assert!(Database::delete(0, &db.db_name).is_ok()); in create_and_drop_database() 101 let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in database_version() 106 let _ = Database::delete(0, &db.db_name); in database_version() 113 let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in error_sql() 117 let _ = Database in error_sql() [all...] |
H A D | test_table.rs | 22 database::Database, 37 Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in create_delete_table() 53 Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in table_restore() 83 fn insert_test_data() -> Database { in insert_test_data() 86 let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in insert_test_data() 156 let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in single_data() 189 let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in multiple_data() 231 let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in insert_query_row() 261 let db = Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false) in update_delete_row() 289 let db = Database in upgrade_table() [all...] |
/base/security/security_guard/services/data_collect/store/include/ |
H A D | database.h | 28 class Database { class 30 Database() = default; 31 ~Database() = default;
|
H A D | database_helper.h | 23 class DatabaseHelper : public Database {
|
/base/security/security_guard/test/unittest/data_collect/include/ |
H A D | database.h | 28 class Database { class 30 Database() = default; 31 ~Database() = default;
|
H A D | database_helper.h | 23 class DatabaseHelper : public Database {
|
/base/security/asset/services/plugin/src/ |
H A D | asset_plugin.rs | 18 database::{get_path, Database}, 133 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; in add() 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() 147 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; in replace() 154 let mut db = Database::build_with_file_name(self.user_id, &db_name, true).map_err(|e| e.code as u32)?; in ce_replace() 163 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; in query() 174 let mut db = Database::build_with_file_name(self.user_id, &db_name, true).map_err(|e| e.code as u32)?; in ce_query() 185 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; in remove() 196 let mut db = Database::build_with_file_name(self.user_id, &db_name, true).map_err(|e| e.code as u32)?; in ce_remove() 211 let mut db = Database in remove_with_specific_cond() [all...] |
/base/security/asset/services/core_service/src/common_event/ |
H A D | listener.rs | 32 database::Database, 82 Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), false)?; in delete_in_de_db_on_package_removed() 100 Database::build(calling_info.user_id(), calling_info.owner_type_enum(), calling_info.owner_info(), true)?; in delete_in_ce_db_on_package_removed() 314 Database::check_db_accessible(from_path.clone(), user_id, db_name.clone(), None)?; in backup_de_db_if_accessible() 333 Database::check_db_accessible(from_path.clone(), user_id, db_name.clone(), Some(&db_key))?; in backup_ce_db_if_accessible()
|
/base/security/asset/services/core_service/src/operations/ |
H A D | operation_add.rs | 24 database::{create_db_instance, Database}, 47 db: &mut Database, in resolve_conflict()
|
H A D | operation_query.rs | 23 database::{create_db_instance, Database}, 42 fn upgrade_version(db: &mut Database, calling_info: &CallingInfo, db_data: &mut DbMap) -> Result<()> { in upgrade_version()
|