Branch data 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-2026, 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 : : #include "varatt.h"
27 : :
28 : : /*
29 : : * At startup time, send a RowDescription message.
30 : : */
31 : : void
32 : 2453 : printsimple_startup(DestReceiver *self, int operation, TupleDesc tupdesc)
33 : : {
34 : : StringInfoData buf;
35 : : int i;
36 : :
37 : 2453 : pq_beginmessage(&buf, PqMsg_RowDescription);
38 : 2453 : pq_sendint16(&buf, tupdesc->natts);
39 : :
40 [ + + ]: 9522 : for (i = 0; i < tupdesc->natts; ++i)
41 : : {
42 : 7069 : Form_pg_attribute attr = TupleDescAttr(tupdesc, i);
43 : :
44 : 7069 : pq_sendstring(&buf, NameStr(attr->attname));
45 : 7069 : pq_sendint32(&buf, 0); /* table oid */
46 : 7069 : pq_sendint16(&buf, 0); /* attnum */
47 : 7069 : pq_sendint32(&buf, (int) attr->atttypid);
48 : 7069 : pq_sendint16(&buf, attr->attlen);
49 : 7069 : pq_sendint32(&buf, attr->atttypmod);
50 : 7069 : pq_sendint16(&buf, 0); /* format code */
51 : : }
52 : :
53 : 2453 : pq_endmessage(&buf);
54 : 2453 : }
55 : :
56 : : /*
57 : : * For each tuple, send a DataRow message.
58 : : */
59 : : bool
60 : 3321 : printsimple(TupleTableSlot *slot, DestReceiver *self)
61 : : {
62 : 3321 : TupleDesc tupdesc = slot->tts_tupleDescriptor;
63 : : StringInfoData buf;
64 : : int i;
65 : :
66 : : /* Make sure the tuple is fully deconstructed */
67 : 3321 : slot_getallattrs(slot);
68 : :
69 : : /* Prepare and send message */
70 : 3321 : pq_beginmessage(&buf, PqMsg_DataRow);
71 : 3321 : pq_sendint16(&buf, tupdesc->natts);
72 : :
73 [ + + ]: 13009 : for (i = 0; i < tupdesc->natts; ++i)
74 : : {
75 : 9688 : Form_pg_attribute attr = TupleDescAttr(tupdesc, i);
76 : : Datum value;
77 : :
78 [ + + ]: 9688 : if (slot->tts_isnull[i])
79 : : {
80 : 1516 : pq_sendint32(&buf, -1);
81 : 1516 : continue;
82 : : }
83 : :
84 : 8172 : value = slot->tts_values[i];
85 : :
86 : : /*
87 : : * We can't call the regular type output functions here because we
88 : : * might not have catalog access. Instead, we must hard-wire
89 : : * knowledge of the required types.
90 : : */
91 [ + - + + : 8172 : switch (attr->atttypid)
- ]
92 : : {
93 : 6789 : case TEXTOID:
94 : : {
95 : 6789 : text *t = DatumGetTextPP(value);
96 : :
97 : 6789 : pq_sendcountedtext(&buf,
98 : 6789 : VARDATA_ANY(t),
99 : 6789 : VARSIZE_ANY_EXHDR(t));
100 : : }
101 : 6789 : break;
102 : :
103 : 0 : case INT4OID:
104 : : {
105 : 0 : int32 num = DatumGetInt32(value);
106 : : char str[12]; /* sign, 10 digits and '\0' */
107 : : int len;
108 : :
109 : 0 : len = pg_ltoa(num, str);
110 : 0 : pq_sendcountedtext(&buf, str, len);
111 : : }
112 : 0 : break;
113 : :
114 : 1347 : case INT8OID:
115 : : {
116 : 1347 : int64 num = DatumGetInt64(value);
117 : : char str[MAXINT8LEN + 1];
118 : : int len;
119 : :
120 : 1347 : len = pg_lltoa(num, str);
121 : 1347 : pq_sendcountedtext(&buf, str, len);
122 : : }
123 : 1347 : break;
124 : :
125 : 36 : case OIDOID:
126 : : {
127 : 36 : Oid num = DatumGetObjectId(value);
128 : : char str[10]; /* 10 digits */
129 : : int len;
130 : :
131 : 36 : len = pg_ultoa_n(num, str);
132 : 36 : pq_sendcountedtext(&buf, str, len);
133 : : }
134 : 36 : break;
135 : :
136 : 0 : default:
137 [ # # ]: 0 : elog(ERROR, "unsupported type OID: %u", attr->atttypid);
138 : : }
139 : : }
140 : :
141 : 3321 : pq_endmessage(&buf);
142 : :
143 : 3321 : return true;
144 : : }
|
