@Override
    public void executeUpdate(Connection connection)  {
        rows.forEach(row -> {
            try {
                setRecordToStatement(statement, fieldTypes, row);
                statement.executeUpdate();
                connection.commit();
            } catch (Exception e) {
               dealExecuteError(
                   connection,
                   e,
                   metricOutputFormat,
                   row,
                   errorLimit,
                   LOG
               );
            }
        });
        rows.clear();
    }
Append mode retract/delete message will not execute
@param record
@throws SQLException
rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/writer/AppendOnlyWriter.java