配置 Oracle 数据源

Oracle 数据源为您提供读取和写入 Oracle 的双向通道数据集成能力，实现不同数据源与 Oracle 之间的数据传输场景。
本文为您介绍 DataSail 的 Oracle 数据同步的能力支持情况。

1 支持的 Oracle 版本

• 离线读写

  版本	离线读（Oracle Reader）	离线写（Oracle Writer）
  Oracle 11.2 or 11gR2	支持	支持
  Oracle 12.1 or 12cR1	支持	支持
  Oracle 12.2 or 12cR2	支持（新版本特性不支持）	支持（新版本特性不支持）
  Oracle 18.3	支持（新版本特性不支持）	支持（新版本特性不支持）
  Oracle 19.x	支持（新版本特性不支持）	支持（新版本特性不支持）
  Oracle 21.1	支持（新版本特性不支持）	支持（新版本特性不支持）

2 使用前提

1. 确保同步任务使用的独享数据集成资源组，具有 Oracle 数据库节点的网络访问能力。详见网络连通解决方案。

2. 子账号新建数据源时，需要有项目的管理员角色，方可以进行新建数据源操作。各角色对应权限说明，详见：管理成员

3 支持的字段类型

• 当前主要字段类型支持情况如下

  字段类型	离线读（Oracle Reader）	离线写（Oracle Writer）
  NUMBER	支持	支持
  NUMERIC	支持	支持
  REAL	支持	支持
  BIT	支持	支持
  BOOL	支持	支持
  BINARY_FLOAT	支持	支持
  BINARY_DOUBLE	支持	支持
  DOUBLE PRECISION	支持	支持
  CHAR	支持	支持
  NCHAR	支持	支持
  VARCHAR2	支持	支持
  NVARCHAR2	支持	支持
  DATE	支持	支持
  TIMESTAMP	支持	支持
  TIMESTAMP WITH TIME ZONE	支持	支持
  TIMESTAMP WITH LOCAL TIME ZONE	支持	支持
  DATETIME	支持	支持
  CLOB	支持	支持
  BLOB	支持	支持
  RAW	支持	支持
  ROWID	支持	支持
  UROWID	支持	支持
  FLOAT	支持	支持
  INTERVAL DAY	支持	不支持
  INTERVAL YEAR	支持	不支持
  BFILE	支持	支持
  LONG	支持	支持
  LONG RAW	支持	支持
  NCLOB	支持	支持
  STRUCT	不支持	不支持
  User-Defined Types	不支持	不支持
  AnyType	不支持	不支持
  AnyData	不支持	不支持
  AnyDataSet	不支持	不支持
  XmlType	支持	支持
  Spatial Types	不支持	不支持
  Media Types	不支持	不支持

• Oracle 读针对 Oracle 类型的转换列表，如下所示：

  类型分类	Oracle 数据类型
  整数类	INTEGER、INT和SMALLINT
  浮点类	NUMBER、NUMERIC、DECIMAL、FLOAT、DOUBLE PRECISIOON、REAL、BINARY_FLOAT、BINARY_DOUBLE、DEC
  字符串类	LONG、CHAR、NCHAR、VARCHAR、VARCHAR2、NVARCHAR2、CLOB、NCLOB、CHARACTER、CHARACTER VARYING、CHAR VARYING、NATIONAL CHARACTER、NATIONAL CHAR、NATIONAL CHARACTER VARYING、NATIONAL CHAR VARYING、NCHAR VARYING、ROWID、UROWID、XMLTYPE
  日期时间类	TIMESTAMP、DATE、TIMESTAMP WITH TIME ZONE、TIMESTAMP WITH LOCAL TIME ZONE、DATETIME
  布尔型	BIT和BOOL
  二进制类	BLOB、BFILE、RAW和LONG RAW

4 数据同步任务开发

4.1 数据源注册

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

4.2 新建任务

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

4.3 可视化配置说明

任务创建成功后，您可根据实际场景，配置Oracle 批式读、Oracle 批式写或 Oracle 流式写等通道任务。

