| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | split_device_log_table_manager.cpp | 40 std::string logTblName = DBConstant::RELATIONAL_PREFIX + table.GetTableName() + "_log"; in GetInsertTrigger()
42 insertTrigger += "naturalbase_rdb_" + table.GetTableName() + "_ON_INSERT AFTER INSERT \n"; in GetInsertTrigger()
43 insertTrigger += "ON '" + table.GetTableName() + "'\n"; in GetInsertTrigger()
58 std::string logTblName = DBConstant::RELATIONAL_PREFIX + table.GetTableName() + "_log"; in GetUpdateTrigger()
60 updateTrigger += "naturalbase_rdb_" + table.GetTableName() + "_ON_UPDATE AFTER UPDATE \n"; in GetUpdateTrigger()
61 updateTrigger += "ON '" + table.GetTableName() + "'\n"; in GetUpdateTrigger()
65 … updateTrigger += "\t UPDATE " + DBConstant::RELATIONAL_PREFIX + table.GetTableName() + "_log"; in GetUpdateTrigger()
89 deleteTrigger += "naturalbase_rdb_" + table.GetTableName() + "_ON_DELETE BEFORE DELETE \n"; in GetDeleteTrigger()
90 deleteTrigger += "ON '" + table.GetTableName() + "'\n"; in GetDeleteTrigger()
92 deleteTrigger += "\t UPDATE " + DBConstant::RELATIONAL_PREFIX + table.GetTableName() + "_log"; in GetDeleteTrigger()
[all …]
|
| H A D | collaboration_log_table_manager.cpp | 50 std::string logTblName = DBConstant::RELATIONAL_PREFIX + table.GetTableName() + "_log"; in GetInsertTrigger()
52 insertTrigger += "naturalbase_rdb_" + table.GetTableName() + "_ON_INSERT AFTER INSERT \n"; in GetInsertTrigger()
53 insertTrigger += "ON '" + table.GetTableName() + "'\n"; in GetInsertTrigger()
70 std::string logTblName = DBConstant::RELATIONAL_PREFIX + table.GetTableName() + "_log"; in GetUpdateTrigger()
72 updateTrigger += "naturalbase_rdb_" + table.GetTableName() + "_ON_UPDATE AFTER UPDATE \n"; in GetUpdateTrigger()
73 updateTrigger += "ON '" + table.GetTableName() + "'\n"; in GetUpdateTrigger()
79 … updateTrigger += "\t UPDATE " + DBConstant::RELATIONAL_PREFIX + table.GetTableName() + "_log"; in GetUpdateTrigger()
104 deleteTrigger += "naturalbase_rdb_" + table.GetTableName() + "_ON_DELETE BEFORE DELETE \n"; in GetDeleteTrigger()
105 deleteTrigger += "ON '" + table.GetTableName() + "'\n"; in GetDeleteTrigger()
109 deleteTrigger += "\t UPDATE " + DBConstant::RELATIONAL_PREFIX + table.GetTableName() + "_log"; in GetDeleteTrigger()
[all …]
|
| H A D | simple_tracker_log_table_manager.cpp | 64 std::string tableName = table.GetTableName(); in GetInsertTrigger()
93 std::string tableName = table.GetTableName(); in GetUpdateTrigger()
121 std::string tableName = table.GetTableName(); in GetDeleteTrigger()
144 std::string tableName = table.GetTableName(); in GetDropTriggers()
|
| H A D | cloud_sync_log_table_manager.cpp | 94 std::string tableName = table.GetTableName(); in GetInsertTrigger()
129 std::string tableName = table.GetTableName(); in GetUpdateTrigger()
159 std::string tableName = table.GetTableName(); in GetDeleteTrigger()
193 std::string tableName = table.GetTableName(); in GetDropTriggers()
|
| H A D | sqlite_single_relational_storage_engine.cpp | 207 if (DBCommon::CaseInsensitiveCompare(schema.GetTable(tableName).GetTableName(), tableName)) { in CreateDistributedTable()
253 bool isUpgraded = schema.GetTable(sharedTableName).GetTableName() == sharedTableName; in CreateDistributedSharedTable()
319 std::string tableName = table.GetTableName(); in CreateDistributedTable()
562 const std::string trackerTableName = iter.second.GetTrackerTable().GetTableName(); in GetOrInitTrackerSchemaFromMeta()
618 … if (strcasecmp(sourceTableInfo.GetTableName().c_str(), reference.sourceTableName.c_str()) != 0 || in CheckReference()
619 … strcasecmp(targetTableInfo.GetTableName().c_str(), reference.targetTableName.c_str()) != 0) { in CheckReference()
701 !DBCommon::CaseInsensitiveCompare(schema.GetTable(tableName).GetTableName(), tableName)) { in CleanTrackerData()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_multistages_capture/src/ |
| H A D | multistages_capture_manager.cpp | 38 if (predicates.GetTableName() != PhotoColumn::PHOTOS_TABLE) { in RemovePhotos()
39 MEDIA_INFO_LOG("Invalid table name: %{public}s", predicates.GetTableName().c_str()); in RemovePhotos()
43 NativeRdb::AbsRdbPredicates predicatesNew(predicates.GetTableName()); in RemovePhotos()
83 if (predicates.GetTableName() != PhotoColumn::PHOTOS_TABLE) { in RestorePhotos()
84 MEDIA_INFO_LOG("Invalid table name: %{public}s", predicates.GetTableName().c_str()); in RestorePhotos()
88 NativeRdb::AbsRdbPredicates predicatesNew(predicates.GetTableName()); in RestorePhotos()
|
| /ohos5.0/base/update/updateservice/services/core/ability/sqlite/core/include/ |
| H A D | table_base_operator.h | 50 std::string GetTableName();
79 return dataBase_->Insert(GetTableName(), dbValues); in Insert()
92 NativeRdb::RdbPredicates predicates(GetTableName()); in DeleteAll()
114 OHOS::NativeRdb::RdbPredicates predicates(GetTableName()); in DeleteById()
123 OHOS::NativeRdb::RdbPredicates predicates(GetTableName()); in QueryAll()
157 std::string TableBaseOperator<Table, T>::GetTableName() in GetTableName() function
163 return table_->GetTableName(); in GetTableName()
|
| /ohos5.0/base/update/updateservice/services/firmware/data/db/src/ |
| H A D | firmware_component_operator.cpp | 28 OHOS::NativeRdb::RdbPredicates predicates(GetTableName()); in UpdateProgressByUrl()
38 OHOS::NativeRdb::RdbPredicates predicates(GetTableName()); in UpdateUrlByVersionId()
46 OHOS::NativeRdb::RdbPredicates predicates(GetTableName()); in QueryByVersionId()
58 OHOS::NativeRdb::RdbPredicates predicates(GetTableName()); in QueryByUrl()
|
| H A D | firmware_task_table_empty.cpp | 20 std::string FirmwareTaskTable::GetTableName() in GetTableName() function in OHOS::UpdateEngine::FirmwareTaskTable
|
| H A D | firmware_component_table_empty.cpp | 21 std::string FirmwareComponentTable::GetTableName() in GetTableName() function in OHOS::UpdateEngine::FirmwareComponentTable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_data_inserter.cpp | 59 TableInfo localTable = localSchema.GetTable(query.GetTableName()); in CreateInserter()
63 inserter.SetInsertTableName(localTable.GetTableName()); in CreateInserter()
65 …SetInsertTableName(DBCommon::GetDistributedTableName(deviceName, localTable.GetTableName(), info)); in CreateInserter()
178 …std::string sql = "DELETE FROM " + DBConstant::RELATIONAL_PREFIX + localTable_.GetTableName() + "_… in GetDeleteLogStmt()
195 …" IN (SELECT data_key FROM " + DBConstant::RELATIONAL_PREFIX + localTable_.GetTableName() + "_log … in GetDeleteSyncDataStmt()
210 const std::string tableName = DBConstant::RELATIONAL_PREFIX + query_.GetTableName() + "_log"; in GetSaveLogStatement()
|
| /ohos5.0/foundation/multimedia/ringtone_library/services/ringtone_data_extension/src/ |
| H A D | ringtone_data_manager.cpp | 126 if (cmd.GetTableName().compare(SIMCARD_SETTING_TABLE) == 0) { in Insert()
198 NativeRdb::RdbPredicates rdbPredicate = RdbUtils::ToPredicates(predicates, cmd.GetTableName()); in Delete()
202 if (cmd.GetTableName().compare(SIMCARD_SETTING_TABLE) == 0) { in Delete()
245 NativeRdb::RdbPredicates rdbPredicate = RdbUtils::ToPredicates(predicates, cmd.GetTableName()); in Update()
277 NativeRdb::RdbPredicates rdbPredicate = RdbUtils::ToPredicates(predicates, cmd.GetTableName()); in Query()
350 RINGTONE_INFO_LOG("openfile table %{public}s", cmd.GetTableName().c_str()); in OpenFile()
351 if (cmd.GetTableName() == RINGTONE_TABLE) { in OpenFile()
|
| H A D | ringtone_rdbstore.cpp | 108 int32_t ret = rdbStore_->Insert(rowId, cmd.GetTableName(), cmd.GetValueBucket()); in Insert()
128 int32_t ret = rdbStore_->Delete(deletedRows, cmd.GetTableName(), predicates->GetWhereClause(), in Delete()
146 int32_t ret = rdbStore_->Update(changedRows, cmd.GetTableName(), cmd.GetValueBucket(), in Update()
|
| /ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/src/rdb/ |
| H A D | rdb_data_manager.cpp | 75 if (absRdbPredicates.GetTableName() != amsRdbConfig_.tableName) { in UpdateData()
90 if (absRdbPredicates.GetTableName() != amsRdbConfig_.tableName) { in DeleteData()
106 if (absRdbPredicates.GetTableName() != amsRdbConfig_.tableName) { in QueryData()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_rdb_transaction.cpp | 256 auto [ret, rows] = transaction_->Insert(cmd.GetTableName(), cmd.GetValueBucket()); in Insert()
274 if (predicates.GetTableName() == PhotoColumn::PHOTOS_TABLE) { in Update()
311 if (cmd.GetTableName() == PhotoColumn::PHOTOS_TABLE) { in Update()
319 auto res = transaction_->Update(cmd.GetTableName(), cmd.GetValueBucket(), in Update()
358 auto [ret, rows] = transaction_->BatchInsert(cmd.GetTableName(), values); in BatchInsert()
393 string tableName = predicates.GetTableName(); in DoDeleteFromPredicates()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_relational_ver_sync_db_interface.cpp | 92 optTableDataWithLog.tableName = query.GetTableName(); in PutSyncDataWithQuery()
109 syncData_[query.GetTableName()][GetStr(virtualRowData.logInfo.hashKey)] = virtualRowData; in PutSyncDataWithQuery()
128 if (localData_.find(query.GetTableName()) == localData_.end()) { in GetSyncData()
133 TableDataWithLog tableDataWithLog = {query.GetTableName(), {}}; in GetSyncData()
134 for (const auto &[hashKey, virtualData] : localData_[query.GetTableName()]) { in GetSyncData()
|
| /ohos5.0/base/update/updateservice/services/firmware/data/db/include/ |
| H A D | firmware_task_table.h | 67 std::string GetTableName() final;
72 std::string GetTableName();
|
| H A D | firmware_component_table.h | 69 std::string GetTableName() final;
74 std::string GetTableName();
|
| /ohos5.0/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/rdb/ |
| H A D | rdb_data_manager.cpp | 204 if (absRdbPredicates.GetTableName() != bmsRdbConfig_.tableName) { in UpdateData()
222 if (absRdbPredicates.GetTableName() != bmsRdbConfig_.tableName) { in UpdateOrInsertData()
260 if (absRdbPredicates.GetTableName() != bmsRdbConfig_.tableName) { in DeleteData()
310 if (absRdbPredicates.GetTableName() != bmsRdbConfig_.tableName) { in QueryData()
420 if (absRdbPredicates.GetTableName() != bmsRdbConfig_.tableName) { in QueryByStep()
|
| /ohos5.0/base/telephony/telephony_data/opkey/src/ |
| H A D | opkey_ability.cpp | 167 …Rdb::RdbPredicates rdbPredicates = ConvertPredicates(absRdbPredicates->GetTableName(), predicates); in Query()
215 …NativeRdb::RdbPredicates rdbPredicates = ConvertPredicates(absRdbPredicates->GetTableName(), predi… in Update()
242 …Rdb::RdbPredicates rdbPredicates = ConvertPredicates(absRdbPredicates->GetTableName(), predicates); in Delete()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_db_proxy.cpp | 314 status = cloudDb->BatchInsert(context->GetTableName(), std::move(record), extend); in DMLActionTask()
320 status = cloudDb->BatchUpdate(context->GetTableName(), std::move(record), extend); in DMLActionTask()
326 status = cloudDb->BatchDelete(context->GetTableName(), extend); in DMLActionTask()
407 std::string tableName = context->GetTableName(); in InnerActionGetEmptyCursor()
453 DBStatus status = cloudDb->Query(context->GetTableName(), queryExtend, data); in QueryAction()
627 std::string CloudDBProxy::CloudActionContext::GetTableName() in GetTableName() function in DistributedDB::CloudDBProxy::CloudActionContext
|
| /ohos5.0/base/telephony/telephony_data/sim/src/ |
| H A D | sim_ability.cpp | 163 …Rdb::RdbPredicates rdbPredicates = ConvertPredicates(absRdbPredicates->GetTableName(), predicates); in Query()
205 ConvertPredicates(absRdbPredicates->GetTableName(), predicates); in Update()
282 …Rdb::RdbPredicates rdbPredicates = ConvertPredicates(absRdbPredicates->GetTableName(), predicates); in Delete()
|
| /ohos5.0/base/telephony/telephony_data/pdp_profile/src/ |
| H A D | pdp_profile_ability.cpp | 223 …result = helper_.Query(ConvertPredicates(absRdbPredicates->GetTableName(), preferapnPredicates), c… in Query()
225 … result = QueryPdpProfile(tempUri, absRdbPredicates->GetTableName(), predicates, columns); in Query()
282 …NativeRdb::RdbPredicates rdbPredicates = ConvertPredicates(absRdbPredicates->GetTableName(), predi… in Update()
347 …Rdb::RdbPredicates rdbPredicates = ConvertPredicates(absRdbPredicates->GetTableName(), predicates); in Delete()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_store.cpp | 182 …return Update(changedRows, predicates.GetTableName(), row, predicates.GetWhereClause(), predicates… in Update()
218 …return Delete(deletedRows, predicates.GetTableName(), predicates.GetWhereClause(), predicates.GetB… in Delete()
239 std::string table = predicates.GetTableName(); in Query()
263 std::string table = predicates.GetTableName(); in QueryByStep()
|
| H A D | sqlite_sql_builder.cpp | 219 std::string tableName = predicates.GetTableName(); in BuildQueryString()
235 std::string tableName = predicates.GetTableName(); in BuildCountString()
243 std::string table = predicates.GetTableName(); in BuildCursorQueryString()
294 std::string table = predicates.GetTableName(); in BuildLockRowQueryString()
|