DCL 3.7.4
Loading...
Searching...
No Matches
PqTypes.cpp File Reference
#include <dcl/Config.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <libpq-fe.h>
#include <catalog/pg_type_d.h>
#include <dcl/Object.h>
#include <dcl/SQLCore.h>
#include "PqTypes.h"

Go to the source code of this file.

Macros

#define __TRACE_THIS   0
#define __DCL_TRACE0_N(fmt)
#define __DCL_TRACE1_N(fmt, arg)
#define __DCL_TRACE2_N(fmt, arg1, arg2)
#define __DCL_TRACE3_N(fmt, arg1, arg2, arg3)
#define __DCL_TRACE4_N(fmt, arg1, arg2, arg3, arg4)
#define __START   0
#define __yyyy   1
#define __MM   2
#define __dd   3
#define __HH   4
#define __mm   5
#define __ss   6
#define __SSS   7
#define __ZH   8
#define __Zm   9
#define __Zs   10
#define __BC   11
#define __DONE   12
#define __P0   0
#define __PT   1
#define __PTDOT   2
#define __PDONE   3
#define SQLTYPE_NAME(_oid, name)

Functions

bool __unescape_hex (const char *_src, const char *&_srcend, char *_dst, char *&_dstend)
bool __unescape_oct (const char *_src, const char *&_srcend, char *_dst, char *&_dstend)
bool __decode_timestamp_iso (const char *_s, const char **_endptr, SQL::TimeStamp &_r)
bool __decode_interval_iso (const char *_s, const char **_endptr, SQL::Interval &_r)
const wchar_t * __dataTypeName (Oid _oid)

Macro Definition Documentation

◆ __BC

#define __BC   11

◆ __DCL_TRACE0_N

#define __DCL_TRACE0_N ( fmt)

Definition at line 31 of file PqTypes.cpp.

◆ __DCL_TRACE1_N

#define __DCL_TRACE1_N ( fmt,
arg )

Definition at line 32 of file PqTypes.cpp.

◆ __DCL_TRACE2_N

#define __DCL_TRACE2_N ( fmt,
arg1,
arg2 )

Definition at line 33 of file PqTypes.cpp.

◆ __DCL_TRACE3_N

#define __DCL_TRACE3_N ( fmt,
arg1,
arg2,
arg3 )

Definition at line 34 of file PqTypes.cpp.

◆ __DCL_TRACE4_N

#define __DCL_TRACE4_N ( fmt,
arg1,
arg2,
arg3,
arg4 )

Definition at line 35 of file PqTypes.cpp.

◆ __dd

#define __dd   3

◆ __DONE

#define __DONE   12

◆ __HH

#define __HH   4

◆ __MM

#define __MM   2

◆ __mm

#define __mm   5

◆ __P0

#define __P0   0

◆ __PDONE

#define __PDONE   3

◆ __PT

#define __PT   1

◆ __PTDOT

#define __PTDOT   2

◆ __ss

#define __ss   6

◆ __SSS

#define __SSS   7

◆ __START

#define __START   0

◆ __TRACE_THIS

#define __TRACE_THIS   0

Definition at line 23 of file PqTypes.cpp.

◆ __yyyy

#define __yyyy   1

◆ __ZH

#define __ZH   8

◆ __Zm

#define __Zm   9

◆ __Zs

#define __Zs   10

◆ SQLTYPE_NAME

#define SQLTYPE_NAME ( _oid,
name )
Value:
case _oid : return L ## name

Definition at line 416 of file PqTypes.cpp.

Function Documentation

◆ __dataTypeName()

const wchar_t * __dataTypeName ( Oid _oid)

Definition at line 418 of file PqTypes.cpp.

