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
31 namespace OHOS::DataShare {
QueryMetaData(const std::string & bundleName,const std::string & storeName,int32_t userId,int32_t appIndex)32 std::pair<bool, DistributedData::StoreMetaData> DataShareDbConfig::QueryMetaData(
33 const std::string &bundleName, const std::string &storeName, int32_t userId, int32_t appIndex)
34 {
35 DistributedData::StoreMetaData meta;
36 meta.deviceId = DistributedData::DeviceManagerAdapter::GetInstance().GetLocalDevice().uuid;
37 meta.user = std::to_string(userId);
38 meta.bundleName = bundleName;
39 meta.storeId = storeName;
40 meta.instanceId = appIndex;
41 DistributedData::StoreMetaData metaData;
42 bool isCreated = DistributedData::MetaDataManager::GetInstance().LoadMeta(meta.GetKey(), metaData, true);
43 return std::make_pair(isCreated, metaData);
44 }
45
GetMetaData(const DbConfig & dbConfig)46 std::pair<int, DistributedData::StoreMetaData> DataShareDbConfig::GetMetaData(const DbConfig &dbConfig)
47 {
48 auto [success, metaData] = QueryMetaData(
49 dbConfig.bundleName, dbConfig.storeName, dbConfig.userId, dbConfig.appIndex);
50 if (!success) {
51 if (!dbConfig.hasExtension) {
52 return std::pair(NativeRdb::E_DB_NOT_EXIST, metaData);
53 }
54 AAFwk::WantParams wantParams;
55 ExtensionConnectAdaptor::TryAndWait(dbConfig.uri, dbConfig.bundleName, wantParams);
56 auto [succ, meta] = QueryMetaData(dbConfig.bundleName, dbConfig.storeName, dbConfig.userId, dbConfig.appIndex);
57 if (!succ) {
58 return std::pair(NativeRdb::E_DB_NOT_EXIST, meta);
59 }
60 metaData = std::move(meta);
61 }
62 return std::pair(E_OK, metaData);
63 }
64
GetDbConfig(DbConfig & dbConfig)65 std::tuple<int, DistributedData::StoreMetaData, std::shared_ptr<DBDelegate>> DataShareDbConfig::GetDbConfig(
66 DbConfig &dbConfig)
67 {
68 auto [errCode, metaData] = GetMetaData(dbConfig);
69 if (errCode != E_OK) {
70 ZLOGE("DB not exist,bundleName:%{public}s,storeName:%{public}s,user:%{public}d,err:%{public}d,uri:%{public}s",
71 dbConfig.bundleName.c_str(), dbConfig.storeName.c_str(), dbConfig.userId, errCode,
72 URIUtils::Anonymous(dbConfig.uri).c_str());
73 RADAR_REPORT(__FUNCTION__, RadarReporter::SILENT_ACCESS, RadarReporter::PROXY_MATEDATA_EXISTS,
74 RadarReporter::FAILED, RadarReporter::ERROR_CODE, RadarReporter::META_DATA_NOT_EXISTS);
75 return std::make_tuple(errCode, metaData, nullptr);
76 }
77 auto dbDelegate = DBDelegate::Create(metaData, dbConfig.extUri, dbConfig.backup);
78 if (dbDelegate == nullptr) {
79 ZLOGE("Create delegate fail, bundleName:%{public}s, userId:%{public}d, uri:%{public}s",
80 dbConfig.bundleName.c_str(), dbConfig.userId, URIUtils::Anonymous(dbConfig.uri).c_str());
81 return std::make_tuple(E_ERROR, metaData, nullptr);
82 }
83 return std::make_tuple(E_OK, metaData, dbDelegate);
84 }
85 } // namespace OHOS::DataShare
86