如何在Apache-Flink中参数化SQL查询

Question

我需要知道我们可以像在Java中使用PreparedStatement一样在Java中参数化Apache-Flink SQL查询。

Select * from emp where emp_id=?

Answer 1

我认为当前不支持JDBC中的PreparedStatement。Flink用例与构建Web应用程序有所不同，我不确定它是否需要SQL注入保护，例如直接在数据库上运行的应用程序。

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