PostgreSQL預(yù)寫日志標(biāo)志位的使用方法和影響

本篇內(nèi)容主要講解“PostgreSQL預(yù)寫日志標(biāo)志位的使用方法和影響”，感興趣的朋友不妨來看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“PostgreSQL預(yù)寫日志標(biāo)志位的使用方法和影響”吧!

創(chuàng)新互聯(lián)是一家專注于網(wǎng)站設(shè)計(jì)制作、做網(wǎng)站與策劃設(shè)計(jì),臥龍網(wǎng)站建設(shè)哪家好?創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設(shè)10多年,網(wǎng)設(shè)計(jì)領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:臥龍等地區(qū)。臥龍做網(wǎng)站價(jià)格咨詢:028-86922220

本篇繼續(xù)演示和講解如何從代碼中翻出自己需要的功能，以邏輯復(fù)制插件為例。過程中不可避免的會(huì)讀很多無關(guān)的代碼，這部分不需要啰嗦，隨著代碼熟悉程度的提高，這些開發(fā)過程中的開銷會(huì)減少。

1、插件初始化設(shè)置callback函數(shù)commit_cb

它處理事務(wù)提交信息，但這里拿不到太多，LogicalDecodingContext 中并沒有包含事務(wù)狀態(tài)。

2、邏輯解碼

src/backend/replication/logical/logical.c

callback函數(shù) commit_cb 封裝在 commit_cb_wrapper 中，設(shè)置到下一層的callback中：

/* commit callback signature */
typedef void (*ReorderBufferCommitCB) (
									   ReorderBuffer *rb,
									   ReorderBufferTXN *txn,
									   XLogRecPtr commit_lsn);

定義就不多說了，我們的目標(biāo)是找到事務(wù)是否有控制標(biāo)志，設(shè)置流程是什么，代碼細(xì)節(jié)有興趣自己看吧。

3、解碼

再繼續(xù)看下去，解碼事務(wù)提交的函數(shù)是：DecodeCommit。

src/backend/replication/logical/decode.c

這里可以看到，對(duì)于回滾掉的事務(wù)，也有一個(gè)專門的處理函數(shù)：DecodeAbort，它直接釋放已經(jīng)解碼的結(jié)構(gòu)。

4、事務(wù)標(biāo)志位

  if (parsed->xinfo & XACT_XINFO_HAS_ORIGIN)
  {
    origin_lsn = parsed->origin_lsn;
    commit_time = parsed->origin_timestamp;
  }

隨著代碼的深入，它終于出現(xiàn)。擴(kuò)展標(biāo)志位xinfo，說擴(kuò)展是由名字猜測(cè)。

/* does this record have a 'xinfo' field or not */
#define XLOG_XACT_HAS_INFO			0x80

而有沒有xinfo由這個(gè)標(biāo)志來確認(rèn)，更多信息可以根據(jù)代碼或者注釋來了解。

5、它是什么時(shí)候設(shè)置的

src/backend/access/transam/xact.c 函數(shù) XactLogCommitRecord

事務(wù)提交時(shí)根據(jù)狀態(tài)寫入。

6、我們還能看出什么

根據(jù)過濾器跳過部分事務(wù)

  if (SnapBuildXactNeedsSkip(ctx->snapshot_builder, buf->origptr) ||
    (parsed->dbId != InvalidOid && parsed->dbId != ctx->slot->data.database) ||
    ctx->fast_forward || FilterByOrigin(ctx, origin_id))
  {
    for (i = 0; i < parsed->nsubxacts; i++)
    {
      ReorderBufferForget(ctx->reorder, parsed->subxacts[i], buf->origptr);
    }
    ReorderBufferForget(ctx->reorder, xid, buf->origptr);

    return;
  }

那么，如果我們想自行控制事務(wù)是否解碼，就可以使用這段邏輯，絲毫不用擔(dān)心。

7、還有更多

繼續(xù)上一點(diǎn)，不管事務(wù)是不是需要復(fù)制，都是要解碼的，根據(jù)過濾條件再釋放，也就是有一些無意義的開銷。

其實(shí)這個(gè)過程還有很多不相關(guān)代碼的閱讀，確定無關(guān)就忽略掉，這里只列出有影響的部分。

到此，相信大家對(duì)“PostgreSQL預(yù)寫日志標(biāo)志位的使用方法和影響”有了更深的了解，不妨來實(shí)際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！

網(wǎng)頁名稱：PostgreSQL預(yù)寫日志標(biāo)志位的使用方法和影響
URL分享：http://muchs.cn/article42/ghedec.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站建設(shè)、、商城網(wǎng)站、網(wǎng)站排名、面包屑導(dǎo)航、標(biāo)簽優(yōu)化

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

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