PostgreSQL預寫日志標志位的使用方法和影響

本篇內容主要講解“PostgreSQL預寫日志標志位的使用方法和影響”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“PostgreSQL預寫日志標志位的使用方法和影響”吧!

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

1、插件初始化設置callback函數commit_cb

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

2、邏輯解碼

src/backend/replication/logical/logical.c

callback函數 commit_cb 封裝在 commit_cb_wrapper 中，設置到下一層的callback中：

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

定義就不多說了，我們的目標是找到事務是否有控制標志，設置流程是什么，代碼細節有興趣自己看吧。

3、解碼

再繼續看下去，解碼事務提交的函數是：DecodeCommit。

src/backend/replication/logical/decode.c

這里可以看到，對于回滾掉的事務，也有一個專門的處理函數：DecodeAbort，它直接釋放已經解碼的結構。

4、事務標志位

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

隨著代碼的深入，它終于出現。擴展標志位xinfo，說擴展是由名字猜測。

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

而有沒有xinfo由這個標志來確認，更多信息可以根據代碼或者注釋來了解。

5、它是什么時候設置的

src/backend/access/transam/xact.c 函數 XactLogCommitRecord

事務提交時根據狀態寫入。

6、我們還能看出什么

根據過濾器跳過部分事務

  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;
  }

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

7、還有更多

繼續上一點，不管事務是不是需要復制，都是要解碼的，根據過濾條件再釋放，也就是有一些無意義的開銷。

其實這個過程還有很多不相關代碼的閱讀，確定無關就忽略掉，這里只列出有影響的部分。

到此，相信大家對“PostgreSQL預寫日志標志位的使用方法和影響”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！