tupconvert.h File Reference

#include "access/attmap.h"
#include "access/htup.h"
#include "access/tupdesc.h"
#include "executor/tuptable.h"
#include "nodes/bitmapset.h"

Include dependency graph for tupconvert.h:

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

Go to the source code of this file.

Data Structures
struct	TupleConversionMap

Typedefs
typedef struct TupleConversionMap	TupleConversionMap

Functions
TupleConversionMap *	convert_tuples_by_position (TupleDesc indesc, TupleDesc outdesc, const char *msg)
TupleConversionMap *	convert_tuples_by_name (TupleDesc indesc, TupleDesc outdesc)
TupleConversionMap *	convert_tuples_by_name_attrmap (TupleDesc indesc, TupleDesc outdesc, AttrMap *attrMap)
HeapTuple	execute_attr_map_tuple (HeapTuple tuple, TupleConversionMap *map)
TupleTableSlot *	execute_attr_map_slot (AttrMap *attrMap, TupleTableSlot *in_slot, TupleTableSlot *out_slot)
Bitmapset *	execute_attr_map_cols (AttrMap *attrMap, Bitmapset *in_cols)
void	free_conversion_map (TupleConversionMap *map)

Typedef Documentation

TupleConversionMap

typedef struct TupleConversionMap TupleConversionMap

Function Documentation

convert_tuples_by_name()

TupleConversionMap * convert_tuples_by_name ( TupleDesc  indesc, TupleDesc  outdesc  )

extern

Definition at line 103 of file tupconvert.c.

{
    AttrMap    *attrMap;
 
    /* Verify compatibility and prepare attribute-number map */
    attrMap = build_attrmap_by_name_if_req(indesc, outdesc, false);
 
    if (attrMap == NULL)
    {
        /* runtime conversion is not needed */
        return NULL;
    }
 
    return convert_tuples_by_name_attrmap(indesc, outdesc, attrMap);
}

References build_attrmap_by_name_if_req(), convert_tuples_by_name_attrmap(), and fb().

Referenced by acquire_inherited_sample_rows(), apply_handle_tuple_routing(), ExecEvalConvertRowtype(), ExecGetChildToRootMap(), MergePartitionsMoveRows(), and SplitPartitionMoveRows().

convert_tuples_by_name_attrmap()

TupleConversionMap * convert_tuples_by_name_attrmap ( TupleDesc  indesc, TupleDesc  outdesc, AttrMap *  attrMap  )

extern

Definition at line 125 of file tupconvert.c.

{
    int         n = outdesc->natts;
    TupleConversionMap *map;
 
    Assert(attrMap != NULL);
 
    /* Prepare the map structure */
    map = palloc_object(TupleConversionMap);
    map->indesc = indesc;
    map->outdesc = outdesc;
    map->attrMap = attrMap;
    /* preallocate workspace for Datum arrays */
    map->outvalues = palloc_array(Datum, n);
    map->outisnull = palloc_array(bool, n);
    n = indesc->natts + 1;      /* +1 for NULL */
    map->invalues = palloc_array(Datum, n);
    map->inisnull = palloc_array(bool, n);
    map->invalues[0] = (Datum) 0;   /* set up the NULL entry */
    map->inisnull[0] = true;
 
    return map;
}

References Assert, TupleConversionMap::attrMap, fb(), TupleConversionMap::indesc, TupleConversionMap::inisnull, TupleConversionMap::invalues, TupleDescData::natts, TupleConversionMap::outdesc, TupleConversionMap::outisnull, TupleConversionMap::outvalues, palloc_array, and palloc_object.

Referenced by convert_tuples_by_name(), and ExecGetRootToChildMap().

convert_tuples_by_position()

TupleConversionMap * convert_tuples_by_position ( TupleDesc  indesc, TupleDesc  outdesc, const char *  msg  )

extern

Definition at line 60 of file tupconvert.c.

