配置OGG 如何批量修改源端及目标端序列值_满足客户变态需求学会这招你就赚了

本文主要是介绍配置OGG 如何批量修改源端及目标端序列值_满足客户变态需求学会这招你就赚了,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

欢迎您关注我的公众号【尚雷的驿站】
****************************************************************************
公众号:尚雷的驿站
CSDN :https://blog.csdn.net/shlei5580
墨天轮:https://www.modb.pro/u/2436
PGFans:https://www.pgfans.cn/user/home?userId=4159
****************************************************************************

一、背景描述

最近,我需要对一套 Oracle 11g 数据库进行迁移。这次迁移不是将源库的所有表数据同步至目标库,而是只需要迁移部分表的数据。

此外,业务要求迁移过程中不能停机,并确保迁移前后的数据一致性,以便在失败时能够回退。因此,我采用了 Oracle GoldenGate (OGG) 来同步数据,并进行了双向同步的配置(关于双向同步的详细内容将在后续进行补充)。

不仅如此,更为苛刻的要求是源端和目标端的序列必须满足以下需求:

  1. 调整新库的序列和步长,并记录当前操作时间:
  • 确保新库的序列号尾数为偶数
  • 将所有序列的步长调整为2
  • 导出调整后的序列信息,以确认调整是否成功
  1. 确认新库的正常执行后,调整旧库的序列和步长,并记录当前操作时间:
  • 确保旧库的序列号尾数为奇数
  • 将所有序列的步长调整为2
  • 导出调整后的序列信息,以确认调整是否成功
    尽管这些要求有些过分,但客户坚持这样要求。虽然这个数据库平时的业务量不大,但是迁移过程中不允许停机,必须实时同步数据,同时源端和目标端必须保持连接,还要保证应用程序可以花费相当长的时间来调整数据源。

通过以上序列的修改,我保证了当应用程序同时连接源端和目标端,并对数据进行修改时,不会因为序列问题导致数据冲突,从而影响了 OGG 的同步过程。因此,我费尽九牛二虎之力,最终编写了一个 PL/SQL 脚本,批量修改了源端和目标端的序列值,以使两端都能满足业务需求。

二、PL/SQL脚本

要分别在源端和目标端执行如下pl/sql脚本:

2.1 源端pl/sql

源端执行如下pl/sql脚本

sqlplus / as sysdba
-- 然后执行如下脚本
SET SERVEROUTPUT ON
DECLARECURSOR c_sequences ISSELECT sequence_owner,sequence_name,increment_by,last_numberFROM dba_sequencesWHERE sequence_owner in ('XXX','XXX') AND (increment_by <> 2 or MOD(last_number, 2) != 1);
BEGINFOR r_sequence IN c_sequences LOOPDECLAREcurrent_val NUMBER;BEGINEXECUTE IMMEDIATE 'ALTER SEQUENCE ' || r_sequence.sequence_owner||'.'||r_sequence.sequence_name || ' INCREMENT BY 1 NOCACHE';EXECUTE IMMEDIATE 'SELECT ' || r_sequence.sequence_owner||'.'||r_sequence.sequence_name || '.NEXTVAL FROM DUAL' into current_val;EXECUTE IMMEDIATE 'ALTER SEQUENCE ' || r_sequence.sequence_owner||'.'||r_sequence.sequence_name || ' INCREMENT BY 2 CACHE 20';DBMS_OUTPUT.PUT_LINE(r_sequence.sequence_name);END;END LOOP; DBMS_OUTPUT.PUT_LINE('序列修改完成');
END;
/

2.2 目标端pl/sql

目标端执行如下pl/sql脚本

sqlplus / as sysdba
-- 然后执行如下脚本
SET SERVEROUTPUT ON
DECLARECURSOR c_sequences ISSELECT sequence_owner,sequence_name,increment_by,last_numberFROM dba_sequencesWHERE sequence_owner in ('XXX','XXX') AND (increment_by <> 2 or MOD(last_number, 2) != 0);
BEGINFOR r_sequence IN c_sequences LOOPDECLAREcurrent_val NUMBER;BEGINEXECUTE IMMEDIATE 'ALTER SEQUENCE ' || r_sequence.sequence_owner||'.'||r_sequence.sequence_name || ' INCREMENT BY 1 NOCACHE';EXECUTE IMMEDIATE 'SELECT ' || r_sequence.sequence_owner||'.'||r_sequence.sequence_name || '.NEXTVAL FROM DUAL' into current_val;EXECUTE IMMEDIATE 'ALTER SEQUENCE ' || r_sequence.sequence_owner||'.'||r_sequence.sequence_name || ' INCREMENT BY 2 CACHE 20';DBMS_OUTPUT.PUT_LINE(r_sequence.sequence_name);END;END LOOP; DBMS_OUTPUT.PUT_LINE('序列修改完成');
END;
/

