printsimple.c File Reference

#include "postgres.h"
#include "access/printsimple.h"
#include "catalog/pg_type.h"
#include "libpq/pqformat.h"
#include "libpq/protocol.h"
#include "utils/builtins.h"

Include dependency graph for printsimple.c:

Go to the source code of this file.

Functions
void	printsimple_startup (DestReceiver *self, int operation, TupleDesc tupdesc)
bool	printsimple (TupleTableSlot *slot, DestReceiver *self)

Function Documentation

printsimple()

bool printsimple	(	TupleTableSlot *	slot,
		DestReceiver *	self
	)

Definition at line 59 of file printsimple.c.

{
    TupleDesc   tupdesc = slot->tts_tupleDescriptor;
    StringInfoData buf;
    int         i;
 
    /* Make sure the tuple is fully deconstructed */
    slot_getallattrs(slot);
 
    /* Prepare and send message */
    pq_beginmessage(&buf, PqMsg_DataRow);
    pq_sendint16(&buf, tupdesc->natts);
 
    for (i = 0; i < tupdesc->natts; ++i)
    {
        Form_pg_attribute attr = TupleDescAttr(tupdesc, i);
        Datum       value;
 
        if (slot->tts_isnull[i])
        {
            pq_sendint32(&buf, -1);
            continue;
        }
 
        value = slot->tts_values[i];
 
        /*
         * We can't call the regular type output functions here because we
         * might not have catalog access.  Instead, we must hard-wire
         * knowledge of the required types.
         */
        switch (attr->atttypid)
        {
            case TEXTOID:
                {
                    text       *t = DatumGetTextPP(value);
 
                    pq_sendcountedtext(&buf,
                                       VARDATA_ANY(t),
                                       VARSIZE_ANY_EXHDR(t));
                }
                break;
 
            case INT4OID:
                {
                    int32       num = DatumGetInt32(value);
                    char        str[12];    /* sign, 10 digits and '\0' */
                    int         len;
 
                    len = pg_ltoa(num, str);
                    pq_sendcountedtext(&buf, str, len);
                }
                break;
 
            case INT8OID:
                {
                    int64       num = DatumGetInt64(value);
                    char        str[MAXINT8LEN + 1];
                    int         len;
 
                    len = pg_lltoa(num, str);
                    pq_sendcountedtext(&buf, str, len);
                }
                break;
 
            case OIDOID:
                {
                    Oid         num = ObjectIdGetDatum(value);
                    char        str[10];    /* 10 digits */
                    int         len;
 
                    len = pg_ultoa_n(num, str);
                    pq_sendcountedtext(&buf, str, len);
                }
                break;
 
            default:
                elog(ERROR, "unsupported type OID: %u", attr->atttypid);
        }
    }
 
    pq_endmessage(&buf);
 
    return true;
}

References buf, DatumGetInt32(), DatumGetInt64(), DatumGetTextPP, elog, ERROR, i, len, MAXINT8LEN, TupleDescData::natts, ObjectIdGetDatum(), pg_lltoa(), pg_ltoa(), pg_ultoa_n(), pq_beginmessage(), pq_endmessage(), pq_sendcountedtext(), pq_sendint16(), pq_sendint32(), PqMsg_DataRow, slot_getallattrs(), str, TupleTableSlot::tts_isnull, TupleTableSlot::tts_tupleDescriptor, TupleTableSlot::tts_values, TupleDescAttr(), value, VARDATA_ANY, and VARSIZE_ANY_EXHDR.

printsimple_startup()

void printsimple_startup	(	DestReceiver *	self,
		int	operation,
		TupleDesc	tupdesc
	)

Definition at line 31 of file printsimple.c.

{
    StringInfoData buf;
    int         i;
 
    pq_beginmessage(&buf, PqMsg_RowDescription);
    pq_sendint16(&buf, tupdesc->natts);
 
    for (i = 0; i < tupdesc->natts; ++i)
    {
        Form_pg_attribute attr = TupleDescAttr(tupdesc, i);
 
        pq_sendstring(&buf, NameStr(attr->attname));
        pq_sendint32(&buf, 0);  /* table oid */
        pq_sendint16(&buf, 0);  /* attnum */
        pq_sendint32(&buf, (int) attr->atttypid);
        pq_sendint16(&buf, attr->attlen);
        pq_sendint32(&buf, attr->atttypmod);
        pq_sendint16(&buf, 0);  /* format code */
    }
 
    pq_endmessage(&buf);
}

References buf, i, NameStr, TupleDescData::natts, pq_beginmessage(), pq_endmessage(), pq_sendint16(), pq_sendint32(), pq_sendstring(), PqMsg_RowDescription, and TupleDescAttr().