1.13.6的flink sql建一张映射到oracle的表,url参数是这么设置么?
是的,1.13.6 版本的 Flink SQL 支持映射 Oracle 表。
要创建一张映射到 Oracle 表的表,可以使用以下语法:
CREATE TABLE table_name (
column_name1 TYPE1,
column_name2 TYPE2,
...
) WITH (
'connector' = 'oracle-cdc',
'url' = 'jdbc:oracle:thin:@hostname:port:sid',
'username' = 'username',
'password' = 'password',
'table_name' = 'source_table_name',
'cdc_column' = 'column_name'
);
其中:
connector 是连接器名称,必须为 oracle-cdc。
url 是连接 Oracle 数据库的 JDBC 连接字符串。
username 是 Oracle 数据库的用户名。
password 是 Oracle 数据库的密码。
table_name 是源表名称。
cdc_column 是 CDC 列名称。
更多信息,请参考官方文档:https://ci.apache.org/projects/flink/flink-docs-release-1.13.6/dev/connectors/table/cdc/oracle_cdc.html。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。