Skip to content

Commit

Permalink
PostgreSQL: pgheap impl for pgproee10
Browse files Browse the repository at this point in the history
  • Loading branch information
Pavel Safonov committed Aug 5, 2022
1 parent 07056c2 commit d148727
Show file tree
Hide file tree
Showing 2 changed files with 67 additions and 0 deletions.
64 changes: 64 additions & 0 deletions format/postgres/flavours/pgproee10/pgheap.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,64 @@
package pgproee10

import (
"github.com/wader/fq/format/postgres/common"
"github.com/wader/fq/format/postgres/flavours/pgproee14/ee14"
"github.com/wader/fq/format/postgres/flavours/postgres14/common14"
"github.com/wader/fq/pkg/decode"
)

// type = struct PageHeaderData {
/* 0 | 8 */ // PageXLogRecPtr pd_lsn;
/* 8 | 2 */ // uint16 pd_checksum;
/* 10 | 2 */ // uint16 pd_flags;
/* 12 | 2 */ // LocationIndex pd_lower;
/* 14 | 2 */ // LocationIndex pd_upper;
/* 16 | 2 */ // LocationIndex pd_special;
/* 18 | 2 */ // uint16 pd_pagesize_version;
/* 20 | 0 */ // ItemIdData pd_linp[];
//
/* total size (bytes): 20 */

// type = struct HeapTupleHeaderData {
/* 0 | 12 */ // union {
/* 12 */ // HeapTupleFields t_heap;
/* 12 */ // DatumTupleFields t_datum;
// } t_choice
/* total size (bytes): 12 */
//
/* 12 | 6 */ // ItemPointerData t_ctid
/* 18 | 2 */ // uint16 t_infomask2
/* 20 | 2 */ // uint16 t_infomask
/* 22 | 1 */ // uint8 t_hoff
/* 23 | 0 */ // bits8 t_bits[]
/* XXX 1-byte padding */
//
/* total size (bytes): 24 */

// type = struct HeapTupleFields {
/* 0 | 4 */ // ShortTransactionId t_xmin;
/* 4 | 4 */ // ShortTransactionId t_xmax;
/* 8 | 4 */ // union {
/* 4 */ // CommandId t_cid;
/* 4 */ // ShortTransactionId t_xvac;
// } t_field3;
/* total size (bytes): 4 */
//
/* total size (bytes): 12 */

// type = struct HeapPageSpecialData {
/* 0 | 8 */ // TransactionId pd_xid_base;
/* 8 | 8 */ // TransactionId pd_multi_base;
/* 16 | 4 */ // ShortTransactionId pd_prune_xid;
/* 20 | 4 */ // uint32 pd_magic;
//
/* total size (bytes): 24 */

func DecodeHeap(d *decode.D) any {
heap := &common14.HeapD{
PageSize: common.HeapPageSize,
DecodePageHeaderDataFn: ee14.DecodePageHeaderData,
DecodePageSpecialFn: ee14.DecodePageSpecial,
}
return common14.DecodeHeap(d, heap)
}
3 changes: 3 additions & 0 deletions format/postgres/pgheap.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ package postgres
import (
"github.com/wader/fq/format"
"github.com/wader/fq/format/postgres/flavours/pgpro14"
"github.com/wader/fq/format/postgres/flavours/pgproee10"
"github.com/wader/fq/format/postgres/flavours/pgproee11"
"github.com/wader/fq/format/postgres/flavours/pgproee12"
"github.com/wader/fq/format/postgres/flavours/pgproee13"
Expand Down Expand Up @@ -39,6 +40,8 @@ func decodePgheap(d *decode.D, in any) any {
return postgres13.DecodeHeap(d)
case PG_FLAVOUR_POSTGRES14, PG_FLAVOUR_POSTGRES:
return postgres14.DecodeHeap(d)
case PG_FLAVOUR_PGPROEE10:
return pgproee10.DecodeHeap(d)
case PG_FLAVOUR_PGPROEE11:
return pgproee11.DecodeHeap(d)
case PG_FLAVOUR_PGPROEE12:
Expand Down

0 comments on commit d148727

Please sign in to comment.