printtup.h File Reference

#include "utils/portal.h"

Include dependency graph for printtup.h:

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

Go to the source code of this file.

Functions
DestReceiver *	printtup_create_DR (CommandDest dest)
void	SetRemoteDestReceiverParams (DestReceiver *self, Portal portal)
void	SendRowDescriptionMessage (StringInfo buf, TupleDesc typeinfo, List *targetlist, int16 *formats)
void	debugStartup (DestReceiver *self, int operation, TupleDesc typeinfo)
bool	debugtup (TupleTableSlot *slot, DestReceiver *self)
void	spi_dest_startup (DestReceiver *self, int operation, TupleDesc typeinfo)
bool	spi_printtup (TupleTableSlot *slot, DestReceiver *self)

Function Documentation

debugStartup()

void debugStartup ( DestReceiver *  self, int  operation, TupleDesc  typeinfo  )

extern

Definition at line 445 of file printtup.c.

{
    int         natts = typeinfo->natts;
    int         i;
 
    /*
     * show the return type of the tuples
     */
    for (i = 0; i < natts; ++i)
        printatt((unsigned) i + 1, TupleDescAttr(typeinfo, i), NULL);
    printf("\t----\n");
}

References fb(), i, printatt(), printf, and TupleDescAttr().

debugtup()

bool debugtup ( TupleTableSlot *  slot, DestReceiver *  self  )

extern

Definition at line 463 of file printtup.c.

{
    TupleDesc   typeinfo = slot->tts_tupleDescriptor;
    int         natts = typeinfo->natts;
    int         i;
    Datum       attr;
    char       *value;
    bool        isnull;
    Oid         typoutput;
    bool        typisvarlena;
 
    for (i = 0; i < natts; ++i)
    {
        attr = slot_getattr(slot, i + 1, &isnull);
        if (isnull)
            continue;
        getTypeOutputInfo(TupleDescAttr(typeinfo, i)->atttypid,
                          &typoutput, &typisvarlena);
 
        value = OidOutputFunctionCall(typoutput, attr);
 
        printatt((unsigned) i + 1, TupleDescAttr(typeinfo, i), value);
    }
    printf("\t----\n");
 
    return true;
}

References fb(), getTypeOutputInfo(), i, TupleDescData::natts, OidOutputFunctionCall(), printatt(), printf, slot_getattr(), TupleTableSlot::tts_tupleDescriptor, TupleDescAttr(), and value.

Referenced by print_slot().

printtup_create_DR()

DestReceiver * printtup_create_DR ( CommandDest  dest )

extern

Definition at line 72 of file printtup.c.

{
    DR_printtup *self = palloc0_object(DR_printtup);
 
    self->pub.receiveSlot = printtup;   /* might get changed later */
    self->pub.rStartup = printtup_startup;
    self->pub.rShutdown = printtup_shutdown;
    self->pub.rDestroy = printtup_destroy;
    self->pub.mydest = dest;
 
    /*
     * Send T message automatically if DestRemote, but not if
     * DestRemoteExecute
     */
    self->sendDescrip = (dest == DestRemote);
 
    self->attrinfo = NULL;
    self->nattrs = 0;
    self->myinfo = NULL;
    self->buf.data = NULL;
    self->tmpcontext = NULL;
 
    return (DestReceiver *) self;
}

References DR_printtup::attrinfo, DR_printtup::buf, StringInfoData::data, DestRemote, fb(), _DestReceiver::mydest, DR_printtup::myinfo, DR_printtup::nattrs, palloc0_object, printtup(), printtup_destroy(), printtup_shutdown(), printtup_startup(), DR_printtup::pub, _DestReceiver::rDestroy, _DestReceiver::receiveSlot, _DestReceiver::rShutdown, _DestReceiver::rStartup, DR_printtup::sendDescrip, and DR_printtup::tmpcontext.

Referenced by CreateDestReceiver().

SendRowDescriptionMessage()

void SendRowDescriptionMessage ( StringInfo  buf, TupleDesc  typeinfo, List *  targetlist, int16 *  formats  )

extern

Definition at line 167 of file printtup.c.

{
    int         natts = typeinfo->natts;
    int         i;
    ListCell   *tlist_item = list_head(targetlist);
 
    /* tuple descriptor message type */
    pq_beginmessage_reuse(buf, PqMsg_RowDescription);
    /* # of attrs in tuples */
    pq_sendint16(buf, natts);
 
    /*
     * Preallocate memory for the entire message to be sent. That allows to
     * use the significantly faster inline pqformat.h functions and to avoid
     * reallocations.
     *
     * Have to overestimate the size of the column-names, to account for
     * character set overhead.
     */
    enlargeStringInfo(buf, (NAMEDATALEN * MAX_CONVERSION_GROWTH /* attname */
                            + sizeof(Oid)   /* resorigtbl */
                            + sizeof(AttrNumber)    /* resorigcol */
                            + sizeof(Oid)   /* atttypid */
                            + sizeof(int16) /* attlen */
                            + sizeof(int32) /* attypmod */
                            + sizeof(int16) /* format */
                            ) * natts);
 
    for (i = 0; i < natts; ++i)
    {
        Form_pg_attribute att = TupleDescAttr(typeinfo, i);
        Oid         atttypid = att->atttypid;
        int32       atttypmod = att->atttypmod;
        Oid         resorigtbl;
        AttrNumber  resorigcol;
        int16       format;
 
        /*
         * If column is a domain, send the base type and typmod instead.
         * Lookup before sending any ints, for efficiency.
         */
        atttypid = getBaseTypeAndTypmod(atttypid, &atttypmod);
 
        /* Do we have a non-resjunk tlist item? */
        while (tlist_item &&
               ((TargetEntry *) lfirst(tlist_item))->resjunk)
            tlist_item = lnext(targetlist, tlist_item);
        if (tlist_item)
        {
            TargetEntry *tle = (TargetEntry *) lfirst(tlist_item);
 
            resorigtbl = tle->resorigtbl;
            resorigcol = tle->resorigcol;
            tlist_item = lnext(targetlist, tlist_item);
        }
        else
        {
            /* No info available, so send zeroes */
            resorigtbl = 0;
            resorigcol = 0;
        }
 
        if (formats)
            format = formats[i];
        else
            format = 0;
 
        pq_writestring(buf, NameStr(att->attname));
        pq_writeint32(buf, resorigtbl);
        pq_writeint16(buf, resorigcol);
        pq_writeint32(buf, atttypid);
        pq_writeint16(buf, att->attlen);
        pq_writeint32(buf, atttypmod);
        pq_writeint16(buf, format);
    }
 
    pq_endmessage_reuse(buf);
}

