开发者社区> 问答> 正文

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

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

展开
收起
cuicuicuic 2023-04-19 14:21:19 126 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,提供丰富的企业级增值功能。
问答排行榜
最热
最新

相关电子书

更多
SQL Server 2017 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载

相关镜像