30 #include "catalog/pg_am_d.h" 45 #define HeapTupleHeaderGetOidOld(tup) \ 47 ((tup)->t_infomask & HEAP_HASOID_OLD) ? \ 48 *((Oid *) ((char *)(tup) + (tup)->t_hoff - sizeof(Oid))) \ 68 for (i = 0; i < len; i++)
69 str[i] = (bits[(i / 8)] & (1 << (i % 8))) ?
'1' :
'0';
97 if ((str[off] ==
'0') || (str[off] ==
'1'))
98 byte = byte | ((str[off] -
'0') << off % 8);
102 errmsg(
"illegal character '%c' in t_bits string", str[off])));
105 bits[off / 8] =
byte;
137 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
138 (
errmsg(
"must be superuser to use raw page functions"))));
149 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
150 errmsg(
"input page too small (%d bytes)", raw_page_size)));
159 elog(
ERROR,
"return type must be a row type");
161 inter_call_data->
tupd = tupdesc;
187 memset(nulls, 0,
sizeof(nulls));
210 lp_offset + lp_len <= raw_page_size)
213 bytea *tuple_data_bytea;
230 tuple_data_len = lp_len - tuphdr->
t_hoff;
233 memcpy(
VARDATA(tuple_data_bytea), (
char *) tuphdr + tuphdr->
t_hoff,
244 tuphdr->
t_hoff <= lp_len &&
278 for (i = 4; i <= 13; i++)
286 inter_call_data->
offset++;
320 nattrs = tupdesc->
natts;
322 if (rel->
rd_rel->relam != HEAP_TABLE_AM_OID)
324 errmsg(
"only heap AM is supported")));
329 errmsg(
"number of attributes in tuple header is greater than number of attributes in tuple descriptor")));
331 for (i = 0; i < nattrs; i++)
335 bytea *attr_data = NULL;
345 if (i >= (t_infomask2 & HEAP_NATTS_MASK))
354 if (attr->attlen == -1)
369 errmsg(
"first byte of varlena attribute is incorrect for attribute %d", i)));
379 if (tupdata_len < off + len)
382 errmsg(
"unexpected end of tuple data")));
384 if (attr->attlen == -1 && do_detoast)
390 memcpy(
VARDATA(attr_data), tupdata + off, len);
403 if (tupdata_len != off)
406 errmsg(
"end of tuple reached without looking at all its data")));
429 bool do_detoast =
false;
430 bits8 *t_bits = NULL;
445 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
446 errmsg(
"must be superuser to use raw page functions")));
464 errmsg(
"argument of t_bits is null, but it is expected to be null and %d character long",
467 bits_str_len = strlen(t_bits_str);
468 if (bits_len != bits_str_len)
471 errmsg(
"unexpected length of t_bits %u, expected %d",
472 bits_str_len, bits_len)));
482 errmsg(
"t_bits string is expected to be NULL, but instead it is %zu bytes length",
483 strlen(t_bits_str))));
489 t_infomask, t_infomask2, t_bits,
509 #define HEAP_TUPLE_INFOMASK_COLS 2 523 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
524 errmsg(
"must be superuser to use raw page functions")));
528 elog(
ERROR,
"return type must be a row type");
534 MemSet(values, 0,
sizeof(values));
535 MemSet(nulls, 0,
sizeof(nulls));
#define DatumGetByteaPCopy(X)
#define VARATT_IS_EXTERNAL_ONDISK(PTR)
#define SizeofHeapTupleHeader
#define HEAP_XMAX_KEYSHR_LOCK
TypeFuncClass get_call_result_type(FunctionCallInfo fcinfo, Oid *resultTypeId, TupleDesc *resultTupleDesc)
#define HEAP_XMAX_LOCK_ONLY
#define att_align_nominal(cur_offset, attalign)
ArrayBuildState * initArrayResult(Oid element_type, MemoryContext rcontext, bool subcontext)
#define RelationGetDescr(relation)
#define HEAP_TUPLE_INFOMASK_COLS
#define att_isnull(ATT, BITS)
#define SRF_IS_FIRSTCALL()
#define PointerGetDatum(X)
HeapTupleHeaderData * HeapTupleHeader
#define TupleDescAttr(tupdesc, i)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
ArrayType * construct_array(Datum *elems, int nelems, Oid elmtype, int elmlen, bool elmbyval, char elmalign)
int errcode(int sqlerrcode)
#define MemSet(start, val, len)
#define HEAP_XMAX_COMMITTED
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, Datum *values, bool *isnull)
#define PG_GETARG_BOOL(n)
ArrayType * construct_empty_array(Oid elmtype)
#define SizeOfPageHeaderData
#define HEAP_XMAX_SHR_LOCK
#define PageGetMaxOffsetNumber(page)
#define SRF_PERCALL_SETUP()
uint64 pg_popcount(const char *buf, int bytes)
#define PG_GETARG_TEXT_PP(n)
#define HEAP_XMIN_INVALID
#define SRF_RETURN_NEXT(_funcctx, _result)
#define VARATT_IS_EXTERNAL(PTR)
#define PG_GETARG_BYTEA_P(n)
#define HeapTupleHeaderGetRawXmax(tup)
void pfree(void *pointer)
#define ItemIdGetLength(itemId)
#define VARATT_IS_EXTERNAL_INDIRECT(PTR)
#define HEAP_XMAX_INVALID
#define HeapTupleHeaderGetNatts(tup)
Relation relation_open(Oid relationId, LOCKMODE lockmode)
Datum heap_tuple_infomask_flags(PG_FUNCTION_ARGS)
#define FirstOffsetNumber
#define HEAP_XMAX_EXCL_LOCK
static bits8 * text_to_bits(char *str, int len)
FormData_pg_attribute * Form_pg_attribute
struct heap_page_items_state heap_page_items_state
#define UInt32GetDatum(X)
#define ItemIdGetOffset(itemId)
MemoryContext CurrentMemoryContext
#define HeapTupleHeaderGetOidOld(tup)
#define PG_RETURN_ARRAYTYPE_P(x)
#define att_addlength_pointer(cur_offset, attlen, attptr)
#define ereport(elevel, rest)
Datum makeArrayResult(ArrayBuildState *astate, MemoryContext rcontext)
#define ERRCODE_DATA_CORRUPTED
#define PageGetItemId(page, offsetNumber)
#define ItemIdGetFlags(itemId)
void * palloc0(Size size)
#define PG_RETURN_DATUM(x)
#define HEAP_KEYS_UPDATED
#define att_align_pointer(cur_offset, attalign, attlen, attptr)
#define PG_GETARG_INT16(n)
#define HEAP_XMAX_IS_MULTI
#define HEAP_XMIN_COMMITTED
#define ItemIdHasStorage(itemId)
Datum tuple_data_split(PG_FUNCTION_ARGS)
PG_FUNCTION_INFO_V1(heap_page_items)
void relation_close(Relation relation, LOCKMODE lockmode)
#define Assert(condition)
MemoryContext multi_call_memory_ctx
#define HeapTupleHeaderGetRawXmin(tup)
#define HeapTupleGetDatum(tuple)
static Datum tuple_data_split_internal(Oid relid, char *tupdata, uint16 tupdata_len, uint16 t_infomask, uint16 t_infomask2, bits8 *t_bits, bool do_detoast)
static Datum values[MAXATTR]
char * text_to_cstring(const text *t)
ArrayBuildState * accumArrayResult(ArrayBuildState *astate, Datum dvalue, bool disnull, Oid element_type, MemoryContext rcontext)
#define HeapTupleHeaderGetRawCommandId(tup)
int errmsg(const char *fmt,...)
#define CStringGetTextDatum(s)
#define SET_VARSIZE(PTR, len)
Datum heap_page_items(PG_FUNCTION_ARGS)
static char * bits_to_text(bits8 *bits, int len)
#define UInt16GetDatum(X)
#define PageGetItem(page, itemId)
#define SRF_RETURN_DONE(_funcctx)
#define SRF_FIRSTCALL_INIT()