1 /*
2 * Copyright (c) 2023 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
16 #include "statement.h"
17 #include "sandbox_manager_log.h"
18
19 namespace OHOS {
20 namespace AccessControl {
21 namespace SandboxManager {
22 namespace {
23 static constexpr OHOS::HiviewDFX::HiLogLabel LABEL = {LOG_CORE, ACCESSCONTROL_DOMAIN_SANDBOXMANAGER, "Statement"};
24 }
25
Statement(sqlite3 * db,const std::string & sql)26 Statement::Statement(sqlite3* db, const std::string &sql) : db_(db), sql_(sql)
27 {
28 if (sqlite3_prepare_v2(db, sql.c_str(), sql.size(), &statement_, nullptr) != SQLITE_OK) {
29 SANDBOXMANAGER_LOG_ERROR(LABEL, "Cannot prepare, errorMsg: %{public}s", sqlite3_errmsg(db_));
30 }
31 }
32
~Statement()33 Statement::~Statement()
34 {
35 sqlite3_finalize(statement_);
36 statement_ = nullptr;
37 }
38
Bind(const int32_t index,const std::string & text)39 void Statement::Bind(const int32_t index, const std::string &text)
40 {
41 if (index < 0) {
42 SANDBOXMANAGER_LOG_ERROR(LABEL, "input index < 0");
43 return;
44 }
45
46 if (sqlite3_bind_text(statement_, index, text.c_str(), text.size(), SQLITE_TRANSIENT) != SQLITE_OK) {
47 SANDBOXMANAGER_LOG_ERROR(LABEL, "Cannot bind string, errorMsg: %{public}s", sqlite3_errmsg(db_));
48 }
49 }
50
Bind(const int32_t index,int32_t value)51 void Statement::Bind(const int32_t index, int32_t value)
52 {
53 if (index < 0) {
54 SANDBOXMANAGER_LOG_ERROR(LABEL, "input index < 0");
55 return;
56 }
57
58 if (sqlite3_bind_int(statement_, index, value) != SQLITE_OK) {
59 SANDBOXMANAGER_LOG_ERROR(LABEL, "Cannot bind int32_t, errorMsg: %{public}s", sqlite3_errmsg(db_));
60 }
61 }
62
Bind(const int32_t index,int64_t value)63 void Statement::Bind(const int32_t index, int64_t value)
64 {
65 if (index < 0) {
66 SANDBOXMANAGER_LOG_ERROR(LABEL, "input index < 0");
67 return;
68 }
69
70 if (sqlite3_bind_int64(statement_, index, value) != SQLITE_OK) {
71 SANDBOXMANAGER_LOG_ERROR(LABEL, "Cannot bind int64_t, errorMsg: %{public}s", sqlite3_errmsg(db_));
72 }
73 }
74
GetColumnInt(const int32_t column) const75 int32_t Statement::GetColumnInt(const int32_t column) const
76 {
77 return sqlite3_column_int(statement_, column);
78 }
79
GetColumnInt64(const int32_t column) const80 int64_t Statement::GetColumnInt64(const int32_t column) const
81 {
82 return sqlite3_column_int64(statement_, column);
83 }
84
GetColumnString(const int32_t column) const85 std::string Statement::GetColumnString(const int32_t column) const
86 {
87 return std::string(reinterpret_cast<const char*>(sqlite3_column_text(statement_, column)));
88 }
89
GetColumnName(const int32_t column) const90 std::string Statement::GetColumnName(const int32_t column) const
91 {
92 return sqlite3_column_name(statement_, column);
93 }
94
Step()95 Statement::State Statement::Step()
96 {
97 int32_t ret = sqlite3_step(statement_);
98 switch (ret) {
99 case SQLITE_ROW:
100 return Statement::State::ROW;
101 case SQLITE_DONE:
102 return Statement::State::DONE;
103 case SQLITE_BUSY:
104 return Statement::State::BUSY;
105 case SQLITE_MISUSE:
106 return Statement::State::MISUSE;
107 default:
108 return Statement::State::UNKNOWN;
109 }
110 }
111
GetParameterIndex(const std::string & name) const112 int32_t Statement::GetParameterIndex(const std::string &name) const
113 {
114 return sqlite3_bind_parameter_index(statement_, name.c_str());
115 }
116
Bind(const std::string & tableColumnName,const VariantValue & value)117 void Statement::Bind(const std::string &tableColumnName, const VariantValue &value)
118 {
119 int32_t index = GetParameterIndex(":" + tableColumnName);
120 if (value.GetType() == ValueType::TYPE_STRING) {
121 Bind(index, value.GetString());
122 } else if (value.GetType() == ValueType::TYPE_INT) {
123 Bind(index, value.GetInt());
124 } else if (value.GetType() == ValueType::TYPE_INT64) {
125 Bind(index, value.GetInt64());
126 }
127 }
128
Reset()129 int32_t Statement::Reset()
130 {
131 return sqlite3_reset(statement_);
132 }
133
GetColumnCount() const134 int32_t Statement::GetColumnCount() const
135 {
136 return sqlite3_column_count(statement_);
137 }
138
GetValue(const int32_t column,const bool flagInt64) const139 VariantValue Statement::GetValue(const int32_t column, const bool flagInt64) const
140 {
141 int32_t type = sqlite3_column_type(statement_, column);
142 switch (type) {
143 case SQLITE_INTEGER:
144 if (flagInt64) {
145 return VariantValue(GetColumnInt64(column));
146 } else {
147 return VariantValue(GetColumnInt(column));
148 }
149 case SQLITE_TEXT:
150 return VariantValue(GetColumnString(column));
151 default:
152 return VariantValue();
153 }
154 }
155 } // namespace SandboxManager
156 } // namespace AccessControl
157 } // namespace OHOS
158