{
    TupleConversionMap *map;
    int         n;
    AttrMap    *attrMap;
 
    /* Verify compatibility and prepare attribute-number map */
    attrMap = build_attrmap_by_position(indesc, outdesc, msg);
 
    if (attrMap == NULL)
    {
        /* runtime conversion is not needed */
        return NULL;
    }
 
    /* Prepare the map structure */
    map = palloc_object(TupleConversionMap);
    map->indesc = indesc;
    map->outdesc = outdesc;
    map->attrMap = attrMap;
    /* preallocate workspace for Datum arrays */
    n = outdesc->natts + 1;     /* +1 for NULL */
    map->outvalues = palloc_array(Datum, n);
    map->outisnull = palloc_array(bool, n);
    n = indesc->natts + 1;      /* +1 for NULL */
    map->invalues = palloc_array(Datum, n);
    map->inisnull = palloc_array(bool, n);
    map->invalues[0] = (Datum) 0;   /* set up the NULL entry */
    map->inisnull[0] = true;
 
    return map;
}

References TupleConversionMap::attrMap, build_attrmap_by_position(), fb(), TupleConversionMap::indesc, TupleConversionMap::inisnull, TupleConversionMap::invalues, TupleDescData::natts, TupleConversionMap::outdesc, TupleConversionMap::outisnull, TupleConversionMap::outvalues, palloc_array, and palloc_object.

Referenced by coerce_function_result_tuple(), exec_stmt_return_next(), plpgsql_exec_trigger(), and tstoreStartupReceiver().

execute_attr_map_cols()

Bitmapset * execute_attr_map_cols ( AttrMap *  attrMap, Bitmapset *  in_cols  )

extern

Definition at line 253 of file tupconvert.c.

{
    Bitmapset  *out_cols;
    int         out_attnum;
 
    /* fast path for the common trivial case */
    if (in_cols == NULL)
        return NULL;
 
    /*
     * For each output column, check which input column it corresponds to.
     */
    out_cols = NULL;
 
    for (out_attnum = FirstLowInvalidHeapAttributeNumber;
         out_attnum <= attrMap->maplen;
         out_attnum++)
    {
        int         in_attnum;
 
        if (out_attnum < 0)
        {
            /* System column. No mapping. */
            in_attnum = out_attnum;
        }
        else if (out_attnum == 0)
            continue;
        else
        {
            /* normal user column */
            in_attnum = attrMap->attnums[out_attnum - 1];
 
            if (in_attnum == 0)
                continue;
        }
 
        if (bms_is_member(in_attnum - FirstLowInvalidHeapAttributeNumber, in_cols))
            out_cols = bms_add_member(out_cols, out_attnum - FirstLowInvalidHeapAttributeNumber);
    }
 
    return out_cols;
}

References AttrMap::attnums, bms_add_member(), bms_is_member(), fb(), FirstLowInvalidHeapAttributeNumber, and AttrMap::maplen.

Referenced by ExecGetInsertedCols(), and ExecGetUpdatedCols().

execute_attr_map_slot()

TupleTableSlot * execute_attr_map_slot ( AttrMap *  attrMap, TupleTableSlot *  in_slot, TupleTableSlot *  out_slot  )

extern

Definition at line 193 of file tupconvert.c.

{
    Datum      *invalues;
    bool       *inisnull;
    Datum      *outvalues;
    bool       *outisnull;
    int         outnatts;
    int         i;
 
    /* Sanity checks */
    Assert(in_slot->tts_tupleDescriptor != NULL &&
           out_slot->tts_tupleDescriptor != NULL);
    Assert(in_slot->tts_values != NULL && out_slot->tts_values != NULL);
 
    outnatts = out_slot->tts_tupleDescriptor->natts;
 
    /* Extract all the values of the in slot. */
    slot_getallattrs(in_slot);
 
    /* Before doing the mapping, clear any old contents from the out slot */
    ExecClearTuple(out_slot);
 
    invalues = in_slot->tts_values;
    inisnull = in_slot->tts_isnull;
    outvalues = out_slot->tts_values;
    outisnull = out_slot->tts_isnull;
 
    /* Transpose into proper fields of the out slot. */
    for (i = 0; i < outnatts; i++)
    {
        int         j = attrMap->attnums[i] - 1;
 
        /* attrMap->attnums[i] == 0 means it's a NULL datum. */
        if (j == -1)
        {
            outvalues[i] = (Datum) 0;
            outisnull[i] = true;
        }
        else
        {
            outvalues[i] = invalues[j];
            outisnull[i] = inisnull[j];
        }
    }
 
    ExecStoreVirtualTuple(out_slot);
 
    return out_slot;
}

