| /base/hiviewdfx/hiview/base/utility/ |
| D | sql_util.cpp | 23 std::string sql; in GenerateCreateSql() local
24 sql += "CREATE TABLE IF NOT EXISTS "; in GenerateCreateSql()
25 sql += table; in GenerateCreateSql()
26 sql += "("; in GenerateCreateSql()
27 sql += "id INTEGER PRIMARY KEY AUTOINCREMENT"; // default field: id in GenerateCreateSql()
29 sql += ", "; in GenerateCreateSql()
30 sql += field.first; in GenerateCreateSql()
31 sql += " "; in GenerateCreateSql()
32 sql += field.second; in GenerateCreateSql()
34 sql += ")"; in GenerateCreateSql()
[all …]
|
| /base/security/asset/services/db_operator/src/ |
| D | table.rs | 51 fn build_sql_columns_not_empty(columns: &Vec<&str>, sql: &mut String) { in build_sql_columns_not_empty()
54 sql.push_str(column); in build_sql_columns_not_empty()
56 sql.push(','); in build_sql_columns_not_empty()
62 fn build_sql_columns(columns: &Vec<&str>, sql: &mut String) { in build_sql_columns()
64 build_sql_columns_not_empty(columns, sql); in build_sql_columns()
66 sql.push('*'); in build_sql_columns()
71 fn build_sql_where(conditions: &DbMap, sql: &mut String) { in build_sql_where()
73 sql.push_str(" where "); in build_sql_where()
75 sql.push_str(column_name); in build_sql_where()
76 sql.push_str("=?"); in build_sql_where()
[all …]
|
| D | statement.rs | 51 pub(crate) sql: String, field
58 pub(crate) fn prepare(sql: &str, db: &'b Database) -> Result<Statement<'b>> { in prepare()
60 let mut sql_s = sql.to_string(); in prepare()
62 let mut stmt = Statement { sql: sql_s, handle: 0, db }; in prepare()
66 stmt.sql.as_ptr(), in prepare()
|
| D | database.rs | 35 fn SqliteExec(db: *mut c_void, sql: *const u8, msg: *mut *mut u8) -> i32; in SqliteExec()
163 let sql = format!("pragma user_version = {}", ver); in set_version() localVariable
164 self.exec(sql.as_str()) in set_version()
206 pub(crate) fn exec(&self, sql: &str) -> Result<()> { in exec()
207 let mut sql_s = sql.to_string(); in exec()
|
| /base/security/access_token/services/privacymanager/src/database/ |
| D | permission_used_record_db.cpp | 216 std::string sql = "insert into " + it->second.tableName_ + " values("; in CreateInsertPrepareSqlCmd() local
219 sql.append(":" + name); in CreateInsertPrepareSqlCmd()
221 sql.append(","); in CreateInsertPrepareSqlCmd()
225 sql.append(")"); in CreateInsertPrepareSqlCmd()
226 return sql; in CreateInsertPrepareSqlCmd()
236 std::string sql = "delete from " + it->second.tableName_ + " where 1 = 1"; in CreateDeletePrepareSqlCmd() local
238 sql.append(" and "); in CreateDeletePrepareSqlCmd()
239 sql.append(name + "=:" + name); in CreateDeletePrepareSqlCmd()
241 return sql; in CreateDeletePrepareSqlCmd()
256 std::string sql = "update " + it->second.tableName_ + " set "; in CreateUpdatePrepareSqlCmd() local
[all …]
|
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/utility/ |
| D | sql_util.cpp | 23 …std::string sql = "CREATE TABLE IF NOT EXISTS " + table + "(" + "seq INTEGER PRIMARY KEY AUTOINCRE… in CreateTable() local
25 sql += ", " + field.first + " " + field.second; in CreateTable()
27 sql += ")"; in CreateTable()
28 return sql; in CreateTable()
33 std::string sql = "DROP TABLE IF EXISTS " + table; in DropTable() local
34 return sql; in DropTable()
|
| /base/security/access_token/services/accesstokenmanager/main/cpp/src/database/ |
| D | access_token_db.cpp | 219 std::string sql = "insert into " + it->second.tableName_ + " values("; in CreateInsertPrepareSqlCmd() local
222 sql.append(":" + columnName); in CreateInsertPrepareSqlCmd()
224 sql.append(","); in CreateInsertPrepareSqlCmd()
228 sql.append(")"); in CreateInsertPrepareSqlCmd()
229 return sql; in CreateInsertPrepareSqlCmd()
239 std::string sql = "delete from " + it->second.tableName_ + " where 1 = 1"; in CreateDeletePrepareSqlCmd() local
241 sql.append(" and "); in CreateDeletePrepareSqlCmd()
242 sql.append(columnName + "=:" + columnName); in CreateDeletePrepareSqlCmd()
244 return sql; in CreateDeletePrepareSqlCmd()
259 std::string sql = "update " + it->second.tableName_ + " set "; in CreateUpdatePrepareSqlCmd() local
[all …]
|
| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/src/ |
| D | data_share_dao.cpp | 50 std::string sql; in IsUidExists() local
51 sql.append("SELECT COUNT(*) FROM ").append(eventTable_) in IsUidExists()
55 if (int ret = dbStore->ExecuteAndGetLong(count, sql, objects); ret != NativeRdb::E_OK) { in IsUidExists()
124 std::string sql; in GetEventListByUid() local
125 sql.append("SELECT ") in GetEventListByUid()
130 auto resultSet = dbStore->QuerySql(sql, std::vector<std::string> {std::to_string(uid)}); in GetEventListByUid()
149 std::string sql; in GetUidByBundleName() local
150 sql.append("SELECT ") in GetUidByBundleName()
155 auto resultSet = dbStore->QuerySql(sql, std::vector<std::string> {bundleName}); in GetUidByBundleName()
174 std::string sql; in GetTotalSubscriberInfo() local
[all …]
|
| D | data_share_store.cpp | 41 std::string sql = SqlUtil::GenerateCreateSql(EventTable::TABLE, fields); in OnCreate() local
42 if (int ret = rdbStore.ExecuteSql(sql); ret != NativeRdb::E_OK) { in OnCreate()
73 std::string sql = SqlUtil::GenerateDropSql(tableName); in DropTable() local
74 if (int ret = dbStore->ExecuteSql(sql); ret != NativeRdb::E_OK) { in DropTable()
|
| /base/hiviewdfx/hiview/framework/native/unified_collection/collector/utils/ |
| D | trace_storage.cpp | 81 std::string sql = SqlUtil::GenerateExistSql(TABLE_NAME); in InitDbStore() local
82 auto retSql = dbStore_->ExecuteSql(sql); in InitDbStore()
136 std::string sql; in GetResultItems() local
137 sql.append("SELECT ") in GetResultItems()
143 …std::shared_ptr<NativeRdb::ResultSet> resultSet = dbStore_->QuerySql(sql, std::vector<std::string>… in GetResultItems()
179 std::string sql = SqlUtil::GenerateCreateSql(TABLE_NAME, fields); in CreateTable() local
180 if (dbStore_->ExecuteSql(sql) != NativeRdb::E_OK) { in CreateTable()
181 HIVIEW_LOGE("failed to create table, sql=%{public}s", sql.c_str()); in CreateTable()
|
| /base/update/updateservice/services/firmware/data/db/src/ |
| D | firmware_database_callback.cpp | 31 for (auto &sql : dbCreateSqlVector) { in OnCreate() local
32 int ret = rdbStore.ExecuteSql(sql); in OnCreate()
34 …OGE("FirmwareDatabaseCallback OnCreate create table %{public}s, ret=%{public}d", sql.c_str(), ret); in OnCreate()
|
| /base/telephony/telephony_data/common/src/ |
| D | rdb_base_helper.cpp | 86 int RdbBaseHelper::ExecuteSql(const std::string &sql) in ExecuteSql() argument
90 ret = store_->ExecuteSql(sql); in ExecuteSql()
95 int RdbBaseHelper::ExecuteSql(const std::string &sql, const std::vector<NativeRdb::ValueObject> &bi… in ExecuteSql() argument
99 ret = store_->ExecuteSql(sql, bindArgs); in ExecuteSql()
105 const std::string &sql, const std::vector<std::string> &selectionArgs) in QuerySql() argument
109 return store_->QuerySql(sql); in QuerySql()
|
| /base/hiviewdfx/hiview/base/event_store/dao/ |
| D | sys_event_query_wrapper.cpp | 51 void QueryStatusLogUtil::LogTooManyQueryRules(const std::string sql) in LogTooManyQueryRules() argument
54 info.append(sql); in LogTooManyQueryRules()
66 void QueryStatusLogUtil::LogQueryOverTime(time_t costTime, const std::string sql, bool innerQuery) in LogQueryOverTime() argument
69 info.append(std::to_string(costTime)).append(SPACE_CONCAT).append("SQL=").append(sql); in LogQueryOverTime()
73 void QueryStatusLogUtil::LogQueryCountOverLimit(const int32_t queryCount, const std::string& sql, in LogQueryCountOverLimit() argument
77 info.append(std::to_string(queryCount)).append(SPACE_CONCAT).append("SQL=").append(sql); in LogQueryCountOverLimit()
81 void QueryStatusLogUtil::LogQueryTooFrequently(const std::string& sql, const std::string& processNa… in LogQueryTooFrequently() argument
88 info.append("SQL=").append(sql); in LogQueryTooFrequently()
|
| /base/telephony/telephony_data/opkey/src/ |
| D | rdb_opkey_callback.cpp | 89 std::string sql; in ClearData() local
90 sql.append("delete from ").append(TABLE_OPKEY_INFO); in ClearData()
91 return rdbStore.ExecuteSql(sql); in ClearData()
|
| /base/telephony/telephony_data/sms_mms/src/ |
| D | rdb_sms_mms_helper.cpp | 238 std::string sql; in QueryMaxGroupId() local
240 sql.append("select MAX(").append(SmsMmsInfo::GROUP_ID).append(") as "); in QueryMaxGroupId()
241 sql.append(maxGroupId).append(" from ") .append(TABLE_SMS_MMS_INFO); in QueryMaxGroupId()
242 return QuerySql(sql); in QueryMaxGroupId()
247 std::string sql; in StatisticsUnRead() local
248 sql.append("select count(*) as totalListCount, "); in StatisticsUnRead()
249 …sql.append("count(CASE WHEN ").append(SmsMmsInfo::MSG_TYPE).append("=0 THEN 1 ELSE null END) as un… in StatisticsUnRead()
250 …sql.append("count(CASE WHEN ").append(SmsMmsInfo::MSG_TYPE).append("=1 THEN 1 ELSE null END) as un… in StatisticsUnRead()
251 …sql.append(" from ").append(TABLE_SMS_MMS_INFO).append(" WHERE ").append(SmsMmsInfo::IS_READ).appe… in StatisticsUnRead()
252 return QuerySql(sql); in StatisticsUnRead()
|
| /base/security/access_token/services/common/database/src/ |
| D | statement.cpp | 27 Statement::Statement(sqlite3* db, const std::string& sql) : db_(db), sql_(sql) in Statement() argument
29 if (sqlite3_prepare_v2(db, sql.c_str(), sql.size(), &statement_, nullptr) != SQLITE_OK) { in Statement()
|
| D | sqlite_helper.cpp | 140 Statement SqliteHelper::Prepare(const std::string& sql) const in Prepare()
142 return Statement(db_, sql); in Prepare()
145 int32_t SqliteHelper::ExecuteSql(const std::string& sql) const in ExecuteSql()
153 int32_t res = sqlite3_exec(db_, sql.c_str(), nullptr, nullptr, &errorMessage); in ExecuteSql()
|
| /base/security/access_token/services/common/database/include/ |
| D | sqlite_helper.h | 40 Statement Prepare(const std::string& sql) const;
41 int32_t ExecuteSql(const std::string& sql) const;
|
| /base/usb/usb_manager/services/native/src/ |
| D | usb_right_database.cpp | 169 int32_t UsbRightDataBase::ExecuteSql(const std::string &sql, const std::vector<OHOS::NativeRdb::Val… in ExecuteSql() argument
175 int32_t ret = store_->ExecuteSql(sql, bindArgs); in ExecuteSql()
184 const std::string &sql, const std::vector<std::string> &selectionArgs) in QuerySql() argument
190 return store_->QuerySql(sql); in QuerySql()
205 std::string sql = CREATE_USB_RIGHT_TABLE; in OnCreate() local
206 int32_t ret = store.ExecuteSql(sql); in OnCreate()
|
| /base/telephony/telephony_data/common/include/ |
| D | rdb_base_helper.h | 52 …const std::string &sql, const std::vector<std::string> &selectionArgs = std::vector<std::string>()…
55 int ExecuteSql(const std::string &sql);
56 int ExecuteSql(const std::string &sql, const std::vector<NativeRdb::ValueObject> &bindArgs);
|
| /base/hiviewdfx/hiview/base/event_store/include/ |
| D | sys_event_query_wrapper.h | 93 static void LogTooManyQueryRules(const std::string sql);
95 static void LogQueryOverTime(time_t costTime, const std::string sql, bool innerQuery = true);
96 static void LogQueryCountOverLimit(const int32_t queryCount, const std::string& sql,
98 …static void LogQueryTooFrequently(const std::string& sql, const std::string& processName = std::st…
|
| /base/telephony/telephony_data/global_params/src/ |
| D | rdb_global_params_callback.cpp | 130 std::string sql; in ClearData() local
131 sql.append("delete from").append(tableName); in ClearData()
132 return rdbStore.ExecuteSql(sql); in ClearData()
|
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/cache/ |
| D | app_event_mapping_dao.cpp | 55 std::string sql = SqlUtil::CreateTable(TABLE, fields); in Create() local
56 if (dbStore_->ExecuteSql(sql) != NativeRdb::E_OK) { in Create()
|
| /base/usb/usb_manager/services/native/include/ |
| D | usb_right_database.h | 60 int32_t ExecuteSql(const std::string &sql,
63 const std::string &sql, const std::vector<std::string> &selectionArgs);
|
| /base/telephony/telephony_data/sim/src/ |
| D | rdb_sim_helper.cpp | 173 std::string sql; in ClearData() local
174 sql.append("delete from ").append(TABLE_SIM_INFO); in ClearData()
175 return ExecuteSql(sql); in ClearData()
|