flink sink方式使用preparestatment的batchexequte

Flink的Sink操作通常用于将处理后的数据流持久化到外部存储系统，如数据库、文件系统等。`BatchExecution`下的`preparedStatement`是在批处理作业期间使用PreparedStatement（预编译语句）进行数据写入的一种常见做法。这种方法可以提高性能，因为预编译SQL减少了每次执行时的解析开销。

以下是使用`preparedStatement`进行批量执行的一般步骤：

1. **创建PreparedStatement**：首先，你需要创建一个PreparedStatement对象，这个对象包含了一个待执行的SQL模板。例如，如果你要插入到MySQL表中，SQL可能是`INSERT INTO table_name (col1, col2) VALUES (?, ?)`。

2. **设置参数**：对于每条即将写入的数据，你需要设置PreparedStatement的占位符（通常用问号`?`表示）。这通常是通过循环或者map结构完成的。

   List<Row> data = ...; // 批量数据
   for (Row row : data) {
       preparedStatement.setObject(1, row.getField(0)); // 设置第一个字段值
       preparedStatement.setObject(2, row.getField(1)); // 设置第二个字段值
       // ...
   }

3. **执行批量提交**：所有数据都设置好后，一次性执行PreparedStatement，将多行数据作为一次批量写入。这在性能上比单独执行每个SQL语句要高效。

   try {
       statement.batch().execute();
   } catch (SQLException e) {
       // 处理异常
   }

4. **关闭资源**：最后别忘了关闭PreparedStatement和Statement，释放连接。

preparedStatement.close();
statement.close();