PostgreSQL Source Code  git master
data.c
Go to the documentation of this file.
1 /* src/interfaces/ecpg/ecpglib/data.c */
2 
3 #define POSTGRES_ECPG_INTERNAL
4 #include "postgres_fe.h"
5 
6 #include <math.h>
7 
8 #include "ecpgerrno.h"
9 #include "ecpglib.h"
10 #include "ecpglib_extern.h"
11 #include "ecpgtype.h"
12 #include "pgtypes_date.h"
13 #include "pgtypes_interval.h"
14 #include "pgtypes_numeric.h"
15 #include "pgtypes_timestamp.h"
16 #include "sqlca.h"
17 
18 /* returns true if character c is a delimiter for the given array type */
19 static bool
20 array_delimiter(enum ARRAY_TYPE isarray, char c)
21 {
22  if (isarray == ECPG_ARRAY_ARRAY && c == ',')
23  return true;
24 
25  if (isarray == ECPG_ARRAY_VECTOR && c == ' ')
26  return true;
27 
28  return false;
29 }
30 
31 /* returns true if character c marks the boundary for the given array type */
32 static bool
33 array_boundary(enum ARRAY_TYPE isarray, char c)
34 {
35  if (isarray == ECPG_ARRAY_ARRAY && c == '}')
36  return true;
37 
38  if (isarray == ECPG_ARRAY_VECTOR && c == '\0')
39  return true;
40 
41  return false;
42 }
43 
44 /* returns true if some garbage is found at the end of the scanned string */
45 static bool
46 garbage_left(enum ARRAY_TYPE isarray, char **scan_length, enum COMPAT_MODE compat)
47 {
48  /*
49  * INFORMIX allows for selecting a numeric into an int, the result is
50  * truncated
51  */
52  if (isarray == ECPG_ARRAY_NONE)
53  {
54  if (INFORMIX_MODE(compat) && **scan_length == '.')
55  {
56  /* skip invalid characters */
57  do
58  {
59  (*scan_length)++;
60  } while (isdigit((unsigned char) **scan_length));
61  }
62 
63  if (**scan_length != ' ' && **scan_length != '\0')
64  return true;
65  }
66  else if (ECPG_IS_ARRAY(isarray) && !array_delimiter(isarray, **scan_length) && !array_boundary(isarray, **scan_length))
67  return true;
68 
69  return false;
70 }
71 
72 /* stolen code from src/backend/utils/adt/float.c */
73 #if defined(WIN32) && !defined(NAN)
74 static const uint32 nan[2] = {0xffffffff, 0x7fffffff};
75 
76 #define NAN (*(const double *) nan)
77 #endif
78 
79 static double
80 get_float8_infinity(void)
81 {
82 #ifdef INFINITY
83  return (double) INFINITY;
84 #else
85  return (double) (HUGE_VAL * HUGE_VAL);
86 #endif
87 }
88 
89 static double
90 get_float8_nan(void)
91 {
92  /* (double) NAN doesn't work on some NetBSD/MIPS releases */
93 #if defined(NAN) && !(defined(__NetBSD__) && defined(__mips__))
94  return (double) NAN;
95 #else
96  return (double) (0.0 / 0.0);
97 #endif
98 }
99 
100 static bool
101 check_special_value(char *ptr, double *retval, char **endptr)
102 {
103  if (pg_strncasecmp(ptr, "NaN", 3) == 0)
104  {
105  *retval = get_float8_nan();
106  *endptr = ptr + 3;
107  return true;
108  }
109  else if (pg_strncasecmp(ptr, "Infinity", 8) == 0)
110  {
111  *retval = get_float8_infinity();
112  *endptr = ptr + 8;
113  return true;
114  }
115  else if (pg_strncasecmp(ptr, "-Infinity", 9) == 0)
116  {
117  *retval = -get_float8_infinity();
118  *endptr = ptr + 9;
119  return true;
120  }
121 
122  return false;
123 }
124 
125 /* imported from src/backend/utils/adt/encode.c */
126 
127 unsigned
128 ecpg_hex_enc_len(unsigned srclen)
129 {
130  return srclen << 1;
131 }
132 
133 unsigned
134 ecpg_hex_dec_len(unsigned srclen)
135 {
136  return srclen >> 1;
137 }
138 
139 static inline char
140 get_hex(char c)
141 {
142  static const int8 hexlookup[128] = {
143  -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
144  -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
145  -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
146  0, 1, 2, 3, 4, 5, 6, 7, 8, 9, -1, -1, -1, -1, -1, -1,
147  -1, 10, 11, 12, 13, 14, 15, -1, -1, -1, -1, -1, -1, -1, -1, -1,
148  -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
149  -1, 10, 11, 12, 13, 14, 15, -1, -1, -1, -1, -1, -1, -1, -1, -1,
150  -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
151  };
152  int res = -1;
153 
154  if (c > 0 && c < 127)
155  res = hexlookup[(unsigned char) c];
156 
157  return (char) res;
158 }
159 
160 static unsigned
161 hex_decode(const char *src, unsigned len, char *dst)
162 {
163  const char *s,
164  *srcend;
165  char v1,
166  v2,
167  *p;
168 
169  srcend = src + len;
170  s = src;
171  p = dst;
172  while (s < srcend)
173  {
174  if (*s == ' ' || *s == '\n' || *s == '\t' || *s == '\r')
175  {
176  s++;
177  continue;
178  }
179  v1 = get_hex(*s++) << 4;
180  if (s >= srcend)
181  return -1;
182 
183  v2 = get_hex(*s++);
184  *p++ = v1 | v2;
185  }
186 
187  return p - dst;
188 }
189 
190 unsigned
191 ecpg_hex_encode(const char *src, unsigned len, char *dst)
192 {
193  static const char hextbl[] = "0123456789abcdef";
194  const char *end = src + len;
195 
196  while (src < end)
197  {
198  *dst++ = hextbl[(*src >> 4) & 0xF];
199  *dst++ = hextbl[*src & 0xF];
200  src++;
201  }
202  return len * 2;
203 }
204 
205 bool
206 ecpg_get_data(const PGresult *results, int act_tuple, int act_field, int lineno,
207  enum ECPGttype type, enum ECPGttype ind_type,
208  char *var, char *ind, long varcharsize, long offset,
209  long ind_offset, enum ARRAY_TYPE isarray, enum COMPAT_MODE compat, bool force_indicator)
210 {
211  struct sqlca_t *sqlca = ECPGget_sqlca();
212  char *pval = (char *) PQgetvalue(results, act_tuple, act_field);
213  int binary = PQfformat(results, act_field);
214  int size = PQgetlength(results, act_tuple, act_field);
215  int value_for_indicator = 0;
216  long log_offset;
217 
218  if (sqlca == NULL)
219  {
220  ecpg_raise(lineno, ECPG_OUT_OF_MEMORY,
221  ECPG_SQLSTATE_ECPG_OUT_OF_MEMORY, NULL);
222  return false;
223  }
224 
225  /*
226  * If we are running in a regression test, do not log the offset variable,
227  * it depends on the machine's alignment.
228  */
229  if (ecpg_internal_regression_mode)
230  log_offset = -1;
231  else
232  log_offset = offset;
233 
234  ecpg_log("ecpg_get_data on line %d: RESULT: %s offset: %ld; array: %s\n", lineno, pval ? (binary ? "BINARY" : pval) : "EMPTY", log_offset, ECPG_IS_ARRAY(isarray) ? "yes" : "no");
235 
236  /* pval is a pointer to the value */
237  if (!pval)
238  {
239  /*
240  * This should never happen because we already checked that we found
241  * at least one tuple, but let's play it safe.
242  */
243  ecpg_raise(lineno, ECPG_NOT_FOUND, ECPG_SQLSTATE_NO_DATA, NULL);
244  return false;
245  }
246 
247  /* We will have to decode the value */
248 
249  /*
250  * check for null value and set indicator accordingly, i.e. -1 if NULL and
251  * 0 if not
252  */
253  if (PQgetisnull(results, act_tuple, act_field))
254  value_for_indicator = -1;
255 
256  switch (ind_type)
257  {
258  case ECPGt_short:
259  case ECPGt_unsigned_short:
260  *((short *) (ind + ind_offset * act_tuple)) = value_for_indicator;
261  break;
262  case ECPGt_int:
263  case ECPGt_unsigned_int:
264  *((int *) (ind + ind_offset * act_tuple)) = value_for_indicator;
265  break;
266  case ECPGt_long:
267  case ECPGt_unsigned_long:
268  *((long *) (ind + ind_offset * act_tuple)) = value_for_indicator;
269  break;
270  case ECPGt_long_long:
271  case ECPGt_unsigned_long_long:
272  *((long long int *) (ind + ind_offset * act_tuple)) = value_for_indicator;
273  break;
274  case ECPGt_NO_INDICATOR:
275  if (value_for_indicator == -1)
276  {
277  if (force_indicator == false)
278  {
279  /*
280  * Informix has an additional way to specify NULLs note
281  * that this uses special values to denote NULL
282  */
283  ECPGset_noind_null(type, var + offset * act_tuple);
284  }
285  else
286  {
287  ecpg_raise(lineno, ECPG_MISSING_INDICATOR,
288  ECPG_SQLSTATE_NULL_VALUE_NO_INDICATOR_PARAMETER,
289  NULL);
290  return false;
291  }
292  }
293  break;
294  default:
295  ecpg_raise(lineno, ECPG_UNSUPPORTED,
296  ECPG_SQLSTATE_ECPG_INTERNAL_ERROR,
297  ecpg_type_name(ind_type));
298  return false;
299  break;
300  }
301 
302  if (value_for_indicator == -1)
303  return true;
304 
305  /* let's check if it really is an array if it should be one */
306  if (isarray == ECPG_ARRAY_ARRAY)
307  {
308  if (*pval != '{')
309  {
310  ecpg_raise(lineno, ECPG_DATA_NOT_ARRAY,
311  ECPG_SQLSTATE_DATATYPE_MISMATCH, NULL);
312  return false;
313  }
314 
315  switch (type)
316  {
317  case ECPGt_char:
318  case ECPGt_unsigned_char:
319  case ECPGt_varchar:
320  case ECPGt_string:
321  break;
322 
323  default:
324  pval++;
325  break;
326  }
327  }
328 
329  do
330  {
331  if (binary)
332  {
333  if (varcharsize == 0 || varcharsize * offset >= size)
334  memcpy(var + offset * act_tuple, pval, size);
335  else
336  {
337  memcpy(var + offset * act_tuple, pval, varcharsize * offset);
338 
339  if (varcharsize * offset < size)
340  {
341  /* truncation */
342  switch (ind_type)
343  {
344  case ECPGt_short:
345  case ECPGt_unsigned_short:
346  *((short *) (ind + ind_offset * act_tuple)) = size;
347  break;
348  case ECPGt_int:
349  case ECPGt_unsigned_int:
350  *((int *) (ind + ind_offset * act_tuple)) = size;
351  break;
352  case ECPGt_long:
353  case ECPGt_unsigned_long:
354  *((long *) (ind + ind_offset * act_tuple)) = size;
355  break;
356  case ECPGt_long_long:
357  case ECPGt_unsigned_long_long:
358  *((long long int *) (ind + ind_offset * act_tuple)) = size;
359  break;
360  default:
361  break;
362  }
363  sqlca->sqlwarn[0] = sqlca->sqlwarn[1] = 'W';
364  }
365  }
366  pval += size;
367  }
368  else
369  {
370  switch (type)
371  {
372  long res;
373  unsigned long ures;
374  double dres;
375  char *scan_length;
376  numeric *nres;
377  date ddres;
378  timestamp tres;
379  interval *ires;
380  char *endptr,
381  endchar;
382 
383  case ECPGt_short:
384  case ECPGt_int:
385  case ECPGt_long:
386  res = strtol(pval, &scan_length, 10);
387  if (garbage_left(isarray, &scan_length, compat))
388  {
389  ecpg_raise(lineno, ECPG_INT_FORMAT,
390  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
391  return false;
392  }
393  pval = scan_length;
394 
395  switch (type)
396  {
397  case ECPGt_short:
398  *((short *) (var + offset * act_tuple)) = (short) res;
399  break;
400  case ECPGt_int:
401  *((int *) (var + offset * act_tuple)) = (int) res;
402  break;
403  case ECPGt_long:
404  *((long *) (var + offset * act_tuple)) = (long) res;
405  break;
406  default:
407  /* Cannot happen */
408  break;
409  }
410  break;
411 
412  case ECPGt_unsigned_short:
413  case ECPGt_unsigned_int:
414  case ECPGt_unsigned_long:
415  ures = strtoul(pval, &scan_length, 10);
416  if (garbage_left(isarray, &scan_length, compat))
417  {
418  ecpg_raise(lineno, ECPG_UINT_FORMAT,
419  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
420  return false;
421  }
422  pval = scan_length;
423 
424  switch (type)
425  {
426  case ECPGt_unsigned_short:
427  *((unsigned short *) (var + offset * act_tuple)) = (unsigned short) ures;
428  break;
429  case ECPGt_unsigned_int:
430  *((unsigned int *) (var + offset * act_tuple)) = (unsigned int) ures;
431  break;
432  case ECPGt_unsigned_long:
433  *((unsigned long *) (var + offset * act_tuple)) = (unsigned long) ures;
434  break;
435  default:
436  /* Cannot happen */
437  break;
438  }
439  break;
440 
441 #ifdef HAVE_STRTOLL
442  case ECPGt_long_long:
443  *((long long int *) (var + offset * act_tuple)) = strtoll(pval, &scan_length, 10);
444  if (garbage_left(isarray, &scan_length, compat))
445  {
446  ecpg_raise(lineno, ECPG_INT_FORMAT, ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
447  return false;
448  }
449  pval = scan_length;
450 
451  break;
452 #endif /* HAVE_STRTOLL */
453 #ifdef HAVE_STRTOULL
454  case ECPGt_unsigned_long_long:
455  *((unsigned long long int *) (var + offset * act_tuple)) = strtoull(pval, &scan_length, 10);
456  if (garbage_left(isarray, &scan_length, compat))
457  {
458  ecpg_raise(lineno, ECPG_UINT_FORMAT, ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
459  return false;
460  }
461  pval = scan_length;
462 
463  break;
464 #endif /* HAVE_STRTOULL */
465 
466  case ECPGt_float:
467  case ECPGt_double:
468  if (isarray && *pval == '"')
469  pval++;
470 
471  if (!check_special_value(pval, &dres, &scan_length))
472  dres = strtod(pval, &scan_length);
473 
474  if (isarray && *scan_length == '"')
475  scan_length++;
476 
477  /* no special INFORMIX treatment for floats */
478  if (garbage_left(isarray, &scan_length, ECPG_COMPAT_PGSQL))
479  {
480  ecpg_raise(lineno, ECPG_FLOAT_FORMAT,
481  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
482  return false;
483  }
484  pval = scan_length;
485 
486  switch (type)
487  {
488  case ECPGt_float:
489  *((float *) (var + offset * act_tuple)) = dres;
490  break;
491  case ECPGt_double:
492  *((double *) (var + offset * act_tuple)) = dres;
493  break;
494  default:
495  /* Cannot happen */
496  break;
497  }
498  break;
499 
500  case ECPGt_bool:
501  if (pval[0] == 'f' && pval[1] == '\0')
502  {
503  *((bool *) (var + offset * act_tuple)) = false;
504  pval++;
505  break;
506  }
507  else if (pval[0] == 't' && pval[1] == '\0')
508  {
509  *((bool *) (var + offset * act_tuple)) = true;
510  pval++;
511  break;
512  }
513  else if (pval[0] == '\0' && PQgetisnull(results, act_tuple, act_field))
514  {
515  /* NULL is valid */
516  break;
517  }
518 
519  ecpg_raise(lineno, ECPG_CONVERT_BOOL,
520  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
521  return false;
522  break;
523 
524  case ECPGt_bytea:
525  {
526  struct ECPGgeneric_bytea *variable =
527  (struct ECPGgeneric_bytea *) (var + offset * act_tuple);
528  long dst_size,
529  src_size,
530  dec_size;
531 
532  dst_size = ecpg_hex_enc_len(varcharsize);
533  src_size = size - 2; /* exclude backslash + 'x' */
534  dec_size = src_size < dst_size ? src_size : dst_size;
535  variable->len = hex_decode(pval + 2, dec_size, variable->arr);
536 
537  if (dst_size < src_size)
538  {
539  long rcv_size = ecpg_hex_dec_len(size - 2);
540 
541  /* truncation */
542  switch (ind_type)
543  {
544  case ECPGt_short:
545  case ECPGt_unsigned_short:
546  *((short *) (ind + ind_offset * act_tuple)) = rcv_size;
547  break;
548  case ECPGt_int:
549  case ECPGt_unsigned_int:
550  *((int *) (ind + ind_offset * act_tuple)) = rcv_size;
551  break;
552  case ECPGt_long:
553  case ECPGt_unsigned_long:
554  *((long *) (ind + ind_offset * act_tuple)) = rcv_size;
555  break;
556  case ECPGt_long_long:
557  case ECPGt_unsigned_long_long:
558  *((long long int *) (ind + ind_offset * act_tuple)) = rcv_size;
559  break;
560  default:
561  break;
562  }
563  sqlca->sqlwarn[0] = sqlca->sqlwarn[1] = 'W';
564  }
565 
566  pval += size;
567  }
568  break;
569 
570  case ECPGt_char:
571  case ECPGt_unsigned_char:
572  case ECPGt_string:
573  {
574  char *str = (char *) (var + offset * act_tuple);
575 
576  /*
577  * If varcharsize is unknown and the offset is that of
578  * char *, then this variable represents the array of
579  * character pointers. So, use extra indirection.
580  */
581  if (varcharsize == 0 && offset == sizeof(char *))
582  str = *(char **) str;
583 
584  if (varcharsize == 0 || varcharsize > size)
585  {
586  /*
587  * compatibility mode, blank pad and null
588  * terminate char array
589  */
590  if (ORACLE_MODE(compat) && (type == ECPGt_char || type == ECPGt_unsigned_char))
591  {
592  memset(str, ' ', varcharsize);
593  memcpy(str, pval, size);
594  str[varcharsize - 1] = '\0';
595 
596  /*
597  * compatibility mode empty string gets -1
598  * indicator but no warning
599  */
600  if (size == 0)
601  {
602  /* truncation */
603  switch (ind_type)
604  {
605  case ECPGt_short:
606  case ECPGt_unsigned_short:
607  *((short *) (ind + ind_offset * act_tuple)) = -1;
608  break;
609  case ECPGt_int:
610  case ECPGt_unsigned_int:
611  *((int *) (ind + ind_offset * act_tuple)) = -1;
612  break;
613  case ECPGt_long:
614  case ECPGt_unsigned_long:
615  *((long *) (ind + ind_offset * act_tuple)) = -1;
616  break;
617  case ECPGt_long_long:
618  case ECPGt_unsigned_long_long:
619  *((long long int *) (ind + ind_offset * act_tuple)) = -1;
620  break;
621  default:
622  break;
623  }
624  }
625  }
626  else
627  {
628  strncpy(str, pval, size + 1);
629  }
630  /* do the rtrim() */
631  if (type == ECPGt_string)
632  {
633  char *last = str + size;
634 
635  while (last > str && (*last == ' ' || *last == '\0'))
636  {
637  *last = '\0';
638  last--;
639  }
640  }
641  }
642  else
643  {
644  strncpy(str, pval, varcharsize);
645 
646  /* compatibility mode, null terminate char array */
647  if (ORACLE_MODE(compat) && (varcharsize - 1) < size)
648  {
649  if (type == ECPGt_char || type == ECPGt_unsigned_char)
650  str[varcharsize - 1] = '\0';
651  }
652 
653  if (varcharsize < size || (ORACLE_MODE(compat) && (varcharsize - 1) < size))
654  {
655  /* truncation */
656  switch (ind_type)
657  {
658  case ECPGt_short:
659  case ECPGt_unsigned_short:
660  *((short *) (ind + ind_offset * act_tuple)) = size;
661  break;
662  case ECPGt_int:
663  case ECPGt_unsigned_int:
664  *((int *) (ind + ind_offset * act_tuple)) = size;
665  break;
666  case ECPGt_long:
667  case ECPGt_unsigned_long:
668  *((long *) (ind + ind_offset * act_tuple)) = size;
669  break;
670  case ECPGt_long_long:
671  case ECPGt_unsigned_long_long:
672  *((long long int *) (ind + ind_offset * act_tuple)) = size;
673  break;
674  default:
675  break;
676  }
677  sqlca->sqlwarn[0] = sqlca->sqlwarn[1] = 'W';
678  }
679  }
680  pval += size;
681  }
682  break;
683 
684  case ECPGt_varchar:
685  {
686  struct ECPGgeneric_varchar *variable =
687  (struct ECPGgeneric_varchar *) (var + offset * act_tuple);
688 
689  variable->len = size;
690  if (varcharsize == 0)
691  strncpy(variable->arr, pval, variable->len);
692  else
693  {
694  strncpy(variable->arr, pval, varcharsize);
695 
696  if (variable->len > varcharsize)
697  {
698  /* truncation */
699  switch (ind_type)
700  {
701  case ECPGt_short:
702  case ECPGt_unsigned_short:
703  *((short *) (ind + ind_offset * act_tuple)) = variable->len;
704  break;
705  case ECPGt_int:
706  case ECPGt_unsigned_int:
707  *((int *) (ind + ind_offset * act_tuple)) = variable->len;
708  break;
709  case ECPGt_long:
710  case ECPGt_unsigned_long:
711  *((long *) (ind + ind_offset * act_tuple)) = variable->len;
712  break;
713  case ECPGt_long_long:
714  case ECPGt_unsigned_long_long:
715  *((long long int *) (ind + ind_offset * act_tuple)) = variable->len;
716  break;
717  default:
718  break;
719  }
720  sqlca->sqlwarn[0] = sqlca->sqlwarn[1] = 'W';
721 
722  variable->len = varcharsize;
723  }
724  }
725  pval += size;
726  }
727  break;
728 
729  case ECPGt_decimal:
730  case ECPGt_numeric:
731  for (endptr = pval; *endptr && *endptr != ',' && *endptr != '}'; endptr++);
732  endchar = *endptr;
733  *endptr = '\0';
734  nres = PGTYPESnumeric_from_asc(pval, &scan_length);
735  *endptr = endchar;
736 
737  /* did we get an error? */
738  if (nres == NULL)
739  {
740  ecpg_log("ecpg_get_data on line %d: RESULT %s; errno %d\n",
741  lineno, pval, errno);
742 
743  if (INFORMIX_MODE(compat))
744  {
745  /*
746  * Informix wants its own NULL value here instead
747  * of an error
748  */
749  nres = PGTYPESnumeric_new();
750  if (nres)
751  ECPGset_noind_null(ECPGt_numeric, nres);
752  else
753  {
754  ecpg_raise(lineno, ECPG_OUT_OF_MEMORY,
755  ECPG_SQLSTATE_ECPG_OUT_OF_MEMORY, NULL);
756  return false;
757  }
758  }
759  else
760  {
761  ecpg_raise(lineno, ECPG_NUMERIC_FORMAT,
762  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
763  return false;
764  }
765  }
766  else
767  {
768  if (!isarray && garbage_left(isarray, &scan_length, compat))
769  {
770  free(nres);
771  ecpg_raise(lineno, ECPG_NUMERIC_FORMAT,
772  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
773  return false;
774  }
775  }
776  pval = scan_length;
777 
778  if (type == ECPGt_numeric)
779  PGTYPESnumeric_copy(nres, (numeric *) (var + offset * act_tuple));
780  else
781  PGTYPESnumeric_to_decimal(nres, (decimal *) (var + offset * act_tuple));
782 
783  PGTYPESnumeric_free(nres);
784  break;
785 
786  case ECPGt_interval:
787  if (*pval == '"')
788  pval++;
789 
790  for (endptr = pval; *endptr && *endptr != ',' && *endptr != '"' && *endptr != '}'; endptr++);
791  endchar = *endptr;
792  *endptr = '\0';
793  ires = PGTYPESinterval_from_asc(pval, &scan_length);
794  *endptr = endchar;
795 
796  /* did we get an error? */
797  if (ires == NULL)
798  {
799  ecpg_log("ecpg_get_data on line %d: RESULT %s; errno %d\n",
800  lineno, pval, errno);
801 
802  if (INFORMIX_MODE(compat))
803  {
804  /*
805  * Informix wants its own NULL value here instead
806  * of an error
807  */
808  ires = (interval *) ecpg_alloc(sizeof(interval), lineno);
809  if (!ires)
810  return false;
811 
812  ECPGset_noind_null(ECPGt_interval, ires);
813  }
814  else
815  {
816  ecpg_raise(lineno, ECPG_INTERVAL_FORMAT,
817  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
818  return false;
819  }
820  }
821  else
822  {
823  if (*scan_length == '"')
824  scan_length++;
825 
826  if (!isarray && garbage_left(isarray, &scan_length, compat))
827  {
828  free(ires);
829  ecpg_raise(lineno, ECPG_INTERVAL_FORMAT,
830  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
831  return false;
832  }
833  }
834  pval = scan_length;
835 
836  PGTYPESinterval_copy(ires, (interval *) (var + offset * act_tuple));
837  free(ires);
838  break;
839 
840  case ECPGt_date:
841  if (*pval == '"')
842  pval++;
843 
844  for (endptr = pval; *endptr && *endptr != ',' && *endptr != '"' && *endptr != '}'; endptr++);
845  endchar = *endptr;
846  *endptr = '\0';
847  ddres = PGTYPESdate_from_asc(pval, &scan_length);
848  *endptr = endchar;
849 
850  /* did we get an error? */
851  if (errno != 0)
852  {
853  ecpg_log("ecpg_get_data on line %d: RESULT %s; errno %d\n",
854  lineno, pval, errno);
855 
856  if (INFORMIX_MODE(compat))
857  {
858  /*
859  * Informix wants its own NULL value here instead
860  * of an error
861  */
862  ECPGset_noind_null(ECPGt_date, &ddres);
863  }
864  else
865  {
866  ecpg_raise(lineno, ECPG_DATE_FORMAT,
867  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
868  return false;
869  }
870  }
871  else
872  {
873  if (*scan_length == '"')
874  scan_length++;
875 
876  if (!isarray && garbage_left(isarray, &scan_length, compat))
877  {
878  ecpg_raise(lineno, ECPG_DATE_FORMAT,
879  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
880  return false;
881  }
882  }
883 
884  *((date *) (var + offset * act_tuple)) = ddres;
885  pval = scan_length;
886  break;
887 
888  case ECPGt_timestamp:
889  if (*pval == '"')
890  pval++;
891 
892  for (endptr = pval; *endptr && *endptr != ',' && *endptr != '"' && *endptr != '}'; endptr++);
893  endchar = *endptr;
894  *endptr = '\0';
895  tres = PGTYPEStimestamp_from_asc(pval, &scan_length);
896  *endptr = endchar;
897 
898  /* did we get an error? */
899  if (errno != 0)
900  {
901  ecpg_log("ecpg_get_data on line %d: RESULT %s; errno %d\n",
902  lineno, pval, errno);
903 
904  if (INFORMIX_MODE(compat))
905  {
906  /*
907  * Informix wants its own NULL value here instead
908  * of an error
909  */
910  ECPGset_noind_null(ECPGt_timestamp, &tres);
911  }
912  else
913  {
914  ecpg_raise(lineno, ECPG_TIMESTAMP_FORMAT,
915  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
916  return false;
917  }
918  }
919  else
920  {
921  if (*scan_length == '"')
922  scan_length++;
923 
924  if (!isarray && garbage_left(isarray, &scan_length, compat))
925  {
926  ecpg_raise(lineno, ECPG_TIMESTAMP_FORMAT,
927  ECPG_SQLSTATE_DATATYPE_MISMATCH, pval);
928  return false;
929  }
930  }
931 
932  *((timestamp *) (var + offset * act_tuple)) = tres;
933  pval = scan_length;
934  break;
935 
936  default:
937  ecpg_raise(lineno, ECPG_UNSUPPORTED,
938  ECPG_SQLSTATE_ECPG_INTERNAL_ERROR,
939  ecpg_type_name(type));
940  return false;
941  break;
942  }
943  if (ECPG_IS_ARRAY(isarray))
944  {
945  bool string = false;
946 
947  /* set array to next entry */
948  ++act_tuple;
949 
950  /* set pval to the next entry */
951 
952  /*
953  * *pval != '\0' should not be needed, but is used as a safety
954  * guard
955  */
956  for (; *pval != '\0' && (string || (!array_delimiter(isarray, *pval) && !array_boundary(isarray, *pval))); ++pval)
957  if (*pval == '"')
958  string = string ? false : true;
959 
960  if (array_delimiter(isarray, *pval))
961  ++pval;
962  }
963  }
964  } while (*pval != '\0' && !array_boundary(isarray, *pval));
965 
966  return true;
967 }
uint32
unsigned int uint32
Definition: c.h:452
int8
signed char int8
Definition: c.h:438
ecpg_hex_enc_len
unsigned ecpg_hex_enc_len(unsigned srclen)
Definition: data.c:128
get_hex
static char get_hex(char c)
Definition: data.c:140
garbage_left
static bool garbage_left(enum ARRAY_TYPE isarray, char **scan_length, enum COMPAT_MODE compat)
Definition: data.c:46
ecpg_hex_dec_len
unsigned ecpg_hex_dec_len(unsigned srclen)
Definition: data.c:134
ecpg_get_data
bool ecpg_get_data(const PGresult *results, int act_tuple, int act_field, int lineno, enum ECPGttype type, enum ECPGttype ind_type, char *var, char *ind, long varcharsize, long offset, long ind_offset, enum ARRAY_TYPE isarray, enum COMPAT_MODE compat, bool force_indicator)
Definition: data.c:206
get_float8_nan
static double get_float8_nan(void)
Definition: data.c:90
hex_decode
static unsigned hex_decode(const char *src, unsigned len, char *dst)
Definition: data.c:161
ecpg_hex_encode
unsigned ecpg_hex_encode(const char *src, unsigned len, char *dst)
Definition: data.c:191
array_delimiter
static bool array_delimiter(enum ARRAY_TYPE isarray, char c)
Definition: data.c:20
get_float8_infinity
static double get_float8_infinity(void)
Definition: data.c:80
array_boundary
static bool array_boundary(enum ARRAY_TYPE isarray, char c)
Definition: data.c:33
check_special_value
static bool check_special_value(char *ptr, double *retval, char **endptr)
Definition: data.c:101
compat
enum COMPAT_MODE compat
Definition: ecpg.c:25
force_indicator
bool force_indicator
Definition: ecpg.c:18
ECPG_CONVERT_BOOL
#define ECPG_CONVERT_BOOL
Definition: ecpgerrno.h:29
ECPG_UNSUPPORTED
#define ECPG_UNSUPPORTED
Definition: ecpgerrno.h:18
ECPG_FLOAT_FORMAT
#define ECPG_FLOAT_FORMAT
Definition: ecpgerrno.h:24
ECPG_INT_FORMAT
#define ECPG_INT_FORMAT
Definition: ecpgerrno.h:22
ECPG_MISSING_INDICATOR
#define ECPG_MISSING_INDICATOR
Definition: ecpgerrno.h:31
ECPG_INTERVAL_FORMAT
#define ECPG_INTERVAL_FORMAT
Definition: ecpgerrno.h:26
ECPG_UINT_FORMAT
#define ECPG_UINT_FORMAT
Definition: ecpgerrno.h:23
ECPG_OUT_OF_MEMORY
#define ECPG_OUT_OF_MEMORY
Definition: ecpgerrno.h:15
ECPG_NOT_FOUND
#define ECPG_NOT_FOUND
Definition: ecpgerrno.h:10
ECPG_DATA_NOT_ARRAY
#define ECPG_DATA_NOT_ARRAY
Definition: ecpgerrno.h:33
ECPG_NUMERIC_FORMAT
#define ECPG_NUMERIC_FORMAT
Definition: ecpgerrno.h:25
ECPG_DATE_FORMAT
#define ECPG_DATE_FORMAT
Definition: ecpgerrno.h:27
ECPG_TIMESTAMP_FORMAT
#define ECPG_TIMESTAMP_FORMAT
Definition: ecpgerrno.h:28
ecpglib_extern.h
ecpg_alloc
char * ecpg_alloc(long, int)
Definition: memory.c:19
ECPG_SQLSTATE_NO_DATA
#define ECPG_SQLSTATE_NO_DATA
Definition: ecpglib_extern.h:234
ECPG_SQLSTATE_ECPG_OUT_OF_MEMORY
#define ECPG_SQLSTATE_ECPG_OUT_OF_MEMORY
Definition: ecpglib_extern.h:255
COMPAT_MODE
COMPAT_MODE
Definition: ecpglib_extern.h:21
ECPG_COMPAT_PGSQL
@ ECPG_COMPAT_PGSQL
Definition: ecpglib_extern.h:22
ECPG_SQLSTATE_ECPG_INTERNAL_ERROR
#define ECPG_SQLSTATE_ECPG_INTERNAL_ERROR
Definition: ecpglib_extern.h:254
ECPG_SQLSTATE_NULL_VALUE_NO_INDICATOR_PARAMETER
#define ECPG_SQLSTATE_NULL_VALUE_NO_INDICATOR_PARAMETER
Definition: ecpglib_extern.h:243
ecpg_log
void ecpg_log(const char *format,...) pg_attribute_printf(1
ORACLE_MODE
#define ORACLE_MODE(X)
Definition: ecpglib_extern.h:28
ecpg_type_name
const char * ecpg_type_name(enum ECPGttype)
Definition: typename.c:17
INFORMIX_MODE
#define INFORMIX_MODE(X)
Definition: ecpglib_extern.h:27
ECPG_SQLSTATE_DATATYPE_MISMATCH
#define ECPG_SQLSTATE_DATATYPE_MISMATCH
Definition: ecpglib_extern.h:250
ECPG_IS_ARRAY
#define ECPG_IS_ARRAY(X)
Definition: ecpglib_extern.h:35
ecpg_raise
void ecpg_raise(int line, int code, const char *sqlstate, const char *str)
Definition: error.c:13
ecpg_internal_regression_mode
bool ecpg_internal_regression_mode
Definition: misc.c:29
ARRAY_TYPE
ARRAY_TYPE
Definition: ecpglib_extern.h:31
ECPG_ARRAY_ARRAY
@ ECPG_ARRAY_ARRAY
Definition: ecpglib_extern.h:32
ECPG_ARRAY_VECTOR
@ ECPG_ARRAY_VECTOR
Definition: ecpglib_extern.h:32
ECPG_ARRAY_NONE
@ ECPG_ARRAY_NONE
Definition: ecpglib_extern.h:32
ECPGttype
ECPGttype
Definition: ecpgtype.h:42
ECPGt_float
@ ECPGt_float
Definition: ecpgtype.h:47
ECPGt_long_long
@ ECPGt_long_long
Definition: ecpgtype.h:45
ECPGt_short
@ ECPGt_short
Definition: ecpgtype.h:43
ECPGt_decimal
@ ECPGt_decimal
Definition: ecpgtype.h:51
ECPGt_bytea
@ ECPGt_bytea
Definition: ecpgtype.h:67
ECPGt_numeric
@ ECPGt_numeric
Definition: ecpgtype.h:49
ECPGt_varchar
@ ECPGt_varchar
Definition: ecpgtype.h:48
ECPGt_timestamp
@ ECPGt_timestamp
Definition: ecpgtype.h:54
ECPGt_unsigned_short
@ ECPGt_unsigned_short
Definition: ecpgtype.h:43
ECPGt_int
@ ECPGt_int
Definition: ecpgtype.h:44
ECPGt_long
@ ECPGt_long
Definition: ecpgtype.h:44
ECPGt_unsigned_char
@ ECPGt_unsigned_char
Definition: ecpgtype.h:43
ECPGt_double
@ ECPGt_double
Definition: ecpgtype.h:47
ECPGt_NO_INDICATOR
@ ECPGt_NO_INDICATOR
Definition: ecpgtype.h:64
ECPGt_date
@ ECPGt_date
Definition: ecpgtype.h:53
ECPGt_interval
@ ECPGt_interval
Definition: ecpgtype.h:55
ECPGt_unsigned_long
@ ECPGt_unsigned_long
Definition: ecpgtype.h:44
ECPGt_bool
@ ECPGt_bool
Definition: ecpgtype.h:46
ECPGt_unsigned_long_long
@ ECPGt_unsigned_long_long
Definition: ecpgtype.h:45
ECPGt_unsigned_int
@ ECPGt_unsigned_int
Definition: ecpgtype.h:44
ECPGt_char
@ ECPGt_char
Definition: ecpgtype.h:43
ECPGt_string
@ ECPGt_string
Definition: ecpgtype.h:65
hexlookup
static const int8 hexlookup[128]
Definition: encode.c:149
PQgetlength
int PQgetlength(const PGresult *res, int tup_num, int field_num)
Definition: fe-exec.c:3821
PQfformat
int PQfformat(const PGresult *res, int field_num)
Definition: fe-exec.c:3642
PQgetvalue
char * PQgetvalue(const PGresult *res, int tup_num, int field_num)
Definition: fe-exec.c:3810
PQgetisnull
int PQgetisnull(const PGresult *res, int tup_num, int field_num)
Definition: fe-exec.c:3835
free
#define free(a)
Definition: header.h:65
ECPGset_noind_null
void ECPGset_noind_null(enum ECPGttype type, void *ptr)
Definition: misc.c:318
ECPGget_sqlca
struct sqlca_t * ECPGget_sqlca(void)
Definition: misc.c:141
false
return false
Definition: isn.c:131
generate_unaccent_rules.type
type
Definition: generate_unaccent_rules.py:276
generate_unaccent_rules.str
str
Definition: generate_unaccent_rules.py:276
len
const void size_t len
Definition: pg_crc32c_sse42.c:24
hextbl
static const char hextbl[]
Definition: pgp-info.c:87
pgtypes_date.h
PGTYPESdate_from_asc
date PGTYPESdate_from_asc(char *, char **)
Definition: datetime.c:47
date
long date
Definition: pgtypes_date.h:9
pgtypes_interval.h
PGTYPESinterval_from_asc
interval * PGTYPESinterval_from_asc(char *, char **)
Definition: interval.c:1003
PGTYPESinterval_copy
int PGTYPESinterval_copy(interval *, interval *)
Definition: interval.c:1082
pgtypes_numeric.h
PGTYPESnumeric_copy
int PGTYPESnumeric_copy(numeric *, numeric *)
Definition: numeric.c:1389
PGTYPESnumeric_new
numeric * PGTYPESnumeric_new(void)
Definition: numeric.c:42
PGTYPESnumeric_to_decimal
int PGTYPESnumeric_to_decimal(numeric *, decimal *)
Definition: numeric.c:1548
PGTYPESnumeric_free
void PGTYPESnumeric_free(numeric *)
Definition: numeric.c:385
PGTYPESnumeric_from_asc
numeric * PGTYPESnumeric_from_asc(char *, char **)
Definition: numeric.c:321
pgtypes_timestamp.h
timestamp
int64 timestamp
Definition: pgtypes_timestamp.h:10
PGTYPEStimestamp_from_asc
timestamp PGTYPEStimestamp_from_asc(char *, char **)
Definition: timestamp.c:206
pg_strncasecmp
int pg_strncasecmp(const char *s1, const char *s2, size_t n)
Definition: pgstrcasecmp.c:69
postgres_fe.h
c
char * c
Definition: preproc-cursor.c:31
sqlca
#define sqlca
Definition: sqlca.h:59
ECPGgeneric_bytea
Definition: ecpglib_extern.h:46
ECPGgeneric_varchar
Definition: ecpglib_extern.h:39
pg_result
Definition: libpq-int.h:169
sqlca_t
Definition: sqlca.h:20