有人用OracleXADataSource 实现 jdbc.exactlyOnceSink的吗？

是的，可以使用OracleXADataSource实现jdbc.exactlyOnceSink。具体步骤如下：

创建OracleXADataSource实例，并设置数据库连接参数（如URL、用户名、密码等）。

创建JdbcSink.Builder实例，并使用OracleXADataSource实例设置数据库连接。

设置JdbcSink.Builder的其他参数，如SQL语句、插入模式等。

调用JdbcSink.Builder的build()方法创建JdbcSink实例。

将JdbcSink实例添加到Flink流程图中，并运行Flink流程图。

例如：

OracleXADataSource xaDataSource = new OracleXADataSource(); xaDataSource.setURL("jdbc:oracle:thin:@localhost:1521:orcl"); xaDataSource.setUser("username"); xaDataSource.setPassword("password");

JdbcSink.Builder<Tuple2<String, Integer>> builder = JdbcSink.buildDataStream(dataStream) .setBatchSize(10) .setDataSource(xaDataSource) .setQuery("INSERT INTO test_table (name, age) VALUES (?, ?)") .setParameterTypes(Types.VARCHAR, Types.INTEGER);

JdbcSink<Tuple2<String, Integer>> sink = builder.build();

dataStream.addSink(sink);

flinkEnv.execute("Jdbc Sink Example");

请注意，使用OracleXADataSource实现jdbc.exactlyOnceSink需要在Oracle数据库中开启XA事务支持。