| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_check_sync_test.cpp | 229 std::string tableName_ = "DistributedDBCloudCheckSyncTest"; member in __anon8249::DistributedDBCloudCheckSyncTest
261 ASSERT_EQ(delegate_->CreateDistributedTable(tableName_, CLOUD_COOPERATION), DBStatus::OK); in SetUp()
302 tableSchema.name = tableName_; in GetSchema()
303 tableSchema.sharedTableName = tableName_ + "_shared"; in GetSchema()
345 InsertCloudTableRecord(tableName_, begin, count, photoSize, assetIsNull); in InsertCloudTableRecord()
396 string sql = "DELETE FROM " + tableName_ + " WHERE id ='" + std::to_string(id) + "';"; in DeleteUserTableRecord()
403 string sql = "DELETE FROM " + tableName_ + " WHERE id IN ("; in DeleteUserTableRecord()
418 ASSERT_EQ(virtualCloudDb_->DeleteByGid(tableName_, idMap), DBStatus::OK); in DeleteCloudTableRecord()
548 ASSERT_EQ(virtualCloudDb_->DeleteByGid(tableName_, idMap), DBStatus::OK); in DeleteCloudDBData()
560 CheckCloudTableCount(tableName_, in SetForkQueryForCloudPrioritySyncTest007()
[all...] |
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 115 std::string tableName_ = "DistributedDBCloudAssetsOperationSyncTest"; member in __anon8248::DistributedDBCloudAssetsOperationSyncTest
118 .tableName = tableName_, .extendColName = "name", .trackerColNames = {"age"}
146 ASSERT_EQ(delegate_->CreateDistributedTable(tableName_, CLOUD_COOPERATION), DBStatus::OK); in SetUp()
186 tableSchema.name = tableName_; in GetSchema()
187 tableSchema.sharedTableName = tableName_ + "_shared"; in GetSchema()
281 ASSERT_EQ(virtualCloudDb_->BatchUpdate(tableName_, std::move(record), extend), DBStatus::OK); in UpdateCloudTableRecord()
318 std::string sql = "UPDATE " + tableName_ + " SET assets = NULL WHERE id = 0;"; in ForkDownloadAndRemoveAsset()
362 InsertUserTableRecord(tableName_, 0, actualCount); in HWTEST_F()
363 std::string tableName = tableName_; in HWTEST_F()
366 std::string sql = "DELETE FROM " + tableName_ in HWTEST_F()
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | tracker_table.cpp | 24 tableName_ = schema.tableName; in Init()
31 return tableName_; in GetTableName()
101 attrStr += R"("NAME": ")" + tableName_ + "\","; in ToString()
145 return DBConstant::RELATIONAL_PREFIX + tableName_ + "_ON_" + TriggerMode::GetTriggerModeString(mode) + "_TEMP"; in GetTempTriggerName()
151 std::string sql = "CREATE TEMP TRIGGER IF NOT EXISTS " + DBConstant::RELATIONAL_PREFIX + tableName_; in GetTempInsertTriggerSql()
152 sql += "_ON_INSERT_TEMP AFTER INSERT ON " + DBConstant::RELATIONAL_PREFIX + tableName_ + "_log"; in GetTempInsertTriggerSql()
157 sql += CloudStorageUtils::GetCursorIncSqlWhenAllow(tableName_) + "\n"; in GetTempInsertTriggerSql()
159 sql += CloudStorageUtils::GetCursorIncSql(tableName_) + "\n"; in GetTempInsertTriggerSql()
161 sql += "UPDATE " + DBConstant::RELATIONAL_PREFIX + tableName_ + "_log" + " SET "; in GetTempInsertTriggerSql()
162 sql += "cursor=" + CloudStorageUtils::GetSelectIncCursorSql(tableName_) in GetTempInsertTriggerSql()
[all...] |
| H A D | table_info.cpp | 219 return tableName_; in GetTableName()
224 tableName_ = tableName; in SetTableName()
319 return !tableName_.empty(); in IsValid()
440 if (!DBCommon::CaseInsensitiveCompare(tableName_, inTableInfo.GetTableName())) { in CompareWithTable()
673 attrStr += R"("NAME": ")" + tableName_ + "\","; in ToTableInfoString()
737 return tableName_.empty() || fields_.empty(); in Empty()
747 if (tableName_ != trackerTable_.GetTableName()) { in CheckTrackerTable()
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_command.cpp | 103 tableName_ = tableName; in SetTableName()
152 if (tableName_.empty()) { in GetTableName()
156 return tableName_; in GetTableName()
269 tableName_ = cmdObj.at(oprnType_); in ParseTableName()
271 tableName_ = cmdObj.at(OperationType::UNKNOWN_TYPE); in ParseTableName()
273 tableName_ = MEDIALIBRARY_TABLE; in ParseTableName()
276 tableName_ = MEDIALIBRARY_TABLE; in ParseTableName()
280 MEDIA_DEBUG_LOG("smart table name is %{public}s", tableName_.c_str()); in ParseTableName()
288 tableName_ = GetDistTable(tableName_, networkI in ParseTableName()
[all...] |
| /foundation/multimedia/ringtone_library/services/ringtone_data_extension/src/ |
| H A D | ringtone_data_command.cpp | 29 : uri_(uri), tableName_(table), oprnType_(type) in RingtoneDataCommand()
66 absRdbPredicates_ = make_unique<RdbPredicates>(tableName_); in GetAbsRdbPredicates()
73 return tableName_; in GetTableName()
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | abs_rdb_predicates.cpp | 29 tableName_ = "";
in AbsRdbPredicates()
33 tableName_ = std::move(tableName);
in AbsRdbPredicates()
34 predicates_.tables_.push_back(tableName_);
in AbsRdbPredicates()
40 tableName_ = "";
in AbsRdbPredicates()
44 tableName_ = *(tables.begin());
in AbsRdbPredicates()
137 return tableName_;
in GetTableName()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | query_sync_object.cpp | 144 len += isTableNameSpecified_ ? Parcel::GetStringLen(tableName_) : 0; in CalculateIdentifyLen()
182 (void)parcel.WriteString(tableName_); in GetIdentify()
232 (void)parcel.WriteString(tableName_); in SerializeData()
374 len += Parcel::GetStringLen(tableName_); in CalculateLen()
393 return tableName_; in GetRelationTableName()
|
| H A D | query_object.cpp | 83 tableName_ = queryExpressions.GetTableName(); in QueryObject()
135 orderByCounts_, isValid_, hasOrderBy_, hasLimit_, hasPrefixKey_, tableName_, isTableNameSpecified_, sortType_}; in GetQueryHelper()
471 const auto &tableInfo = schemaObj.GetTable(tableName_);
495 tableName_ = tableName;
501 return tableName_;
|
| H A D | sqlite_query_helper.h | 43 std::string tableName_; member
94 return tableName_; in GetTableName()
168 std::string tableName_; member in DistributedDB::final
|
| H A D | sqlite_query_helper.cpp | 142 tableName_(info.tableName_), in SqliteQueryHelper()
330 sql = PRE_QUERY_ITEM_SQL + tableName_ + " WHERE hash_key=? AND (flag&0x01=0) "; in GetSyncDataCheckSql()
531 PRE_QUERY_COUNT_ITEM_SQL : PRE_QUERY_ITEM_SQL) + tableName_ + " ", FILTER_REMOTE_QUERY); in GetSyncDataQuerySql()
932 sql = GetSelectAndFromClauseForRDB(tableName_, fieldNames); in GetRelationalMissQuerySql()
951 sql = AssembleSqlForSuggestIndex(GetSelectAndFromClauseForRDB(tableName_, fieldNames), GetFlagClauseForRDB()); in GetRelationalSyncDataQuerySql()
1047 sql += " FROM '" + tableName_ + "' AS a INNER JOIN "; in GetRelationalSyncDataQuerySqlWithLimit()
1048 sql += DBConstant::RELATIONAL_PREFIX + tableName_ + "_log"; in GetRelationalSyncDataQuerySqlWithLimit()
1182 sql += CloudStorageUtils::GetLeftJoinLogSql(tableName_, false); in AppendCloudQuery()
1225 sql += CloudStorageUtils::GetLeftJoinLogSql(tableName_, fals in AppendCloudGidQuery()
[all...] |
| H A D | query_object.h | 80 std::string tableName_ = "sync_data"; member in DistributedDB::QueryObject
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_continue_token.cpp | 22 : isGettingDeletedData_(false), queryObj_(queryObject), tableName_(queryObj_.GetTableName()), timeRange_(timeRange) in SQLiteSingleVerRelationalContinueToken()
146 std::string tableName = DBConstant::RELATIONAL_PREFIX + tableName_ + "_log"; in GetDeletedDataSQL()
|
| H A D | sqlite_single_ver_relational_continue_token.h | 57 const std::string &tableName_; member in DistributedDB::SQLiteSingleVerRelationalContinueToken
|
| /foundation/multimedia/ringtone_library/services/ringtone_data_extension/include/ |
| H A D | ringtone_data_command.h | 64 std::string tableName_; member in OHOS::Media::RingtoneDataCommand
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/relational/ |
| H A D | tracker_table.h | 59 std::string tableName_; member in DistributedDB::TrackerTable
|
| H A D | table_info.h | 143 std::string tableName_; member in DistributedDB::TableInfo
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | query_expression.cpp | 74 tableName_("sync_data"), // default kv type store table name in QueryExpression()
276 tableName_ = tableName; in SetTableName()
282 return tableName_; in GetTableName()
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/include/ |
| H A D | medialibrary_command.h | 96 std::string tableName_; member in OHOS::Media::MediaLibraryCommand
|
| /foundation/multimedia/media_library/frameworks/services/media_scanner/src/scanner/ |
| H A D | metadata.cpp | 467 tableName_ = tableName; in SetTableName()
472 return tableName_; in GetTableName()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_db_proxy.h | 130 std::string tableName_; member in DistributedDB::CloudDBProxy::CloudActionContext
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/include/ |
| H A D | query_expression.h | 174 std::string tableName_; member in DistributedDB::final
|
| /foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/ |
| H A D | abs_rdb_predicates.h | 328 std::string tableName_;
member in OHOS::NativeRdb::AbsRdbPredicates
|
| /foundation/filemanagement/dfs_service/services/clouddisk_database/include/ |
| H A D | clouddisk_rdbstore.h | 99 std::string tableName_ = FileColumn::FILES_TABLE; member in OHOS::FileManagement::CloudDisk::final
|
| /foundation/multimedia/media_library/frameworks/services/media_scanner/include/scanner/ |
| H A D | metadata.h | 241 std::string tableName_; member in OHOS::Media::Metadata
|