ogg參數(shù)之handlecollisions

本文主要探討 handlecollisions 參數(shù)的作用。

創(chuàng)新互聯(lián)專注于峰峰礦企業(yè)網(wǎng)站建設(shè),成都響應(yīng)式網(wǎng)站建設(shè)公司,商城網(wǎng)站開發(fā)。峰峰礦網(wǎng)站建設(shè)公司,為峰峰礦等地區(qū)提供建站服務(wù)。全流程按需策劃設(shè)計，專業(yè)設(shè)計，全程項(xiàng)目跟蹤，創(chuàng)新互聯(lián)專業(yè)和態(tài)度為您提供的服務(wù)

環(huán)境

ogg12c 版本。

源端目標(biāo)端都在 a 列上有主鍵。

準(zhǔn)備工作

停掉抽取進(jìn)程和投遞進(jìn)程

源端插入幾條數(shù)據(jù)

源端抽取進(jìn)程跳過這些 insert ， alter extract EXT_MI01,begin now

啟動抽取進(jìn)程和投遞進(jìn)程

Delete 實(shí)驗(yàn)

目標(biāo)端

SQL> select * from t3;

A EUTIME B

---------- --------------- ----------

1 3

2 22-OCT-18 3

3 22-OCT-18 3

3 rows selected.

源端：

SQL> select * from t3;

A EUTIME B

---------- --------------- ----------

1 3

2 22-OCT-18 3

3 22-OCT-18 3

4 23-OCT-18 3

5 23-OCT-18 3

5 rows selected.

源端 delete ，并提交

SQL> delete from t3 where a=4;

復(fù)制進(jìn)程 abend ：

2018-10-23 14:39:05 WARNING OGG-01004 Aborted grouped transaction on 'MING.T3', Database error 1403 (OCI Error ORA-01403: no data found, SQL <DELETE FROM "MING"."T3" WHERE "A" = :b0 A

ND "EUTIME" = :b1 AND "B" = :b2 AND ROWNUM = 1>).

2018-10-23 14:39:05 WARNING OGG-01003 Repositioning to rba 2135 in seqno 7.

2018-10-23 14:39:05 WARNING OGG-01154 SQL error 1403 mapping MING.T3 to MING.T3 OCI Error ORA-01403: no data found, SQL <DELETE FROM "MING"."T3" WHERE "A" = :b0 AND "EUTIME" = :b1 AND

"B" = :b2 AND ROWNUM = 1>.

Source Context :

SourceModule : [er.errors]

SourceID : [/scratch/aime/adestore/views/aime_adc4150330/oggcore/OpenSys/src/app/er/errors.cpp]

SourceFunction : [take_rep_err_action]

SourceLine : [941]

ThreadBacktrace : [15] elements

: [/u01/app/oracle/products/ogg/libgglog.so(CMessageContext::AddThreadContext()+0x1b) [0x7f9d6f0554eb]]

: [/u01/app/oracle/products/ogg/libgglog.so(CMessageFactory::CreateMessage(CSourceContext*, unsigned int, ...)+0x135) [0x7f9d6f04f5c5]]

: [/u01/app/oracle/products/ogg/libgglog.so(_MSG_ERR_MAP_TO_TANDEM_FAILED(CSourceContext*, ggs::gglib::ggapp::CQualDBObjName<(DBObjType)1> const&, ggs::gglib::g

gapp::CQualDBObjName<(DBObjType)1> const&, CMessageFactory::MessageDisposition)+0x50) [0x7f9d6f048c7c]]

: [/u01/app/oracle/products/ogg/replicat(take_rep_err_action(short, int, char const*, extr_ptr_def*, std_rec_hdr_def*, char*, file_def*, bool)+0x17aa) [0x5b63ef

]]

