2. 程式人生 > >OGG進程拆分（單表拆成多個進程）

OGG進程拆分（單表拆成多個進程）

阿新 • • 發佈：2017-09-20
byte utf 主機 al32utf8 spa pup epo 同時 edi

OGG進程拆分（單表拆成多個進程） 概要： 《OGG進程拆分》介紹了如何將一個入庫進程中的多個表拆分到其他進程中。本篇將著重介紹如何使用多個進程同時入庫一張表。 適用條件： 1）入庫進程只同步一張表，但仍有延時 2）目標段主機CPU、內存壓力不大，以便有足夠的資源添加新的入庫進程 本示例將RZG_CXI2中的HX_SB.SB_CWBB_XQYKJZZ_ZCFZB表拆分到RZG_CXI1-RZG_CXI8這8個進程中 1. 創建新添加進程的配置文件 edit params RZG_CXI1 ##添加以下內容## REPLICAT RZG_CXI1 SETENV (ORACLE_SID="hasthxcx1") SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8) Userid ggs,PASSWORD AACAAAAAAAAAAAIAUCOJGDDFPFHEGCPD, BLOWFISH, ENCRYPTKEY DEFAULT REPORT AT 01:59 REPORTROLLOVER AT 02:00 CACHEMGR, CACHESIZE 256MB REPERROR DEFAULT,ABEND DISCARDFILE ./dirrpt/RZG_CXI1.dsc,APPEND,MEGABYTES 100 DISCARDROLLOVER AT 06:00 GETTRUNCATES NUMFILES 3000 EOFDELAYCSECS 30 ASSUMETARGETDEFS ALLOWNOOPUPDATES DYNAMICRESOLUTION GETUPDATEBEFORES NOCOMPRESSDELETES MAP HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , TARGET HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , colmap (usedefaults , & sjtb_sj = @date ("yyyy-mm-dd hh:mi:ss.ffffff", "JTS", @GETENV("JULIANTIMESTAMP"))), FILTER (@RANGE (1, 8)); ##結束##
edit params RZG_CXI2 ##開始## REPLICAT RZG_CXI2 SETENV (ORACLE_SID="hasthxcx1") SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8) Userid ggs,PASSWORD AACAAAAAAAAAAAIAUCOJGDDFPFHEGCPD, BLOWFISH, ENCRYPTKEY DEFAULT REPORT AT 01:59 REPORTROLLOVER AT 02:00 CACHEMGR, CACHESIZE 256MB REPERROR DEFAULT,ABEND DISCARDFILE ./dirrpt/RZG_CXI2.dsc,APPEND,MEGABYTES 100 DISCARDROLLOVER AT 06:00 GETTRUNCATES NUMFILES 3000 EOFDELAYCSECS 30 ASSUMETARGETDEFS ALLOWNOOPUPDATES DYNAMICRESOLUTION GETUPDATEBEFORES NOCOMPRESSDELETES MAP HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , TARGET HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , colmap (usedefaults , & sjtb_sj = @date ("yyyy-mm-dd hh:mi:ss.ffffff", "JTS", @GETENV("JULIANTIMESTAMP"))), FILTER (@RANGE (2, 8)); ##結束##
edit params RZG_CXI3 ##開始## REPLICAT RZG_CXI3 SETENV (ORACLE_SID="hasthxcx1") SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8) Userid ggs,PASSWORD AACAAAAAAAAAAAIAUCOJGDDFPFHEGCPD, BLOWFISH, ENCRYPTKEY DEFAULT REPORT AT 01:59 REPORTROLLOVER AT 02:00 CACHEMGR, CACHESIZE 256MB REPERROR DEFAULT,ABEND DISCARDFILE ./dirrpt/RZG_CXI3.dsc,APPEND,MEGABYTES 100 DISCARDROLLOVER AT 06:00 GETTRUNCATES NUMFILES 3000 EOFDELAYCSECS 30 ASSUMETARGETDEFS ALLOWNOOPUPDATES DYNAMICRESOLUTION GETUPDATEBEFORES NOCOMPRESSDELETES MAP HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , TARGET HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , colmap (usedefaults , & sjtb_sj = @date ("yyyy-mm-dd hh:mi:ss.ffffff", "JTS", @GETENV("JULIANTIMESTAMP"))), FILTER (@RANGE (3, 8)); ##結束##
edit params RZG_CXI4 ##開始## REPLICAT RZG_CXI4 SETENV (ORACLE_SID="hasthxcx1") SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8) Userid ggs,PASSWORD AACAAAAAAAAAAAIAUCOJGDDFPFHEGCPD, BLOWFISH, ENCRYPTKEY DEFAULT REPORT AT 01:59 REPORTROLLOVER AT 02:00 CACHEMGR, CACHESIZE 256MB REPERROR DEFAULT,ABEND DISCARDFILE ./dirrpt/RZG_CXI4.dsc,APPEND,MEGABYTES 100 DISCARDROLLOVER AT 06:00 GETTRUNCATES NUMFILES 3000 EOFDELAYCSECS 30 ASSUMETARGETDEFS ALLOWNOOPUPDATES DYNAMICRESOLUTION GETUPDATEBEFORES NOCOMPRESSDELETES MAP HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , TARGET HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , colmap (usedefaults , & sjtb_sj = @date ("yyyy-mm-dd hh:mi:ss.ffffff", "JTS", @GETENV("JULIANTIMESTAMP"))), FILTER (@RANGE (4, 8)); ##結束## edit params RZG_CXI5 ##開始## REPLICAT RZG_CXI5 SETENV (ORACLE_SID="hasthxcx1") SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8) Userid ggs,PASSWORD AACAAAAAAAAAAAIAUCOJGDDFPFHEGCPD, BLOWFISH, ENCRYPTKEY DEFAULT REPORT AT 01:59 REPORTROLLOVER AT 02:00 CACHEMGR, CACHESIZE 256MB REPERROR DEFAULT,ABEND DISCARDFILE ./dirrpt/RZG_CXI5.dsc,APPEND,MEGABYTES 100 DISCARDROLLOVER AT 06:00 GETTRUNCATES NUMFILES 3000 EOFDELAYCSECS 30 ASSUMETARGETDEFS ALLOWNOOPUPDATES DYNAMICRESOLUTION GETUPDATEBEFORES NOCOMPRESSDELETES MAP HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , TARGET HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , colmap (usedefaults , & sjtb_sj = @date ("yyyy-mm-dd hh:mi:ss.ffffff", "JTS", @GETENV("JULIANTIMESTAMP"))), FILTER (@RANGE (5, 8)); ##結束## edit params RZG_CXI6 ##開始## REPLICAT RZG_CXI6 SETENV (ORACLE_SID="hasthxcx1") SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8) Userid ggs,PASSWORD AACAAAAAAAAAAAIAUCOJGDDFPFHEGCPD, BLOWFISH, ENCRYPTKEY DEFAULT REPORT AT 01:59 REPORTROLLOVER AT 02:00 CACHEMGR, CACHESIZE 256MB REPERROR DEFAULT,ABEND DISCARDFILE ./dirrpt/RZG_CXI6.dsc,APPEND,MEGABYTES 100 DISCARDROLLOVER AT 06:00 GETTRUNCATES NUMFILES 3000 EOFDELAYCSECS 30 ASSUMETARGETDEFS ALLOWNOOPUPDATES DYNAMICRESOLUTION GETUPDATEBEFORES NOCOMPRESSDELETES MAP HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , TARGET HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , colmap (usedefaults , & sjtb_sj = @date ("yyyy-mm-dd hh:mi:ss.ffffff", "JTS", @GETENV("JULIANTIMESTAMP"))), FILTER (@RANGE (6, 8)); ##結束## edit params RZG_CXI7 ##開始## REPLICAT RZG_CXI7 SETENV (ORACLE_SID="hasthxcx1") SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8) Userid ggs,PASSWORD AACAAAAAAAAAAAIAUCOJGDDFPFHEGCPD, BLOWFISH, ENCRYPTKEY DEFAULT REPORT AT 01:59 REPORTROLLOVER AT 02:00 CACHEMGR, CACHESIZE 256MB REPERROR DEFAULT,ABEND DISCARDFILE ./dirrpt/RZG_CXI7.dsc,APPEND,MEGABYTES 100 DISCARDROLLOVER AT 06:00 GETTRUNCATES NUMFILES 3000 EOFDELAYCSECS 30 ASSUMETARGETDEFS ALLOWNOOPUPDATES DYNAMICRESOLUTION GETUPDATEBEFORES NOCOMPRESSDELETES MAP HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , TARGET HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , colmap (usedefaults , & sjtb_sj = @date ("yyyy-mm-dd hh:mi:ss.ffffff", "JTS", @GETENV("JULIANTIMESTAMP"))), FILTER (@RANGE (7, 8)); ##結束## edit params RZG_CXI8 ##開始## REPLICAT RZG_CXI8 SETENV (ORACLE_SID="hasthxcx1") SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8) Userid ggs,PASSWORD AACAAAAAAAAAAAIAUCOJGDDFPFHEGCPD, BLOWFISH, ENCRYPTKEY DEFAULT REPORT AT 01:59 REPORTROLLOVER AT 02:00 CACHEMGR, CACHESIZE 256MB REPERROR DEFAULT,ABEND DISCARDFILE ./dirrpt/RZG_CXI8.dsc,APPEND,MEGABYTES 100 DISCARDROLLOVER AT 06:00 GETTRUNCATES NUMFILES 3000 EOFDELAYCSECS 30 ASSUMETARGETDEFS ALLOWNOOPUPDATES DYNAMICRESOLUTION GETUPDATEBEFORES NOCOMPRESSDELETES MAP HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , TARGET HX_SB.SB_CWBB_XQYKJZZ_ZCFZB , colmap (usedefaults , & sjtb_sj = @date ("yyyy-mm-dd hh:mi:ss.ffffff", "JTS", @GETENV("JULIANTIMESTAMP"))), FILTER (@RANGE (8, 8)); ##結束## 1，查看 日誌序列號和rba (添加進程時註意修改trail文件名，日誌序號，rba) 等stop後查看 info RZG_CX2I GGSCI (hasthxcxdb01) 33> info RZG_CX2I REPLICAT RZG_CX2I Last Started 2016-06-02 11:39 Status RUNNING Checkpoint Lag 91:53:11 (updated 03:12:24 ago) Log Read Checkpoint File ./dirdat/za003124 2016-05-30 19:43:03.015049 RBA 114276026 2，登錄數據庫 dblogin Userid ggs,PASSWORD AACAAAAAAAAAAAIAUCOJGDDFPFHEGCPD, BLOWFISH, ENCRYPTKEY DEFAULT ##密文部分為OGG用戶ggs的密碼，也可用明文 3.，添加進程 RZG_CXI 上面已經編輯過8個進程的參數文件，這裏添加進程即可 $ ggsci add replicat RZG_CXI1, exttrail ./dirdat/za add replicat RZG_CXI2, exttrail ./dirdat/za add replicat RZG_CXI3, exttrail ./dirdat/za add replicat RZG_CXI4, exttrail ./dirdat/za add replicat RZG_CXI5, exttrail ./dirdat/za add replicat RZG_CXI6, exttrail ./dirdat/za add replicat RZG_CXI7, exttrail ./dirdat/za add replicat RZG_CXI8, exttrail ./dirdat/za 4， 修改進程檢查點 $ ggsci alter replicat RZG_CXI1, extseqno 3124, extrba 114276026 alter replicat RZG_CXI2, extseqno 3124, extrba 114276026 alter replicat RZG_CXI3, extseqno 3124, extrba 114276026 alter replicat RZG_CXI4, extseqno 3124, extrba 114276026 alter replicat RZG_CXI5, extseqno 3124, extrba 114276026 alter replicat RZG_CXI6, extseqno 3124, extrba 114276026 alter replicat RZG_CXI7, extseqno 3124, extrba 114276026 alter replicat RZG_CXI8, extseqno 3124, extrba 114276026 5，啟動新增的8個進程 　start RZG_CXI* 6，再次登錄數據庫，刪除原進程 dblogin Userid ggs,PASSWORD AACAAAAAAAAAAAIAUCOJGDDFPFHEGCPD, BLOWFISH, ENCRYPTKEY DEFAULT delete RZG_CX2I

