配置 GBase8S 数据源

GBase8S 数据源为您提供可视化读取和脚本模式（DSL）读取、写入 GBase8S 数据库的能力，实现和不同数据源进行数据传输。
本文为您介绍 DataSail 的 GBase8S 数据同步的能力支持情况。

1 使用限制

1. 目前仅支持 GBase 8s V8.8（兼容 openGauss、PostgreSQL、MySQL）以及 GBase 8s V8.8（兼容 Oracle）两个版本。

2. DSL 模式写入 GBase8S 时，仅支持 directlyInsert 模式。

2 支持的字段类型

2.1 GBase 8s V8.8（兼容 openGauss、PostgreSQL、MySQL）

2.2 GBase 8s V8.8（兼容 Oracle）

3 数据同步任务开发

3.1 数据源注册

新建数据源操作详见配置数据源，下面为您介绍用连接串方式配置 GBase8s 数据源信息：

3.2 新建离线任务

GBase8s 数据源测试连通性成功后，进入到数据开发界面，开始新建 GBase8s 相关通道任务。
新建任务方式详见离线数据同步。

3.3 可视化配置说明

任务创建成功后，您可根据实际场景，配置 GBase8s 离线读或 GBase8s 离线写等通道任务。

3.3.1 GBase8s 离线读

数据来源选择 GBase8s，并完成以下相关参数配置：
其中参数名称前带 * 的为必填参数，名称前未带 * 的为可选填参数。

3.3.2 GBase8s 离线写

目前暂不支持可视化配置离线数据写入 GBase8s，敬请期待。

3.3.3 字段映射

数据来源和目标端配置完成后，需要指定来源和目标端的字段映射关系，根据字段映射关系，数据集成任务将源端字段中的数据，写入到目标端对应字段中。
您可通过以下三种方式操作字段映射关系：

• 自动添加：单击自动添加按钮，根据两端数据表信息，可以自动填充来源和目标的字段信息。

• 手动添加：单击手动添加按钮，可以手动编辑来源和目标的字段信息，可以逐个添加。

• 移动\删除字段：您也可以根据需要移动字段映射顺序或删除字段。

3.4 DSL 配置说明

GBase8s 数据源支持使用脚本模式（DSL）的方式进行配置。
在某些复杂场景下，或当数据源类型暂不支持可视化配置时，您可通过任务脚本的方式，按照统一的 Json 格式，编写 GBase8s Reader 和 GBase8s Writer 参数脚本代码，来运行数据集成任务。

3.4.1 进入 DSL 模式

进入 DSL 模式操作流程，可详见 MySQL 数据源-4.4.1 进入DSL 模式。

3.4.2 GBase8s Reader

进入 DSL 模式编辑界面后，您可根据实际情况替换相应参数，GBase8s 离线读脚本示例如下：

{
  "job": {
    "common": {
      ...
    },
    "reader": {
      "type": "gbase8s",
      "datasource_id": null,
      "class": "com.bytedance.dts.batch.jdbc.GBase8sInputFormat",
      "connections": [
        {
          "slaves": [
            {
              "host": "*.*.*.*",
              "db_url": "jdbc:gbasedbt-sqli://host:port/dts_test:GBASEDBTSERVER=dtstest;DB_LOCALE=zh_CN.utf8;CLIENT_LOCALE=zh_CN.utf8;NEWCODESET=UTF8,utf8,57372;",
              "port": 9091
            }
          ],
          "shardNumber": 0
        }
      ],
      "user_name": "username",
      "password": "password",
      "db_name":"dts_test",
      "table_name": "foo",
      "split_pk":"cc",
      "columns" :[
        {
          "name":"cc",
          "type":"char"
        },
        {
          "name":"nc",
          "type":"nchar"
        }
      ]
    },
    "writer": {
      ...
    }
  }
}

Reader 参数说明，其中参数名称前带 * 的为必填参数，名称前未带 * 的为可选填参数：

3.4.4 GBase8S Writer

根据实际情况替换 GBase8S Writer 相应参数，GBase8S Writer 脚本示例如下：

{
  "job": {
    "common": {
      ...
    },
    "reader": {
      ...
    },
    "writer": {
      "type": "gbase8s",
      "datasource_id": null,
      "class": "com.bytedance.dts.batch.jdbc.GBase8sOutputFormat",
      "write_mode": "directlyInsert",
      "user_name": "username",
      "password": "pdw",
      "db_name":"dts_test",
      "table_name": "foo",
      "connections": [
        {
          "host": "*.*.*.*",
          "db_url": "jdbc:gbasedbt-sqli://ip:port/dts_test:GBASEDBTSERVER=dtstest;DB_LOCALE=zh_CN.utf8;CLIENT_LOCALE=zh_CN.utf8;NEWCODESET=UTF8,utf8,57372;user=gbasedbt;password=123qweABC",
          "port": 9091
        }
      ],
      "columns" :[
        {
          "name":"cc",
          "type":"char"
        },
        {
          "name":"nc",
          "type":"nchar"
        }
      ]
    }
  }
}

Writer 参数说明，其中参数名称前带 * 的为必填参数，名称前未带 * 的为可选填参数：