419{
420 switch (_oid) {
421 SQLTYPE_NAME(BOOLOID, "BOOL"); // 16
422 SQLTYPE_NAME(BYTEAOID, "BYTEA"); // 17
423 SQLTYPE_NAME(CHAROID, "CHAR"); // 18
424 SQLTYPE_NAME(NAMEOID, "NAME"); // 19
425 SQLTYPE_NAME(INT8OID, "INT8"); // 20
426 SQLTYPE_NAME(INT2OID, "INT2"); // 21
427 SQLTYPE_NAME(INT4OID, "INT4"); // 23
428
429 SQLTYPE_NAME(TEXTOID, "TEXT"); // 25
430 SQLTYPE_NAME(JSONOID, "JSON"); // 114
431 SQLTYPE_NAME(XMLOID, "XML"); // 142
432
433 SQLTYPE_NAME(POINTOID, "POINT"); // 600
434 SQLTYPE_NAME(LSEGOID, "LSEG"); // 601
435 SQLTYPE_NAME(PATHOID, "PATH"); // 602
436 SQLTYPE_NAME(BOXOID, "BOX"); // 603
437 SQLTYPE_NAME(POLYGONOID, "POLYGON"); // 604
438 SQLTYPE_NAME(LINEOID, "LINE"); // 628
439
440 SQLTYPE_NAME(FLOAT4OID, "FLOAT4"); // 700
441 SQLTYPE_NAME(FLOAT8OID, "FLOAT8"); // 701
442
443 SQLTYPE_NAME(UNKNOWNOID, "UNKNOWN"); // 705
444
445 SQLTYPE_NAME(CIRCLEOID, "CIRCLE"); // 718
446
447 SQLTYPE_NAME(MONEYOID, "MONEY"); // 790
448
449 SQLTYPE_NAME(MACADDROID, "MACADDR"); // 829
450 SQLTYPE_NAME(INETOID, "INET"); // 869
451 SQLTYPE_NAME(CIDROID, "CIDR"); // 650
452 SQLTYPE_NAME(MACADDR8OID, "MACADDR8"); // 774
453
454 SQLTYPE_NAME(BPCHAROID, "BPCHAR"); // 1042
455 SQLTYPE_NAME(VARCHAROID, "VARCHAR"); // 1043
456 SQLTYPE_NAME(DATEOID, "DATE"); // 1082
457 SQLTYPE_NAME(TIMEOID, "TIME"); // 1083
458 SQLTYPE_NAME(TIMESTAMPOID, "TIMESTAMP"); // 1183
459 SQLTYPE_NAME(TIMESTAMPTZOID, "TIMESTAMPTZ"); // 1184
460 SQLTYPE_NAME(INTERVALOID, "INTERVAL"); // 1186
461 SQLTYPE_NAME(TIMETZOID, "TIMETZ"); // 1266
462
463 SQLTYPE_NAME(BITOID, "BIT"); // 1560
464 SQLTYPE_NAME(VARBITOID, "VARBIT"); // 1562
465
466 SQLTYPE_NAME(NUMERICOID, "NUMERIC"); // 1700
467
468 SQLTYPE_NAME(UUIDOID, "UUID"); // 2950
469 SQLTYPE_NAME(TSVECTOROID, "TSVECTOR"); // 3614
470 SQLTYPE_NAME(TSQUERYOID, "TSQUERY"); // 3615
471 SQLTYPE_NAME(JSONBOID, "JSONB"); // 3802
472 SQLTYPE_NAME(JSONPATHOID, "JSONPATHO"); // 4072
473
474 SQLTYPE_NAME(ANYOID, "ANY"); // 2276
475 SQLTYPE_NAME(ANYARRAYOID, "ANYARRAY"); // 2277
476 SQLTYPE_NAME(VOIDOID, "VOID"); // 2278
477
478 SQLTYPE_NAME(BOOLARRAYOID, "BOOLARRAY"); // 1000
479 SQLTYPE_NAME(BYTEAARRAYOID, "BYTEAARRAY"); //
480 SQLTYPE_NAME(CHARARRAYOID, "CHARARRAY"); //
481 SQLTYPE_NAME(NAMEARRAYOID, "NAMEARRAY"); //
482 SQLTYPE_NAME(INT8ARRAYOID, "INT8ARRAY"); //
483 SQLTYPE_NAME(INT2ARRAYOID, "INT2ARRAY"); // 1005
484 SQLTYPE_NAME(INT2VECTORARRAYOID, "INT2VECTORARRAY"); // 1006
485 SQLTYPE_NAME(INT4ARRAYOID, "INT4ARRAY"); // 1007
486 SQLTYPE_NAME(TEXTARRAYOID, "TEXTARRAY"); // 1009
487 SQLTYPE_NAME(OIDARRAYOID, "OIDARRAY"); // 1028
488 SQLTYPE_NAME(TIDARRAYOID, "TIDARRAY"); //
489 SQLTYPE_NAME(XIDARRAYOID, "XIDARRAY"); //
490 SQLTYPE_NAME(CIDARRAYOID, "CIDARRAY"); // 1012
491 SQLTYPE_NAME(OIDVECTORARRAYOID, "OIDVECTORARRAY"); // 1013
492 SQLTYPE_NAME(JSONARRAYOID, "JSONARRAY"); // 199
493 SQLTYPE_NAME(XMLARRAYOID, "XMLARRAY"); // 143
494 SQLTYPE_NAME(XID8ARRAYOID, "XID8ARRAY"); //
495 SQLTYPE_NAME(POINTARRAYOID, "POINTARRAY"); // 1017
496 SQLTYPE_NAME(LSEGARRAYOID, "LSEGARRAY"); //
497 SQLTYPE_NAME(PATHARRAYOID, "PATHARRAY"); //
498 SQLTYPE_NAME(BOXARRAYOID, "BOXARRAY"); //
499 SQLTYPE_NAME(POLYGONARRAYOID, "POLYGONARRAY"); //
500 SQLTYPE_NAME(LINEARRAYOID, "LINEARRAY"); //
501 SQLTYPE_NAME(FLOAT4ARRAYOID, "FLOAT4ARRAY"); // 1021
502 SQLTYPE_NAME(FLOAT8ARRAYOID, "FLOAT8ARRAY"); //
503 SQLTYPE_NAME(CIRCLEARRAYOID, "CIRCLEARRAY"); //
504 SQLTYPE_NAME(MONEYARRAYOID, "MONEYARRAY"); // 719
505 SQLTYPE_NAME(MACADDRARRAYOID, "MACADDRARRAY"); //
506 SQLTYPE_NAME(INETARRAYOID, "INETARRAY"); //
507 SQLTYPE_NAME(CIDRARRAYOID, "CIDRARRAY"); //
508 SQLTYPE_NAME(MACADDR8ARRAYOID, "MACADDR8ARRAY"); //
509 SQLTYPE_NAME(ACLITEMARRAYOID, "ACLITEMARRAY"); //
510 SQLTYPE_NAME(BPCHARARRAYOID, "BPCHARARRAY"); //
511 SQLTYPE_NAME(VARCHARARRAYOID, "VARCHARARRAY"); //
512 SQLTYPE_NAME(DATEARRAYOID, "DATEARRAY"); //
513 SQLTYPE_NAME(TIMEARRAYOID, "TIMEARRAY"); //
514 SQLTYPE_NAME(TIMESTAMPARRAYOID, "TIMESTAMPARRAY"); //
515 SQLTYPE_NAME(TIMESTAMPTZARRAYOID, "TIMESTAMPTZARRAY"); //
516 SQLTYPE_NAME(INTERVALARRAYOID, "INTERVALARRAY"); //
517 SQLTYPE_NAME(TIMETZARRAYOID, "TIMETZARRAY"); //
518 SQLTYPE_NAME(BITARRAYOID, "BITARRAY"); //
519 SQLTYPE_NAME(VARBITARRAYOID, "VARBITARRAY"); //
520 SQLTYPE_NAME(NUMERICARRAYOID, "NUMERICARRAY"); //
521 SQLTYPE_NAME(REFCURSORARRAYOID, "REFCURSORARRAY"); //
522 SQLTYPE_NAME(UUIDARRAYOID, "UUIDARRAY"); //
523 SQLTYPE_NAME(TSVECTORARRAYOID, "TSVECTORARRAY"); //
524 SQLTYPE_NAME(GTSVECTORARRAYOID, "GTSVECTORARRAY"); //
525 SQLTYPE_NAME(TSQUERYARRAYOID, "TSQUERYARRAY"); //
526 SQLTYPE_NAME(JSONBARRAYOID, "JSONBARRAY"); //
527 SQLTYPE_NAME(JSONPATHARRAYOID, "JSONPATHARRAY"); //
528 default: return L"Unknown Type (Binary Mapped)";
529 }
530}
SQLTYPE_NAME
#define SQLTYPE_NAME(_oid, name)
Definition PqTypes.cpp:416

