修改bug

This commit is contained in:
hekaiyu 2025-11-21 16:53:10 +08:00
parent 3598d3f230
commit 259604d42a

View File

@ -251,10 +251,10 @@ public class SyncDataJob implements Job {
String sql; String sql;
// 构建完整的SQL语句 // 构建完整的SQL语句
if (SourceDataTypeEnum.ORACLE.getKey().equals(dbType)) { if (SourceDataTypeEnum.ORACLE.getKey().equals(dbType)) {
sql = "DELETE FROM \"" + stasSyncStrategy.getSourceOwner().toUpperCase() + "\".\"" + sql = "DELETE FROM \"" + stasSyncStrategy.getTargetOwner().toUpperCase() + "\".\"" +
stasSyncStrategy.getTableName() + "\" WHERE " + whereClause; stasSyncStrategy.getTableName() + "\" WHERE " + whereClause;
} else { } else {
sql = "DELETE FROM \"" + stasSyncStrategy.getSourceOwner().toLowerCase() + "\".\"" + sql = "DELETE FROM \"" + stasSyncStrategy.getTargetOwner().toLowerCase() + "\".\"" +
stasSyncStrategy.getTableName() + "\" WHERE " + whereClause; stasSyncStrategy.getTableName() + "\" WHERE " + whereClause;
} }