如何解决Oracle GoldenGate 没有主键的问题？
本站文章除注明转载外，均为本站原创： 转载自love wife love life —Roger 的Oracle技术博客 本文链接地址: 如何解决Oracle GoldenGate 没有主键的问题？ 针对没有主键的情况，GoldenGate大概提供了3种方案，大致如下： 1、默认使用所有列当主键，通过keyco
本站文章除注明转载外，均为本站原创： 转载自love wife & love life —Roger 的Oracle技术博客
本文链接地址: 如何解决Oracle GoldenGate 没有主键的问题？
针对没有主键的情况，GoldenGate大概提供了3种方案，大致如下：
1、默认使用所有列当主键，通过keycols来实现，这种其实存在一定的问题，在这次的项目中直接否定。
2、通过在源端表中添加ogg_key_id列的方式来实现，这可能会影响应用，因此也直接否定。
3、通过在目标端的表中添加rowid类型的伪列，来实现。通过测试，发现这种相对靠谱，如下是我的测试过程.
我这里测试的ogg抽取9208 Dataguard standby,同步到10205的例子。另外，我们这里9i的环境和10g环境均在同一个主机.
1、源端
说明：这里我模拟的是9i环境超过32列的情况.
—创建测试表
SQL> conn roger/roger Connected. SQL> create table t_ALL_TABLES as select * from sys.ALL_TABLES where 1=2; Table created.
—源端OGG配置
GGSCI (killdb.com) 2> view param ext_std
extract ext_std
userid ggs@killdb,password ggs
tranlogoptions archivedlogonly
tranlogoptions altarchivelogdest /home/ora9/arch_s
exttrail /home/ora9/ggs/dirdat/ra
discardfile ./dirrpt/exta.dsc,append, megabytes 500
fetchoptions USEROWID
table roger.t_all_tables, tokens (TKN-ROWID = @GETENV ("RECORD", "rowid")) keycols (owner) ;
table roger.t_buffer;
GGSCI (killdb.com) 3> view param dp1
EXTRACT dp1
RMTHOST 192.168.109.12, MGRPORT 7809 TCPBUFSIZE 5000000
PASSTHRU
RMTTRAIL ./dirdat/r1
NUMFILES 3000
TABLE roger.*;
GGSCI (killdb.com) 5> dblogin userid ggs@killdb,password ggs
Successfully logged into database.
GGSCI (killdb.com) 6> add trandata roger.t_all_Tables cols(owner) nokey
2014-12-17 01:49:59 WARNING OGG-00869 No unique key is defined for table T_ALL_TABLES. All viable columns will be used to represent the key, but may not guarantee uniqueness. KEYCOLS may be used to define the key.
Logging of supplemental redo data enabled for table ROGER.T_ALL_TABLES.
2. 目标端
—创建测试表
www.killdb.com>create table t_all_tables as select * from sys.all_tables where 1=2; Table created. www.killdb.com>alter table t_all_Tables drop column STATUS ; Table altered. www.killdb.com>alter table t_all_Tables drop column DROPPED; Table altered. www.killdb.com>alter table t_all_tables add (row_id rowid); Table altered. www.killdb.com> alter table roger.t_all_Tables add constraint t_all_tables_pk unique (row_id) enable; Table altered.
—目标端OGG配置
GGSCI (killdb.com) 2> view param rep6
replicat rep6
userid ggs@Roger,password AADAAAAAAAAAAADAKHEJYIFGVAKDPFZBGDFJNEQBBJRISJAAOCHHZEWCEFTCRIRCJDSHUHAJZBFDZEWC,encryptkey kasaur_key
reperror default, discard
discardfile ./dirrpt/rep6.dsc, append, megabytes 50
handlecollisions
assumetargetdefs
----allownoopupdates
numfiles 3000
map roger.t_buffer, target roger.t_buffer;
map roger.t_all_tables , target roger.t_all_tables colmap (usedefaults, row_id = @token ("TKN-ROWID")) keycols (row_id);
3. 启动进程
–源端
GGSCI (killdb.com) 5> info all Program Status Group Lag Time Since Chkpt MANAGER RUNNING EXTRACT RUNNING DP1 00:00:00 00:00:07 EXTRACT RUNNING EXT_STD 00:00:00 00:00:07
—目标端
GGSCI (killdb.com) 3> info all Program Status Group Lag at Chkpt Time Since Chkpt MANAGER RUNNING JAGENT STOPPED EXTRACT ABENDED DP1 00:00:00 568:19:49 EXTRACT ABENDED EXT1 00:00:00 309:16:06 REPLICAT STOPPED REP5 00:00:00 596:25:54 REPLICAT RUNNING REP6 00:00:00 00:00:02
4. 源端插入测试数据
模拟insert：
–源端
SQL> insert into t_all_Tables select * from sys.all_Tables where rownum commit; Commit complete. SQL> alter system switch logfile; System altered. SQL>
—-目标端
www.killdb.com>select count(1) from t_all_Tables; COUNT(1) ---------- 10 www.killdb.com>select owner,table_name,row_id from t_all_Tables; OWNER TABLE_NAME ROW_ID ------------------------------ ------------------------------ ------------------ SYS SEG$ AAAH3QAABAAAV0yAAA SYS CLU$ AAAH3QAABAAAV0yAAB SYS OBJ$ AAAH3QAABAAAV0yAAC SYS FILE$ AAAH3QAABAAAV0yAAD SYS COL$ AAAH3QAABAAAV0yAAE SYS CON$ AAAH3QAABAAAV0yAAF SYS PROXY_DATA$ AAAH3QAABAAAV0yAAG SYS USER$ AAAH3QAABAAAV0yAAH SYS IND$ AAAH3QAABAAAV0yAAI SYS FET$ AAAH3QAABAAAV0yAAJ 10 rows selected.
模式delete：
–源端
SQL> delete from t_all_tables where rownum commit; Commit complete. SQL> alter system switch logfile; System altered. SQL> select count(1) from t_all_tables; COUNT(1) ---------- 6 SQL> select owner,table_name,rowid from t_all_tables; OWNER TABLE_NAME ROWID ------------------------------ ------------------------------ ------------------ SYS COL$ AAAH3QAABAAAV0yAAE SYS CON$ AAAH3QAABAAAV0yAAF SYS PROXY_DATA$ AAAH3QAABAAAV0yAAG SYS USER$ AAAH3QAABAAAV0yAAH SYS IND$ AAAH3QAABAAAV0yAAI SYS FET$ AAAH3QAABAAAV0yAAJ 6 rows selected.
—目标端：
www.killdb.com>select count(1) from t_all_Tables; COUNT(1) ---------- 6 www.killdb.com>select owner,table_name,row_id from t_all_Tables; OWNER TABLE_NAME ROW_ID ------------------------------ ------------------------------ ------------------ SYS COL$ AAAH3QAABAAAV0yAAE SYS CON$ AAAH3QAABAAAV0yAAF SYS PROXY_DATA$ AAAH3QAABAAAV0yAAG SYS USER$ AAAH3QAABAAAV0yAAH SYS IND$ AAAH3QAABAAAV0yAAI SYS FET$ AAAH3QAABAAAV0yAAJ 6 rows selected. www.killdb.com>
模拟update：
—源端：
SQL> select owner,table_name,rowid from t_all_tables; OWNER TABLE_NAME ROWID ------------------------------ ------------------------------ ------------------ SYS COL$ AAAH3QAABAAAV0yAAE SYS CON$ AAAH3QAABAAAV0yAAF SYS PROXY_DATA$ AAAH3QAABAAAV0yAAG SYS USER$ AAAH3QAABAAAV0yAAH SYS IND$ AAAH3QAABAAAV0yAAI SYS FET$ AAAH3QAABAAAV0yAAJ 6 rows selected. SQL> update t_all_tables set owner='killdb.com' where table_name='COL$'; 1 row updated. SQL> update t_all_tables set owner='killdb.com' where rowid='AAAH3QAABAAAV0yAAF'; 1 row updated. SQL> commit; Commit complete. SQL> alter system switch logfile; System altered. SQL> select owner,table_name,rowid from t_all_tables; OWNER TABLE_NAME ROWID ------------------------------ ------------------------------ ------------------ killdb.com COL$ AAAH3QAABAAAV0yAAE killdb.com CON$ AAAH3QAABAAAV0yAAF SYS PROXY_DATA$ AAAH3QAABAAAV0yAAG SYS USER$ AAAH3QAABAAAV0yAAH SYS IND$ AAAH3QAABAAAV0yAAI SYS FET$ AAAH3QAABAAAV0yAAJ 6 rows selected.
–目标端：
www.killdb.com> select owner,table_name,row_id from t_all_Tables; OWNER TABLE_NAME ROW_ID ------------------------------ ------------------------------ ------------------ killdb.com COL$ AAAH3QAABAAAV0yAAE killdb.com CON$ AAAH3QAABAAAV0yAAF SYS PROXY_DATA$ AAAH3QAABAAAV0yAAG SYS USER$ AAAH3QAABAAAV0yAAH SYS IND$ AAAH3QAABAAAV0yAAI SYS FET$ AAAH3QAABAAAV0yAAJ 6 rows selected. www.killdb.com>
我们可以看到ogg完全是可以支持利用构造rowid伪列的方式来解决没有主键的问题。 然而这种方法
也有一个很大的问题：迁移之后，新环境中的row_id 伪列需要进行drop，这个drop的动作是非常坑爹的。
例如我们客户这里的系统，均为2.5TB以上的，最大12TB的库，那么drop column就疯掉了。
Related posts:
- 解密dbms_rowid -for 10g
- goldengate 学习系列1–10gasm to 11gR2 asm 单向复制(DDL支持)
- goldengate 学习系列2–相关配置说明
- goldengate 学习系列3–一对多的复制配置
- Goldengate monitor v11.1 Configure for Linux X86
핫 AI 도구
Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱
AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.
Undress AI Tool
무료로 이미지를 벗다
Clothoff.io
AI 옷 제거제
AI Hentai Generator
AI Hentai를 무료로 생성하십시오.
인기 기사
뜨거운 도구
메모장++7.3.1
사용하기 쉬운 무료 코드 편집기
SublimeText3 중국어 버전
중국어 버전, 사용하기 매우 쉽습니다.
스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경
드림위버 CS6
시각적 웹 개발 도구
SublimeText3 Mac 버전
신 수준의 코드 편집 소프트웨어(SublimeText3)
뜨거운 주제
7467
15
1376
52
77
11
45
19
18
19
Oracle에서 환경 변수를 구성하는 방법
Apr 11, 2025 pm 07:18 PM
Oracle Environment 변수 구성 안내서 : Oracle_home 환경 변수를 생성하여 Oracle Home 디렉토리를 가리 킵니다. 경로 환경 변수에 Oracle Binary Directory를 추가하십시오. TNS_ADMIN 환경 변수를 설정하십시오 (파일의 TNS를 사용하여 이름이 지정된 경우). 환경 변수 설정을 확인하여 출력이 설정 변수를 표시하는지 확인하십시오.
Oracle을 수반하는 방법
Apr 11, 2025 pm 07:33 PM
Oracle은 여러 가지 중복 제거 쿼리 방법을 제공합니다. 별개의 키워드는 각 열에 고유 한 값을 반환합니다. 그룹 별 조항은 결과를 그룹화하고 각 그룹에 대해 비 반복 값을 반환합니다. 고유 한 키워드는 고유 한 행만 포함 된 인덱스를 만드는 데 사용되며 인덱스 쿼리는 자동으로 망상됩니다. row_number () 함수는 고유 한 숫자를 할당하고 1 행 만 포함하는 결과를 필터링합니다. 최소 () 또는 max () 함수는 숫자 열의 비 반복 값을 반환합니다. 교차 연산자는 두 결과 세트의 공통 값을 반환합니다 (중복 없음).
Oracle 데이터베이스를 가져 오는 방법
Apr 11, 2025 pm 08:06 PM
데이터 가져 오기 방법 : 1. SQLLOADER 유틸리티 사용 : 데이터 파일 준비, 제어 파일 작성 및 SQLLOADER 실행; 2. IMP/EXP 도구를 사용하십시오 : 데이터 내보내기, 데이터 가져 오기. 팁 : 1. 빅 데이터 세트에 권장되는 SQL*로더; 2. 대상 테이블이 존재해야하고 열 정의가 일치해야합니다. 3. 가져 오기 후에는 데이터 무결성을 확인해야합니다.
Oracle에서 Barbled 코드를 해결하는 방법
Apr 11, 2025 pm 10:09 PM
데이터베이스 문자 세트를 확인하여 데이터와 일치하는지 확인하여 Oracle Garbled 문제를 해결할 수 있습니다. 클라이언트 문자 세트를 데이터베이스와 일치하도록 설정하십시오. 데이터베이스 문자 세트와 일치하도록 데이터 변환 또는 열 문자 세트를 수정하십시오. 유니 코드 문자 세트를 사용하고 멀티 바이트 문자 세트를 피하십시오. 데이터베이스 및 클라이언트의 언어 설정이 올바른지 확인하십시오.
Oracle에 저장된 절차를 사용하는 방법
Apr 11, 2025 pm 07:03 PM
저장된 절차는 데이터베이스에 저장 될 수 있으며 별도의 단위로 반복적으로 호출 될 수있는 SQL 문의 세트입니다. 매개 변수 (In, Out, Inout)를 수락하고 코드 재사용, 보안, 성능 및 모듈성의 장점을 제공 할 수 있습니다. 예 : 저장된 프로 시저를 작성하여 Calculate_sum 두 숫자의 합을 계산하고 Out 매개 변수에 저장하십시오.
Oracle에 테이블 필드를 추가하는 방법
Apr 11, 2025 pm 07:30 PM
Alter Table 문을 사용하십시오. 특정 구문은 다음과 같습니다. Alter Table_Name Add Column_name Data_Type [제한 조건 -Clause]. 여기서 : table_name은 테이블 이름, column_name은 필드 이름, data_type는 데이터 유형이며, 제한 조건은 선택적 제한 조건입니다. 예 : Alter Table 직원 이메일 추가 Varchar2 (100) 직원 테이블에 이메일 필드를 추가합니다.
Oracle의 테이블 스페이스 크기를 확인하는 방법
Apr 11, 2025 pm 08:15 PM
Oracle 테이블 스페이스 크기를 쿼리하려면 다음 단계를 따르십시오. 쿼리를 실행하여 테이블 스페이스 이름을 결정하십시오. 쿼리를 실행하여 테이블 스페이스 크기를 쿼리하십시오. sum (bytes)을 total_size, sum (bytes_free)으로 sum (bytes_free), sum (bytes) - sum (bytes_free)으로 dba_data_fices where tablespace_.
Oracle에서 기본 주요 제약 조건을 만드는 방법
Apr 11, 2025 pm 07:15 PM
기본 키는 테이블의 각 행을 고유하게 식별하는 특수 열 또는 열의 조합입니다. 테이블의 레코드가 고유하고 다음과 같이 작성할 수 있습니다. Alter Table 문을 사용하여 테이블 이름을 지정합니다. 기본 키어 키워드 다음 열 이름을 추가하여 기본 키로 지정하십시오. 주요 주요 제약 조건은 데이터 고유성을 보장하고, 쿼리 속도를 개선하며, 중복 레코드를 방지하며 테이블 조인을 단순화하는 데 도움이됩니다.
