flink table api 写入数据到tidb

Flink Table API是Apache Flink提供的一种高级SQL接口，它允许用户以SQL的形式进行流处理和批处理任务的操作。将Flink Table API的数据写入TiDB（开源的关系型数据库）需要几个步骤：

1. **设置连接**: 首先，你需要在Flink环境中配置一个连接到TiDB的JDBC URL，例如 `jdbc:mysql://<TiDB地址>:<端口>/<数据库名>`。

2. **创建TableSource**: 使用`CREATE TABLE`语句定义一个从TiDB读取的表，比如：

   CREATE TABLE my_tdb_table (
       id INT,
       name STRING
   ) WITH (
       'connector' = 'jdbc',
       'url' = '<your TiDB JDBC URL>',
       'table-name' = '<your TiDB table name>'
   );

3. **执行SQL查询**: 在Flink SQL或Table API中，你可以执行SQL查询来获取数据，然后通过`INSERT INTO`语句将其写入TiDB：

   INSERT INTO my_output_table
   SELECT * FROM my_tdb_table;

或者使用`Sink`函数，如`Flink.tableEnvironment.executeSql("INSERT INTO ...")`。

4. **执行作业**: 最后，提交作业让Flink将数据写入TiDB。