Age Owner Branch data TLA Line data Source code
1 : : /*-------------------------------------------------------------------------
2 : : *
3 : : * printsimple.c
4 : : * Routines to print out tuples containing only a limited range of
5 : : * builtin types without catalog access. This is intended for
6 : : * backends that don't have catalog access because they are not bound
7 : : * to a specific database, such as some walsender processes. It
8 : : * doesn't handle standalone backends or protocol versions other than
9 : : * 3.0, because we don't need such handling for current applications.
10 : : *
11 : : * Portions Copyright (c) 1996-2024, PostgreSQL Global Development Group
12 : : * Portions Copyright (c) 1994, Regents of the University of California
13 : : *
14 : : * IDENTIFICATION
15 : : * src/backend/access/common/printsimple.c
16 : : *
17 : : *-------------------------------------------------------------------------
18 : : */
19 : : #include "postgres.h"
20 : :
21 : : #include "access/printsimple.h"
22 : : #include "catalog/pg_type.h"
23 : : #include "libpq/pqformat.h"
24 : : #include "libpq/protocol.h"
25 : : #include "utils/builtins.h"
26 : :
27 : : /*
28 : : * At startup time, send a RowDescription message.
29 : : */
30 : : void
2637 rhaas@postgresql.org 31 :CBC 2057 : printsimple_startup(DestReceiver *self, int operation, TupleDesc tupdesc)
32 : : {
33 : : StringInfoData buf;
34 : : int i;
35 : :
236 nathan@postgresql.or 36 :GNC 2057 : pq_beginmessage(&buf, PqMsg_RowDescription);
2377 andres@anarazel.de 37 :CBC 2057 : pq_sendint16(&buf, tupdesc->natts);
38 : :
2637 rhaas@postgresql.org 39 [ + + ]: 7936 : for (i = 0; i < tupdesc->natts; ++i)
40 : : {
2429 andres@anarazel.de 41 : 5879 : Form_pg_attribute attr = TupleDescAttr(tupdesc, i);
42 : :
2637 rhaas@postgresql.org 43 : 5879 : pq_sendstring(&buf, NameStr(attr->attname));
2328 44 : 5879 : pq_sendint32(&buf, 0); /* table oid */
45 : 5879 : pq_sendint16(&buf, 0); /* attnum */
2377 andres@anarazel.de 46 : 5879 : pq_sendint32(&buf, (int) attr->atttypid);
47 : 5879 : pq_sendint16(&buf, attr->attlen);
48 : 5879 : pq_sendint32(&buf, attr->atttypmod);
2328 rhaas@postgresql.org 49 : 5879 : pq_sendint16(&buf, 0); /* format code */
50 : : }
51 : :
2637 52 : 2057 : pq_endmessage(&buf);
53 : 2057 : }
54 : :
55 : : /*
56 : : * For each tuple, send a DataRow message.
57 : : */
58 : : bool
59 : 2834 : printsimple(TupleTableSlot *slot, DestReceiver *self)
60 : : {
61 : 2834 : TupleDesc tupdesc = slot->tts_tupleDescriptor;
62 : : StringInfoData buf;
63 : : int i;
64 : :
65 : : /* Make sure the tuple is fully deconstructed */
66 : 2834 : slot_getallattrs(slot);
67 : :
68 : : /* Prepare and send message */
236 nathan@postgresql.or 69 :GNC 2834 : pq_beginmessage(&buf, PqMsg_DataRow);
2377 andres@anarazel.de 70 :CBC 2834 : pq_sendint16(&buf, tupdesc->natts);
71 : :
2637 rhaas@postgresql.org 72 [ + + ]: 11057 : for (i = 0; i < tupdesc->natts; ++i)
73 : : {
2429 andres@anarazel.de 74 : 8223 : Form_pg_attribute attr = TupleDescAttr(tupdesc, i);
75 : : Datum value;
76 : :
2637 rhaas@postgresql.org 77 [ + + ]: 8223 : if (slot->tts_isnull[i])
78 : : {
2377 andres@anarazel.de 79 : 1273 : pq_sendint32(&buf, -1);
2637 rhaas@postgresql.org 80 : 1273 : continue;
81 : : }
82 : :
83 : 6950 : value = slot->tts_values[i];
84 : :
85 : : /*
86 : : * We can't call the regular type output functions here because we
87 : : * might not have catalog access. Instead, we must hard-wire
88 : : * knowledge of the required types.
89 : : */
90 [ + - + + : 6950 : switch (attr->atttypid)
- ]
91 : : {
92 : 5771 : case TEXTOID:
93 : : {
94 : 5771 : text *t = DatumGetTextPP(value);
95 : :
2637 rhaas@postgresql.org 96 :UBC 0 : pq_sendcountedtext(&buf,
2637 rhaas@postgresql.org 97 [ - + ]:CBC 5771 : VARDATA_ANY(t),
41 heikki.linnakangas@i 98 [ - + - - :GNC 5771 : VARSIZE_ANY_EXHDR(t));
- - - - -
+ ]
99 : : }
2637 rhaas@postgresql.org 100 :CBC 5771 : break;
101 : :
2629 rhaas@postgresql.org 102 :UBC 0 : case INT4OID:
103 : : {
2524 bruce@momjian.us 104 : 0 : int32 num = DatumGetInt32(value);
105 : : char str[12]; /* sign, 10 digits and '\0' */
106 : : int len;
107 : :
1401 drowley@postgresql.o 108 : 0 : len = pg_ltoa(num, str);
41 heikki.linnakangas@i 109 :UNC 0 : pq_sendcountedtext(&buf, str, len);
110 : : }
2629 rhaas@postgresql.org 111 :UBC 0 : break;
112 : :
2629 rhaas@postgresql.org 113 :CBC 1148 : case INT8OID:
114 : : {
2524 bruce@momjian.us 115 : 1148 : int64 num = DatumGetInt64(value);
116 : : char str[MAXINT8LEN + 1];
117 : : int len;
118 : :
1401 drowley@postgresql.o 119 : 1148 : len = pg_lltoa(num, str);
41 heikki.linnakangas@i 120 :GNC 1148 : pq_sendcountedtext(&buf, str, len);
121 : : }
2629 rhaas@postgresql.org 122 :CBC 1148 : break;
123 : :
648 peter@eisentraut.org 124 : 31 : case OIDOID:
125 : : {
126 : 31 : Oid num = ObjectIdGetDatum(value);
127 : : char str[10]; /* 10 digits */
128 : : int len;
129 : :
130 : 31 : len = pg_ultoa_n(num, str);
41 heikki.linnakangas@i 131 :GNC 31 : pq_sendcountedtext(&buf, str, len);
132 : : }
648 peter@eisentraut.org 133 :CBC 31 : break;
134 : :
2637 rhaas@postgresql.org 135 :UBC 0 : default:
136 [ # # ]: 0 : elog(ERROR, "unsupported type OID: %u", attr->atttypid);
137 : : }
138 : : }
139 : :
2637 rhaas@postgresql.org 140 :CBC 2834 : pq_endmessage(&buf);
141 : :
142 : 2834 : return true;
143 : : }
|