◆ __decode_interval_iso()

bool __decode_interval_iso ( const char * _s,
const char ** _endptr,
SQL::Interval & _r )

Definition at line 308 of file PqTypes.cpp.

312{
313 __DCL_ASSERT(_s);
314#ifndef __DCL_DEBUG
315 if (!_s) {
316 if (_endptr) {
317 *_endptr = _s;
318 }
319 return false;
320 }
321#endif
322
323 if (*_s != 'P') {
324 // invalid string
325 if (_endptr) {
326 *_endptr = _s;
327 }
328 return false;
329 }
330 _s++;
331
332#define __P0 0
333#define __PT 1
334#define __PTDOT 2
335#define __PDONE 3
336
337 bool r = true;
338 int state = __P0; // P3Y6M4DT12H30M5S
339 memset(&_r, 0, sizeof(_r));
340
341 char dotsign = '+'; // '.'에서 부호를 보관해야 SSS 사용할 수 있다.
342 char* endptr = (char*)_s;
343 for (; ; ) {
344 errno = 0;
345 const char* nptr = endptr;
346 long n = strtol(nptr, &endptr, 10);
347 if (errno == ERANGE) {
348 // invalid string
349 r = false;
350 break;
351 }
352 __DCL_TRACE4_N(L"state[%d] [%p][%hc] [%d]\n",
353 state, endptr, (*endptr ? *endptr : '$'), n);
354 switch (*endptr) {
355 case 'Y':
356 _r.years = (int32_t)n;
357 break;
358 case 'M':
359 if (state == __PT) {
360 _r.mins = (int8_t)n;
361 }
362 else {
363 _r.months = (int8_t)n;
364 }
365 break;
366 case 'D':
367 _r.days = (int32_t)n;
368 break;
369 case 'T':
370 state = __PT;
371 break;
372 case 'H':
373 _r.hours = (int8_t)n;
374 break;
375 case '.':
376 state = __PTDOT;
377 dotsign = *nptr;
378 _r.secs = (int8_t)n;
379 break;
380 case 'S': {
381 if (state == __PTDOT) {
382 _r.fracs = __fraction_normalize(n)
383 * (dotsign == '-' ? -1 : 1);
384 }
385 else {
386 _r.secs = (int8_t)n;
387 }
388 state = __PDONE;
389 break;
390 }
391 case '\0': {
392 state = __PDONE;
393 break;
394 }
395 default: {
396 // invalid string
397 r = false;
398 state = __PDONE;
399 }
400 }
401
402 if (state == __PDONE) {
403 break;
404 }
405 else {
406 endptr++;
407 }
408 }
409
410 if (_endptr) {
411 *_endptr = endptr;
412 }
413 return r;
414}
r
IOException *size_t r
Definition MediaInfo.cpp:82
__DCL_ASSERT
#define __DCL_ASSERT(expr)
Definition Object.h:394
__DCL_TRACE4_N
#define __DCL_TRACE4_N(fmt, arg1, arg2, arg3, arg4)
Definition PqTypes.cpp:35
__PTDOT
#define __PTDOT
__P0
#define __P0
__PDONE
#define __PDONE
__PT
#define __PT
SQL::Interval::years
int32_t years
Definition SQLCore.h:126
SQL::Interval::days
int32_t days
Definition SQLCore.h:128
SQL::Interval::hours
int8_t hours
Definition SQLCore.h:129
SQL::Interval::mins
int8_t mins
Definition SQLCore.h:130
SQL::Interval::fracs
int32_t fracs
Definition SQLCore.h:132
SQL::Interval::months
int8_t months
Definition SQLCore.h:127
SQL::Interval::secs
int8_t secs
Definition SQLCore.h:131

