建sink表时,jdbc url这样写报错,这样的格式对吗?

2249问.png

展开
收起
游客3oewgrzrf6o5c 2022-07-27 17:38:26 476 分享 版权
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    似乎存在一些语法错误和格式问题。正确的 JDBC URL 格式应该是:

    Copy
    jdbc:mysql://:/?=&=...
    其中:

    表示 MySQL 服务器的主机名或 IP 地址;

    表示 MySQL 服务器的端口号,通常为 3306;

    表示要连接的数据库名称;

    和 表示连接参数的键值对,多个参数之间使用 & 符号连接。
    因此,您可以尝试将您提供的 JDBC URL 修改为以下格式:

    Copy
    jdbc:mysql://118.2.64.3306/dbname?serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useSSL=false
    其中,dbname 表示要连接的数据库名称,serverTimezone、allowPublicKeyRetrieval 和 useSSL 是一些常用的连接参数,您可以根据实际需求进行调整。需要注意的是,JDBC URL 中的所有参数都需要用 & 符号连接,不要使用空格或其他分隔符。

    另外,建议您在创建 JDBC Sink 表时,还需指定正确的用户名和密码,以确保能够成功连接到 MySQL 数据库。例如:

    scheme
    Copy
    CREATE TABLE allusers (
    id INT,
    name STRING,
    age INT
    ) WITH (
    'connector.type' = 'jdbc',
    'connector.url' = 'jdbc:mysql://118.2.64.3306/dbname?serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useSSL=false',
    'connector.table' = 'allusers',
    'connector.username' = '',
    'connector.password' = ''
    )

    2023-07-17 13:40:03
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
还有其他疑问?
咨询AI助理