如何在apache-flink中参数化sql查询

Question

我需要知道我们是否可以像我们在java中使用PreparedStatement进行sql查询一样参数化apache-flink sql query。

Select * from emp where emp_id=?

Answer 1

我不认为目前Flink在JDBC中支持像PreparedStatement这样的东西。Flink用例与构建web应用程序有点不同，我不确定它是否需要SQL注入保护，就像直接在数据库上操作的应用程序一样。

我不确定您的用例是什么，但从技术上讲，您可以看看this库，它提供了创建离线预准备语句的可能性。