attmap.h File Reference

#include "access/attnum.h"
#include "access/tupdesc.h"

Include dependency graph for attmap.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	AttrMap

Typedefs
typedef struct AttrMap	AttrMap

Functions
AttrMap *	make_attrmap (int maplen)
void	free_attrmap (AttrMap *map)
AttrMap *	build_attrmap_by_name (TupleDesc indesc, TupleDesc outdesc, bool missing_ok)
AttrMap *	build_attrmap_by_name_if_req (TupleDesc indesc, TupleDesc outdesc, bool missing_ok)
AttrMap *	build_attrmap_by_position (TupleDesc indesc, TupleDesc outdesc, const char *msg)

Typedef Documentation

AttrMap

typedef struct AttrMap AttrMap

Function Documentation

build_attrmap_by_name()

AttrMap * build_attrmap_by_name	(	TupleDesc	indesc,
		TupleDesc	outdesc,
		bool	missing_ok
	)

Definition at line 175 of file attmap.c.

{
    AttrMap    *attrMap;
    int         outnatts;
    int         innatts;
    int         i;
    int         nextindesc = -1;
 
    outnatts = outdesc->natts;
    innatts = indesc->natts;
 
    attrMap = make_attrmap(outnatts);
    for (i = 0; i < outnatts; i++)
    {
        Form_pg_attribute outatt = TupleDescAttr(outdesc, i);
        char       *attname;
        Oid         atttypid;
        int32       atttypmod;
        int         j;
 
        if (outatt->attisdropped)
            continue;           /* attrMap->attnums[i] is already 0 */
        attname = NameStr(outatt->attname);
        atttypid = outatt->atttypid;
        atttypmod = outatt->atttypmod;
 
        /*
         * Now search for an attribute with the same name in the indesc. It
         * seems likely that a partitioned table will have the attributes in
         * the same order as the partition, so the search below is optimized
         * for that case.  It is possible that columns are dropped in one of
         * the relations, but not the other, so we use the 'nextindesc'
         * counter to track the starting point of the search.  If the inner
         * loop encounters dropped columns then it will have to skip over
         * them, but it should leave 'nextindesc' at the correct position for
         * the next outer loop.
         */
        for (j = 0; j < innatts; j++)
        {
            Form_pg_attribute inatt;
 
            nextindesc++;
            if (nextindesc >= innatts)
                nextindesc = 0;
 
            inatt = TupleDescAttr(indesc, nextindesc);
            if (inatt->attisdropped)
                continue;
            if (strcmp(attname, NameStr(inatt->attname)) == 0)
            {
                /* Found it, check type */
                if (atttypid != inatt->atttypid || atttypmod != inatt->atttypmod)
                    ereport(ERROR,
                            (errcode(ERRCODE_DATATYPE_MISMATCH),
                             errmsg("could not convert row type"),
                             errdetail("Attribute \"%s\" of type %s does not match corresponding attribute of type %s.",
                                       attname,
                                       format_type_be(outdesc->tdtypeid),
                                       format_type_be(indesc->tdtypeid))));
                attrMap->attnums[i] = inatt->attnum;
                break;
            }
        }
        if (attrMap->attnums[i] == 0 && !missing_ok)
            ereport(ERROR,
                    (errcode(ERRCODE_DATATYPE_MISMATCH),
                     errmsg("could not convert row type"),
                     errdetail("Attribute \"%s\" of type %s does not exist in type %s.",
                               attname,
                               format_type_be(outdesc->tdtypeid),
                               format_type_be(indesc->tdtypeid))));
    }
    return attrMap;
}

References attname, AttrMap::attnums, ereport, errcode(), errdetail(), errmsg(), ERROR, format_type_be(), i, j, make_attrmap(), NameStr, TupleDescData::natts, TupleDescData::tdtypeid, and TupleDescAttr().

Referenced by addFkRecurseReferencing(), ATExecAttachPartitionIdx(), ATPrepAlterColumnType(), AttachPartitionEnsureIndexes(), build_attrmap_by_name_if_req(), CloneFkReferenced(), CloneFkReferencing(), DefineIndex(), DefineRelation(), ExecInitPartitionInfo(), expandTableLikeClause(), map_partition_varattnos(), MergeConstraintsIntoExisting(), and RemoveInheritance().

build_attrmap_by_name_if_req()

AttrMap * build_attrmap_by_name_if_req	(	TupleDesc	indesc,
		TupleDesc	outdesc,
		bool	missing_ok
	)

Definition at line 261 of file attmap.c.

{
    AttrMap    *attrMap;
 
    /* Verify compatibility and prepare attribute-number map */
    attrMap = build_attrmap_by_name(indesc, outdesc, missing_ok);
 
    /* Check if the map has a one-to-one match */
    if (check_attrmap_match(indesc, outdesc, attrMap))
    {
        /* Runtime conversion is not needed */
        free_attrmap(attrMap);
        return NULL;
    }
 
    return attrMap;
}