References Assert, AttrMap::attnums, ExecClearTuple(), ExecStoreVirtualTuple(), fb(), i, j, and slot_getallattrs().

Referenced by AfterTriggerExecute(), AfterTriggerSaveEvent(), apply_handle_tuple_routing(), CopyFrom(), CopyRelationTo(), ExecConstraints(), ExecCrossPartitionUpdate(), ExecDelete(), ExecFindPartition(), ExecInsert(), ExecPartitionCheckEmitError(), ExecPrepareTupleRouting(), ExecWithCheckOptions(), MergePartitionsMoveRows(), pgoutput_change(), ReportNotNullViolationError(), SplitPartitionMoveRows(), TransitionTableAddTuple(), and tstoreReceiveSlot_tupmap().

execute_attr_map_tuple()

HeapTuple execute_attr_map_tuple ( HeapTuple  tuple, TupleConversionMap *  map  )

extern

Definition at line 155 of file tupconvert.c.

{
    AttrMap    *attrMap = map->attrMap;
    Datum      *invalues = map->invalues;
    bool       *inisnull = map->inisnull;
    Datum      *outvalues = map->outvalues;
    bool       *outisnull = map->outisnull;
    int         i;
 
    /*
     * Extract all the values of the old tuple, offsetting the arrays so that
     * invalues[0] is left NULL and invalues[1] is the first source attribute;
     * this exactly matches the numbering convention in attrMap.
     */
    heap_deform_tuple(tuple, map->indesc, invalues + 1, inisnull + 1);
 
    /*
     * Transpose into proper fields of the new tuple.
     */
    Assert(attrMap->maplen == map->outdesc->natts);
    for (i = 0; i < attrMap->maplen; i++)
    {
        int         j = attrMap->attnums[i];
 
        outvalues[i] = invalues[j];
        outisnull[i] = inisnull[j];
    }
 
    /*
     * Now form the new tuple.
     */
    return heap_form_tuple(map->outdesc, outvalues, outisnull);
}

References Assert, AttrMap::attnums, TupleConversionMap::attrMap, heap_deform_tuple(), heap_form_tuple(), i, TupleConversionMap::indesc, TupleConversionMap::inisnull, TupleConversionMap::invalues, j, AttrMap::maplen, TupleDescData::natts, TupleConversionMap::outdesc, TupleConversionMap::outisnull, and TupleConversionMap::outvalues.

Referenced by acquire_inherited_sample_rows(), coerce_function_result_tuple(), exec_stmt_return_next(), ExecEvalConvertRowtype(), and plpgsql_exec_trigger().

free_conversion_map()

void free_conversion_map ( TupleConversionMap *  map )

extern

Definition at line 300 of file tupconvert.c.

{
    /* indesc and outdesc are not ours to free */
    free_attrmap(map->attrMap);
    pfree(map->invalues);
    pfree(map->inisnull);
    pfree(map->outvalues);
    pfree(map->outisnull);
    pfree(map);
}

References TupleConversionMap::attrMap, free_attrmap(), TupleConversionMap::inisnull, TupleConversionMap::invalues, TupleConversionMap::outisnull, TupleConversionMap::outvalues, and pfree().

Referenced by acquire_inherited_sample_rows(), MergePartitionsMoveRows(), SplitPartitionMoveRows(), and tstoreShutdownReceiver().