| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_data_transformer_test.cpp | 82 logInfo.dataKey = i; in GenerateTableDataWithLog()
89 if (origin.dataKey != target.dataKey) { in Equal()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 24 int CloudSyncUtils::GetCloudPkVals(const VBucket &datum, const std::vector<std::string> &pkColNames, int64_t dataKey, in GetCloudPkVals() argument
35 cloudPkVals.emplace_back(dataKey); in GetCloudPkVals()
184 cloudLogInfo.dataKey = 0; in GetCloudLogInfo()
203 ret = CloudSyncUtils::GetCloudPkVals(localInfo.primaryKeys, changedData.field, localInfo.logInfo.dataKey, in SaveChangedDataByType()
206 ret = CloudSyncUtils::GetCloudPkVals(datum, changedData.field, localInfo.logInfo.dataKey, cloudPkVals); in SaveChangedDataByType()
588 // use dataIndex as dataKey avoid get same pk with no pk schema in CalOpType()
|
| H A D | cloud_sync_utils.h | 35 static int GetCloudPkVals(const VBucket &datum, const std::vector<std::string> &pkColNames, int64_t dataKey,
|
| H A D | cloud_syncer.cpp | 790 param.downloadData.data[idx], param.pkColNames, dataInfo.localInfo.logInfo.dataKey, pkVals); in HandleTagAssets()
1779 param.downloadData.existDataKey[index] = logInfo.logInfo.dataKey; in GetLocalInfo()
|
| H A D | cloud_syncer_extend.cpp | 464 logInfo.dataKey = DBConstant::DEFAULT_ROW_ID; in CommitDownloadAssets()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.h | 319 int64_t dataKey);
390 int RemoveDataAndLog(const std::string &tableName, int64_t dataKey);
424 int64_t dataKey, OpType opType);
442 bool IsNeedUpdateAssetId(const TableSchema &tableSchema, int64_t dataKey, const VBucket &vBucket);
447 int UpdateAssetId(const TableSchema &tableSchema, int64_t dataKey, const VBucket &vBucket);
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 1043 int SQLiteSingleVerRelationalStorageExecutor::RemoveDataAndLog(const std::string &tableName, int64_t dataKey) in RemoveDataAndLog() argument
1047 std::to_string(dataKey); in RemoveDataAndLog()
1054 std::to_string(dataKey); in RemoveDataAndLog()
1493 const TableSchema &tableSchema, const VBucket &vBucket, int64_t dataKey, OpType opType) in OnlyUpdateAssetId()
1503 if (!IsNeedUpdateAssetId(tableSchema, dataKey, vBucket)) { in OnlyUpdateAssetId()
1506 int errCode = UpdateAssetId(tableSchema, dataKey, vBucket); in OnlyUpdateAssetId()
1623 int SQLiteSingleVerRelationalStorageExecutor::UpdateAssetId(const TableSchema &tableSchema, int64_t dataKey, in UpdateAssetId() argument
1652 updateAssetIdSql += " WHERE " + std::string(DBConstant::SQLITE_INNER_ROWID) + " = " + std::to_string(dataKey) + ";"; in UpdateAssetId()
1731 if (logInfo.cloudGid.empty() && logInfo.dataKey == DBConstant::DEFAULT_ROW_ID) { in UpdateRecordFlag()
1492 OnlyUpdateAssetId(const std::string &tableName, const TableSchema &tableSchema, const VBucket &vBucket, int64_t dataKey, OpType opType) OnlyUpdateAssetId() argument
|
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 92 logInfo.dataKey = sqlite3_column_int64(statement, index++); in GetLogInfoByStatement()
644 const TrackerTable &trackerTable, int64_t dataKey) in InsertCloudData()
647 if (dataKey > 0) { in InsertCloudData()
648 errCode = RemoveDataAndLog(tableSchema.name, dataKey); in InsertCloudData()
1313 bool SQLiteSingleVerRelationalStorageExecutor::IsNeedUpdateAssetId(const TableSchema &tableSchema, int64_t dataKey, in IsNeedUpdateAssetId() argument
1335 std::to_string(dataKey) + ";"; in IsNeedUpdateAssetId()
643 InsertCloudData(VBucket &vBucket, const TableSchema &tableSchema, const TrackerTable &trackerTable, int64_t dataKey) InsertCloudData() argument
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 543 logInfo.dataKey = sqlite3_column_int64(logStatement, 0); // 0 means dataKey index in GetLogData()
817 SQLiteUtils::BindInt64ToStatement(statement, 1, rowid); // 1 means dataKey index in SaveSyncLog()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | data_transformer.h | 31 int64_t dataKey = -1; member
|
| /foundation/graphic/graphic_2d/frameworks/vulkan_layers/swapchain_layer/ |
| H A D | swapchain_layer.cpp | 134 LayerData* GetLayerDataPtr(DispatchKey dataKey) in GetLayerDataPtr() argument
137 auto it = g_layerDataMap.find(dataKey); in GetLayerDataPtr()
140 g_layerDataMap[dataKey] = layerData; in GetLayerDataPtr()
147 void FreeLayerDataPtr(DispatchKey dataKey) in FreeLayerDataPtr() argument
149 auto it = g_layerDataMap.find(dataKey); in FreeLayerDataPtr()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 1129 bool isDeleted = logInfo.dataKey == DBConstant::DEFAULT_ROW_ID; in GetUpdateRecordFlagSql()
1150 sql += " data_key = '" + std::to_string(logInfo.dataKey) + "'"; in GetUpdateRecordFlagSql()
1165 bool isDeleted = logInfo.dataKey == DBConstant::DEFAULT_ROW_ID; in GetUpdateRecordFlagSqlUpload()
1188 sql += " data_key = '" + std::to_string(logInfo.dataKey) + "'"; in GetUpdateRecordFlagSqlUpload()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | object_manager_test.cpp | 762 std::string dataKey = prefix + "_p_data"; in HWTEST_F() local
766 result.insert({dataKey, value0}); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_relational_sync_test.cpp | 759 virtualRowData.logInfo.dataKey = 3; // 3 fake datakey in operator ()()
979 virtualRowData.logInfo.dataKey = 4; // 4 fake datakey in operator ()()
|
| H A D | distributeddb_interfaces_relational_test.cpp | 1181 rowData.logInfo.dataKey = rowid; in operator ()()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1847 downloadData.existDataKey.push_back(dataInfoWithLog.logInfo.dataKey); in UpsertDataInTransaction()
1918 logInfo.dataKey = rowId; in UpdateRecordFlagAfterUpload()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_asset_compare_test.cpp | 1038 dataInfo.localInfo.logInfo.dataKey = 1; in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_executor_utils.cpp | 358 dataInfoWithLog.logInfo.dataKey = sqlite3_column_int64(stmt, index++); in FillLogInfoWithStmt()
|