新建 Oracle 数据源

配置好数据源是创建数据迁移任务的前提。启动数据迁移前，您必须新建 Oracle 数据库作为源端或者目标端的数据源。本文为您介绍如何在 OceanBase 迁移服务（OceanBase Migration Service，OMS）中新建 Oracle 数据源。

操作步骤

1. 登录 OMS 控制台。

2. 在左侧导航栏，单击 数据源管理。

3. 在 数据源管理 页面，单击右上角的 新建数据源。

   

4. 在 新建数据源 对话框，选择 数据源类型 为 Oracle，配置各项参数。

   参数	描述
   数据源标识	建议使用中文、数字和字母的组合。名称中不能包含空格，长度不能超过 32 个字符。 注意： 数据源标识在 OMS 系统内是全局唯一的。
   地域	从下拉列表中选择数据源所属的地域（即部署 OMS 时配置的 cm_region 参数）。 注意： 仅多地域场景下会显示该参数。 请确保数据源与地域的映射关系保持一致，否则可能导致迁移同步性能较差。
   数据库属性	包括 主库、主库+备库 和 备库，选择目标属性后，根据页面配置相应的参数。 说明： 选择 主库+备库 和 备库 时，请配置 Oracle 数据库为 ADG（Active Data Guard）模式。Oracle 11g 之后的版本默认为 ADG 模式。
   主机 IP	数据库宿主机的 IP。您需要输入物理 RDS 的地址，请勿填写中间件的地址。
   端口	数据库宿主机 IP 的端口号。
   数据库用户名	用于数据迁移或数据同步的 Oracle 数据库的用户名称。建议您为迁移或同步任务创建单独的数据库用户。
   数据库密码	数据库用户的密码。
   Service Name	Oracle 数据库的 Service 名称。
   Schema Name（可选）	Oracle 数据库的 Schema 名称。 说明 如果您配置了 Schema Name，当数据源作为源端时，数据迁移或数据同步任务仅支持选择指定 Schema Name 下的迁移或同步对象。 如果您未配置 Schema Name，则可以将您可读权限内的全部 Schema 作为迁移或同步对象。
   备注（可选）	数据源的备注信息。

5. （可选）如果您需要在增量同步时消费 Kafka 中的数据同步至目标端数据库，请在 新建数据源 对话框，勾选 通过 Kafka 获取增量数据，并配置各项参数。

   

   参数	描述
   Kafka 数据源	选择通过 Kafka 获取增量数据后，需要绑定 Kafka 数据源。Kafka 保存 OGG 转换的 Oracle 增量日志信息，以便 OMS 消费。如果未绑定，Oracle 增量同步将通过 LOGMINER 方式获取增量数据。
   Topic	从下拉列表中选择当前 Kafka 数据源的某个 Topic。
   增量消息格式	目前支持 ogg_json 和 ogg_json_row。kafka.props 配置文件参考请参见下文，更多详情请参见 Using the JSON Formatter。

   kafka.props 配置文件参考如下：

   -- 此处以表名作为 Topic 名称。如果您已指定 Topic，则直接使用 Topic 名称即可。
   gg.handler.kafkahandler.topicMappingTemplate=${tableName}     
   -- 修改为 JSON 格式。
   gg.handler.kafkahandler.format=json   
   -- 增加 Kafka lib 文件所在路径。                       
   gg.classpath=dirprm/:/opt/oracle/ogg_kafka/lib/kafka_libs/*  
   gg.handler.kafkahandler.includeTokens=true
   gg.handler.kafkahandler.format.metaColumnsTemplate=${objectname[table]},${optype[op_type]},${timestamp[op_ts]},${currenttimestamp[current_ts]},${position[pos]},${alltokens[tokens]},${primarykeycolumns[primary_keys]}
   
   -- 根据表名分片，确保同一张表的顺序性。
   gg.handler.kafkahandler.keyMappingTemplate=${tableName}       
   gg.handler.kafkahandler.mode=op
   
   -- 使用消息格式为 ogg_json_row 时，请配置下述参数。配置后当 Update 更新了主键时，ogg 会将消息格式中的 "op_type": "U" 拆分为 "op_type": "D" 和 "op_type": "I"(即先删除后插入数据)，并且没有 before 和 after。
   -- 修改为 json_row 格式。
   gg.handler.kafkahandler.format=json_row                      
   gg.handler.kafkahandler.format.pkUpdateHandling=delete-insert
   
   -- 如果您需要投递事务的 CSN、XID 和 TXIND，则配置下述参数。
   gg.handler.kafkahandler.format.metaColumnsTemplate=${objectname[table]},${optype[op_type]},${timestamp[op_ts]},${currenttimestamp[current_ts]},${position[pos]},${alltokens[tokens]},${primarykeycolumns[primary_keys]},${csn},${xid},${txind}
   

6. 单击 测试连接，验证 OMS 和数据源的网络连接，以及用户名和密码的有效性。

7. 测试连接通过后，单击 确定。