References build_attrmap_by_name(), check_attrmap_match(), and free_attrmap().

Referenced by addFkRecurseReferenced(), convert_tuples_by_name(), ExecConstraints(), ExecGetRootToChildMap(), ExecInitPartitionDispatchInfo(), ExecPartitionCheckEmitError(), ExecWithCheckOptions(), init_tuple_slot(), and ReportNotNullViolationError().

build_attrmap_by_position()

AttrMap * build_attrmap_by_position	(	TupleDesc	indesc,
		TupleDesc	outdesc,
		const char *	msg
	)

Definition at line 75 of file attmap.c.

{
    AttrMap    *attrMap;
    int         nincols;
    int         noutcols;
    int         n;
    int         i;
    int         j;
    bool        same;
 
    /*
     * The length is computed as the number of attributes of the expected
     * rowtype as it includes dropped attributes in its count.
     */
    n = outdesc->natts;
    attrMap = make_attrmap(n);
 
    j = 0;                      /* j is next physical input attribute */
    nincols = noutcols = 0;     /* these count non-dropped attributes */
    same = true;
    for (i = 0; i < n; i++)
    {
        Form_pg_attribute outatt = TupleDescAttr(outdesc, i);
 
        if (outatt->attisdropped)
            continue;           /* attrMap->attnums[i] is already 0 */
        noutcols++;
        for (; j < indesc->natts; j++)
        {
            Form_pg_attribute inatt = TupleDescAttr(indesc, j);
 
            if (inatt->attisdropped)
                continue;
            nincols++;
 
            /* Found matching column, now check type */
            if (outatt->atttypid != inatt->atttypid ||
                (outatt->atttypmod != inatt->atttypmod && outatt->atttypmod >= 0))
                ereport(ERROR,
                        (errcode(ERRCODE_DATATYPE_MISMATCH),
                         errmsg_internal("%s", _(msg)),
                         errdetail("Returned type %s does not match expected type %s in column \"%s\" (position %d).",
                                   format_type_with_typemod(inatt->atttypid,
                                                            inatt->atttypmod),
                                   format_type_with_typemod(outatt->atttypid,
                                                            outatt->atttypmod),
                                   NameStr(outatt->attname),
                                   noutcols)));
            attrMap->attnums[i] = (AttrNumber) (j + 1);
            j++;
            break;
        }
        if (attrMap->attnums[i] == 0)
            same = false;       /* we'll complain below */
    }
 
    /* Check for unused input columns */
    for (; j < indesc->natts; j++)
    {
        if (TupleDescCompactAttr(indesc, j)->attisdropped)
            continue;
        nincols++;
        same = false;           /* we'll complain below */
    }
 
    /* Report column count mismatch using the non-dropped-column counts */
    if (!same)
        ereport(ERROR,
                (errcode(ERRCODE_DATATYPE_MISMATCH),
                 errmsg_internal("%s", _(msg)),
                 errdetail("Number of returned columns (%d) does not match "
                           "expected column count (%d).",
                           nincols, noutcols)));
 
    /* Check if the map has a one-to-one match */
    if (check_attrmap_match(indesc, outdesc, attrMap))
    {
        /* Runtime conversion is not needed */
        free_attrmap(attrMap);
        return NULL;
    }
 
    return attrMap;
}

References _, CompactAttribute::attisdropped, AttrMap::attnums, check_attrmap_match(), ereport, errcode(), errdetail(), errmsg_internal(), ERROR, format_type_with_typemod(), free_attrmap(), i, j, make_attrmap(), NameStr, TupleDescData::natts, TupleDescAttr(), and TupleDescCompactAttr().

Referenced by convert_tuples_by_position().

free_attrmap()

void free_attrmap

(

AttrMap *

map

)

Definition at line 56 of file attmap.c.

{
    pfree(map->attnums);
    pfree(map);
}

References AttrMap::attnums, and pfree().

Referenced by addFkRecurseReferenced(), ATExecAttachPartitionIdx(), build_attrmap_by_name_if_req(), build_attrmap_by_position(), DefineIndex(), free_conversion_map(), get_rel_sync_entry(), logicalrep_partition_open(), logicalrep_rel_open(), logicalrep_relmap_free_entry(), and MergeAttributes().

make_attrmap()

AttrMap * make_attrmap

(

int

maplen

)

Definition at line 40 of file attmap.c.

{
    AttrMap    *res;
 
    res = (AttrMap *) palloc0(sizeof(AttrMap));
    res->maplen = maplen;
    res->attnums = (AttrNumber *) palloc0(sizeof(AttrNumber) * maplen);
    return res;
}

References AttrMap::attnums, AttrMap::maplen, and palloc0().

Referenced by build_attrmap_by_name(), build_attrmap_by_position(), logicalrep_partition_open(), logicalrep_rel_open(), and MergeAttributes().