1 /*
2 * Copyright (c) 2024 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15 #define LOG_TAG "DataShareDbConfig"
16
17 #include "data_share_db_config.h"
18
19 #include <tuple>
20 #include <utility>
21
22 #include "datashare_errno.h"
23 #include "datashare_radar_reporter.h"
24 #include "device_manager_adapter.h"
25 #include "extension_connect_adaptor.h"
26 #include "log_print.h"
27 #include "metadata/meta_data_manager.h"
28 #include "uri_utils.h"
29 #include "utils/anonymous.h"
30 #include "ipc_skeleton.h"
31
32 namespace OHOS::DataShare {
QueryMetaData(const std::string & bundleName,const std::string & storeName,int32_t userId,int32_t appIndex)33 std::pair<bool, DistributedData::StoreMetaData> DataShareDbConfig::QueryMetaData(
34 const std::string &bundleName, const std::string &storeName, int32_t userId, int32_t appIndex)
35 {
36 TimeoutReport timeoutReport({bundleName, "", storeName, __FUNCTION__, 0});
37 DistributedData::StoreMetaData meta;
38 meta.deviceId = DistributedData::DeviceManagerAdapter::GetInstance().GetLocalDevice().uuid;
39 meta.user = std::to_string(userId);
40 meta.bundleName = bundleName;
41 meta.storeId = storeName;
42 meta.instanceId = appIndex;
43 DistributedData::StoreMetaData metaData;
44 bool isCreated = DistributedData::MetaDataManager::GetInstance().LoadMeta(meta.GetKey(), metaData, true);
45 auto callingPid = IPCSkeleton::GetCallingPid();
46 timeoutReport.Report(std::to_string(userId), callingPid, appIndex);
47 return std::make_pair(isCreated, metaData);
48 }
49
GetMetaData(const DbConfig & dbConfig)50 std::pair<int, DistributedData::StoreMetaData> DataShareDbConfig::GetMetaData(const DbConfig &dbConfig)
51 {
52 auto [success, metaData] = QueryMetaData(
53 dbConfig.bundleName, dbConfig.storeName, dbConfig.userId, dbConfig.appIndex);
54 if (!success) {
55 if (!dbConfig.hasExtension) {
56 return std::pair(NativeRdb::E_DB_NOT_EXIST, metaData);
57 }
58 AAFwk::WantParams wantParams;
59 ExtensionConnectAdaptor::TryAndWait(dbConfig.uri, dbConfig.bundleName, wantParams);
60 auto [succ, meta] = QueryMetaData(dbConfig.bundleName, dbConfig.storeName, dbConfig.userId, dbConfig.appIndex);
61 if (!succ) {
62 return std::pair(NativeRdb::E_DB_NOT_EXIST, meta);
63 }
64 metaData = std::move(meta);
65 }
66 return std::pair(E_OK, metaData);
67 }
68
GetDbConfig(DbConfig & dbConfig)69 std::tuple<int, DistributedData::StoreMetaData, std::shared_ptr<DBDelegate>> DataShareDbConfig::GetDbConfig(
70 DbConfig &dbConfig)
71 {
72 auto [errCode, metaData] = GetMetaData(dbConfig);
73 if (errCode != E_OK) {
74 ZLOGE("DB not exist,bundleName:%{public}s,storeName:%{public}s,user:%{public}d,err:%{public}d,uri:%{public}s",
75 dbConfig.bundleName.c_str(), dbConfig.storeName.c_str(), dbConfig.userId, errCode,
76 URIUtils::Anonymous(dbConfig.uri).c_str());
77 RADAR_REPORT(__FUNCTION__, RadarReporter::SILENT_ACCESS, RadarReporter::PROXY_MATEDATA_EXISTS,
78 RadarReporter::FAILED, RadarReporter::ERROR_CODE, RadarReporter::META_DATA_NOT_EXISTS);
79 return std::make_tuple(errCode, metaData, nullptr);
80 }
81 auto dbDelegate = DBDelegate::Create(metaData, dbConfig.extUri, dbConfig.backup);
82 if (dbDelegate == nullptr) {
83 ZLOGE("Create delegate fail, bundleName:%{public}s, userId:%{public}d, uri:%{public}s",
84 dbConfig.bundleName.c_str(), dbConfig.userId, URIUtils::Anonymous(dbConfig.uri).c_str());
85 return std::make_tuple(E_ERROR, metaData, nullptr);
86 }
87 return std::make_tuple(E_OK, metaData, dbDelegate);
88 }
89 } // namespace OHOS::DataShare
90