Oracle GoldenGate 全面解析
Oracle GoldenGate 全面解析
Oracle GoldenGate 是一种实时数据集成和复制解决方案,广泛应用于数据同步、数据库迁移、高可用性和灾难恢复等场景。以下将详细解答您提出的关于 Oracle GoldenGate 的一系列问题。
1. Oracle GoldenGate 的架构组成及其核心组件的作用
架构组成
Oracle GoldenGate 采用分布式架构,主要包括以下核心组件:
- Extract(提取进程)
- Pump(中继进程,可选)
- Trail File(轨迹文件)
- Data Pump(数据泵,可选)
- Replicat(复制进程)
- Manager(管理进程)
核心组件作用
a. Extract(提取进程)
- 作用:从源数据库的日志文件(如 Oracle 的 redo logs)中提取数据变更(INSERT、UPDATE、DELETE 等),并将其写入轨迹文件。
- 特点:
- 支持直连(Direct Connect)和基于日志的提取。
- 可以配置为支持多线程提取,提高性能。
b. Pump(中继进程)
- 作用:将 Extract 进程生成的轨迹文件传输到目标系统或其他中继点,支持跨网络的数据传输。
- 特点:
- 可选组件,用于实现分布式架构。
- 提高数据传输的可靠性和灵活性。
c. Trail File(轨迹文件)
- 作用:存储从源数据库提取的变更数据,是 Extract 和 Replicat 之间的数据传输媒介。
- 特点:
- 分为源端轨迹(Source Trail)和目标端轨迹(Target Trail)。
- 支持本地磁盘和网络共享存储。
d. Replicat(复制进程)
- 作用:从轨迹文件中读取变更数据,并将其应用到目标数据库,实现数据同步。
- 特点:
- 支持多线程复制,提升应用性能。
- 提供灵活的错误处理和恢复机制。
e. Manager(管理进程)
- 作用:负责启动、停止和监控 GoldenGate 的其他进程(如 Extract 和 Replicat)。
- 特点:
- 管理资源分配和进程间通信。
- 提供命令行接口用于进程管理。
f. Data Pump(数据泵,可选)
- 作用:作为 Extract 和 Pump 的中间层,增强数据传输的能力,支持复杂网络拓扑。
- 特点:
- 提供数据的压缩、加密等功能。
- 提高数据传输的效率和安全性。
2. 配置 GoldenGate 实现 Oracle 到 Oracle 的实时数据同步的关键配置步骤
实现 Oracle 到 Oracle 的实时数据同步主要包括以下步骤:
前提条件
-
源数据库和目标数据库:
- 确保两端数据库版本兼容,已启动 ARCHIVELOG 模式(对于 Oracle)。
- 配置必要的权限和网络连通性。
-
GoldenGate 安装:
- 在源和目标服务器上安装相同版本的 GoldenGate 软件。
- 配置环境变量和路径,确保 GoldenGate 可执行文件可访问。
配置步骤
a. 配置源数据库
-
创建 GoldenGate 用户和赋权:
CREATE USER ggadmin IDENTIFIED BY password; GRANT DBA TO ggadmin; GRANT SELECT ANY TABLE TO ggadmin; GRANT SELECT ANY TRANSACTION TO ggadmin; -
配置 Supplemental Logging:
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA; ALTER TABLE your_table ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;
b. 配置 GoldenGate 管理进程
- 启动 Manager 进程:
- 编辑
GLOBALS文件,设置数据库连接参数(可选)。
GGSCI> EDIT PARAMS MGR- 内容示例:
PORT 7809- 启动 Manager:
GGSCI> START MANAGER - 编辑
c. 配置 Extract 进程
-
创建 Extract 参数文件:
GGSCI> ADD EXTRACT extract_name, TRANLOG, BEGIN NOW -
编辑 Extract 参数文件:
GGSCI> EDIT PARAMS extract_name- 内容示例:
EXTRACT extract_name USERID ggadmin, PASSWORD password EXTTRAIL ./dirdat/et, EXTRACTTRANSLOG TABLE schema.your_table; -
启动 Extract 进程:
GGSCI> START EXTRACT extract_name
d. 配置 Trail 文件(源端)
- 配置 Trail 处理:
- 上一步中
EXTTRAIL参数已指定轨迹文件存储路径。
- 上一步中
e. 传输 Trail 文件(数据泵或泵进程,可选)
-
添加 Pump 进程(如有跨网络需求):
GGSCI> ADD EXTRACT pump_name, EXTTRAILSOURCE ./dirdat/et -
编辑 Pump 参数文件:
GGSCI> EDIT PARAMS pump_name- 内容示例:
EXTRACT pump_name PASSTHRU RMTHOST target_host, MGRPORT 7809 RMTTRAIL ./dirdat/rt -
启动 Pump 进程:
GGSCI> START EXTRACT pump_name
f. 配置 Replicat 进程(目标端)
-
创建 Replicat 参数文件:
GGSCI> ADD REPLICAT rep_name, EXTTRAIL ./dirdat/rt -
编辑 Replicat 参数文件:
GGSCI> EDIT PARAMS rep_name- 内容示例:
REPLICAT rep_name USERID ggadmin, PASSWORD password ASSUMETARGETDEFS MAP schema.your_table, TARGET schema.your_table; -
启动 Replicat 进程:
GGSCI> START REPLICAT rep_name
g. 验证同步
-
查看进程状态:
GGSCI> INFO EXTRACT * GGSCI> INFO REPLICAT * -
检查同步数据:在目标数据库验证数据是否已同步。
3. GoldenGate 的检查点(Checkpoint)机制及其对数据复制可靠性的保障
检查点(Checkpoint)机制
GoldenGate 的检查点是用来记录进程在轨迹文件中的当前位置和状态的信息。它确保在进程重启或故障恢复时能够从上一次的检查点位置继续处理,避免数据丢失或重复。
检查点的作用
- 数据一致性:确保 Replicat 在应用数据时不会遗漏任何变更,维护源和目标数据库的一致性。
- 故障恢复:在系统崩溃或进程停止后,GoldenGate 可以基于检查点信息快速恢复进程,不需重新传输全部数据。
- 性能优化:通过定期记录检查点,减少重启时的恢复时间,提高整体性能。
检查点的工作原理
- Extract 进程:记录已成功提取并写入轨迹文件的位置。
- Replicat 进程:记录已成功应用到目标数据库的位置。
- 检查点文件:通常存储在
dirchk目录下,以.chk为后缀,包含进程的检查点信息。
保障数据复制可靠性
- 持久化记录:检查点信息定期写入磁盘,确保在意外故障后可以恢复。
- 同步机制:Replicat 在应用每一批变更数据后更新检查点,确保每次数据应用都有对应的记录。
- 事务边界管理:检查点机制与事务日志结合,确保完整事务在目标端完整应用。
4. 处理 GoldenGate 同步过程中出现的数据冲突(如主键冲突)的解决方案
在数据同步过程中,可能会遇到数据冲突,例如主键冲突(Primary Key Violation)。以下是处理此类冲突的常见方法:
冲突类型
- 主键冲突:目标数据库已存在相同主键的数据。
- 唯一约束冲突:某个字段的唯一性被违反。
- 引用完整性冲突:外键约束被破坏。
解决方案
a. 预防措施
-
确保数据唯一性:
- 在源和目标数据库中严格管理主键。
- 使用复合主键或其他唯一标识符避免冲突。
-
同步顺序管理:
- 确保数据插入、更新、删除的顺序与源数据库一致,防止约束冲突。
b. 冲突检测与处理
-
Transformed Replicat:
- 使用参数文件中的
相关文章:
Oracle GoldenGate 全面解析
Oracle GoldenGate 全面解析 Oracle GoldenGate 是一种实时数据集成和复制解决方案,广泛应用于数据同步、数据库迁移、高可用性和灾难恢复等场景。以下将详细解答您提出的关于 Oracle GoldenGate 的一系列问题。 1. Oracle GoldenGate 的架构组成及其核心组件的作用 架构组成…...
C++进阶——AVL树的实现
1、AVL的概念 1.1 AVL 树的发明 AVL 树由 G.M. Adelson-Velsky 和 E.M. Landis 在 1962 年的论文《An algorithm for the organization of information》中提出。他们的设计目标是解决二叉搜索树在动态操作(插入、删除)中可能退化为链表的问题。 1.2 …...
S32K144入门笔记(十三):LPIT的API函数解读
目录 1. SDK中的函数 2. API函数的释义 2.1 获取默认参数 2.2 初始化 2.3 启动与停止 2.4 计数值的设置于读取 2.5 中断API 1. SDK中的函数 在使用SDK的非抽象驱动函数时,函数的定义与声明在文件lpit_driver.c和lpit_driver.h中,一共有19个函数&a…...
打包当前Ubuntu镜像 制作Ubuntu togo系统
我的系统的基本情况说明: 我原来的系统的具体型号如下: uname -rLinux Engine 5.15.0-134-generic #145~20.04.1-Ubuntu SMP Mon Feb 17 13:27:16 UTC 2025 x86_64 x86_64 x86_64 GNU/Linux我原来的硬盘以及分区策略如下: 可以看到我的分区…...
系统架构设计师—案例分析—架构设计
文章目录 经典架构风格对比面向对象架构风格/显示调用风格优点缺点举例 事件驱动的系统/隐式调用风格优点缺点举例 基于规则的系统架构风格优点缺点举例 管道过滤器风格优点缺点举例 仓库风格优点缺点举例 解释器风格优点缺点举例 分层架构风格优点缺点举例 经典架构风格对比 …...
基于javaweb的SpringBoot智能相册管理系统图片相册系统设计与实现(源码+文档+部署讲解)
技术范围:SpringBoot、Vue、SSM、HLMT、Jsp、PHP、Nodejs、Python、爬虫、数据可视化、小程序、安卓app、大数据、物联网、机器学习等设计与开发。 主要内容:免费功能设计、开题报告、任务书、中期检查PPT、系统功能实现、代码编写、论文编写和辅导、论…...
Android 14 Telephony 网络选择功能介绍
一、总体介绍 (一)功能 手动搜网的流程:用户通过UI触发,调用TelephonyManager的API,比如startNetworkScan,然后这个请求会传递到RIL层,通过AT命令与基带通信,进行网络扫描。结果返回后,经过TelephonyRegistry通知应用层。中间可能涉及IPC,比如Binder通信,因为应用和…...
Leetcode 刷题笔记1 单调栈part01
leetcode 739 每日温度 对于单调栈问题,我觉得是在循环外部增加一些辅助项减少时间复杂度,但增加内存空间的利用 class Solution:def dailyTemperatures(self, temperatures: List[int]) -> List[int]:ans [0] * len(temperatures)stack []for i …...
深入解析音频编解码器(Audio CODEC):硬件、接口与驱动开发
音频编解码器(Audio CODEC)是音频处理系统中的核心组件,负责 模拟信号与数字信号的相互转换,广泛应用于 智能音箱、嵌入式系统、消费电子产品 等设备。本篇文章将从 硬件结构、接口解析、驱动开发 和 软件配置 等方面,…...
深度学习【迭代梯度下降法求解线性回归】
梯度下降法 梯度下降法是一种常用迭代方法,其目的是让输入向量找到一个合适的迭代方向,使得输出值能达到局部最小值。在拟合线性回归方程时,我们把损失函数视为以参数向量为输入的函数,找到其梯度下降的方向并进行迭代࿰…...
[Lc14_priority_queue] 最后一块石头重量 | 数据流中的第 K 大元素 | 前K个高频单词 | 数据流的中位数
目录 1.最后一块石头的重量 题解 2.数据流中的第 K 大元素 题解 3.前K个高频单词 题解 代码 ⭕4.数据流的中位数 题解 在C中,使用标准库中的priority_queue,默认情况下它是一个最大堆(即大堆排序),这意味着最…...
熔断和降级的区别,具体使用场景有哪些?
熔断与降级的核心区别在于触发条件和应用目标,具体差异及使用场景如下: 一、核心区别 对比维度熔断降级触发原因下游依赖服务故障(如超时、异常率过高)触发系统整体负载过高或流量洪峰管理目标层级框架级保护(无业务优…...
利用hexo+github部署属于自己的个人博客网站(2025年3月所写)
利用hexogithub部署属于自己的个人博客网站 前情提要:如果你出现了莫名其妙的报错,可能与权限有关,可以以管理员的身份运行git bash或者cmd 本篇博客仅限于利用hexo搭建博客,并且部署到github上面,让自己可以有一个访…...
首页性能优化
首页性能提升是前端优化中的核心任务之一,因为首页是用户访问的第一入口,其加载速度和交互体验直接影响用户的留存率和转化率。 1. 性能瓶颈分析 在优化之前,首先需要通过工具分析首页的性能瓶颈。常用的工具包括: Chrome DevTo…...
使用usb-cam包时填充摄像头参数话题
问题描述: 在启动usb摄像头之后,像apriltag_ros等包需要读取摄像头的内参信息,但是usb-cam默认是没有内参信息发布的,需要自己填写或标定。 解决方案: 如果你有内参数据或者急于验证后续代码的逻辑正确性,…...
pandas学习笔记(一)——基础知识和应用案例
pandas学习笔记 基础语法参考菜鸟教程:https://www.runoob.com/pandas/pandas-tutorial.html # jupyter import pandas as pd import matplotlib from matplotlib import pyplot as plt import numpy as npmatplotlib.use(TkAgg)data {timestamp: [1, 2, 3, 4, 5…...
SpringBoot + Mybatis Plus 整合 Redis
Redis 在用户管理系统中的典型应用场景 结合你的用户增删改查接口,以下是 Redis 的实用场景和具体实现方案: 场景作用实现方案用户信息缓存减少数据库压力,加速查询响应使用 Spring Cache Redis 注解缓存登录 Token 存储分布式 Session 或…...
【AI 大模型】RAG 检索增强生成 ⑤ ( 向量数据库 | 向量数据库 索引结构和搜索算法 | 常见 向量数据库 对比 | 安装并使用 向量数据库 chromadb 案例 )
文章目录 一、向量数据库1、向量数据库引入2、向量数据库简介3、向量数据库 索引结构和搜索算法4、向量数据库 应用场景5、传统数据库 与 向量数据库 对比 二、常见 向量数据库 对比三、向量数据库 案例1、安装 向量数据库 chromadb2、核心要点 解析① 创建数据库实例② 创建数…...
解决single cell portal点击下载但跳转的是网页
Single cell RNA-seq of Tmem100-lineage cells in a mouse model of osseointegration - Single Cell Portal 想下载个小鼠数据集: 点击下载跳转为网页: 复制bulk download给的链接无法下载 bulk download给的原链接: curl.exe "http…...
基于 Prometheus + Grafana 监控微服务和数据库
以下是基于 Prometheus Grafana 监控微服务和数据库的详细指南,包含架构设计、安装配置及验证步骤: 一、整体架构设计 二、监控微服务 1. 微服务指标暴露 Spring Boot 应用: xml <!-- 添加 Micrometer 依赖 --> <dependency>…...
GitHub Copilot 在 VS Code 上的终极中文指南:从安装到高阶玩法
GitHub Copilot 在 VS Code 上的终极中文指南:从安装到高阶玩法 前言 GitHub Copilot 作为 AI 编程助手,正在彻底改变开发者的编码体验。本文将针对中文开发者,深度解析如何在 VS Code 中高效使用 Copilot,涵盖基础设置、中文优化…...
为什么选择 Rust 和 WebAssembly?
一、低级控制与高级体验 在 Web 应用开发中,JavaScript 虽然灵活,但往往难以保证稳定的性能。其动态类型系统和垃圾回收(GC)机制会导致性能波动,甚至在不经意间因偏离 JIT(即时编译器)的最佳路…...
Vala语言基础知识-源文件和编译
源文件和编译 Vala代码以.vala为扩展名。与Java等语言不同,Vala不强制要求严格的文件结构——它没有类似Java的"包"(package)或"类文件"(class file)的概念,而是通过文件内的文本…...
CAN总线的CC帧和FD帧之间如何仲裁
为满足CAN总线日益提高的带宽需求,博世公司于2012年推出CAN FD(具有灵活数据速率的CAN)标准,国际标准化组织(ISO)2015年通过ISO 11898-1:2015标准,正式将CAN FD纳入国际标准,以示区别…...
SpringBoot 第一课(Ⅲ) 配置类注解
目录 一、PropertySource 二、ImportResource ①SpringConfig (Spring框架全注解) ②ImportResource注解实现 三、Bean 四、多配置文件 多Profile文件的使用 文件命名约定: 激活Profile: YAML文件支持多文档块ÿ…...
Python的类和对象(4)
1、反射 动态的给类和对象添加属性,获取属性,删除属性,修改属性【反射】。 --4个内置函数 1)设置属性:setattr( 对象/类,属性名,属性值) 2)获取属性:getattr(对象/类&am…...
使用EasyExcel进行简单的导入、导出
准备 在pom.xml添加依赖 <!-- EasyExcel --><dependency><groupId>com.alibaba</groupId><artifactId>easyexcel</artifactId><version>3.1.1</version></dependency>导入 controller // 用户导入Operation(summary…...
Excel(函数篇):COUNTIF与CONUTIFS函数、SUMIF与SUMIFS函数、ROUND函数、MATCH与INDEX函数、混合引用与条件格式
目录 COUNTIF和COUNTIFS函数COUNTIF函数COUNTIFS函数SUMIF和SUMIFS函数SUMIF函数SUMIFS函数SUMIFS函数与控件实现动态年月汇总ROUND、ROUNDUP、ROUNDDOWN函数单元格混合引用条件格式与公式,标记整行数据MATCH和INDEX函数COUNTIF和COUNTIFS函数 COUNTIF函数 统计下“苏州”出现…...
虚拟定位 1.2.0.2 | 虚拟定位,上班打卡,校园跑步模拟
Fake Location是一款运行于安卓平台上的功能强大、简单实用的虚拟定位软件。它能够帮助用户自定义位置到地图上的任意地方,以ROOT环境运行不易被检测,同时也支持免ROOT运行。提供路线模拟、步频模拟、WIFI模拟等方式,支持反检测。 大小&…...
【最大异或和——可持久化Trie】
题目 代码 #include <bits/stdc.h> using namespace std;const int N 6e510; //注意这里起始有3e5,又可能插入3e5 const int M N * 25;int rt[N], tr[M][2]; //根,trie int idx, cnt, br[M]; //根分配器,点分配器,点的相…...
