Как параметризовать SQL-запрос в apache-flink - PullRequest
0 голосов
/ 03 мая 2019

Мне нужно знать, можем ли мы параметризировать SQL-запрос Apache-Flink, как мы делаем в Java для SQL-запроса, используя PreparedStatement.

Select * from emp where emp_id=?

1 Ответ

0 голосов
/ 03 мая 2019

Я не думаю, что в настоящее время Flink поддерживает что-то вроде PreparedStatement в JDBC.Вариант использования Flink немного отличается от построения веб-приложений, и я не совсем уверен, нужна ли ему защита от SQL-инъекций, например, приложения, работающие непосредственно с базой данных.

Я не уверен, каков Ваш вариант использования, но технически Вы можете взглянуть на эту библиотеку, которая предлагает возможность создавать готовые операторы в автономном режиме.

...