PostgreSQL: fix

wader · Aug 4, 2022 · d9de2d4 · d9de2d4
1 parent 96a96a5
commit d9de2d4
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/format/postgres/common/pgheap.go b/format/postgres/common/pgheap.go
@@ -5,14 +5,19 @@ import (
 )
 
 const (
-	HeapPageSize = 8192
+	HeapPageSize             = 8192
+	FirstNormalTransactionId = 3
 
 	LP_UNUSED   = 0 /* unused (should always have lp_len=0) */
 	LP_NORMAL   = 1 /* used (should always have lp_len>0) */
 	LP_REDIRECT = 2 /* HOT redirect (should have lp_len=0) */
 	LP_DEAD     = 3
 )
 
+func TransactionIdIsNormal(xid uint64) bool {
+	return xid >= FirstNormalTransactionId
+}
+
 type lpOffMapper struct{}
 
 func (m lpOffMapper) MapScalar(s scalar.S) (scalar.S, error) {

diff --git a/format/postgres/flavours/postgres14/common14/pgheap.go b/format/postgres/flavours/postgres14/common14/pgheap.go
@@ -477,12 +477,12 @@ type TransactionMapper struct {
 func (m TransactionMapper) MapScalar(s scalar.S) (scalar.S, error) {
 	xid := s.ActualU()
 
-	if m.Page.PdXidBase != 0 && m.Tuple.IsMulti == 0 {
+	if m.Page.PdXidBase != 0 && m.Tuple.IsMulti == 0 && common.TransactionIdIsNormal(xid) {
 		xid64 := xid + m.Page.PdXidBase
 		s.Sym = fmt.Sprintf("%d", xid64)
 	}
 
-	if m.Page.PdMultiBase != 0 && m.Tuple.IsMulti != 0 {
+	if m.Page.PdMultiBase != 0 && m.Tuple.IsMulti != 0 && common.TransactionIdIsNormal(xid) {
 		xid64 := xid + m.Page.PdMultiBase
 		s.Sym = fmt.Sprintf("%d", xid64)
 	}