OGG進程拆分（單表拆成多個進程）

相關推薦

OGG進程拆分（單表拆成多個進程）

byte utf 主機 al32utf8 spa pup epo 同時 edi OGG進程拆分（單表拆成多個進程） 概要： 《OGG進程拆分》介紹了如何將一個入庫進程中的多個表拆分到其他進程中。本篇將著重介紹如何使用多個進程同時入庫一張表。 適用條件： 1）入庫進程只同

Hibernate中多對多的annotation的寫法（中間表可以有多個欄位）

一般情況下，多對多的關聯關係是需要中間表的； 情況一：如果中間表僅僅是做關聯用的，它裡面僅有2個外來鍵做聯合主鍵，則使用ManyToMany（不用寫中間表的Model，只需要寫出兩張主表的model即可） 學生表 @Entity@Table(name = "T_STUDENT")@SequenceGener

基於註解的Hibernate JPA操作CRUD（單表、一對多和多對多）

0.maven引入相關依賴資源 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/200

SpringBoot進階之檔案上傳（單檔案上傳/多檔案上傳）

1.單檔案上傳 private String uploadPath="D:\\tomcat\\apache-tomcat-7.0.81-windows-x64\\apache-tomcat-7

C 將一個單鏈表拆成3個迴圈連結串列，其中一個是純數字，一個純字母，一個其他字元

