@Override
    public String getDeleteStatement(String tableName, String[] conditionFields) {
        String conditionClause =
                Arrays.stream(conditionFields)
                        .map(f -> format("%s = :%s", quoteIdentifier(f), f))
                        .collect(Collectors.joining(" AND "));
        Pair<String, String> databaseAndTableName = getDatabaseAndTableName(tableName);
        return "ALTER TABLE "
                + quoteIdentifier(databaseAndTableName.getLeft())
                + POINT
                + quoteIdentifier(databaseAndTableName.getRight())
                + " DELETE WHERE " + conditionClause;
    }
Get delete one row statement by condition fields
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialect.java