FlinkSQL connector jdbc 用户密码是否可以加密/隐藏

[杨东树 <ya...@163.com>]

各位好，
       考虑到数据库用户、密码安全性问题，使用FlinkSQL connector jdbc时，请问如何对数据库的用户密码进行加密/隐藏呢。例如如下常用sql中的password:
CREATE TABLE wordcount_sink (
 word String,
 cnt BIGINT,
 primary key (word) not enforced
) WITH (
 'connector' = 'jdbc',
 'url' = 'jdbc:mysql://localhost:3306/flink',
 'username' = 'root',
 'password' = '123456',
 'table-name' = 'wordcount_sink'
);

Re: FlinkSQL connector jdbc 用户密码是否可以加密/隐藏

[Feng Jin <ji...@gmail.com>]

1. 目前 JDBC connector 本身不支持加密， 我理解可以在提交 SQL 给 SQL 文本来做加解密的操作，或者做一些变量替换来隐藏密码。

2. 可以考虑提前创建好 jdbc catalog，从而避免编写 DDL 暴露密码。


Best,
Feng

On Sun, Mar 10, 2024 at 9:50 PM 杨东树 <ya...@163.com> wrote:

> 各位好，
>        考虑到数据库用户、密码安全性问题，使用FlinkSQL connector
> jdbc时，请问如何对数据库的用户密码进行加密/隐藏呢。例如如下常用sql中的password:
> CREATE TABLE wordcount_sink (
>  word String,
>  cnt BIGINT,
>  primary key (word) not enforced
> ) WITH (
>  'connector' = 'jdbc',
>  'url' = 'jdbc:mysql://localhost:3306/flink',
>  'username' = 'root',
>  'password' = '123456',
>  'table-name' = 'wordcount_sink'
> );

Re: FlinkSQL connector jdbc 用户密码是否可以加密/隐藏

[gongzhongqiang <go...@apache.org>]

hi, 东树
   隐藏sql中的敏感信息，这个需要外部的大数据平台来做。
比如：StreamPark 的变量管理，可以提前维护好配置信息，编写sql时引用配置，由平台提交至flink时解析sql并替换变量。

Best,
Zhongqiang Gong

杨东树 <ya...@163.com> 于2024年3月10日周日 21:50写道：

> 各位好，
>        考虑到数据库用户、密码安全性问题，使用FlinkSQL connector
> jdbc时，请问如何对数据库的用户密码进行加密/隐藏呢。例如如下常用sql中的password:
> CREATE TABLE wordcount_sink (
>  word String,
>  cnt BIGINT,
>  primary key (word) not enforced
> ) WITH (
>  'connector' = 'jdbc',
>  'url' = 'jdbc:mysql://localhost:3306/flink',
>  'username' = 'root',
>  'password' = '123456',
>  'table-name' = 'wordcount_sink'
> );