前面相關操作在這呢，這個函式依託於此 //結構體 typedef struct Node { ElementType data; struct Node * next; } LNode, * LinkNode; //將一個單鏈表拆成3個迴圈連結串列，其中一個是純數字

Hibernate中多對多的annotation的寫法（中間表可以有多個額外新增的欄位）

方案一   中間表聯合主鍵，自動生成 一般情況下，多對多的關聯關係是需要中間表的； 情況一：如果中間表僅僅是做關聯用的，它裡面僅有2個外來鍵做聯合主鍵，則使用ManyToMany（不用寫中間表的Model，只需要寫出兩張主表的model即可） 學生表 @Entity@Table(name = "T_STUD

gradle多專案構建Android （一個專案中引用多個庫專案 ）（十）

update time:2019-1-11 Author:要你命三千又三千 type:學習筆記 專案分類 前提了解 庫專案（對應的 apply plugin:’ com.android.library） 應用專案(com.android.application)

C#程序調用cmd.exe執行其他exe進程（並且含多個參數），並把進程結果返回給字符串

() stat syntax || 錯誤 void dia clas ring 1.關鍵代碼部分。 using System.Diagnostics; public class CmdHelper {

數據庫：MySQL（單表的表記錄的操作）（二）

基礎上 des 別名 order by data database values 生成 結果 一、表記錄的增刪改查 1、增加表記錄 <1>插入一條記錄： 　　insert ［into］ tab_name (field1,filed2,.......) val

Java，基於SSM,省市區三級聯動後臺查詢（單表），附（建表語句+查詢Sql）

1、建表語句 CREATE TABLE "hxdb"."sys_area" ( "id" varchar(64) COLLATE "default" NOT NULL, "code" varchar(

mysql之後查詢相關（單表）

1mysql的加法運算 mysql使用加法運算的時候，如果相加的兩個欄位或者其中的一個欄位不是數字型別，則會轉換為0，再相加。如下圖所示： 如果將ename屬性和job屬性相加，則會得出如下結果： SELECT ename+job FROM emp; 如果將s

SQL面試題 三（單表、多表查詢）

一、給定一張學生成績表tb_grade：學號，姓名，科目號，科目名，分數。（如下表） （select * from tb_grade order by Sno,Cno;）+------+-------+-----+-------+-------+ | Sno  | Sna

資料庫模型設計連載之（單表模式 ）

原文地址：http://blog.csdn.net/liu7537/article/details/713966 （三）單表模式 單表模式，就是把相關子類的屬性統統集中在一個表裡，通過“類別”欄位來區分表內記錄所屬的子類以及該類的有效屬性。在實際案例當中，單表模式的應用

mybatis框架之mapper的xml配置的編寫（單表）

在使用mybatis的時候，我們要用到mapper對映，也就是說，一個專案有持久層dao，業務層service，表現層contraller，現在加上一個mapper對映。在mapper中，介面要和xml配置檔名字一樣。 如： 在介面中，我們定義一些方法，這些方法在持久層dao中要用

MYSQL常用查詢語句（單表）

本文主要介紹MYSQL常用的簡單查詢語句： 1.欄位名起別名查詢,關鍵字AS後為所起的別名。如： SELECT   id   AS userID, username   AS    uname   FROM   users; 2.WHERE語句進行條件查詢。如： SE

Realm的簡單使用（單表_增刪改查_包含非同步操作）

學習參考網址： 具體程式碼： 由於互動的資料被我固定了，又為了防止因為資料是固定的而發生異常，所以寫了些異常捕獲，只要添上互動的資料，功能沒有任何問題，就可以不用寫這些異常捕獲了。 前期準備： 1.在project的gradle裡新增classp

Python中使用SQLAlchemy連線Mysql資料庫（單表操作）

一，SQLAlchemy的安裝 使用 $ easy_install sqlalchemy 或 $ pip install sqlalchemy 如果出現什麼錯，就進去root使用者下進行安裝試試，或者網上查查 >>>

sqoop命令，mysql匯入到hbase（單表，整個資料庫匯入）

在搭建大資料平臺的時候，如何把傳統mysql資料庫匯入到hbase中顯得格外的重要，所以現在我們來介紹一些基本的操作。 1.測試mysql能否連線 注意：這裡你需要掌握資料庫的知識，先把資料庫設

在一個進程中定義多個線程

daemon 之前 args 設置 tar main art blog thread import threadingfrom time import ctime,sleepimport timedef music(name): print(‘listening to

多個線程實現順序打印數據，（可自定義線程一次打印數量和總數量）

技術分享 str logs ges his .get shm import pre 　　最近看到一道面試題：讓3個線程順序打印數字，如線程1打印1-5，線程2打印6-10，線程3打印11-15,然後是線程1打印16-20...一直打印到75結束。 　　這到題主要問題有兩點