1 /*
2 * Copyright (c) 2023-2025 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 #include "app_event_dao.h"
16
17 #include "app_event_cache_common.h"
18 #include "app_event_store.h"
19 #include "hiappevent_base.h"
20 #include "hilog/log.h"
21 #include "rdb_helper.h"
22 #include "sql_util.h"
23
24 #undef LOG_DOMAIN
25 #define LOG_DOMAIN 0xD002D07
26
27 #undef LOG_TAG
28 #define LOG_TAG "EventDao"
29
30 namespace OHOS {
31 namespace HiviewDFX {
32 namespace AppEventDao {
33 using namespace AppEventCacheCommon;
Create(NativeRdb::RdbStore & dbStore)34 int Create(NativeRdb::RdbStore& dbStore)
35 {
36 /**
37 * table: events
38 *
39 * |-------|--------|------|------|------|-----|-----|----------|---------|----------|------------|--------|
40 * ------------|
41 * | seq | domain | name | type | tz | pid | tid | trace_id | span_id | pspan_id | trace_flag | params |
42 * running_id |
43 * |-------|--------|------|------|------|-----|-----|----------|---------|----------|------------|--------|
44 * ------------|
45 * | INT64 | TEXT | TEXT | INT | TEXT | INT | INT | INT64 | INT64 | INT64 | INT | TEXT |
46 * TEXT |
47 * |-------|--------|------|------|------|-----|-----|----------|---------|----------|------------|--------|
48 * ------------|
49 */
50 const std::vector<std::pair<std::string, std::string>> fields = {
51 {Events::FIELD_DOMAIN, SqlUtil::SQL_TEXT_TYPE},
52 {Events::FIELD_NAME, SqlUtil::SQL_TEXT_TYPE},
53 {Events::FIELD_TYPE, SqlUtil::SQL_INT_TYPE},
54 {Events::FIELD_TIME, SqlUtil::SQL_INT_TYPE},
55 {Events::FIELD_TZ, SqlUtil::SQL_TEXT_TYPE},
56 {Events::FIELD_PID, SqlUtil::SQL_INT_TYPE},
57 {Events::FIELD_TID, SqlUtil::SQL_INT_TYPE},
58 {Events::FIELD_TRACE_ID, SqlUtil::SQL_INT_TYPE},
59 {Events::FIELD_SPAN_ID, SqlUtil::SQL_INT_TYPE},
60 {Events::FIELD_PSPAN_ID, SqlUtil::SQL_INT_TYPE},
61 {Events::FIELD_TRACE_FLAG, SqlUtil::SQL_INT_TYPE},
62 {Events::FIELD_PARAMS, SqlUtil::SQL_TEXT_TYPE},
63 {Events::FIELD_RUNNING_ID, SqlUtil::SQL_TEXT_TYPE},
64 };
65 std::string sql = SqlUtil::CreateTable(Events::TABLE, fields);
66 return dbStore.ExecuteSql(sql);
67 }
68
Insert(std::shared_ptr<NativeRdb::RdbStore> dbStore,std::shared_ptr<AppEventPack> event,int64_t & seq)69 int Insert(std::shared_ptr<NativeRdb::RdbStore> dbStore, std::shared_ptr<AppEventPack> event, int64_t& seq)
70 {
71 NativeRdb::ValuesBucket bucket;
72 bucket.PutString(Events::FIELD_DOMAIN, event->GetDomain());
73 bucket.PutString(Events::FIELD_NAME, event->GetName());
74 bucket.PutInt(Events::FIELD_TYPE, event->GetType());
75 bucket.PutLong(Events::FIELD_TIME, event->GetTime());
76 bucket.PutString(Events::FIELD_TZ, event->GetTimeZone());
77 bucket.PutInt(Events::FIELD_PID, event->GetPid());
78 bucket.PutInt(Events::FIELD_TID, event->GetTid());
79 bucket.PutLong(Events::FIELD_TRACE_ID, event->GetTraceId());
80 bucket.PutLong(Events::FIELD_SPAN_ID, event->GetSpanId());
81 bucket.PutLong(Events::FIELD_PSPAN_ID, event->GetPspanId());
82 bucket.PutInt(Events::FIELD_TRACE_FLAG, event->GetTraceFlag());
83 bucket.PutString(Events::FIELD_PARAMS, event->GetParamStr());
84 bucket.PutString(Events::FIELD_RUNNING_ID, event->GetRunningId());
85 return dbStore->Insert(seq, Events::TABLE, bucket);
86 }
87
Delete(std::shared_ptr<NativeRdb::RdbStore> dbStore,int64_t eventSeq)88 int Delete(std::shared_ptr<NativeRdb::RdbStore> dbStore, int64_t eventSeq)
89 {
90 NativeRdb::AbsRdbPredicates predicates(Events::TABLE);
91 if (eventSeq > 0) {
92 predicates.EqualTo(Events::FIELD_SEQ, eventSeq);
93 }
94 int deleteRows = 0;
95 int ret = dbStore->Delete(deleteRows, predicates);
96 HILOG_INFO(LOG_CORE, "delete %{public}d records, eventSeq=%{public}" PRId64 ", ret=%{public}d",
97 deleteRows, eventSeq, ret);
98 return ret;
99 }
100
Delete(std::shared_ptr<NativeRdb::RdbStore> dbStore,const std::vector<int64_t> & eventSeqs)101 int Delete(std::shared_ptr<NativeRdb::RdbStore> dbStore, const std::vector<int64_t>& eventSeqs)
102 {
103 if (eventSeqs.empty()) {
104 return NativeRdb::E_OK;
105 }
106 NativeRdb::AbsRdbPredicates predicates(Events::TABLE);
107 std::vector<std::string> eventSeqStrs(eventSeqs.size());
108 std::transform(eventSeqs.begin(), eventSeqs.end(), eventSeqStrs.begin(), [](int64_t eventSeq) {
109 return std::to_string(eventSeq);
110 });
111 predicates.In(Events::FIELD_SEQ, eventSeqStrs);
112
113 int deleteRows = 0;
114 int ret = dbStore->Delete(deleteRows, predicates);
115 HILOG_INFO(LOG_CORE, "delete %{public}d records, ret=%{public}d", deleteRows, ret);
116 return ret;
117 }
118 } // namespace AppEventDao
119 } // namespace HiviewDFX
120 } // namespace OHOS
121