: [/u01/app/oracle/products/ogg/replicat(replicate_io(ggs::gglib::ggdatasource::DataSource*, file_def*, ggs::gglib::gglcr::CommonLCR const*, ggs::gglib::gglcr::

CommonLCR*, extr_ptr_def*, int*, int)+0x3847) [0x63ad27]]

: [/u01/app/oracle/products/ogg/replicat(process_record(ggs::gglib::ggdatasource::DataSource*, file_def*&, ggs::gglib::gglcr::CommonLCR const*, ggs::gglib::gglc

r::CommonLCR*, short&, extr_ptr_def*&, extr_ptr_def*&, int&, int&, int&, bool)+0x2f8) [0x63f018]]

: [/u01/app/oracle/products/ogg/replicat(ggs::er::ReplicatContext::processReplicatLoop(ggs::Heartbeat::MapGeneratorParams&)+0x1061) [0x5f6cc1]]

: [/u01/app/oracle/products/ogg/replicat(ggs::er::ReplicatContext::run(ggs::Heartbeat::MapGeneratorParams&)+0x29) [0x5eae39]]

: [/u01/app/oracle/products/ogg/replicat() [0x633c7b]]

: [/u01/app/oracle/products/ogg/replicat(ggs::gglib::MultiThreading::MainThread::ExecMain()+0x60) [0x6ecbe0]]

: [/u01/app/oracle/products/ogg/replicat(ggs::gglib::MultiThreading::Thread::RunThread(ggs::gglib::MultiThreading::Thread::ThreadArgs*)+0x14d) [0x6edbfd]]

: [/u01/app/oracle/products/ogg/replicat(ggs::gglib::MultiThreading::MainThread::Run(int, char**)+0xb1) [0x6edce1]]

: [/u01/app/oracle/products/ogg/replicat(main+0x3b) [0x636c9b]]

: [/lib64/libc.so.6(__libc_start_main+0xfd) [0x37cba1ed1d]]

: [/u01/app/oracle/products/ogg/replicat() [0x56c559]]

2018-10-23 14:39:05 ERROR OGG-01296 Error mapping from MING.T3 to MING.T3.

復(fù)制進(jìn)程修改參數(shù)，添加 handlecollisions

map ming.t3, target ming.t3,handlecollisions;

啟動復(fù)制進(jìn)程

start rep_mi01

GGSCI (ORADB-8955.datadept.eastmoney.com.sh) 79> stats REP_MI01,table ming.t3,total

Sending STATS request to REPLICAT REP_MI01 ...

Start of Statistics at 2018-10-23 14:53:21.

Replicating from MING.T3 to MING.T3:

*** Total statistics since 2018-10-23 14:53:03 ***

Total inserts 0.00

Total updates 0.00

Total deletes 1.00

Total discards 0.00

Total operations 1.00

Total delete collisions 1.00

End of Statistics

Update 實(shí)驗(yàn)

去掉 handlecollisions 參數(shù)，源端插入數(shù)據(jù)抽取進(jìn)程并跳過這些差異數(shù)據(jù)。

源端

SQL> select * from t3;

A EUTIME B

---------- --------------- ----------

1 3

2 22-OCT-18 3

3 22-OCT-18 3

5 23-OCT-18 3

6 23-OCT-18 3

4 23-OCT-18 3

6 rows selected.

目標(biāo)端

SQL> select * from t3;

A EUTIME B

---------- --------------- ----------

1 3

2 22-OCT-18 3

3 22-OCT-18 3

3 rows selected.

源端 update 一條數(shù)據(jù)并提交：

SQL> update t3 set a=7,b=4 where a=6;

目標(biāo)端復(fù)制進(jìn)程 abend

