Flink CDC里如何把这个新的sqlStatment返回出去？

在Flink CDC中，你可以通过以下步骤将新的SQL语句返回出去：

1. 首先，你需要创建一个StatementSetter接口的实现类。这个接口有一个方法setSqlStatement，你可以在这里设置你的SQL语句。

public class MyStatementSetter implements StatementSetter {
    private String sql;

    @Override
    public void setSqlStatement(String sql) {
        this.sql = sql;
    }

    public String getSql() {
        return sql;
    }
}

1. 然后，你需要在你的Flink CDC程序中创建一个DebeziumSourceFunction实例，并传入你的StatementSetter实现类的实例。

DebeziumSourceFunction<String> sourceFunction = new DebeziumSourceFunction<>(
    configuration,
    new MyStatementSetter(),
    tableIdentification,
    deserializer,
    databaseHistory,
    handleEventsMethod,
    handleQueryRequestMethod);

1. 最后，你可以在你的handleEventsMethod或者handleQueryRequestMethod方法中获取到你的SQL语句。

@Override
public void handleEvents(Collection<Row> rows, long timestamp) {
    for (Row row : rows) {
        String sql = myStatementSetter.getSql();
        // do something with the sql statement
    }
}

@Override
public void handleQueryRequest(long timestamp, String sql) {
    String sqlStatement = myStatementSetter.getSql();
    // do something with the sql statement
}

这样，你就可以在你的Flink CDC程序中获取到新的SQL语句了。