Oracle GoldenGate Java Adapter 开发介绍

Oracle GoldenGate Java Adapter开发主要涉及到两个方面

  1. Oracle GoldenGate VAM 消息捕获
  2. java 用户如何将捕获的 Oracle 数据变化的信息进行传送

Oracle GoldenGate VAM 消息捕获

介绍

Oracle GoldenGate VAM 消息捕获通过连接到 JMS 传递来解析消息,并通过 VAM 接口将其发送到构建消息数据的 Oracle GoldenGate 中提取。 这允许将 JMS 消息传递到为目标数据库运行的 Oracle GoldenGate 系统。

使用 Oracle GoldenGate VAM 消息捕获需要两个组件:

  1. 连接到 Oracle GoldenGate 抽取进程的动态库
  2. 使用消息捕获属性文件和解析器特定的数据定义来创建 Oracle GoldenGate 源定义文件的应用

配置消息捕获操作的三个部分

  1. 消息连接:连接属性中的值,例如 JMS 客户机的 Java 类路径,JMS 源目标名称,JNDI 连接属性和安全信息
  2. 解析:属性文件中设置固定宽度,逗号分隔或 XML 消息的解析规则。 这包括诸如要使用的分隔符,交易开始和结束的值以及日期格式等设置
  3. VAM接口:为 Oracle GoldenGate 核心提取过程设置标识 VAM,dll 等的参数和属性文件

典型配置

消息捕获示例图
如图所示,JMS 消息由 Oracle GoldenGate 适配器中的JMS处理程序拾取,并使用适配器的消息捕获接口传输到抽取进程。 抽取过程中通过网络将数据抽取到 Oracle GoldenGate 目标实例。 然后,目标库中 Replicat 进程更新目标数据库

java 用户如何将捕获的 Oracle 数据变化的信息进行传送

介绍

通过 Oracle GoldenGate Java API,Oracle GoldenGate 捕获的事务数据可以传递到关系数据库以外的目标,如 JMS(Java 消息服务),写入磁盘的文件或与自定义应用程序集成
Oracle GoldenGate for Java 提供了从 Oracle GoldenGate 抽取进程执行 Java 代码的能力

用 Oracle GoldenGate for Java 需要两个组件

1.动态链接或共享库,以 C / C ++ 实现,通过 C API 和 Oracle GoldenGate Extract 进程集成
2.一组 Java 库(jars),包括 Oracle GoldenGate Java API
示例图
如图所示,用户通过 Oracle GoldenGate 提供的接口,获取到数据库的数据变化信息,然后通过 JMS 消息传递接口进行传送

具体配置操作如下

编辑属性文件

  1. 设置主机名,端口号,输出文件名,JMS 连接设置
  2. 添加/删除要向其发送事务的活动目标(例如 JMS 或文件)
  3. 打开/关闭调试级日志记录
  4. 确定使用的消息格式

自定义发送到JMS或文件的消息的格式

  1. 设置预先存在的格式过程的属性(固定长度或字段分隔的消息格式)
  2. 自定义消息模板,使用 Velocity 模板宏语言
  3. 编写自定义 Java 代码
  4. 编写自定义 Java 代码以提供事务和操作的自定义处理,过滤或实现自定义消息格式

适配器开发中应用到的主要 jar 包如下

主要jar包

下载地址

jar包下载
下载文件

查看评论