#include "postgres.h"
#include "access/htup_details.h"
#include "catalog/pg_type.h"
#include "miscadmin.h"
#include "parser/parse_type.h"
#include "utils/acl.h"
#include "utils/builtins.h"
#include "utils/resowner_private.h"
#include "utils/syscache.h"
Go to the source code of this file.
Functions | |
TupleDesc | CreateTemplateTupleDesc (int natts, bool hasoid) |
TupleDesc | CreateTupleDesc (int natts, bool hasoid, Form_pg_attribute *attrs) |
TupleDesc | CreateTupleDescCopy (TupleDesc tupdesc) |
TupleDesc | CreateTupleDescCopyConstr (TupleDesc tupdesc) |
void | FreeTupleDesc (TupleDesc tupdesc) |
void | IncrTupleDescRefCount (TupleDesc tupdesc) |
void | DecrTupleDescRefCount (TupleDesc tupdesc) |
bool | equalTupleDescs (TupleDesc tupdesc1, TupleDesc tupdesc2) |
void | TupleDescInitEntry (TupleDesc desc, AttrNumber attributeNumber, const char *attributeName, Oid oidtypeid, int32 typmod, int attdim) |
void | TupleDescInitEntryCollation (TupleDesc desc, AttrNumber attributeNumber, Oid collationid) |
TupleDesc | BuildDescForRelation (List *schema) |
TupleDesc | BuildDescFromLists (List *names, List *types, List *typmods, List *collations) |
Definition at line 538 of file tupdesc.c.
References ACL_USAGE, aclcheck_error_type(), ACLCHECK_OK, TypeName::arrayBounds, tupleDesc::attrs, tupleConstr::check, ColumnDef::colname, tupleDesc::constr, CreateTemplateTupleDesc(), tupleConstr::defval, ereport, errcode(), errmsg(), ERROR, GetColumnDefCollation(), GetUserId(), tupleConstr::has_not_null, ColumnDef::inhcount, ColumnDef::is_local, ColumnDef::is_not_null, lfirst, list_length(), tupleDesc::natts, NULL, tupleConstr::num_check, tupleConstr::num_defval, palloc0(), pg_type_aclcheck(), TypeName::setof, ColumnDef::storage, TupleDescInitEntry(), TupleDescInitEntryCollation(), ColumnDef::typeName, and typenameTypeIdAndMod().
Referenced by DefineRelation(), and DefineVirtualRelation().
{ int natts; AttrNumber attnum; ListCell *l; TupleDesc desc; bool has_not_null; char *attname; Oid atttypid; int32 atttypmod; Oid attcollation; int attdim; /* * allocate a new tuple descriptor */ natts = list_length(schema); desc = CreateTemplateTupleDesc(natts, false); has_not_null = false; attnum = 0; foreach(l, schema) { ColumnDef *entry = lfirst(l); AclResult aclresult; /* * for each entry in the list, get the name and type information from * the list and have TupleDescInitEntry fill in the attribute * information we need. */ attnum++; attname = entry->colname; typenameTypeIdAndMod(NULL, entry->typeName, &atttypid, &atttypmod); aclresult = pg_type_aclcheck(atttypid, GetUserId(), ACL_USAGE); if (aclresult != ACLCHECK_OK) aclcheck_error_type(aclresult, atttypid); attcollation = GetColumnDefCollation(NULL, entry, atttypid); attdim = list_length(entry->typeName->arrayBounds); if (entry->typeName->setof) ereport(ERROR, (errcode(ERRCODE_INVALID_TABLE_DEFINITION), errmsg("column \"%s\" cannot be declared SETOF", attname))); TupleDescInitEntry(desc, attnum, attname, atttypid, atttypmod, attdim); /* Override TupleDescInitEntry's settings as requested */ TupleDescInitEntryCollation(desc, attnum, attcollation); if (entry->storage) desc->attrs[attnum - 1]->attstorage = entry->storage; /* Fill in additional stuff not handled by TupleDescInitEntry */ desc->attrs[attnum - 1]->attnotnull = entry->is_not_null; has_not_null |= entry->is_not_null; desc->attrs[attnum - 1]->attislocal = entry->is_local; desc->attrs[attnum - 1]->attinhcount = entry->inhcount; } if (has_not_null) { TupleConstr *constr = (TupleConstr *) palloc0(sizeof(TupleConstr)); constr->has_not_null = true; constr->defval = NULL; constr->num_defval = 0; constr->check = NULL; constr->num_check = 0; desc->constr = constr; } else { desc->constr = NULL; } return desc; }
Definition at line 634 of file tupdesc.c.
References Assert, CreateTemplateTupleDesc(), lfirst, lfirst_int, lfirst_oid, list_head(), list_length(), lnext, tupleDesc::natts, strVal, TupleDescInitEntry(), and TupleDescInitEntryCollation().
Referenced by ExecInitFunctionScan(), and transformRangeFunction().
{ int natts; AttrNumber attnum; ListCell *l1; ListCell *l2; ListCell *l3; ListCell *l4; TupleDesc desc; natts = list_length(names); Assert(natts == list_length(types)); Assert(natts == list_length(typmods)); Assert(natts == list_length(collations)); /* * allocate a new tuple descriptor */ desc = CreateTemplateTupleDesc(natts, false); attnum = 0; l2 = list_head(types); l3 = list_head(typmods); l4 = list_head(collations); foreach(l1, names) { char *attname = strVal(lfirst(l1)); Oid atttypid; int32 atttypmod; Oid attcollation; atttypid = lfirst_oid(l2); l2 = lnext(l2); atttypmod = lfirst_int(l3); l3 = lnext(l3); attcollation = lfirst_oid(l4); l4 = lnext(l4); attnum++; TupleDescInitEntry(desc, attnum, attname, atttypid, atttypmod, 0); TupleDescInitEntryCollation(desc, attnum, attcollation); } return desc; }
Definition at line 40 of file tupdesc.c.
References AssertArg, ATTRIBUTE_FIXED_PART_SIZE, tupleDesc::attrs, tupleDesc::constr, i, MAXALIGN, tupleDesc::natts, palloc(), tupleDesc::tdhasoid, tupleDesc::tdrefcount, tupleDesc::tdtypeid, and tupleDesc::tdtypmod.
Referenced by aclexplode(), AllocateRelationDesc(), build_function_result_tupdesc_d(), build_row_from_vars(), BuildDescForRelation(), BuildDescFromLists(), BuildHardcodedDescriptor(), ConstructTupleDescriptor(), create_toast_table(), CreateTupleDescCopy(), CreateTupleDescCopyConstr(), dblink_get_notify(), dblink_get_pkey(), ExecInitFunctionScan(), ExecMakeTableFunctionResult(), ExecTypeFromExprList(), ExecTypeFromTLInternal(), expandRecordVariable(), ExplainResultDesc(), formrdesc(), GetPGVariableResultDesc(), init_fcache(), initGinState(), load_relcache_init_file(), materializeQueryResult(), materializeResult(), pg_buffercache_pages(), pg_cursor(), pg_get_keywords(), pg_get_multixact_members(), pg_identify_object(), pg_lock_status(), pg_logdir_ls(), pg_prepared_statement(), pg_prepared_xact(), pg_sequence_parameters(), pg_stat_file(), pg_stat_get_activity(), pg_timezone_abbrevs(), pg_timezone_names(), pg_xlogfile_name_offset(), prs_setup_firstcall(), show_all_settings(), ShowAllGUCConfig(), ShowGUCConfigOption(), ts_setup_firstcall(), tt_setup_firstcall(), and TypeGetTupleDesc().
{ TupleDesc desc; char *stg; int attroffset; /* * sanity checks */ AssertArg(natts >= 0); /* * Allocate enough memory for the tuple descriptor, including the * attribute rows, and set up the attribute row pointers. * * Note: we assume that sizeof(struct tupleDesc) is a multiple of the * struct pointer alignment requirement, and hence we don't need to insert * alignment padding between the struct and the array of attribute row * pointers. * * Note: Only the fixed part of pg_attribute rows is included in tuple * descriptors, so we only need ATTRIBUTE_FIXED_PART_SIZE space per attr. * That might need alignment padding, however. */ attroffset = sizeof(struct tupleDesc) + natts * sizeof(Form_pg_attribute); attroffset = MAXALIGN(attroffset); stg = palloc(attroffset + natts * MAXALIGN(ATTRIBUTE_FIXED_PART_SIZE)); desc = (TupleDesc) stg; if (natts > 0) { Form_pg_attribute *attrs; int i; attrs = (Form_pg_attribute *) (stg + sizeof(struct tupleDesc)); desc->attrs = attrs; stg += attroffset; for (i = 0; i < natts; i++) { attrs[i] = (Form_pg_attribute) stg; stg += MAXALIGN(ATTRIBUTE_FIXED_PART_SIZE); } } else desc->attrs = NULL; /* * Initialize other fields of the tupdesc. */ desc->natts = natts; desc->constr = NULL; desc->tdtypeid = RECORDOID; desc->tdtypmod = -1; desc->tdhasoid = hasoid; desc->tdrefcount = -1; /* assume not reference-counted */ return desc; }
TupleDesc CreateTupleDesc | ( | int | natts, | |
bool | hasoid, | |||
Form_pg_attribute * | attrs | |||
) |
Definition at line 111 of file tupdesc.c.
References AssertArg, tupleDesc::attrs, tupleDesc::constr, tupleDesc::natts, palloc(), tupleDesc::tdhasoid, tupleDesc::tdrefcount, tupleDesc::tdtypeid, and tupleDesc::tdtypmod.
Referenced by InsertOneTuple().
{ TupleDesc desc; /* * sanity checks */ AssertArg(natts >= 0); desc = (TupleDesc) palloc(sizeof(struct tupleDesc)); desc->attrs = attrs; desc->natts = natts; desc->constr = NULL; desc->tdtypeid = RECORDOID; desc->tdtypmod = -1; desc->tdhasoid = hasoid; desc->tdrefcount = -1; /* assume not reference-counted */ return desc; }
Definition at line 140 of file tupdesc.c.
References ATTRIBUTE_FIXED_PART_SIZE, tupleDesc::attrs, CreateTemplateTupleDesc(), i, tupleDesc::natts, tupleDesc::tdhasoid, tupleDesc::tdtypeid, and tupleDesc::tdtypmod.
Referenced by assign_record_type_typmod(), ATGetQueueEntry(), build_row_from_class(), check_sql_fn_retval(), connectby_text(), connectby_text_serial(), CopyCachedPlan(), crosstab(), crosstab_hash(), database_to_xmlschema_internal(), deflist_to_tuplestore(), do_autovacuum(), each_worker(), exec_move_row(), exec_stmt_return(), ExecInitFunctionScan(), ExecPrepareTuplestoreResult(), FetchPreparedStatementResultDesc(), fmgr_sql(), init_fcache(), json_array_elements(), json_populate_recordset(), LookupTupleHashEntry(), materializeResult(), PersistHoldablePortal(), plperl_return_next(), plpgsql_exec_function(), PLy_spi_execute_fetch_result(), RelationBuildLocalRelation(), RelationNameGetTupleDesc(), RevalidateCachedQuery(), schema_to_xmlschema_internal(), spi_dest_startup(), storeRow(), UtilityTupleDescriptor(), and xpath_table().
{ TupleDesc desc; int i; desc = CreateTemplateTupleDesc(tupdesc->natts, tupdesc->tdhasoid); for (i = 0; i < desc->natts; i++) { memcpy(desc->attrs[i], tupdesc->attrs[i], ATTRIBUTE_FIXED_PART_SIZE); desc->attrs[i]->attnotnull = false; desc->attrs[i]->atthasdef = false; } desc->tdtypeid = tupdesc->tdtypeid; desc->tdtypmod = tupdesc->tdtypmod; return desc; }
Definition at line 166 of file tupdesc.c.
References attrDefault::adbin, ATTRIBUTE_FIXED_PART_SIZE, tupleDesc::attrs, constrCheck::ccbin, constrCheck::ccname, constrCheck::ccvalid, tupleConstr::check, tupleDesc::constr, CreateTemplateTupleDesc(), tupleConstr::defval, tupleConstr::has_not_null, i, tupleDesc::natts, tupleConstr::num_check, tupleConstr::num_defval, palloc(), palloc0(), pstrdup(), tupleDesc::tdhasoid, tupleDesc::tdtypeid, and tupleDesc::tdtypmod.
Referenced by CatalogCacheInitializeCache(), and lookup_rowtype_tupdesc_copy().
{ TupleDesc desc; TupleConstr *constr = tupdesc->constr; int i; desc = CreateTemplateTupleDesc(tupdesc->natts, tupdesc->tdhasoid); for (i = 0; i < desc->natts; i++) { memcpy(desc->attrs[i], tupdesc->attrs[i], ATTRIBUTE_FIXED_PART_SIZE); } if (constr) { TupleConstr *cpy = (TupleConstr *) palloc0(sizeof(TupleConstr)); cpy->has_not_null = constr->has_not_null; if ((cpy->num_defval = constr->num_defval) > 0) { cpy->defval = (AttrDefault *) palloc(cpy->num_defval * sizeof(AttrDefault)); memcpy(cpy->defval, constr->defval, cpy->num_defval * sizeof(AttrDefault)); for (i = cpy->num_defval - 1; i >= 0; i--) { if (constr->defval[i].adbin) cpy->defval[i].adbin = pstrdup(constr->defval[i].adbin); } } if ((cpy->num_check = constr->num_check) > 0) { cpy->check = (ConstrCheck *) palloc(cpy->num_check * sizeof(ConstrCheck)); memcpy(cpy->check, constr->check, cpy->num_check * sizeof(ConstrCheck)); for (i = cpy->num_check - 1; i >= 0; i--) { if (constr->check[i].ccname) cpy->check[i].ccname = pstrdup(constr->check[i].ccname); if (constr->check[i].ccbin) cpy->check[i].ccbin = pstrdup(constr->check[i].ccbin); cpy->check[i].ccvalid = constr->check[i].ccvalid; } } desc->constr = cpy; } desc->tdtypeid = tupdesc->tdtypeid; desc->tdtypmod = tupdesc->tdtypmod; return desc; }
void DecrTupleDescRefCount | ( | TupleDesc | tupdesc | ) |
Definition at line 291 of file tupdesc.c.
References Assert, CurrentResourceOwner, FreeTupleDesc(), ResourceOwnerForgetTupleDesc(), and tupleDesc::tdrefcount.
Referenced by ATExecAddOf(), ResourceOwnerReleaseInternal(), and transformOfType().
{ Assert(tupdesc->tdrefcount > 0); ResourceOwnerForgetTupleDesc(CurrentResourceOwner, tupdesc); if (--tupdesc->tdrefcount == 0) FreeTupleDesc(tupdesc); }
Definition at line 309 of file tupdesc.c.
References attrDefault::adbin, attrDefault::adnum, tupleDesc::attrs, constrCheck::ccbin, constrCheck::ccname, tupleConstr::check, tupleDesc::constr, tupleConstr::defval, tupleConstr::has_not_null, i, NameStr, tupleDesc::natts, NULL, tupleConstr::num_check, tupleConstr::num_defval, tupleDesc::tdhasoid, and tupleDesc::tdtypeid.
Referenced by acquire_inherited_sample_rows(), assign_record_type_typmod(), ProcedureCreate(), RelationClearRelation(), and RevalidateCachedQuery().
{ int i, j, n; if (tupdesc1->natts != tupdesc2->natts) return false; if (tupdesc1->tdtypeid != tupdesc2->tdtypeid) return false; if (tupdesc1->tdhasoid != tupdesc2->tdhasoid) return false; for (i = 0; i < tupdesc1->natts; i++) { Form_pg_attribute attr1 = tupdesc1->attrs[i]; Form_pg_attribute attr2 = tupdesc2->attrs[i]; /* * We do not need to check every single field here: we can disregard * attrelid and attnum (which were used to place the row in the attrs * array in the first place). It might look like we could dispense * with checking attlen/attbyval/attalign, since these are derived * from atttypid; but in the case of dropped columns we must check * them (since atttypid will be zero for all dropped columns) and in * general it seems safer to check them always. * * attcacheoff must NOT be checked since it's possibly not set in both * copies. */ if (strcmp(NameStr(attr1->attname), NameStr(attr2->attname)) != 0) return false; if (attr1->atttypid != attr2->atttypid) return false; if (attr1->attstattarget != attr2->attstattarget) return false; if (attr1->attlen != attr2->attlen) return false; if (attr1->attndims != attr2->attndims) return false; if (attr1->atttypmod != attr2->atttypmod) return false; if (attr1->attbyval != attr2->attbyval) return false; if (attr1->attstorage != attr2->attstorage) return false; if (attr1->attalign != attr2->attalign) return false; if (attr1->attnotnull != attr2->attnotnull) return false; if (attr1->atthasdef != attr2->atthasdef) return false; if (attr1->attisdropped != attr2->attisdropped) return false; if (attr1->attislocal != attr2->attislocal) return false; if (attr1->attinhcount != attr2->attinhcount) return false; if (attr1->attcollation != attr2->attcollation) return false; /* attacl, attoptions and attfdwoptions are not even present... */ } if (tupdesc1->constr != NULL) { TupleConstr *constr1 = tupdesc1->constr; TupleConstr *constr2 = tupdesc2->constr; if (constr2 == NULL) return false; if (constr1->has_not_null != constr2->has_not_null) return false; n = constr1->num_defval; if (n != (int) constr2->num_defval) return false; for (i = 0; i < n; i++) { AttrDefault *defval1 = constr1->defval + i; AttrDefault *defval2 = constr2->defval; /* * We can't assume that the items are always read from the system * catalogs in the same order; so use the adnum field to identify * the matching item to compare. */ for (j = 0; j < n; defval2++, j++) { if (defval1->adnum == defval2->adnum) break; } if (j >= n) return false; if (strcmp(defval1->adbin, defval2->adbin) != 0) return false; } n = constr1->num_check; if (n != (int) constr2->num_check) return false; for (i = 0; i < n; i++) { ConstrCheck *check1 = constr1->check + i; ConstrCheck *check2 = constr2->check; /* * Similarly, don't assume that the checks are always read in the * same order; match them up by name and contents. (The name * *should* be unique, but...) */ for (j = 0; j < n; check2++, j++) { if (strcmp(check1->ccname, check2->ccname) == 0 && strcmp(check1->ccbin, check2->ccbin) == 0) break; } if (j >= n) return false; } } else if (tupdesc2->constr != NULL) return false; return true; }
void FreeTupleDesc | ( | TupleDesc | tupdesc | ) |
Definition at line 223 of file tupdesc.c.
References Assert, tupleConstr::check, tupleDesc::constr, tupleConstr::defval, i, tupleConstr::num_check, tupleConstr::num_defval, pfree(), and tupleDesc::tdrefcount.
Referenced by DecrTupleDescRefCount(), exec_move_row(), exec_stmt_block(), ExecMakeTableFunctionResult(), ExecPrepareTuplestoreResult(), PLy_result_dealloc(), RelationDestroyRelation(), RevalidateCachedQuery(), and TypeCacheRelCallback().
{ int i; /* * Possibly this should assert tdrefcount == 0, to disallow explicit * freeing of un-refcounted tupdescs? */ Assert(tupdesc->tdrefcount <= 0); if (tupdesc->constr) { if (tupdesc->constr->num_defval > 0) { AttrDefault *attrdef = tupdesc->constr->defval; for (i = tupdesc->constr->num_defval - 1; i >= 0; i--) { if (attrdef[i].adbin) pfree(attrdef[i].adbin); } pfree(attrdef); } if (tupdesc->constr->num_check > 0) { ConstrCheck *check = tupdesc->constr->check; for (i = tupdesc->constr->num_check - 1; i >= 0; i--) { if (check[i].ccname) pfree(check[i].ccname); if (check[i].ccbin) pfree(check[i].ccbin); } pfree(check); } pfree(tupdesc->constr); } pfree(tupdesc); }
void IncrTupleDescRefCount | ( | TupleDesc | tupdesc | ) |
Definition at line 273 of file tupdesc.c.
References Assert, CurrentResourceOwner, ResourceOwnerEnlargeTupleDescs(), ResourceOwnerRememberTupleDesc(), and tupleDesc::tdrefcount.
Referenced by lookup_rowtype_tupdesc(), and lookup_rowtype_tupdesc_noerror().
{ Assert(tupdesc->tdrefcount >= 0); ResourceOwnerEnlargeTupleDescs(CurrentResourceOwner); tupdesc->tdrefcount++; ResourceOwnerRememberTupleDesc(CurrentResourceOwner, tupdesc); }
void TupleDescInitEntry | ( | TupleDesc | desc, | |
AttrNumber | attributeNumber, | |||
const char * | attributeName, | |||
Oid | oidtypeid, | |||
int32 | typmod, | |||
int | attdim | |||
) |
Definition at line 442 of file tupdesc.c.
References AssertArg, tupleDesc::attrs, elog, ERROR, GETSTRUCT, HeapTupleIsValid, MemSet, NAMEDATALEN, NameStr, namestrcpy(), tupleDesc::natts, NULL, ObjectIdGetDatum, PointerIsValid, ReleaseSysCache(), SearchSysCache1, and TYPEOID.
Referenced by aclexplode(), build_function_result_tupdesc_d(), build_row_from_vars(), BuildDescForRelation(), BuildDescFromLists(), create_toast_table(), dblink_get_notify(), dblink_get_pkey(), ExecInitFunctionScan(), ExecMakeTableFunctionResult(), ExecTypeFromExprList(), ExecTypeFromTLInternal(), expandRecordVariable(), ExplainResultDesc(), GetPGVariableResultDesc(), init_fcache(), initGinState(), materializeQueryResult(), materializeResult(), pg_buffercache_pages(), pg_cursor(), pg_get_keywords(), pg_get_multixact_members(), pg_identify_object(), pg_lock_status(), pg_logdir_ls(), pg_prepared_statement(), pg_prepared_xact(), pg_sequence_parameters(), pg_stat_file(), pg_stat_get_activity(), pg_timezone_abbrevs(), pg_timezone_names(), pg_xlogfile_name_offset(), prs_setup_firstcall(), resolve_polymorphic_tupdesc(), show_all_settings(), ShowAllGUCConfig(), ShowGUCConfigOption(), ts_setup_firstcall(), tt_setup_firstcall(), and TypeGetTupleDesc().
{ HeapTuple tuple; Form_pg_type typeForm; Form_pg_attribute att; /* * sanity checks */ AssertArg(PointerIsValid(desc)); AssertArg(attributeNumber >= 1); AssertArg(attributeNumber <= desc->natts); /* * initialize the attribute fields */ att = desc->attrs[attributeNumber - 1]; att->attrelid = 0; /* dummy value */ /* * Note: attributeName can be NULL, because the planner doesn't always * fill in valid resname values in targetlists, particularly for resjunk * attributes. */ if (attributeName != NULL) namestrcpy(&(att->attname), attributeName); else MemSet(NameStr(att->attname), 0, NAMEDATALEN); att->attstattarget = -1; att->attcacheoff = -1; att->atttypmod = typmod; att->attnum = attributeNumber; att->attndims = attdim; att->attnotnull = false; att->atthasdef = false; att->attisdropped = false; att->attislocal = true; att->attinhcount = 0; /* attacl, attoptions and attfdwoptions are not present in tupledescs */ tuple = SearchSysCache1(TYPEOID, ObjectIdGetDatum(oidtypeid)); if (!HeapTupleIsValid(tuple)) elog(ERROR, "cache lookup failed for type %u", oidtypeid); typeForm = (Form_pg_type) GETSTRUCT(tuple); att->atttypid = oidtypeid; att->attlen = typeForm->typlen; att->attbyval = typeForm->typbyval; att->attalign = typeForm->typalign; att->attstorage = typeForm->typstorage; att->attcollation = typeForm->typcollation; ReleaseSysCache(tuple); }
void TupleDescInitEntryCollation | ( | TupleDesc | desc, | |
AttrNumber | attributeNumber, | |||
Oid | collationid | |||
) |
Definition at line 513 of file tupdesc.c.
References AssertArg, tupleDesc::attrs, tupleDesc::natts, and PointerIsValid.
Referenced by build_row_from_vars(), BuildDescForRelation(), BuildDescFromLists(), ExecInitFunctionScan(), ExecTypeFromExprList(), ExecTypeFromTLInternal(), expandRecordVariable(), initGinState(), and resolve_polymorphic_tupdesc().