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

有人用flink sql插数据到pg吗,我这个pg版本好像不支持upsert 语法?

有人用flink sql插数据到pg吗,我这个pg版本好像不支持upsert 语法?

展开
收起
cuicuicuic 2023-05-16 17:12:07 220 0
1 条回答
写回答
取消 提交回答
  • 存在即是合理

    不知道你的flink sql版本和pg版本。但是,根据我的了解,Flink SQL支持PostgreSQL数据库,并且可以使用upsert语法。

    在Flink SQL中,可以使用以下语法将数据插入到PostgreSQL表中:

    INSERT INTO table_name (column1, column2, ...) VALUES (value1, value2, ...);
    

    如果要使用upsert语法,则可以使用以下语法:

    INSERT INTO table_name (column1, column2, ...) 
    SELECT value1, value2, ... FROM other_table WHERE NOT EXISTS (
      SELECT * FROM table_name WHERE column1 = value1 AND column2 = value2 ...);
    

    请注意,upsert语法需要PostgreSQL 9.3或更高版本才支持。如果pg版本低于9.3,则可能不支持upsert语法。

    2023-05-18 13:29:14
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

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