开发者社区> 问答> 正文

问一下,使用sql-client时,想用jdbc catalog mysql,怎么在启动sql-cl

问一下,使用sql-client时,想用jdbc catalog mysql,怎么在启动sql-client时,使用yaml配置的catalog?image.png image.png

展开
收起
真的很搞笑 2023-04-19 14:21:19 142 0
2 条回答
写回答
取消 提交回答
  • https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/table/jdbc/,此回答整理自钉群“Flink CDC 社区”

    2023-04-19 22:27:39
    赞同 展开评论 打赏
  • 随心分享,欢迎友善交流讨论:)

    要在启动SQL Client时使用YAML配置的JDBC Catalog,可以按照以下步骤操作:

    在Flink的conf目录下创建一个名为flink-sql-client.yaml的文件,如果该文件已经存在,可以直接编辑该文件。 在该文件中添加以下配置信息,用于配置JDBC Catalog: catalogs: mysql: type: jdbc # jdbc连接信息 ... 其中,type字段指定了Catalog的类型为JDBC,mysql是Catalog的名称,后面的配置就是JDBC连接信息,需要根据具体情况进行修改,比如:

    catalogs: mysql: type: jdbc property-version: 1 # 连接信息 default-database: test username: root password: root # 驱动类名 driver: com.mysql.jdbc.Driver url: jdbc:mysql://localhost:3306/test?useSSL=false 在启动SQL Client时,添加--defaults指定flink-sql-client.yaml文件的路径,例如: ./bin/sql-client.sh embedded --defaults /path/to/flink-sql-client.yaml 启动SQL Client后,可以使用USE CATALOG语句切换到mysql Catalog,并且可以使用SHOW TABLES语句查看该Catalog下的所有表格。

    2023-04-19 16:21:57
    赞同 展开评论 打赏
来源圈子
更多
收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
问答排行榜
最热
最新

相关电子书

更多
One Box: 解读事务与分析一体化数据库 HybridDB for MySQL 立即下载
One Box:解读事务与分析一体化数据库HybridDB for MySQL 立即下载
如何支撑HTAP场景-HybridDB for MySQL系统架构和技术演进 立即下载

相关镜像