◆ __decode_timestamp_iso()

bool __decode_timestamp_iso ( const char * _s,
const char ** _endptr,
SQL::TimeStamp & _r )

Definition at line 176 of file PqTypes.cpp.

180{
181 __DCL_ASSERT(_s);
182#ifndef __DCL_DEBUG
183 if (!_s) {
184 if (_endptr) {
185 *_endptr = _s;
186 }
187 return false;
188 }
189#endif
190
191#define __START 0
192#define __yyyy 1
193#define __MM 2
194#define __dd 3
195#define __HH 4
196#define __mm 5
197#define __ss 6
198#define __SSS 7
199#define __ZH 8
200#define __Zm 9
201#define __Zs 10
202#define __BC 11
203#define __DONE 12
204
205 int state = __START; // yyyy-MM-dd'T'HH:mm:ss.SSSZ
206 memset(&_r, 0, sizeof(_r));
207 _r.tzoff = INT16_MIN;
208
209 bool r = true;
210 char* endptr = (char*)_s;
211 for (; ; ) {
212 errno = 0;
213 const char* nptr = endptr;
214 long n = strtol(nptr, &endptr, 10);
215 if (errno == ERANGE) {
216 // invalid string
217 r = false;
218 break;
219 }
220 if (state == __START) {
221 if (*endptr == '-') {
222 state = __yyyy;
223 }
224 else if (*endptr == ':') {
225 state = __HH;
226 }
227 else {
228 // invalid string
229 r = false;
230 break;
231 }
232 }
233 else if (*endptr == 'B') {
234 state = __BC;
235 }
236 else {
237 // '\0' == *endptr || strchr("- T:.+", *endptr)
238 state++;
239 }
240
241 __DCL_TRACE4_N(L"state[%2d] n[%10d] [%p][%hc]\n",
242 state, n, endptr, *endptr ? *endptr : '$');
243 switch (state) {
244 case __yyyy:
245 _r.year = (int16_t)n;
246 break;
247 case __MM:
248 _r.month = (uint8_t)n;
249 break;
250 case __dd:
251 _r.day = (uint8_t)n;
252 break;
253 case __HH:
254 _r.hour = (uint8_t)n;
255 break;
256 case __mm:
257 _r.min = (uint8_t)n;
258 break;
259 case __ss:
260 _r.sec = (uint8_t)n;
261 break;
262 case __SSS:
263 _r.frac = __fraction_normalize(n);
264 break;
265 case __ZH:
266 _r.tzoff = (int16_t)(n * 60);
267 break;
268 case __Zm:
269 _r.tzoff += (int16_t)n;
270 break;
271 case __Zs:
272 // +08:27:52 BC PostgreSQL Bug!! ignore
273 break;
274 case __BC: {
275 __DCL_ASSERT(*(endptr + 1) == 'C');
276 _r.year *= -1;
277 state = __DONE;
278 break;
279 }
280 default: {
281 __DCL_ASSERT(false);
282 }
283 }
284
285 if (*endptr == '\0' || state == __DONE) {
286 break;
287 }
288 else {
289 __DCL_TRACE1_N(L"[%hs]\n", (*endptr ? endptr : "(nil)"));
290 if ((state == __ss || state == __SSS)
291 && (*endptr == '+' || *endptr == '-')
292 ) {
293 state = __SSS;
294 // 부호와 함께 strtol 후 __ZH 상태가 된다.
295 }
296 else {
297 endptr++;
298 }
299 }
300 }
301
302 if (_endptr) {
303 *_endptr = endptr;
304 }
305 return r;
306}
INT16_MIN
#define INT16_MIN
Definition Config.h:284
__SSS
#define __SSS
__DONE
#define __DONE
__yyyy
#define __yyyy
__Zm
#define __Zm
__MM
#define __MM
__BC
#define __BC
__dd
#define __dd
__DCL_TRACE1_N
#define __DCL_TRACE1_N(fmt, arg)
Definition PqTypes.cpp:32
__mm
#define __mm
__START
#define __START
__Zs
#define __Zs
__ZH
#define __ZH
__HH
#define __HH
__ss
#define __ss
SQL::TimeStamp::frac
uint32_t frac
Definition SQLCore.h:118
SQL::TimeStamp::tzoff
int16_t tzoff
Definition SQLCore.h:119
SQL::TimeStamp::min
uint8_t min
Definition SQLCore.h:116
SQL::TimeStamp::sec
uint8_t sec
Definition SQLCore.h:117
SQL::TimeStamp::hour
uint8_t hour
Definition SQLCore.h:115
SQL::TimeStamp::day
uint8_t day
Definition SQLCore.h:114
SQL::TimeStamp::year
int16_t year
Definition SQLCore.h:112
SQL::TimeStamp::month
uint8_t month
Definition SQLCore.h:113

