/foundation/resourceschedule/device_usage_statistics/test/unittest/ |
H A D | bundle_active_usage_database_test.cpp | 60 auto database = std::make_shared<BundleActiveUsageDatabase>(); in HWTEST_F() local 63 database->sortedTableArray_ = {{1}}; in HWTEST_F() 64 database->eventTableName_ = "defaultBundleName"; in HWTEST_F() 65 database->bundleHistoryTableName_ = "defaultBundleName"; in HWTEST_F() 66 database->moduleRecordsTableName_ = "defaultBundleName"; in HWTEST_F() 67 database->formRecordsTableName_ = "defaultBundleName"; in HWTEST_F() 69 database->OnPackageUninstalled(userId, bundleName, 0, 0); in HWTEST_F() 70 EXPECT_NE(database, nullptr); in HWTEST_F() 82 auto database = std::make_shared<BundleActiveUsageDatabase>(); in HWTEST_F() local 85 database in HWTEST_F() 99 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 115 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 129 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 143 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 160 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 179 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 197 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 213 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local [all...] |
H A D | device_usage_statistics_service_test.cpp | 307 auto database = std::make_shared<BundleActiveUsageDatabase>(); in HWTEST_F() local 311 database->eventTableName_ = "defaultTableName"; in HWTEST_F() 312 EXPECT_EQ(database->JudgeQueryCondition(beginTime, endTime, eventTableTime), QUERY_CONDITION_INVALID); in HWTEST_F() 316 EXPECT_EQ(database->JudgeQueryCondition(beginTime, endTime, eventTableTime), QUERY_CONDITION_INVALID); in HWTEST_F() 328 auto database = std::make_shared<BundleActiveUsageDatabase>(); in HWTEST_F() local 330 EXPECT_EQ(database->GetSystemEventName(userId), "SYSTEM_LOCK"); in HWTEST_F() 333 EXPECT_EQ(database->GetSystemEventName(userId), "SYSTEM_UNLOCK"); in HWTEST_F() 336 EXPECT_EQ(database->GetSystemEventName(userId), "SYSTEM_SLEEP"); in HWTEST_F() 339 EXPECT_EQ(database->GetSystemEventName(userId), "SYSTEM_WAKEUP"); in HWTEST_F() 342 EXPECT_EQ(database in HWTEST_F() 354 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 373 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 392 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 408 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 424 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 440 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 456 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 471 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 492 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 507 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 524 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 546 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 584 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 607 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 622 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 650 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 1149 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 1166 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 1187 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 1208 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 1231 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 1251 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 1274 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 1303 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 1347 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local 1366 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local [all...] |
H A D | device_usage_statistics_mock_test.cpp | 372 auto database = std::make_shared<BundleActiveUsageDatabase>(); in HWTEST_F() local 376 database->InitUsageGroupDatabase(databaseType, forModuleRecords); in HWTEST_F() 378 database->HandleTableInfo(databaseType); in HWTEST_F() 380 database->GetOverdueTableCreateTime(databaseType, currentTimeMillis); in HWTEST_F() 383 database->GetBundleHistoryData(userId); in HWTEST_F() 385 database->GetDurationData(); in HWTEST_F() 387 database->GetCurrentUsageData(databaseType, userId); in HWTEST_F() 391 database->QueryDatabaseUsageStats(databaseType, beginTime, endTime, userId); in HWTEST_F() 394 database->QueryDatabaseEvents(beginTime, endTime, userId, bundleName); in HWTEST_F() 397 database in HWTEST_F() 417 auto database = std::make_shared<BundleActiveUsageDatabase>(); HWTEST_F() local [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | cloud_test.cpp | 90 SchemaMeta::Database database; in HWTEST_F() local 91 database.name = TEST_CLOUD_STORE; in HWTEST_F() 92 database.alias = "database_alias_test"; in HWTEST_F() 96 schemaMeta.databases.emplace_back(database); in HWTEST_F() 107 EXPECT_EQ(database.alias, database2.alias); in HWTEST_F() 111 EXPECT_NE(database.alias, database3.alias); in HWTEST_F()
|
H A D | cloud_service_impl_test.cpp | 173 SchemaMeta::Database database; in HWTEST_F() local 174 database.name = TEST_CLOUD_STORE; in HWTEST_F() 175 database.alias = TEST_CLOUD_DATABASE_ALIAS_1; in HWTEST_F() 178 schemaMeta.databases.emplace_back(database); in HWTEST_F() 194 DistributedData::Database database; in HWTEST_F() local 195 auto result = cloudServiceImpl_->QueryStatistics(metaData, database); in HWTEST_F()
|
H A D | rdb_general_store_test.cpp | 80 metaData_.dataDir = "/data/service/el1/public/database/" + std::string(BUNDLE_NAME) + "/rdb";
in InitMetaData() 294 DistributedData::Database database;
in HWTEST_F() local 297 auto result = store->Bind(database, bindInfos, config);
in HWTEST_F() 308 result = store->Bind(database, bindInfos, config);
in HWTEST_F() 317 result = store->Bind(database, bindInfos, config);
in HWTEST_F() 324 result = store->Bind(database, bindInfos, config);
in HWTEST_F() 340 DistributedData::Database database;
in HWTEST_F() local 349 auto result = store->Bind(database, bindInfos, config);
in HWTEST_F() 354 result = store->Bind(database, bindInfos, config);
in HWTEST_F() 369 DistributedData::Database database;
in HWTEST_F() local [all...] |
H A D | kvdb_general_store_test.cpp | 78 metaData_.dataDir = "/data/service/el1/public/database/" + std::string(bundleName) + "/kvdb"; in InitMetaData() 316 mkdir(("/data/service/el1/public/database/" + std::string(bundleName)).c_str(), in HWTEST_F() 344 DistributedData::Database database; in HWTEST_F() local 348 auto ret = store->Bind(database, bindInfos, config); in HWTEST_F() 356 ret = store->Bind(database, bindInfos, config); in HWTEST_F() 363 ret = store->Bind(database, bindInfos, config); in HWTEST_F() 371 ret = store->Bind(database, bindInfos, config); in HWTEST_F() 375 ret = store->Bind(database, bindInfos, config); in HWTEST_F() 438 mkdir(("/data/service/el1/public/database/" + std::string(bundleName)).c_str(), in HWTEST_F()
|
H A D | cloud_data_test.cpp | 215 SchemaMeta::Database database; in InitSchemaMeta() local 216 database.name = TEST_CLOUD_STORE; in InitSchemaMeta() 217 database.alias = TEST_CLOUD_DATABASE_ALIAS_1; in InitSchemaMeta() 218 database.tables.emplace_back(table); in InitSchemaMeta() 222 schemaMeta_.databases.emplace_back(database); in InitSchemaMeta() 223 database.alias = TEST_CLOUD_DATABASE_ALIAS_2; in InitSchemaMeta() 224 schemaMeta_.databases.emplace_back(database); in InitSchemaMeta() 364 * @tc.desc: Query the statistics of cloud records in a specified database. 400 * @tc.desc: Query the statistics of all local database cloud records. 1721 SchemaMeta::Database database; in HWTEST_F() local [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/service_impl/ |
H A D | cloud_db.rs | 28 database: Database, 33 /// Initialize a CloudDatabase with user id and database. This function will send IPC request 34 /// with user id to get relating cloud database information. 35 pub fn new(user_id: i32, bundle_name: &str, database: Database) -> SyncResult<CloudDatabase> { in new() 36 let db = ipc_conn::Database::try_from(&database)?; in new() 40 database, in new() 45 /// Execute a sql on the cloud database. Unsupported currently. 55 /// Insert a batch of value buckets into the cloud database, with specific target table name. 88 /// Update a batch of value buckets in the cloud database, with specific target table name. 109 /// Delete a batch of value buckets from the cloud database, wit [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
H A D | schema_meta.cpp | 107 for (const auto &database : databases) { in GetDataBase() 108 if (database.name == storeId) { in GetDataBase() 109 return database; in GetDataBase()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
H A D | cloud_server_impl.cpp | 167 void *database = nullptr; in GetDatabases() local 169 status = OhCloudExtVectorGet(databases.get(), i, &database, reinterpret_cast<unsigned int *>(&dbLen)); in GetDatabases() 170 if (status != ERRNO_SUCCESS || database == nullptr) { in GetDatabases() 173 OhCloudExtDatabase *db = reinterpret_cast<OhCloudExtDatabase *>(database); in GetDatabases() 324 OhCloudExtVector *database = OhCloudExtVectorNew(OhCloudExtRustType::VALUETYPE_DATABASE); in Subscribe() local 325 if (database == nullptr) { in Subscribe() 334 auto status = OhCloudExtVectorPush(database, data.first, data.second); in Subscribe() 341 const_cast<void *>(reinterpret_cast<const void *>(bundle.c_str())), bundle.size(), database, databaseLen); in Subscribe() 542 for (auto &database : databases) { in Unsubscribe() 543 auto it = dbRelation.relations.find(database in Unsubscribe() [all...] |
H A D | cloud_db_impl.h | 32 explicit CloudDbImpl(OhCloudExtCloudDatabase *database);
|
H A D | cloud_db_impl.cpp | 25 CloudDbImpl::CloudDbImpl(OhCloudExtCloudDatabase *database) : database_(database) in CloudDbImpl() argument
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/ |
H A D | mod.rs | 18 mod database; modules 32 pub(crate) use database::DatabaseStub;
|
H A D | database.rs | 33 // Duration for which the cloud database is locked, in seconds. 36 // Session ID for locking the cloud database. 60 database: &Database, 68 .write(database)
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/c_adapter/ |
H A D | cloud_extension.rs | 85 /// Create an CloudAssetLoader instance by bundle name and database pointer. This function only borrows 86 /// database, so this pointer won't be taken by CloudAssetLoader. Users should free it if the database 239 /// Initialize a CloudDatabase instance with bundle name and database. The database passed in will 247 database: *mut OhCloudExtDatabase, 249 if database.is_null() || bundle_name.is_null() { 252 let database = match OhCloudExtDatabase::get_inner(database, SafetyCheckId::Database) { 260 if let Ok(db) = cloud_db::CloudDatabase::new(user_id, bundle_name, database) { [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
H A D | cloud_service_impl.cpp | 218 for (const auto &database : schemaMeta.databases) { in DoClean() 220 meta.storeId = database.name; in DoClean() 430 ZLOGE("GetDbInfoFromExtraData failed, empty database info. traceId:%{public}s.", prepareTraceId.c_str()); in NotifyDataChange() 446 for (auto &database : schemaMeta.databases) { in ExecuteStatistics() 447 if (storeId.empty() || database.alias == storeId) { in ExecuteStatistics() 450 meta.storeId = database.name; in ExecuteStatistics() 460 result.insert_or_assign(database.alias, QueryStatistics(meta, database)); in ExecuteStatistics() 467 const DistributedData::Database &database) in QueryStatistics() 476 infos.reserve(database in QueryStatistics() 466 QueryStatistics(const StoreMetaData &storeMetaData, const DistributedData::Database &database) QueryStatistics() argument [all...] |
H A D | sync_manager.cpp | 300 for (const auto &database : schema.databases) { in GetPostEventTask() 301 if (!info.Contains(database.name)) { in GetPostEventTask() 307 StoreInfo storeInfo = { 0, schema.bundleName, database.name, cloud.apps[schema.bundleName].instanceId, in GetPostEventTask() 319 auto query = info.GenerateQuery(database.name, database.GetTableNames()); in GetPostEventTask() 403 ZLOGI("database:<%{public}d:%{public}s:%{public}s:%{public}s> sync start", storeInfo.user,
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/include/ |
H A D | cloud_extension.h | 51 * Besides, CloudAssetLoader is only valid when the database passed in its initialization 150 OhCloudExtDatabase *database 322 * @brief Pass a batch of subscription orders to a CloudSync pointer, with target database information
|
/foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/ |
H A D | RdbStoreReadOnlyJsunit.test.js | 67 console.error(TAG, `init database failed, errCode:${err.code}, message:${err.message}`); 92 * @tc.name open read-only database if the database is not exist 95 * 2. open read-only database 106 console.error(TAG, `open read-only database failed, errCode:${err.code}, message:${err.message}`); 113 * @tc.name insert data into read-only database 133 * @tc.name update data in read-only database 155 * @tc.name delete data from read-only database 176 * @tc.name execute transaction for read-only database 196 * @tc.name get user_version from read-only database [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
H A D | kvdb_general_store.cpp | 78 static DBSchema GetDBSchema(const Database &database) in GetDBSchema() argument 81 schema.tables.resize(database.tables.size()); in GetDBSchema() 82 for (size_t i = 0; i < database.tables.size(); i++) { in GetDBSchema() 83 const Table &table = database.tables[i]; in GetDBSchema() 228 Database &database, const std::map<uint32_t, BindInfo> &bindInfos, const CloudConfig &config) in Bind() 236 auto dbSchema = GetDBSchema(database); in Bind() 227 Bind( Database &database, const std::map<uint32_t, BindInfo> &bindInfos, const CloudConfig &config) Bind() argument
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
H A D | general_store_mock.h | 24 int32_t Bind(Database &database, const std::map<uint32_t, BindInfo> &bindInfos,
|
H A D | general_store_mock.cpp | 18 int32_t GeneralStoreMock::Bind(Database &database, const std::map<uint32_t, BindInfo> &bindInfos, in Bind() argument
|
/foundation/filemanagement/dfs_service/test/unittests/cloud_disk/mock/ |
H A D | file_operations_cloud_mock.cpp | 205 auto database = instance->GetCloudDatabase(userId, bundleName); in GetDatabase() local 206 if (database == nullptr) { in GetDatabase() 207 LOGE("get cloud file kit database fail"); in GetDatabase() 210 return database; in GetDatabase() 251 LOGE("Failed to get database"); in GenerateCloudId()
|
/foundation/filemanagement/dfs_service/services/cloudfiledaemon/src/fuse_manager/ |
H A D | fuse_manager.cpp | 219 shared_ptr<CloudFile::CloudDatabase> database; member 327 if (!data->database) { in GetDatabase() 334 data->database = instance->GetCloudDatabase(data->userId, PHOTOS_BUNDLE_NAME); in GetDatabase() 335 if (data->database == nullptr) { in GetDatabase() 336 LOGE("get cloud file kit database fail"); in GetDatabase() 340 return data->database; in GetDatabase() 774 shared_ptr<CloudFile::CloudDatabase> database = GetDatabase(data); in CloudOpenHelper() local 778 if (!database) { in CloudOpenHelper() 779 LOGE("database is null"); in CloudOpenHelper() 792 cInode->readSession = database in CloudOpenHelper() [all...] |