2018-10-23 15:06:20 WARNING OGG-01004 Aborted grouped transaction on 'MING.T3', Database error 1403 (OCI Error ORA-01403: no data found, SQL <UPDATE "MING"."T3" x SET x."A" = :a3,x."EU

TIME" = :a4,x."B" = :a5 WHERE x."A" = :b0>).

2018-10-23 15:06:20 WARNING OGG-01003 Repositioning to rba 5635 in seqno 7.

2018-10-23 15:06:20 WARNING OGG-01154 SQL error 1403 mapping MING.T3 to MING.T3 OCI Error ORA-01403: no data found, SQL <UPDATE "MING"."T3" x SET x."A" = :a3,x."EUTIME" = :a4,x."B" = :

a5 WHERE x."A" = :b0>.

Source Context :

SourceModule : [er.errors]

SourceID : [/scratch/aime/adestore/views/aime_adc4150330/oggcore/OpenSys/src/app/er/errors.cpp]

SourceFunction : [take_rep_err_action]

SourceLine : [941]

ThreadBacktrace : [15] elements

: [/u01/app/oracle/products/ogg/libgglog.so(CMessageContext::AddThreadContext()+0x1b) [0x7f552516e4eb]]

: [/u01/app/oracle/products/ogg/libgglog.so(CMessageFactory::CreateMessage(CSourceContext*, unsigned int, ...)+0x135) [0x7f55251685c5]]

: [/u01/app/oracle/products/ogg/libgglog.so(_MSG_ERR_MAP_TO_TANDEM_FAILED(CSourceContext*, ggs::gglib::ggapp::CQualDBObjName<(DBObjType)1> const&, ggs::gglib::g

gapp::CQualDBObjName<(DBObjType)1> const&, CMessageFactory::MessageDisposition)+0x50) [0x7f5525161c7c]]

: [/u01/app/oracle/products/ogg/replicat(take_rep_err_action(short, int, char const*, extr_ptr_def*, std_rec_hdr_def*, char*, file_def*, bool)+0x17aa) [0x5b63ef

]]

: [/u01/app/oracle/products/ogg/replicat(replicate_io(ggs::gglib::ggdatasource::DataSource*, file_def*, ggs::gglib::gglcr::CommonLCR const*, ggs::gglib::gglcr::

CommonLCR*, extr_ptr_def*, int*, int)+0x3847) [0x63ad27]]

: [/u01/app/oracle/products/ogg/replicat(process_record(ggs::gglib::ggdatasource::DataSource*, file_def*&, ggs::gglib::gglcr::CommonLCR const*, ggs::gglib::gglc

r::CommonLCR*, short&, extr_ptr_def*&, extr_ptr_def*&, int&, int&, int&, bool)+0x2f8) [0x63f018]]

: [/u01/app/oracle/products/ogg/replicat(ggs::er::ReplicatContext::processReplicatLoop(ggs::Heartbeat::MapGeneratorParams&)+0x1061) [0x5f6cc1]]

: [/u01/app/oracle/products/ogg/replicat(ggs::er::ReplicatContext::run(ggs::Heartbeat::MapGeneratorParams&)+0x29) [0x5eae39]]

: [/u01/app/oracle/products/ogg/replicat() [0x633c7b]]

: [/u01/app/oracle/products/ogg/replicat(ggs::gglib::MultiThreading::MainThread::ExecMain()+0x60) [0x6ecbe0]]

: [/u01/app/oracle/products/ogg/replicat(ggs::gglib::MultiThreading::Thread::RunThread(ggs::gglib::MultiThreading::Thread::ThreadArgs*)+0x14d) [0x6edbfd]]

: [/u01/app/oracle/products/ogg/replicat(ggs::gglib::MultiThreading::MainThread::Run(int, char**)+0xb1) [0x6edce1]]

: [/u01/app/oracle/products/ogg/replicat(main+0x3b) [0x636c9b]]

: [/lib64/libc.so.6(__libc_start_main+0xfd) [0x37cba1ed1d]]

: [/u01/app/oracle/products/ogg/replicat() [0x56c559]]

2018-10-23 15:06:20 ERROR OGG-01296 Error mapping from MING.T3 to MING.T3.

復(fù)制進(jìn)程添加

map ming.t3, target ming.t3,handlecollisions;

開啟復(fù)制進(jìn)程

start rep_mi01

handlecollisions 變 update 為 insert 了

SQL> select * from t3;

A EUTIME B

---------- --------------- ----------

1 3

2 22-OCT-18 3

3 22-OCT-18 3

7 23-OCT-18 4

4 rows selected.

Insert 實(shí)驗(yàn)

目標(biāo)端插入一條數(shù)據(jù)并提交

SQL> insert into t3(a,b) values(9,9);

源端插入主鍵為 9 的數(shù)據(jù)

SQL> insert into t3(a) values(9);

SQL> commit;

SQL> select * from t3;

A EUTIME B

---------- --------------- ----------

1 3

2 22-OCT-18 3

3 22-OCT-18 3

5 23-OCT-18 4

7 23-OCT-18 4

4 23-OCT-18 3

8 23-OCT-18 3

9 23-OCT-18 3

8 rows selected.

目標(biāo)端：

SQL> select * from t3;

A EUTIME B

---------- --------------- ----------

1 3

2 22-OCT-18 3

3 22-OCT-18 3

7 23-OCT-18 4

5 23-OCT-18 4

8 23-OCT-18 3

9 23-OCT-18 3

7 rows selected.

目標(biāo)端復(fù)制進(jìn)程沒有 abend ，舊的數(shù)據(jù)被覆蓋，以源端為主。

去掉復(fù)制進(jìn)程中的 handlecollisions ，源端插入數(shù)據(jù)

SQL> insert into t3(a,b) values(10,10);

SQL> commit;

源端插入數(shù)據(jù)并提交

SQL> insert into t3(a) values(10);

源端進(jìn)程 abend

2018-10-23 15:36:46 WARNING OGG-00869 OCI Error ORA-00001: (MING. (status = 1), SQL <INSERT INTO "MING"."T3" ("A","EUTIME","B") VALUES (:a0,:a1,:a2)>.

2018-10-23 15:36:46 WARNING OGG-01004 Aborted grouped transaction on 'MING.T3', Database error 1 (OCI Error ORA-00001: (MING. (status = 1), SQL <INSERT INTO "MING"."T3" ("A","EUTIME",

"B") VALUES (:a0,:a1,:a2)>).

2018-10-23 15:36:46 WARNING OGG-01003 Repositioning to rba 6366 in seqno 7.

2018-10-23 15:36:46 WARNING OGG-01154 SQL error 1 mapping MING.T3 to MING.T3 OCI Error ORA-00001: (MING. (status = 1), SQL <INSERT INTO "MING"."T3" ("A","EUTIME","B") VALUES (:a0,:a1,

:a2)>.

Source Context :

SourceModule : [er.errors]

SourceID : [/scratch/aime/adestore/views/aime_adc4150330/oggcore/OpenSys/src/app/er/errors.cpp]

SourceFunction : [take_rep_err_action]

SourceLine : [941]

ThreadBacktrace : [15] elements

: [/u01/app/oracle/products/ogg/libgglog.so(CMessageContext::AddThreadContext()+0x1b) [0x7f118d26c4eb]]

: [/u01/app/oracle/products/ogg/libgglog.so(CMessageFactory::CreateMessage(CSourceContext*, unsigned int, ...)+0x135) [0x7f118d2665c5]]

: [/u01/app/oracle/products/ogg/libgglog.so(_MSG_ERR_MAP_TO_TANDEM_FAILED(CSourceContext*, ggs::gglib::ggapp::CQualDBObjName<(DBObjType)1> const&, ggs::gglib::g

gapp::CQualDBObjName<(DBObjType)1> const&, CMessageFactory::MessageDisposition)+0x50) [0x7f118d25fc7c]]

: [/u01/app/oracle/products/ogg/replicat(take_rep_err_action(short, int, char const*, extr_ptr_def*, std_rec_hdr_def*, char*, file_def*, bool)+0x17aa) [0x5b63ef

]]

: [/u01/app/oracle/products/ogg/replicat(replicate_io(ggs::gglib::ggdatasource::DataSource*, file_def*, ggs::gglib::gglcr::CommonLCR const*, ggs::gglib::gglcr::

CommonLCR*, extr_ptr_def*, int*, int)+0x3847) [0x63ad27]]

: [/u01/app/oracle/products/ogg/replicat(process_record(ggs::gglib::ggdatasource::DataSource*, file_def*&, ggs::gglib::gglcr::CommonLCR const*, ggs::gglib::gglc

r::CommonLCR*, short&, extr_ptr_def*&, extr_ptr_def*&, int&, int&, int&, bool)+0x2f8) [0x63f018]]

: [/u01/app/oracle/products/ogg/replicat(ggs::er::ReplicatContext::processReplicatLoop(ggs::Heartbeat::MapGeneratorParams&)+0x1061) [0x5f6cc1]]

: [/u01/app/oracle/products/ogg/replicat(ggs::er::ReplicatContext::run(ggs::Heartbeat::MapGeneratorParams&)+0x29) [0x5eae39]]

: [/u01/app/oracle/products/ogg/replicat() [0x633c7b]]

: [/u01/app/oracle/products/ogg/replicat(ggs::gglib::MultiThreading::MainThread::ExecMain()+0x60) [0x6ecbe0]]

: [/u01/app/oracle/products/ogg/replicat(ggs::gglib::MultiThreading::Thread::RunThread(ggs::gglib::MultiThreading::Thread::ThreadArgs*)+0x14d) [0x6edbfd]]

: [/u01/app/oracle/products/ogg/replicat(ggs::gglib::MultiThreading::MainThread::Run(int, char**)+0xb1) [0x6edce1]]

: [/u01/app/oracle/products/ogg/replicat(main+0x3b) [0x636c9b]]

: [/lib64/libc.so.6(__libc_start_main+0xfd) [0x37cba1ed1d]]

: [/u01/app/oracle/products/ogg/replicat() [0x56c559]]

2018-10-23 15:36:46 ERROR OGG-01296 Error mapping from MING.T3 to MING.T3.

再次加入 handlecollisions 參數(shù)，目標(biāo)端數(shù)據(jù)被修改為與源端一致。

總結(jié)：

1.handlecollisions 是復(fù)制進(jìn)程參數(shù)

2. 對于 delete 操作，無 handlecollisions 參數(shù)，源端 delete 一條數(shù)據(jù)，目標(biāo)端沒有符合要求，那么復(fù)制進(jìn)程會 abend ；

有 handlecollisions 參數(shù)，復(fù)制進(jìn)程不會 abend ，目標(biāo)端會跳過 delete

3. 對于 update 操作，無 handlecollisions 參數(shù)，源端 update 一條數(shù)據(jù)，目標(biāo)端沒有符合要求，那么復(fù)制進(jìn)程會 abend ；

有 handlecollisions 參數(shù)，復(fù)制進(jìn)程不會 abend ，目標(biāo)端將 update 變?yōu)?insert ，將數(shù)據(jù)插入目標(biāo)端。

4. 對于 insert 操作，無 handlecollisions 參數(shù)，源端 insert 一條數(shù)據(jù)，目標(biāo)端違反了唯一性約束，那么復(fù)制進(jìn)程會 abend ；

有 handlecollisions 參數(shù)，復(fù)制進(jìn)程不會 abend ，目標(biāo)端將按照源端數(shù)據(jù)，修改目標(biāo)端違反唯一性約束的數(shù)據(jù)。

網(wǎng)頁名稱：ogg參數(shù)之handlecollisions
當(dāng)前地址：http://muchs.cn/article24/jojsce.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供企業(yè)建站、網(wǎng)站維護(hù)、服務(wù)器托管、定制網(wǎng)站、網(wǎng)站制作、微信公眾號

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容