这个 flink 里面的 JDBC catalog一般大家都在什么时候有

这个 flink 里面的 JDBC catalog 一般大家都在什么时候有,就是我再写flilnk sql 需要postgre 数据库的数据的时候 然后直接就用这个去查询然后出结果,那怎么和 flink sql 一起关联呢?

展开
收起
圆葱猪肉包 2023-03-21 14:08:03 232 分享 版权
2 条回答
写回答
取消 提交回答
  • 发表文章、提出问题、分享经验、结交志同道合的朋友

    Flink中的JDBC Catalog是在使用Flink SQL时与外部数据库进行交互的一种方式。

    可以在Flink SQL中使用JDBC Catalog来访问外部数据库中的数据。例如,以下是使用JDBC Catalog访问PostgreSQL数据库中的数据的示例代码:

    // 声明要查询的表
    String tableName = "my_table";
    
    // 使用JDBC Catalog创建外部表
    tableEnv.executeSql(String.format(
        "CREATE TABLE %s (\n" +
        "  column1 STRING,\n" +
        "  column2 INT\n" +
        ") WITH (\n" +
        "  'connector' = 'jdbc',\n" +
        "  'url' = 'jdbc:postgresql://localhost:5432/my_db',\n" +
        "  'table-name' = '%s',\n" +
        "  'username' = 'my_user',\n" +
        "  'password' = 'my_password'\n" +
        ")",
        tableName, tableName));
    
    // 执行查询操作
    Table resultTable = tableEnv.sqlQuery(String.format(
        "SELECT column1, column2 FROM %s WHERE column2 > 100",
        tableName));
    
    // 输出查询结果
    resultTable.print();
    
    
    2023-03-24 15:35:58
    赞同 展开评论
  • GitHub https://github.com/co63oc/cloud

    Flink-cdc实时读postgresql https://www.cnblogs.com/xiongmozhou/p/14817641.html

    2023-03-24 15:26:15
    赞同 展开评论

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

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