SeaTunnel JDBC DB2 Sink Connector支持的工作原理，快来学习吧！

支撑引擎

Spark
Flink
SeaTunnel Zeta

主要功能

• 准确一次性
• CDC（变更数据捕获）

运用 Xa 业务 来确保 准确一次性。因此，只支撑对支撑 Xa 业务 的数据库进行 准确一次性 操作。您能够设置 is_exactly_once=true 来启用它。

描绘

经过 JDBC 写入数据。支撑批处理模式和流式模式，支撑并发写入，支撑准确一次性语义（运用 XA 业务确保）。

支撑的数据源信息

数据库依靠

请下载与 ‘Maven’ 相对应的支撑列表，并将其复制到 '$SEATNUNNEL_HOME/plugins/jdbc/lib/' 作业目录中
例如，对于 DB2 数据源：cp db2-connector-java-xxx.jar $SEATNUNNEL_HOME/plugins/jdbc/lib/

数据类型映射

Sink 选项

提示

假如未设置 partition_column，则将以单一并发方式运行；假如设置了 partition_column，则依据使命的并发度并行履行。

使命示例

简单示例：

该示例界说了一个 SeaTunnel 同步使命，经过 FakeSource 主动生成数据并发送到 JDBC Sink。FakeSource 生成一共 16 行数据（row.num=16），每行有两个字段，name（字符串类型）和 age（整数类型）。最终的目标表是 test_table，在表中也将有 16 行数据。在运行此作业之前，您需要在您的 DB2 中创建数据库 test 和表 test_table。假如您没有装置和布置 SeaTunnel，请依照 装置 SeaTunnel 中的阐明装置和布置 SeaTunnel。然后依照 运用 SeaTunnel 引擎快速入门 中的阐明运行此作业。

# 界说运行时环境
env {
  # 您能够在这里设置 Flink 装备
  execution.parallelism = 1
  job.mode = "BATCH"
}
source {
  # 这是一个示例源插件，仅用于测试和演示源插件功能
  FakeSource {
    parallelism = 1
    result_table_name = "fake"
    row.num = 16
    schema = {
      fields {
        name = "string"
        age = "int"
      }
    }
  }
  # 假如您想要获取更多关于怎么装备 SeaTunnel 并检查完好的源插件列表的信息，
  # 请拜访 https://seatunnel.apache.org/docs/category/source-v2
}
transform {
  # 假如您想要获取更多关于怎么装备 SeaTunnel 并检查完好的转换插件列表的信息，
  # 请拜访 https://seatunnel.apache.org/docs/category/transform-v2
}

生成 Sink SQL

该示例不需要编写杂乱的 SQL 句子，您能够装备数据库称号和表称号，以主动生成要插入的句子。

sink {
    jdbc {
        url = "jdbc:db2://127.0.0.1:50000/dbname"
        driver = "com.ibm.db2.jdbc.app.DB2Driver"
        user = "root"
        password = "123456"
        query = "insert into test_table(name,age) values(?,?)"
        }
  #  假如您想要获取更多关于怎么装备 SeaTunnel 并检查完好的接收插件列表的信息，
  #  请拜访 https://seatunnel.apache.org/docs/category/sink-v2
}
sink {
    jdbc {
        url = "jdbc:db2://127.0.0.1:50000/dbname"
        driver = "com.ibm.db2.jdbc.app.DB2Driver"
        user = "root"
        password = "123456"
        # 依据数据库表名主动生成 SQL 句子
        generate_sink_sql = true
        database = test
        table = test_table
    }
}

准确一次性：

为了确保准确写入场景，我们确保准确一次性。 sink { jdbc { url = “jdbc:db2://127.0.0.1:50000/dbname” driver = “com.ibm.db2.jdbc.app.DB2Driver”

    max_retries = 0
    user = "root"
    password = "123456"
    query = "insert into test_table(name,age) values(?,?)"
    is_exactly_once = "true"
    xa_data_source_class_name = "com.db2.cj.jdbc.Db2XADataSource"
}

}

本文由 白鲸开源科技 供给发布支撑！