| /ohos5.0/base/security/asset/services/db_operator/src/ |
| H A D | table.rs | 75 sql.push_str(column); in build_sql_columns_not_empty()
77 sql.push(','); in build_sql_columns_not_empty()
87 sql.push('*'); in build_sql_columns()
94 sql.push_str(" where "); in build_sql_where()
120 sql.push('?'); in build_sql_values()
122 sql.push(','); in build_sql_values()
219 self.db.exec(&sql) in delete()
233 sql.push(' '); in create_with_version()
242 sql.push(',') in create_with_version()
245 sql.push_str(");"); in create_with_version()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | tracker_table.cpp | 70 return sql; in GetDiffTrackerValSql()
89 return sql; in GetDiffIncCursorSql()
155 sql += "BEGIN\n"; in GetTempInsertTriggerSql()
167 sql += "\nEND;"; in GetTempInsertTriggerSql()
168 return sql; in GetTempInsertTriggerSql()
177 sql += "BEGIN\n"; in GetTempUpdateTriggerSql()
192 sql += "\nEND;"; in GetTempUpdateTriggerSql()
193 return sql; in GetTempUpdateTriggerSql()
206 return sql; in GetTempDeleteTriggerSql()
225 sql += "\nEND;"; in GetTempDeleteTriggerSql()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_query_helper.cpp | 109 return sql; in GetSelectAndFromClauseForRDB()
302 sql = !hasPrefixKey_ ? sql : (sql + " AND (key>=? AND key<=?) "); in GetQuerySql()
303 sql = keys_.empty() ? sql : (sql + " AND " + MapKeysInToSql(keys_.size())); in GetQuerySql()
331 sql = keys_.empty() ? sql : (sql + " AND " + MapKeysInToSql(keys_.size())); in GetSyncDataCheckSql()
392 sql = !hasPrefixKey_ ? sql : (sql + " AND (key>=? AND key<=?) "); in GetCountQuerySql()
393 sql = keys_.empty() ? sql : (sql + " AND " + MapKeysInToSql(keys_.size())); in GetCountQuerySql()
530 sql = !hasPrefixKey_ ? sql : (sql + " AND (key>=? AND key<=?) "); in GetSyncDataQuerySql()
531 sql = keys_.empty() ? sql : (sql + " AND " + MapKeysInToSql(keys_.size())); in GetSyncDataQuerySql()
532 sql = hasSubQuery ? sql : (sql + " AND (timestamp>=? AND timestamp<?) "); in GetSyncDataQuerySql()
950 sql = hasSubQuery ? sql : (sql + GetTimeRangeClauseForRDB()); in GetRelationalSyncDataQuerySql()
[all …]
|
| H A D | sqlite_single_ver_storage_executor_cache.cpp | 129 std::string sql; in GetMinVersionCacheData() local
161 std::string sql; in MigrateRmDevData() local
230 std::string sql; in GetMaxVersionInCacheDb() local
232 sql = GET_MAX_VER_CACHEDATA_FROM_MAINHANDLE; in GetMaxVersionInCacheDb()
310 std::string sql; in CheckDataWithQuery() local
311 DBCommon::VectorToString(item.value, sql); in CheckDataWithQuery()
428 std::string sql; in DelCacheDbDataByVersion() local
462 std::string sql; in VacuumLocalData() local
600 std::string sql; in GetExpandedCheckSql() local
602 errCode = helper.GetSyncDataCheckSql(sql); in GetExpandedCheckSql()
[all …]
|
| /ohos5.0/base/hiviewdfx/hiview/base/utility/ |
| H A D | sql_util.cpp | 23 std::string sql; in GenerateCreateSql() local
25 sql += table; in GenerateCreateSql()
26 sql += "("; in GenerateCreateSql()
29 sql += ", "; in GenerateCreateSql()
31 sql += " "; in GenerateCreateSql()
34 sql += ")"; in GenerateCreateSql()
35 return sql; in GenerateCreateSql()
41 return sql; in GenerateExistSql()
46 std::string sql; in GenerateDropSql() local
48 sql += table; in GenerateDropSql()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | sqlite_sql_builder.cpp | 45 std::string sql; in BuildDeleteString() local
48 return sql; in BuildDeleteString()
59 std::string sql; in BuildUpdateString() local
80 return sql; in BuildUpdateString()
94 std::string sql; in BuildQueryString() local
106 outSql = sql; in BuildQueryString()
117 std::string sql; in BuildCountString() local
121 return sql; in BuildCountString()
245 return sql; in BuildCursorQueryString()
287 return sql; in BuildCursorQueryString()
[all …]
|
| H A D | trans_db.cpp | 43 std::string sql("INSERT"); in Insert() local
49 sql.append(split).append(key); in Insert()
58 sql.append(") VALUES ("); in Insert()
63 sql.append(")"); in Insert()
116 std::string sql("UPDATE"); in Update() local
122 sql.append(split); in Update()
128 sql.append(key).append("=?"); in Update()
135 sql.append(" WHERE ").append(where); in Update()
158 std::string sql; in Delete() local
159 sql.append("DELETE FROM ").append(table); in Delete()
[all …]
|
| H A D | rdb_store_impl.cpp | 174 std::string sql; in GetModifyTime() local
176 sql.append(logTable); in GetModifyTime()
179 sql.append(")"); in GetModifyTime()
191 std::string sql; in GetModifyTimeByRowId() local
196 sql.append(")"); in GetModifyTimeByRowId()
773 std::string sql; in GetHashKeyForLockRow() local
964 std::string sql; in Insert() local
985 sql.append(")"); in Insert()
1065 std::string sql; in Update() local
1109 std::string sql; in Delete() local
[all …]
|
| H A D | rdb_store.cpp | 225 std::string sql; in Query() local
227 orderBy, limit, offset, sql); in Query()
231 return QuerySql(sql, args); in Query()
236 std::string sql; in Query() local
250 return QuerySql(sql, ToValues(args)); in QuerySql()
255 return QueryByStep(sql, ToValues(args)); in QueryByStep()
261 std::string sql; in QueryByStep() local
303 auto [errCode, value] = Execute(sql, args); in ExecuteAndGetLong()
312 auto [errCode, value] = Execute(sql, args); in ExecuteAndGetString()
321 auto [errCode, value] = Execute(sql, args); in ExecuteForLastInsertedRowId()
[all …]
|
| /ohos5.0/base/security/access_token/services/privacymanager/src/database/ |
| H A D | permission_used_record_db.cpp | 389 sql.append(")"); in CreateInsertPrepareSqlCmd()
390 return sql; in CreateInsertPrepareSqlCmd()
407 return sql; in CreateQueryPrepareSqlCmd()
422 return sql; in CreateDeletePrepareSqlCmd()
454 return sql; in CreateUpdatePrepareSqlCmd()
496 sql.append("0)"); in CreateSelectByConditionPrepareSqlCmd()
500 return sql; in CreateSelectByConditionPrepareSqlCmd()
510 return sql; in CreateCountPrepareSqlCmd()
539 sql.append(" )"); in CreateDeleteExpireRecordsPrepareSqlCmd()
540 return sql; in CreateDeleteExpireRecordsPrepareSqlCmd()
[all …]
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_backup_extension/src/restore/ |
| H A D | gallery_db_upgrade.cpp | 62 int32_t ret = store.ExecuteSql(sql); in AddPhotoQualityOfGalleryMedia()
67 sql.c_str()); in AddPhotoQualityOfGalleryMedia()
82 int32_t ret = store.ExecuteSql(sql); in AddRelativeBucketIdOfGalleryAlbum()
87 sql.c_str()); in AddRelativeBucketIdOfGalleryAlbum()
106 int32_t ret = store.ExecuteSql(sql); in GarbageAlbumCheckOrAddRelativeBucketId()
110 sql.c_str()); in GarbageAlbumCheckOrAddRelativeBucketId()
122 int32_t ret = store.ExecuteSql(sql); in GarbageAlbumCheckOrAddType()
134 int32_t ret = store.ExecuteSql(sql); in AddIndexOfGalleryAlbum()
138 sql.c_str()); in AddIndexOfGalleryAlbum()
147 int32_t ret = store.ExecuteSql(sql); in AddIndexOfAlbumPlugin()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_ext_test.cpp | 212 std::string sql; in PrepareData() local
723 std::string sql; variable
786 std::string sql = "begin;"; variable
793 sql = "commit;";
806 sql = "begin;";
812 sql = "rollback;";
928 ExecSqlAndWaitForObserver(db, sql, lock);
939 ExecSqlAndWaitForObserver(db, sql, lock);
1470 sql += "PRIMARY KEY (id, name));"; in CreateTableForStoreObserver()
1476 std::string sql = "begin;"; in PrepareDataForStoreObserver() local
[all …]
|
| H A D | distributeddb_interfaces_relational_tracker_table_test.cpp | 120 sql.pop_back(); in BatchUpdateTableName2Data()
121 sql += " where id = "; in BatchUpdateTableName2Data()
1263 condition.sql = querySql;
1272 condition.sql = querySql;
1281 condition.sql = querySql;
1312 condition.sql = querySql;
1378 condition.sql = delSql;
1387 condition.sql = insSql;
1571 condition.sql = delSql;
1609 condition.sql = "BEGIN";
[all …]
|
| H A D | distributeddb_cloud_interfaces_reference_test.cpp | 314 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), SQLITE_OK);
344 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), SQLITE_OK);
381 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), SQLITE_OK);
438 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), SQLITE_OK); in NormalSetReferenceTest()
513 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), SQLITE_OK); in ReferenceChangeTest()
608 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), SQLITE_OK);
612 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), SQLITE_OK);
684 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), SQLITE_OK);
690 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), SQLITE_OK);
770 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), SQLITE_OK);
[all …]
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | database.rs | 146 let sql = format!( in contains_task() localVariable
161 let sql = format!( in query_task_token_id() localVariable
220 let sql = format!( in insert_task() localVariable
289 let sql = format!( in clear_invalid_records() localVariable
308 let sql = format!( in update_task() localVariable
317 let sql = format!( in update_task_state() localVariable
328 let sql = format!( in update_task_sizes() localVariable
466 let sql = format!( in delete_early_records() localVariable
501 let sql = format!( in get_task_qos_info() localVariable
546 let sql = format!( in get_app_task_qos_infos() localVariable
[all …]
|
| /ohos5.0/foundation/communication/netmanager_base/services/netstatsmanager/src/ |
| H A D | net_stats_database_helper.cpp | 112 int32_t ret = statement_.Prepare(sqlite_, sql); in InsertData()
146 int32_t ret = statement_.Prepare(sqlite_, sql); in SelectData()
246 std::string sql = in QueryData() local
297 std::string sql = in DeleteData() local
299 return ExecSql(sql, nullptr, sqlCallback); in DeleteData()
329 std::string sql = "DELETE FROM " + tableName; in ClearData() local
341 sql = "VACUUM"; in ClearData()
436 ret = ExecSql(sql, nullptr, sqlCallback); in ExecTableUpgrade()
451 ret = ExecSql(sql, nullptr, sqlCallback); in ExecTableUpgrade()
500 return ExecSql(sql, nullptr, sqlCallback); in UpdateTableVersion()
[all …]
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_file_operations.cpp | 416 sql += "SELECT "; in BuildCompatQuerySql()
457 sql = "SELECT "; in BuildQueryFileSql()
463 sql += " FROM ("; in BuildQueryFileSql()
465 sql += " UNION "; in BuildQueryFileSql()
467 sql += " UNION "; in BuildQueryFileSql()
469 sql += ") "; in BuildQueryFileSql()
472 sql += groupBy; in BuildQueryFileSql()
475 sql += having; in BuildQueryFileSql()
485 sql += orderBy; in BuildQueryFileSql()
489 sql += limit; in BuildQueryFileSql()
[all …]
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/photo_album_operation/ |
| H A D | photo_album_merge_operation.cpp | 66 int32_t ret = this->rdbStorePtr_->ExecuteSql(sql, bindArgs); in DeleteDuplicateRelationshipInPhotoMap()
69 sql.c_str(), in DeleteDuplicateRelationshipInPhotoMap()
82 std::string sql = this->SQL_PHOTO_MAP_MOVE_RELATIONSHIP_UPDATE; in UpdateRelationshipInPhotoMap() local
84 int32_t ret = this->rdbStorePtr_->ExecuteSql(sql, bindArgs); in UpdateRelationshipInPhotoMap()
87 sql.c_str(), in UpdateRelationshipInPhotoMap()
100 std::string sql = this->SQL_PHOTOS_MOVE_RELATIONSHIP_UPDATE; in UpdateRelationshipInPhotos() local
102 int32_t ret = this->rdbStorePtr_->ExecuteSql(sql, bindArgs); in UpdateRelationshipInPhotos()
105 sql.c_str(), in UpdateRelationshipInPhotos()
118 std::string sql = this->SQL_PHOTO_ALBUM_DELETE; in DeleteOldAlbum() local
120 int32_t ret = this->rdbStorePtr_->ExecuteSql(sql, bindArgs); in DeleteOldAlbum()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/ |
| H A D | storage_fuzzer.cpp | 125 const std::string sql = "PRAGMA journal_mode=WAL;"; in CreateDB() local
263 RdbTestUtils::ExecSql(db, sql); in CreateTableForStoreObserver()
265 RdbTestUtils::ExecSql(db, sql); in CreateTableForStoreObserver()
267 sql += "PRIMARY KEY (id, name));"; in CreateTableForStoreObserver()
268 RdbTestUtils::ExecSql(db, sql); in CreateTableForStoreObserver()
275 RdbTestUtils::ExecSql(db, sql); in InitLogicDeleteData()
278 RdbTestUtils::ExecSql(db, sql); in InitLogicDeleteData()
287 RdbTestUtils::ExecSql(db, sql); in InitDataStatus()
293 RdbTestUtils::ExecSql(db, sql); in InitDataStatus()
301 SQLiteUtils::GetStatement(db, sql, stmt); in GetHashKey()
[all …]
|
| /ohos5.0/base/security/access_token/services/accesstokenmanager/main/cpp/src/database/ |
| H A D | access_token_open_callback.cpp | 44 sql.append(" (") in CreateHapTokenInfoTable()
73 return rdbStore.ExecuteSql(sql); in CreateHapTokenInfoTable()
82 sql.append(" (") in CreateNativeTokenInfoTable()
101 return rdbStore.ExecuteSql(sql); in CreateNativeTokenInfoTable()
110 sql.append(" (") in CreatePermissionDefinitionTable()
141 return rdbStore.ExecuteSql(sql); in CreatePermissionDefinitionTable()
150 sql.append(" (") in CreatePermissionStateTable()
171 return rdbStore.ExecuteSql(sql); in CreatePermissionStateTable()
180 sql.append(" (") in CreatePermissionRequestToggleStatusTable()
193 return rdbStore.ExecuteSql(sql); in CreatePermissionRequestToggleStatusTable()
[all …]
|
| /ohos5.0/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/utility/ |
| H A 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()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 65 querySql = sql; in GetQueryInfoSql()
76 sql.pop_back(); in GetFillDownloadAssetStatement()
584 std::string sql; in CleanTrackerData() local
831 std::string sql; in GetReferenceGidSql() local
833 sql += "("; in GetReferenceGidSql()
844 sql.pop_back(); in GetReferenceGidSql()
858 return sql; in GetReferenceGidSql()
1010 std::string sql; in GetCloudDeleteSql() local
1028 return sql; in GetCloudDeleteSql()
1461 sql.pop_back(); in GetAndBindFillUploadAssetStatement()
[all …]
|
| /ohos5.0/base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/src/ |
| H A 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()
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
175 sql.append("SELECT ") in GetTotalSubscriberInfo()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/ |
| H A D | rdb_store_impl.h | 44 … std::shared_ptr<AbsSharedResultSet> QuerySql(const std::string &sql, const Values &args) override;
46 int ExecuteSql(const std::string &sql, const Values &args) override;
48 int ExecuteAndGetLong(int64_t &outValue, const std::string &sql, const Values &args) override;
49 …int ExecuteAndGetString(std::string &outValue, const std::string &sql, const Values &args) overrid…
51 …int ExecuteForChangedRowCount(int64_t &outValue, const std::string &sql, const Values &args) overr…
102 int ExecuteByTrxId(const std::string &sql, int64_t trxId, bool closeConnAfterExecute = false,
105 const std::string &sql, const ValueObject &object, int sqlType);
106 int CheckAttach(const std::string &sql);
107 std::pair<int32_t, Stmt> BeginExecuteSql(const std::string &sql);
116 std::pair<int32_t, Stmt> GetStatement(const std::string& sql, bool read = false) const;
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 113 std::string sql; in PrepareDataBase() local
122 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), E_OK); in PrepareDataBase()
135 sql = "insert into " + tableName + "(id, name, age)" \ in PrepareDataBase()
139 sql = "insert into " + tableName + "(id, name)" \ in PrepareDataBase()
143 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), E_OK); in PrepareDataBase()
173 std::string sql = in PrepareDataBaseForAsset() local
175 EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), E_OK); in PrepareDataBaseForAsset()
1267 std::string sql; in DeleteWithPkTest() local
1342 sql = "drop table t_cloud;";
1358 sql = "drop table t_device;";
[all …]
|