◆ __unescape_hex()

bool __unescape_hex ( const char * _src,
const char *& _srcend,
char * _dst,
char *& _dstend )

Definition at line 59 of file PqTypes.cpp.

63{
64 __DCL_ASSERT(_src && _srcend && _dst && _dstend);
65#ifndef __DCL_DEBUG
66 if (!(_src && _srcend && _dst && _dstend)) {
67 return false;
68 }
69#endif
70
71 bool r = true;
72 if (__is_hex_escaped(_src)) {
73 _src++; _src++;
74 }
75
76 while (_src + 1 < _srcend && _dst < _dstend) {
77 char high, low;
78 high = __nibble__(*_src++);
79 if (high == (char)-1) {
80 // invalid char
81 r = false;
82 continue;
83 }
84 low = __nibble__(*_src++);
85 if (low == (char)-1) {
86 // invali char
87 r = false;
88 continue;
89 }
90 *_dst++ = (high << 4) | low;
91 }
92
93 _srcend = _src;
94 _dstend = _dst;
95 return r;
96}
__is_hex_escaped
bool __is_hex_escaped(const char *_src)
Definition PqTypes.h:111

◆ __unescape_oct()

bool __unescape_oct ( const char * _src,
const char *& _srcend,
char * _dst,
char *& _dstend )

