开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

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

2249问.png

展开
收起
游客3oewgrzrf6o5c 2022-07-27 17:38:26 416 0
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 集群和引擎,提高作业开发运维效率。

相关电子书

更多
File Format Benchmark - Avro, JSON, ORC, & Parquet 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载