[發(fā)明專利]一種基于RAC的數(shù)據(jù)庫(kù)日志文件讀取方法和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201911156736.7
• 申請(qǐng)日: 2019-11-22
• 公開（公告）號(hào): CN111061690B
• 公開（公告）日: 2023-08-22
• 發(fā)明（設(shè)計(jì)）人: 孫峰;陳艷;余院蘭
• 申請(qǐng)（專利權(quán)）人: 武漢達(dá)夢(mèng)數(shù)據(jù)庫(kù)股份有限公司
• 主分類號(hào): G06F16/17
• 分類號(hào): G06F16/17;G06F16/176;G06F16/18
• 代理公司: 深圳市六加知識(shí)產(chǎn)權(quán)代理有限公司 44372
• 代理人: 向彬

1.一種基于RAC的數(shù)據(jù)庫(kù)日志文件讀取方法，其特征在于，包括：

將需讀取的日志文件分為連續(xù)的數(shù)據(jù)片，每個(gè)數(shù)據(jù)片中包含至少一個(gè)日志塊，每一個(gè)數(shù)據(jù)片的數(shù)據(jù)量小于等于預(yù)設(shè)閾值；其中，所述數(shù)據(jù)片的大小為：

其中，ORA_IO_READ_BUFFER為每個(gè)線程度讀取的數(shù)據(jù)塊大小，MAX_IO_READ為預(yù)設(shè)數(shù)據(jù)長(zhǎng)度閾值，LOG_BLOCK_SIZE為Direct?I/O讀寫限制的日志塊大小；

創(chuàng)建至少2個(gè)日志讀取線程，日志讀取線程數(shù)量小于等于每個(gè)數(shù)據(jù)片中包含的日志塊數(shù)量；

根據(jù)日志讀取線程的數(shù)量計(jì)算每個(gè)日志讀取線程需讀取的日志文件起始日志塊偏移值，根據(jù)日志塊偏移值為每個(gè)日志讀取線程分配需讀取的數(shù)據(jù)塊，每個(gè)數(shù)據(jù)塊包含至少一個(gè)日志塊；

建立日志緩存區(qū)，所述日志緩存區(qū)的大小不小于劃分后的數(shù)據(jù)片大小，且以日志塊大小為標(biāo)準(zhǔn)對(duì)齊內(nèi)存地址，啟動(dòng)所有日志讀取線程，每個(gè)日志讀取線程按照被分配的需讀取的日志塊偏移值以日志塊為單位對(duì)數(shù)據(jù)片日志文件并行讀取；其中，并發(fā)讀取時(shí)所有線程一次讀取的日志大小為：

其中，REAL_LOG_SIZE為實(shí)際讀取的大小,?n為同時(shí)并發(fā)讀取的日志讀取線程數(shù)量，MAX_IO_READ為預(yù)設(shè)數(shù)據(jù)長(zhǎng)度閾值，LOG_BLOCK_SIZE為Direct?I/O讀寫限制的日志塊大小；

對(duì)每個(gè)日志讀取線程讀取到的每一個(gè)日志塊進(jìn)行數(shù)據(jù)校驗(yàn)，判斷每一個(gè)日志塊是否讀取正確；若讀取正確，將讀取到的日志塊放入日志緩存區(qū)；若讀取錯(cuò)誤，重新對(duì)讀取不正確的日志塊進(jìn)行讀取；將每個(gè)日志讀取線程讀取到的數(shù)據(jù)塊存入日志緩存區(qū)中相應(yīng)的偏移位置；直至將被分配的需讀取的數(shù)據(jù)塊讀取完成；

將每個(gè)日志讀取線程讀取到的數(shù)據(jù)塊按照原日志文件中的順序合并為讀取到的數(shù)據(jù)片；

對(duì)待讀取的日志文件中的每一個(gè)數(shù)據(jù)片依次進(jìn)行讀取，直至日志文件讀取完成。

2.根據(jù)權(quán)利要求1所述的基于RAC的數(shù)據(jù)庫(kù)日志文件讀取方法，其特征在于，所述將需讀取的日志文件分為連續(xù)的數(shù)據(jù)片之前，還包括：

創(chuàng)建日志讀取管理線程，所述日志讀取管理線程獲取日志文件讀取請(qǐng)求、完成日志文件讀取過程中的計(jì)算任務(wù)，并對(duì)日志讀取線程進(jìn)行管理，所述計(jì)算任務(wù)包括將需讀取的日志文件分為連續(xù)的數(shù)據(jù)片、計(jì)算每個(gè)日志讀取線程需讀取的日志文件起始日志塊偏移值、將每個(gè)日志讀取線程讀取到的數(shù)據(jù)塊按照原日志文件中的順序合并為讀取到的數(shù)據(jù)片。

3.根據(jù)權(quán)利要求2所述的基于RAC的數(shù)據(jù)庫(kù)日志文件讀取方法，其特征在于，還包括：

進(jìn)行日志文件讀取前，日志讀取管理線程判斷需讀取的日志文件是否已被讀取；

若是，不進(jìn)行日志讀取；

若否，開始進(jìn)行日志讀取。

4.根據(jù)權(quán)利要求1所述的基于RAC的數(shù)據(jù)庫(kù)日志文件讀取方法，其特征在于，還包括：

需讀取的日志文件全部讀取并存入日志緩沖區(qū)后，讀取管理線程將日志緩沖區(qū)中的全部數(shù)據(jù)整體取出，保存為新的日志文件，或?qū)?shù)據(jù)提供給其它需要使用日志文件數(shù)據(jù)的功能模塊。

5.根據(jù)權(quán)利要求1所述的基于RAC的數(shù)據(jù)庫(kù)日志文件讀取方法，其特征在于，還包括：

存在已完成被分配的數(shù)據(jù)塊讀取任務(wù)的空閑日志讀取線程，且日志文件未讀取完成時(shí)，讀取管理線程按順序?yàn)榭臻e日志讀取線程再次分配需讀取的數(shù)據(jù)塊。

6.根據(jù)權(quán)利要求5所述的基于RAC的數(shù)據(jù)庫(kù)日志文件讀取方法，其特征在于：

當(dāng)需讀取的日志文件中未被讀取的數(shù)據(jù)長(zhǎng)度小于讀取管理線程劃分的每個(gè)日志讀取線程的需讀取的日志塊總長(zhǎng)度時(shí)，日志讀取線程需讀取的數(shù)據(jù)塊長(zhǎng)度與日志文件中未被讀取的數(shù)據(jù)長(zhǎng)度一致。

7.一種基于RAC的數(shù)據(jù)庫(kù)日志文件讀取裝置，其特征在于：

包括至少一個(gè)處理器和存儲(chǔ)器，所述至少一個(gè)處理器和存儲(chǔ)器之間通過數(shù)據(jù)總線連接，所述存儲(chǔ)器存儲(chǔ)有可被所述至少一個(gè)處理器執(zhí)行的指令，所述指令在被所述處理器執(zhí)行后，用于完成權(quán)利要求1-6任一所述的基于RAC的數(shù)據(jù)庫(kù)日志文件讀取方法。