4.3.1 Oracle 批式读

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

4.3.2 Oracle 批式写

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

4.3.3 Oracle 流式写

支持可视化方式配置流式写入 Oracle 单表。Oracle Writer 通过 JDBC 远程连接 Oracle 数据库，并执行相应的 SQL 语句，将数据写入Oracle。流式写入 Oracle 配置方式如下：

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

4.3.4 字段映射

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

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

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

  说明

  来源端字段信息支持输入数据库函数和常量配置，单击手动添加按钮，在源表字段中输入需添加的值，并选择函数或常量类型，例如：

  • 函数：支持您输入 now()、current_timestamp() 等 Oracle 数据库支持的函数。

  • 常量：您可自定义输入常量值，'123'、'${DATE}'、'${hour}' 等，输入值两侧需要加上英文单引号，支持结合时间变量参数使用。

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

4.4 DSL 配置说明

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

4.4.1 进入 DSL 模式

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

4.4.2 Oracle 批式读

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

// 变量使用规则如下:
// 1.自定义参数变量: {{}}, 比如{{number}}
// 2.系统时间变量${}, 比如 ${date}、${hour}
// **************************************
{
    // [required] dsl version, suggest to use latest version
    "version": "0.2",
    // [required] execution mode, supoort streaming / batch now
    "type": "batch",
    // reader config
    "reader": {
        // [required] datasource type
        "type": "oracle",
        // [optional] datasource id, set it if you have registered datasource
        "datasource_id": 12345,
        // [required] user parameter
        "parameter": {
            // ********** please write here **********
            // "key" : value
            "columns": [
                {
                    "name": "name_sample",
                    "type": "type_sample"
                }
            ],
            "filter": "id > 10",
            "split_pk": "split_pk_sample",
            "table_schema":"table_schema",
            "table_name": "table_name_sample"
        }
    },
    // writer config
    "writer": {
    },
    // common config
    "common": {
        // [required] user parameter
        "parameter": {
            // ********** please write here **********
            // "key" : value
        }
    }
}

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

4.4.3 Oracle 批式写

根据实际情况替换 Oracle 批式写相应参数，Oracle 批式写脚本示例如下：

// **************************************
// 变量使用规则如下:
// 1.自定义参数变量: {{}}, 比如{{number}}
// 2.系统时间变量${}, 比如 ${date}、${hour}
// **************************************
{
    // [required] dsl version, suggest to use latest version
    "version": "0.2",
    // [required] execution mode, supoort streaming / batch now
    "type": "batch",
    // reader config
    "reader": {
        // [required] datasource type
        "type": "xx",
        // [optional] datasource id, set it if you have registered datasource
        "datasource_id": null,
        // [required] user parameter
        "parameter": {
            // ********** please write here **********
            // "key" : value
          
        }
    },
    // writer config
    "writer": {
        // [required] datasource type
        "type": "oracle",
        // [optional] datasource id, set it if you have registered datasource
        "datasource_id": 12345,
        // [required] user parameter
        "parameter": {
            // ********** please write here **********
            // "key" : value
            "table_schema":"table_schema",
            "table_name":"table_1",
            "pre_sql_list":[""],
            "post_sql_list":[""],
            "write_mode":"directlyInsert",
            "columns": [
                {
                    "name": "name_sample",
                    "type": "type_sample"
                }
            ]
        }
    },
    // common config
    "common": {
        // [required] user parameter
        "parameter": {
            // ********** please write here **********
            // "key" : value
        }
    }
}

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

4.5 高级参数说明

• 对于可视化通道任务，读参数需要加上 job.reader. 前缀，写参数需要加上 job.writer. 前缀，如下图所示：
  

• 对于 DSL 任务，读参数请配置到 reader.parameter 下，写参数请配置到 writer.parameter 下，直接输入参数名称和参数值。如下图所示：
  

4.5.1 Oracle 批式读

批式读支持以下高级参数，您可根据实际情况进行配置：

4.5.2 Oracle 批式写

批式写支持以下高级参数，您可根据实际情况进行配置：