Definition at line 108 of file PqTypes.cpp.

112{
113 __DCL_ASSERT(_src && _srcend && _dst && _dstend);
114#ifndef __DCL_DEBUG
115 if (!(_src && _srcend && _dst && _dstend)) {
116 return false;
117 }
118#endif
119 bool r = true;
120 while (_src < _srcend && _dst < _dstend) {
121 if (*_src == '\\') {
122 _src++;
123 if (_src < _srcend) {
124 if (*_src == '\\') {
125 *_dst++ = *_src;
126 continue;
127 }
128 if ((_src + 3) < _srcend) {
129 if (__is_first_oct_digit(*(_src))
130 && __is_oct_digit(*(_src + 1))
131 && __is_oct_digit(*(_src + 2))
132 ) {
133 unsigned char c = (*_src++ - '0');
134 c = (c << 3) | (*_src++ - '0');
135 c = (c << 3) | (*_src++ - '0');
136 *_dst++ = c;
137 }
138 else {
139 // invalid char
140 r = false;
141 continue;
142 }
143
144 }
145 }
146 else {
147 // invalid last char
148 r = false;
149 }
150 }
151 else {
152 *_dst++ = *_src++;
153 }
154 }
155
156 _srcend = _src;
157 _dstend = _dst;
158 return r;
159}