2.3 比对序列

可通过用在源端和目标端创建一个dblink,通过dblink来比对源端和目标端的序列值。
脚本如下:

conn xxx/xxx
WITH source_seq AS (SELECT sequence_name, last_number, increment_byFROM all_sequencesWHERE sequence_owner in ('XXX','XXX')
),
target_seq AS (SELECT sequence_name, last_number, increment_byFROM all_sequences@XXX.XXXWHERE sequence_owner in ('XXX','XXX')
)
SELECT 'SOURCE' AS seq_type, sequence_name, last_number, increment_by
FROM source_seq
UNION ALL
SELECT 'TARGET' AS seq_type, sequence_name, last_number, increment_by
FROM target_seq;

这篇关于配置OGG 如何批量修改源端及目标端序列值_满足客户变态需求学会这招你就赚了的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/824038

相关文章

Jenkins分布式集群配置方式

《Jenkins分布式集群配置方式》:本文主要介绍Jenkins分布式集群配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1.安装jenkins2.配置集群总结Jenkins是一个开源项目,它提供了一个容易使用的持续集成系统,并且提供了大量的plugin满

SpringBoot线程池配置使用示例详解

《SpringBoot线程池配置使用示例详解》SpringBoot集成@Async注解,支持线程池参数配置(核心数、队列容量、拒绝策略等)及生命周期管理,结合监控与任务装饰器,提升异步处理效率与系统... 目录一、核心特性二、添加依赖三、参数详解四、配置线程池五、应用实践代码说明拒绝策略(Rejected

SQL Server配置管理器无法打开的四种解决方法

《SQLServer配置管理器无法打开的四种解决方法》本文总结了SQLServer配置管理器无法打开的四种解决方法,文中通过图文示例介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的... 目录方法一:桌面图标进入方法二:运行窗口进入检查版本号对照表php方法三:查找文件路径方法四:检查 S

Linux中SSH服务配置的全面指南

《Linux中SSH服务配置的全面指南》作为网络安全工程师,SSH(SecureShell)服务的安全配置是我们日常工作中不可忽视的重要环节,本文将从基础配置到高级安全加固,全面解析SSH服务的各项参... 目录概述基础配置详解端口与监听设置主机密钥配置认证机制强化禁用密码认证禁止root直接登录实现双因素

嵌入式数据库SQLite 3配置使用讲解

《嵌入式数据库SQLite3配置使用讲解》本文强调嵌入式项目中SQLite3数据库的重要性,因其零配置、轻量级、跨平台及事务处理特性,可保障数据溯源与责任明确,详细讲解安装配置、基础语法及SQLit... 目录0、惨痛教训1、SQLite3环境配置(1)、下载安装SQLite库(2)、解压下载的文件(3)、

Linux如何快速检查服务器的硬件配置和性能指标

《Linux如何快速检查服务器的硬件配置和性能指标》在运维和开发工作中,我们经常需要快速检查Linux服务器的硬件配置和性能指标,本文将以CentOS为例,介绍如何通过命令行快速获取这些关键信息,... 目录引言一、查询CPU核心数编程(几C?)1. 使用 nproc(最简单)2. 使用 lscpu(详细信

利用Python脚本实现批量将图片转换为WebP格式

《利用Python脚本实现批量将图片转换为WebP格式》Python语言的简洁语法和库支持使其成为图像处理的理想选择,本文将介绍如何利用Python实现批量将图片转换为WebP格式的脚本,WebP作为... 目录简介1. python在图像处理中的应用2. WebP格式的原理和优势2.1 WebP格式与传统

Nginx 重写与重定向配置方法

《Nginx重写与重定向配置方法》Nginx重写与重定向区别:重写修改路径(客户端无感知),重定向跳转新URL(客户端感知),try_files检查文件/目录存在性,return301直接返回永久重... 目录一.try_files指令二.return指令三.rewrite指令区分重写与重定向重写: 请求

Nginx 配置跨域的实现及常见问题解决

《Nginx配置跨域的实现及常见问题解决》本文主要介绍了Nginx配置跨域的实现及常见问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来... 目录1. 跨域1.1 同源策略1.2 跨域资源共享(CORS)2. Nginx 配置跨域的场景2.1

gitlab安装及邮箱配置和常用使用方式

《gitlab安装及邮箱配置和常用使用方式》:本文主要介绍gitlab安装及邮箱配置和常用使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1.安装GitLab2.配置GitLab邮件服务3.GitLab的账号注册邮箱验证及其分组4.gitlab分支和标签的