References buf, enlargeStringInfo(), fb(), format, getBaseTypeAndTypmod(), i, lfirst, list_head(), lnext(), MAX_CONVERSION_GROWTH, NAMEDATALEN, NameStr, pq_beginmessage_reuse(), pq_endmessage_reuse(), pq_sendint16(), pq_writeint16(), pq_writeint32(), pq_writestring(), PqMsg_RowDescription, and TupleDescAttr().

Referenced by exec_describe_portal_message(), exec_describe_statement_message(), and printtup_startup().

SetRemoteDestReceiverParams()

void SetRemoteDestReceiverParams ( DestReceiver *  self, Portal  portal  )

extern

Definition at line 101 of file printtup.c.

{
    DR_printtup *myState = (DR_printtup *) self;
 
    Assert(myState->pub.mydest == DestRemote ||
           myState->pub.mydest == DestRemoteExecute);
 
    myState->portal = portal;
}

References Assert, DestRemote, DestRemoteExecute, and fb().

Referenced by exec_execute_message(), and exec_simple_query().

spi_dest_startup()

void spi_dest_startup ( DestReceiver *  self, int  operation, TupleDesc  typeinfo  )

extern

Definition at line 2123 of file spi.c.

{
    SPITupleTable *tuptable;
    MemoryContext oldcxt;
    MemoryContext tuptabcxt;
 
    if (_SPI_current == NULL)
        elog(ERROR, "spi_dest_startup called while not connected to SPI");
 
    if (_SPI_current->tuptable != NULL)
        elog(ERROR, "improper call to spi_dest_startup");
 
    /* We create the tuple table context as a child of procCxt */
 
    oldcxt = _SPI_procmem();    /* switch to procedure memory context */
 
    tuptabcxt = AllocSetContextCreate(CurrentMemoryContext,
                                      "SPI TupTable",
                                      ALLOCSET_DEFAULT_SIZES);
    MemoryContextSwitchTo(tuptabcxt);
 
    _SPI_current->tuptable = tuptable = palloc0_object(SPITupleTable);
    tuptable->tuptabcxt = tuptabcxt;
    tuptable->subid = GetCurrentSubTransactionId();
 
    /*
     * The tuptable is now valid enough to be freed by AtEOSubXact_SPI, so put
     * it onto the SPI context's tuptables list.  This will ensure it's not
     * leaked even in the unlikely event the following few lines fail.
     */
    slist_push_head(&_SPI_current->tuptables, &tuptable->next);
 
    /* set up initial allocations */
    tuptable->alloced = 128;
    tuptable->vals = palloc_array(HeapTuple, tuptable->alloced);
    tuptable->numvals = 0;
    tuptable->tupdesc = CreateTupleDescCopy(typeinfo);
 
    MemoryContextSwitchTo(oldcxt);
}

References _SPI_current, _SPI_procmem(), SPITupleTable::alloced, ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate, CreateTupleDescCopy(), CurrentMemoryContext, elog, ERROR, fb(), GetCurrentSubTransactionId(), MemoryContextSwitchTo(), SPITupleTable::next, SPITupleTable::numvals, palloc0_object, palloc_array, slist_push_head(), SPITupleTable::subid, SPITupleTable::tupdesc, SPITupleTable::tuptabcxt, _SPI_connection::tuptable, _SPI_connection::tuptables, and SPITupleTable::vals.

spi_printtup()

bool spi_printtup ( TupleTableSlot *  slot, DestReceiver *  self  )

extern

Definition at line 2170 of file spi.c.

{
    SPITupleTable *tuptable;
    MemoryContext oldcxt;
 
    if (_SPI_current == NULL)
        elog(ERROR, "spi_printtup called while not connected to SPI");
 
    tuptable = _SPI_current->tuptable;
    if (tuptable == NULL)
        elog(ERROR, "improper call to spi_printtup");
 
    oldcxt = MemoryContextSwitchTo(tuptable->tuptabcxt);
 
    if (tuptable->numvals >= tuptable->alloced)
    {
        /* Double the size of the pointer array */
        uint64      newalloced = tuptable->alloced * 2;
 
        tuptable->vals = (HeapTuple *) repalloc_huge(tuptable->vals,
                                                     newalloced * sizeof(HeapTuple));
        tuptable->alloced = newalloced;
    }
 
    tuptable->vals[tuptable->numvals] = ExecCopySlotHeapTuple(slot);
    (tuptable->numvals)++;
 
    MemoryContextSwitchTo(oldcxt);
 
    return true;
}

References _SPI_current, SPITupleTable::alloced, elog, ERROR, ExecCopySlotHeapTuple(), fb(), MemoryContextSwitchTo(), SPITupleTable::numvals, repalloc_huge(), SPITupleTable::tuptabcxt, _SPI_connection::tuptable, and SPITupleTable::vals.