33#include "utils/fmgroids.h"
44#define JB_PATH_CREATE 0x0001
45#define JB_PATH_DELETE 0x0002
46#define JB_PATH_REPLACE 0x0004
47#define JB_PATH_INSERT_BEFORE 0x0008
48#define JB_PATH_INSERT_AFTER 0x0010
49#define JB_PATH_CREATE_OR_INSERT \
50 (JB_PATH_INSERT_BEFORE | JB_PATH_INSERT_AFTER | JB_PATH_CREATE)
51#define JB_PATH_FILL_GAPS 0x0020
52#define JB_PATH_CONSISTENT_POSITION 0x0040
320#define JsValueIsNull(jsv) \
322 (!(jsv)->val.json.str || (jsv)->val.json.type == JSON_TOKEN_NULL) : \
323 (!(jsv)->val.jsonb || (jsv)->val.jsonb->type == jbvNull))
325#define JsValueIsString(jsv) \
326 ((jsv)->is_json ? (jsv)->val.json.type == JSON_TOKEN_STRING \
327 : ((jsv)->val.jsonb && (jsv)->val.jsonb->type == jbvString))
329#define JsObjectIsEmpty(jso) \
331 ? hash_get_num_entries((jso)->val.json_hash) == 0 \
332 : ((jso)->val.jsonb_cont == NULL || \
333 JsonContainerSize((jso)->val.jsonb_cont) == 0))
335#define JsObjectFree(jso) \
337 if ((jso)->is_json) \
338 hash_destroy((jso)->val.json_hash); \
362 bool normalize_results);
431 bool is_json,
bool have_record_arg);
433 bool is_json,
bool have_record_arg,
452 bool *isnull,
Node *escontext,
bool omit_quotes);
458 bool omit_scalar_quotes);
475 Node *escontext,
bool omit_quotes);
481 bool *path_nulls,
int path_len,
577 bool skipNested =
false;
584 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
585 errmsg(
"cannot call %s on a scalar",
586 "jsonb_object_keys")));
589 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
590 errmsg(
"cannot call %s on an array",
591 "jsonb_object_keys")));
599 state->result_count = 0;
600 state->sent_count = 0;
613 cstr =
palloc(v.
val.string.len + 1 *
sizeof(
char));
614 memcpy(cstr, v.
val.string.val, v.
val.string.len);
615 cstr[v.
val.string.len] =
'\0';
629 char *nxt =
state->result[
state->sent_count++];
648 (
errcode(ERRCODE_UNTRANSLATABLE_CHARACTER),
649 errmsg(
"unsupported Unicode escape sequence"),
656 elog(
ERROR,
"JSON semantic action function did not provide error information");
660 (
errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
661 errmsg(
"invalid input syntax for type %s",
"json"),
679 const char *context_start;
680 const char *context_end;
681 const char *line_start;
689 context_start = line_start;
691 Assert(context_end >= context_start);
694 while (context_end - context_start >= 50)
698 context_start +=
pg_mblen(context_start);
708 if (context_start - line_start <= 3)
709 context_start = line_start;
712 ctxtlen = context_end - context_start;
713 ctxt =
palloc(ctxtlen + 1);
714 memcpy(ctxt, context_start, ctxtlen);
715 ctxt[ctxtlen] =
'\0';
721 prefix = (context_start > line_start) ?
"..." :
"";
724 *context_end !=
'\n' && *context_end !=
'\r') ?
"..." :
"";
726 return errcontext(
"JSON data, line %d: %s%s%s",
751 state->result_size = 256;
752 state->result_count = 0;
753 state->sent_count = 0;
777 char *nxt =
state->result[
state->sent_count++];
798 _state->
result = (
char **)
816 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
817 errmsg(
"cannot call %s on an array",
818 "json_object_keys")));
831 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
832 errmsg(
"cannot call %s on a scalar",
833 "json_object_keys")));
853 result =
get_worker(json, &fnamestr, NULL, 1,
false);
891 result =
get_worker(json, &fnamestr, NULL, 1,
true);
1048 tpath =
palloc(npath *
sizeof(
char *));
1049 ipath =
palloc(npath *
sizeof(
int));
1051 for (
i = 0;
i < npath;
i++)
1061 if (*tpath[
i] !=
'\0')
1068 if (endptr == tpath[
i] || *endptr !=
'\0' || errno != 0)
1077 result =
get_worker(json, tpath, ipath, npath, as_text);
1107 bool normalize_results)
1117 state->normalize_results = normalize_results;
1118 state->npath = npath;
1119 state->path_names = tpath;
1120 state->path_indexes = ipath;
1122 state->array_cur_index =
palloc(
sizeof(
int) * npath);
1125 state->pathok[0] =
true;
1156 return state->tresult;
1165 if (lex_level == 0 && _state->
npath == 0)
1184 if (lex_level == 0 && _state->
npath == 0)
1200 bool get_next =
false;
1203 if (lex_level <= _state->npath &&
1204 _state->
pathok[lex_level - 1] &&
1207 strcmp(fname, _state->
path_names[lex_level - 1]) == 0)
1209 if (lex_level < _state->npath)
1212 _state->
pathok[lex_level] =
true;
1247 bool get_last =
false;
1251 if (lex_level <= _state->npath &&
1252 _state->
pathok[lex_level - 1] &&
1255 strcmp(fname, _state->
path_names[lex_level - 1]) == 0)
1257 if (lex_level < _state->npath)
1260 _state->
pathok[lex_level] =
false;
1300 if (lex_level < _state->npath)
1321 else if (lex_level == 0 && _state->
npath == 0)
1340 if (lex_level == 0 && _state->
npath == 0)
1356 bool get_next =
false;
1360 if (lex_level <= _state->npath)
1363 if (lex_level <= _state->npath &&
1364 _state->
pathok[lex_level - 1] &&
1368 if (lex_level < _state->npath)
1371 _state->
pathok[lex_level] =
true;
1404 bool get_last =
false;
1408 if (lex_level <= _state->npath &&
1409 _state->
pathok[lex_level - 1] &&
1413 if (lex_level < _state->npath)
1416 _state->
pathok[lex_level] =
false;
1451 if (lex_level == 0 && _state->
npath == 0)
1536 bool have_object =
false,
1562 if (npath <= 0 && jbvp == NULL)
1577 for (
i = 0;
i < npath;
i++)
1588 else if (have_array)
1596 lindex =
strtoint(indextext, &endptr, 10);
1597 if (endptr == indextext || *endptr !=
'\0' || errno != 0)
1618 if (lindex == INT_MIN || -lindex > nelements)
1624 index = nelements + lindex;
1641 else if (
i == npath - 1)
1646 container = jbvp->
val.binary.data;
1654 have_object =
false;
1685 bool *path_nulls =
palloc0(path_len *
sizeof(
bool));
1738 for (
int i = level + 1;
i < path_len;
i++)
1754 if (badp ==
c || *badp !=
'\0' || errno != 0)
1758 newkey.
val.string.val =
c;
1759 newkey.
val.string.len = strlen(
c);
1778 if (tpath[(path_len - level) - 1] ==
jbvArray)
1789 for (
int i = path_len - 1;
i > level;
i--)
1813 return v->
val.boolean ?
1884 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1885 errmsg(
"cannot get array length of a scalar")));
1888 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1889 errmsg(
"cannot get array length of a non-array")));
1907 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1908 errmsg(
"cannot get array length of a non-array")));
1921 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1922 errmsg(
"cannot get array length of a scalar")));
1980 bool skipNested =
false;
1987 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1988 errmsg(
"cannot call %s on a non-object",
1995 "jsonb_each temporary cxt",
2008 bool nulls[2] = {
false,
false};
2081 state->normalize_results = as_text;
2082 state->next_scalar =
false;
2085 "json_each temporary cxt",
2128 bool nulls[2] = {
false,
false};
2175 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2176 errmsg(
"cannot deconstruct an array as an object")));
2189 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2190 errmsg(
"cannot deconstruct a scalar")));
2227 bool skipNested =
false;
2234 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2235 errmsg(
"cannot extract elements from a scalar")));
2238 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2239 errmsg(
"cannot extract elements from an object")));
2246 "jsonb_array_elements temporary cxt",
2258 bool nulls[1] = {
false};
2334 state->normalize_results = as_text;
2335 state->next_scalar =
false;
2338 "json_array_elements temporary cxt",
2380 bool nulls[1] = {
false};
2425 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2426 errmsg(
"cannot call %s on a non-array",
2440 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2441 errmsg(
"cannot call %s on a scalar",
2482 false,
true, (
Node *) &escontext);
2491 false,
false, NULL);
2516 (
errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
2517 errmsg(
"expected JSON array"),
2521 (
errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
2522 errmsg(
"expected JSON array")));
2534 for (
i = 0;
i < ndim;
i++)
2539 (
errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
2540 errmsg(
"expected JSON array"),
2541 errhint(
"See the array element %s of key \"%s\".",
2545 (
errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
2546 errmsg(
"expected JSON array"),
2547 errhint(
"See the array element %s.",
2578 for (
i = 0;
i < ndims;
i++)
2592 int dim = ctx->
sizes[ndim];
2594 if (ctx->
dims[ndim] == -1)
2595 ctx->
dims[ndim] = dim;
2596 else if (ctx->
dims[ndim] != dim)
2598 (
errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
2599 errmsg(
"malformed JSON array"),
2600 errdetail(
"Multidimensional arrays must have "
2601 "sub-arrays with matching dimensions.")));
2604 ctx->
sizes[ndim] = 0;
2608 ctx->
sizes[ndim - 1]++;
2621 bool element_isnull;
2638 ctx->
sizes[ndim - 1]++;
2648 int ndim =
state->lex->lex_level;
2650 if (
state->ctx->ndims <= 0)
2655 else if (ndim < state->ctx->ndims)
2672 int ndim =
state->lex->lex_level;
2674 if (ctx->
ndims <= 0)
2680 if (ndim < ctx->ndims)
2695 int ndim =
state->lex->lex_level;
2697 if (
state->ctx->ndims <= 0 || ndim ==
state->ctx->ndims)
2700 state->element_start =
state->lex->token_start;
2701 state->element_type =
state->lex->token_type;
2702 state->element_scalar = NULL;
2714 int ndim =
state->lex->lex_level;
2718 if (ndim == ctx->
ndims)
2731 else if (
state->element_scalar)
2740 state->element_start) *
sizeof(
char);
2757 int ndim =
state->lex->lex_level;
2759 if (ctx->
ndims <= 0)
2764 else if (ndim < ctx->ndims)
2772 if (ndim == ctx->
ndims)
2798 memset(&
sem, 0,
sizeof(
sem));
2859 if (ctx->
ndims <= 0 &&
2916 const char *colname,
2994 "populate_composite",
3015 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
3017 ?
errmsg(
"cannot call %s on a scalar",
3018 "populate_composite")
3019 :
errmsg(
"cannot call %s on an array",
3020 "populate_composite")));
3060 const char *colname,
3088 defaultval, mcxt, &jso, escontext);
3105 if (typid != io->
base_typid && typid != RECORDOID)
3126 bool *isnull,
Node *escontext,
bool omit_quotes)
3130 const char *json = NULL;
3140 if ((typid == JSONOID || typid == JSONBOID) &&
3171 else if (typid == JSONBOID)
3197 jbv->
val.binary.len);
3199 elog(
ERROR,
"unrecognized jsonb type: %d", (
int) jbv->
type);
3219 const char *colname,
3235 jsv, isnull, escontext, omit_quotes);
3260 column->
typid = typid;
3265 elog(
ERROR,
"cache lookup failed for type %u", typid);
3269 if (
type->typtype == TYPTYPE_DOMAIN)
3276 int32 base_typmod = typmod;
3300 else if (
type->typtype == TYPTYPE_COMPOSITE || typid == RECORDOID)
3309 else if (IsTrueArrayType(
type))
3348 bool *isnull,
bool omit_quotes,
3354 jsv.
is_json = json_type == JSONOID;
3384 jbv.
val.string.len = strlen(
str);
3385 jbv.
val.string.val =
str;
3391 jbv.
val.binary.data = &jsonb->
root;
3401 escontext, omit_quotes);
3409 const char *colname,
3415 bool omit_scalar_quotes)
3449 isnull, escontext, omit_scalar_quotes);
3467 jsv, isnull, escontext, omit_scalar_quotes);
3470 elog(
ERROR,
"unrecognized type category '%c'", typcat);
3484 data->record_typmod = 0;
3485 data->ncolumns = ncolumns;
3506 return hashentry != NULL;
3531 int ncolumns = tupdesc->
natts;
3543 if (record == NULL ||
3559 nulls = (
bool *)
palloc(ncolumns *
sizeof(
bool));
3569 tuple.
t_data = defaultval;
3576 for (
i = 0;
i < ncolumns; ++
i)
3583 for (
i = 0;
i < ncolumns; ++
i)
3586 char *colname =
NameStr(att->attname);
3591 if (att->attisdropped)
3607 if (defaultval && !found)
3647 (
errcode(ERRCODE_DATATYPE_MISMATCH),
3649 errmsg(
"first argument of %s must be a row type",
3671 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3673 errmsg(
"could not determine row type for result of %s",
3675 errhint(
"Provide a non-null record argument, "
3676 "or call the function in the FROM clause "
3677 "using a column definition list.")));
3700 bool is_json,
bool have_record_arg,
3703 int json_arg_num = have_record_arg ? 1 : 0;
3723 if (have_record_arg)
3730 if (!have_record_arg)
3740 if (cache->
argtype == RECORDOID)
3754 if (cache->
argtype == RECORDOID)
3790 jbv.
val.binary.data = &jb->
root;
3796 NULL, fnmcxt, rec, &jsv, &isnull,
3936 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
3949 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4042 bool is_json,
bool have_record_arg)
4044 int json_arg_num = have_record_arg ? 1 : 0;
4055 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
4056 errmsg(
"set-valued function called in context that cannot accept a set")));
4060 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
4061 errmsg(
"materialize mode required, but it is not allowed in this context")));
4076 if (have_record_arg)
4083 if (!have_record_arg)
4093 if (cache->
argtype == RECORDOID)
4107 if (cache->
argtype == RECORDOID)
4135 state->cache = cache;
4169 bool skipNested =
false;
4174 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4175 errmsg(
"cannot call %s on a non-array",
4191 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4192 errmsg(
"argument of %s must be an array of objects",
4224 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4225 errmsg(
"cannot call %s on an object",
4275 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4276 errmsg(
"argument of %s must be an array of objects",
4296 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4297 errmsg(
"cannot call %s on a scalar",
4518 state->skip_next_null =
false;
4519 state->strip_in_arrays = strip_in_arrays;
4533 state->strval->len));
4543 bool strip_in_arrays =
false;
4550 bool last_was_key =
false;
4568 last_was_key =
true;
4575 last_was_key =
false;
4586 if (strip_in_arrays)
4674 bool skipNested =
false;
4679 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4680 errmsg(
"cannot delete from scalar")));
4693 memcmp(keyptr, v.
val.string.val, keylen) == 0))
4728 bool skipNested =
false;
4733 (
errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
4734 errmsg(
"wrong number of array subscripts")));
4738 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4739 errmsg(
"cannot delete from scalar")));
4760 for (
i = 0;
i < keys_len;
i++)
4771 if (keylen == v.
val.string.len &&
4772 memcmp(keyptr, v.
val.string.val, keylen) == 0)
4818 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4819 errmsg(
"cannot delete from scalar")));
4823 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4824 errmsg(
"cannot delete from object using integer index")));
4833 n = v.
val.array.nElems;
4886 (
errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
4887 errmsg(
"wrong number of array subscripts")));
4891 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4892 errmsg(
"cannot set path in scalar")));
4904 res =
setPath(&it, path_elems, path_nulls, path_len, &st,
4932 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4933 errmsg(
"null_value_treatment must be \"delete_key\", \"return_target\", \"use_json_null\", or \"raise_exception\"")));
4942 if (strcmp(handle_val,
"raise_exception") == 0)
4945 (
errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED),
4946 errmsg(
"JSON value must not be null"),
4947 errdetail(
"Exception was raised because null_value_treatment is \"raise_exception\"."),
4948 errhint(
"To avoid, either change the null_value_treatment argument or ensure that an SQL NULL is not passed.")));
4951 else if (strcmp(handle_val,
"use_json_null") == 0)
4957 fcinfo->args[2].value =
newval;
4958 fcinfo->args[2].isnull =
false;
4961 else if (strcmp(handle_val,
"delete_key") == 0)
4965 else if (strcmp(handle_val,
"return_target") == 0)
4974 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4975 errmsg(
"null_value_treatment must be \"delete_key\", \"return_target\", \"use_json_null\", or \"raise_exception\"")));
4997 (
errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
4998 errmsg(
"wrong number of array subscripts")));
5002 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
5003 errmsg(
"cannot delete path in scalar")));
5015 res =
setPath(&it, path_elems, path_nulls, path_len, &st,
5045 (
errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
5046 errmsg(
"wrong number of array subscripts")));
5050 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
5051 errmsg(
"cannot set path in scalar")));
5060 res =
setPath(&it, path_elems, path_nulls, path_len, &st, 0, &
newval,
5205 bool *path_nulls,
int path_len,
5214 if (path_nulls[level])
5216 (
errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED),
5217 errmsg(
"path element at position %d is null",
5233 v.
val.array.rawScalar)
5235 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
5236 errmsg(
"cannot replace existing key"),
5237 errdetail(
"The path assumes key is a composite object, "
5238 "but it is a scalar value.")));
5241 setPathArray(it, path_elems, path_nulls, path_len, st, level,
5249 setPathObject(it, path_elems, path_nulls, path_len, st, level,
5266 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
5267 errmsg(
"cannot replace existing key"),
5268 errdetail(
"The path assumes key is a composite object, "
5269 "but it is a scalar value.")));
5274 elog(
ERROR,
"unrecognized iterator result: %d", (
int) r);
5290 text *pathelem = NULL;
5296 if (level >= path_len || path_nulls[level])
5306 (level == path_len - 1))
5318 for (
i = 0;
i < npairs;
i++)
5327 k.
val.string.len) == 0)
5331 if (level == path_len - 1)
5339 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
5340 errmsg(
"cannot replace existing key"),
5341 errhint(
"Try using the function jsonb_set "
5342 "to replace key value.")));
5354 setPath(it, path_elems, path_nulls, path_len,
5355 st, level + 1,
newval, op_type);
5361 level == path_len - 1 &&
i == npairs - 1)
5378 int walking_level = 1;
5380 while (walking_level != 0)
5414 (void)
push_path(st, level, path_elems, path_nulls,
5435 if (level < path_len && !path_nulls[level])
5442 if (badp ==
c || *badp !=
'\0' || errno != 0)
5444 (
errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
5445 errmsg(
"path element at position %d is not an integer: \"%s\"",
5461 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
5462 errmsg(
"path element at position %d is out of range: %d",
5477 if (
idx > 0 &&
idx > nelems)
5486 if ((
idx == INT_MIN || nelems == 0) && (level == path_len - 1) &&
5500 for (
i = 0;
i < nelems;
i++)
5504 if (
i ==
idx && level < path_len)
5508 if (level == path_len - 1)
5527 (
void)
setPath(it, path_elems, path_nulls, path_len,
5528 st, level + 1,
newval, op_type);
5538 int walking_level = 1;
5540 while (walking_level != 0)
5583 (void)
push_path(st, level, path_elems, path_nulls,
5614 errmsg(
"wrong flag type, only arrays and scalars are allowed")));
5620 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
5621 errmsg(
"flag array element is not a string"),
5622 errhint(
"Possible values are: \"string\", \"numeric\", \"boolean\", \"key\", and \"all\".")));
5624 if (v.
val.string.len == 3 &&
5627 else if (v.
val.string.len == 3 &&
5630 else if (v.
val.string.len == 6 &&
5633 else if (v.
val.string.len == 7 &&
5636 else if (v.
val.string.len == 7 &&
5641 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
5642 errmsg(
"wrong flag in flag array: \"%s\"",
5644 errhint(
"Possible values are: \"string\", \"numeric\", \"boolean\", \"key\", and \"all\".")));
5649 elog(
ERROR,
"unexpected end of flag array");
5654 elog(
ERROR,
"unexpected end of flag array");
5741 state->action_state = action_state;
5742 state->flags = flags;
5815 bool is_scalar =
false;
5824 out = transform_action(action_state, v.
val.string.val, v.
val.string.len);
5840 res->
val.array.rawScalar = is_scalar;
5862 state->action = transform_action;
5863 state->action_state = action_state;
6012 *outfuncoid = F_BOOLOUT;
6027 *outfuncoid = F_DATE_OUT;
6032 *outfuncoid = F_TIMESTAMP_OUT;
6036 case TIMESTAMPTZOID:
6037 *outfuncoid = F_TIMESTAMPTZ_OUT;
6054 || typoid == ANYCOMPATIBLEARRAYOID || typoid == RECORDARRAYOID)
6056 *outfuncoid = F_ARRAY_OUT;
6061 *outfuncoid = F_RECORD_OUT;
6082 *outfuncoid = castfunc;
Datum idx(PG_FUNCTION_ARGS)
#define PG_GETARG_ARRAYTYPE_P(n)
bool array_contains_nulls(ArrayType *array)
ArrayBuildState * accumArrayResult(ArrayBuildState *astate, Datum dvalue, bool disnull, Oid element_type, MemoryContext rcontext)
Datum makeMdArrayResult(ArrayBuildState *astate, int ndims, int *dims, int *lbs, MemoryContext rcontext, bool release)
void deconstruct_array_builtin(ArrayType *array, Oid elmtype, Datum **elemsp, bool **nullsp, int *nelemsp)
ArrayBuildState * initArrayResult(Oid element_type, MemoryContext rcontext, bool subcontext)
Datum numeric_out(PG_FUNCTION_ARGS)
static Datum values[MAXATTR]
#define CStringGetTextDatum(s)
#define TextDatumGetCString(d)
#define unconstify(underlying_type, expr)
#define IS_HIGHBIT_SET(ch)
#define FLEXIBLE_ARRAY_MEMBER
#define MemSet(start, val, len)
#define OidIsValid(objectId)
bool domain_check_safe(Datum value, bool isnull, Oid domainType, void **extra, MemoryContext mcxt, Node *escontext)
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
void hash_destroy(HTAB *hashp)
HTAB * hash_create(const char *tabname, long nelem, const HASHCTL *info, int flags)
int errdetail_internal(const char *fmt,...)
int errdetail(const char *fmt,...)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereturn(context, dummy_value,...)
#define errsave(context,...)
#define ereport(elevel,...)
Datum HeapTupleHeaderGetDatum(HeapTupleHeader tuple)
@ SFRM_Materialize_Random
struct varlena * pg_detoast_datum_packed(struct varlena *datum)
void fmgr_info_cxt(Oid functionId, FmgrInfo *finfo, MemoryContext mcxt)
bool InputFunctionCallSafe(FmgrInfo *flinfo, char *str, Oid typioparam, int32 typmod, fmNodePtr escontext, Datum *result)
Oid get_fn_expr_argtype(FmgrInfo *flinfo, int argnum)
#define PG_GETARG_TEXT_PP(n)
#define DatumGetHeapTupleHeader(X)
#define DatumGetTextPP(X)
#define DirectFunctionCall1(func, arg1)
#define PG_GETARG_HEAPTUPLEHEADER(n)
#define PG_RETURN_TEXT_P(x)
#define PG_RETURN_INT32(x)
#define PG_GETARG_INT32(n)
#define PG_GETARG_BOOL(n)
#define PG_RETURN_DATUM(x)
#define PG_RETURN_POINTER(x)
#define PG_GETARG_TEXT_P(n)
void InitMaterializedSRF(FunctionCallInfo fcinfo, bits32 flags)
TypeFuncClass get_call_result_type(FunctionCallInfo fcinfo, Oid *resultTypeId, TupleDesc *resultTupleDesc)
#define SRF_IS_FIRSTCALL()
#define SRF_PERCALL_SETUP()
#define SRF_RETURN_NEXT(_funcctx, _result)
#define SRF_FIRSTCALL_INIT()
#define SRF_RETURN_DONE(_funcctx)
#define MAT_SRF_USE_EXPECTED_DESC
Assert(PointerIsAligned(start, uint64))
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
void heap_deform_tuple(HeapTuple tuple, TupleDesc tupleDesc, Datum *values, bool *isnull)
#define HeapTupleIsValid(tuple)
static int32 HeapTupleHeaderGetTypMod(const HeapTupleHeaderData *tup)
static uint32 HeapTupleHeaderGetDatumLength(const HeapTupleHeaderData *tup)
static void * GETSTRUCT(const HeapTupleData *tuple)
static Oid HeapTupleHeaderGetTypeId(const HeapTupleHeaderData *tup)
static uint32 pg_abs_s32(int32 a)
if(TABLE==NULL||TABLE_index==NULL)
static void ItemPointerSetInvalid(ItemPointerData *pointer)
void escape_json_text(StringInfo buf, const text *txt)
void escape_json_with_len(StringInfo buf, const char *str, int len)
void escape_json(StringInfo buf, const char *str)
JsonParseErrorType pg_parse_json(JsonLexContext *lex, const JsonSemAction *sem)
JsonLexContext * makeJsonLexContextCstringLen(JsonLexContext *lex, const char *json, size_t len, int encoding, bool need_escapes)
JsonParseErrorType json_lex(JsonLexContext *lex)
char * json_errdetail(JsonParseErrorType error, JsonLexContext *lex)
JsonParseErrorType json_count_array_elements(JsonLexContext *lex, int *elements)
void freeJsonLexContext(JsonLexContext *lex)
@ JSON_UNICODE_CODE_POINT_ZERO
@ JSON_UNICODE_UNTRANSLATABLE
@ JSON_UNICODE_HIGH_ESCAPE
@ JSON_TOKEN_OBJECT_START
char * JsonbUnquote(Jsonb *jb)
Datum jsonb_in(PG_FUNCTION_ARGS)
char * JsonbToCString(StringInfo out, JsonbContainer *in, int estimated_len)
char * JsonbToCStringIndent(StringInfo out, JsonbContainer *in, int estimated_len)
#define JsonContainerIsScalar(jc)
#define JsonContainerIsArray(jc)
#define JsonContainerSize(jc)
#define JB_ROOT_IS_OBJECT(jbp_)
static Datum JsonbPGetDatum(const Jsonb *p)
#define IsAJsonbScalar(jsonbval)
#define PG_RETURN_JSONB_P(x)
#define JB_ROOT_IS_ARRAY(jbp_)
#define PG_GETARG_JSONB_P(x)
#define JsonContainerIsObject(jc)
static Jsonb * DatumGetJsonbP(Datum d)
#define JB_ROOT_IS_SCALAR(jbp_)
#define JB_ROOT_COUNT(jbp_)
JsonbValue * getKeyJsonValueFromContainer(JsonbContainer *container, const char *keyVal, int keyLen, JsonbValue *res)
JsonbValue * pushJsonbValue(JsonbParseState **pstate, JsonbIteratorToken seq, JsonbValue *jbval)
JsonbIterator * JsonbIteratorInit(JsonbContainer *container)
void JsonbToJsonbValue(Jsonb *jsonb, JsonbValue *val)
JsonbIteratorToken JsonbIteratorNext(JsonbIterator **it, JsonbValue *val, bool skipNested)
JsonbValue * getIthJsonbValueFromContainer(JsonbContainer *container, uint32 i)
Jsonb * JsonbValueToJsonb(JsonbValue *val)
Datum jsonb_populate_recordset(PG_FUNCTION_ARGS)
JsonLexContext * makeJsonLexContext(JsonLexContext *lex, text *json, bool need_escapes)
static JsonParseErrorType get_array_element_end(void *state, bool isnull)
static Datum elements_worker(FunctionCallInfo fcinfo, const char *funcname, bool as_text)
static JsonParseErrorType hash_array_start(void *state)
Datum jsonb_object_keys(PG_FUNCTION_ARGS)
static JsonParseErrorType populate_recordset_array_start(void *state)
static JsonParseErrorType transform_string_values_array_start(void *state)
static JsonParseErrorType get_object_field_start(void *state, char *fname, bool isnull)
static JsonParseErrorType elements_object_start(void *state)
static JsonParseErrorType transform_string_values_object_field_start(void *state, char *fname, bool isnull)
Datum jsonb_array_elements(PG_FUNCTION_ARGS)
static JsonParseErrorType iterate_values_object_field_start(void *state, char *fname, bool isnull)
struct PopulateArrayContext PopulateArrayContext
static JsonbValue * IteratorConcat(JsonbIterator **it1, JsonbIterator **it2, JsonbParseState **state)
Datum json_each_text(PG_FUNCTION_ARGS)
Datum json_populate_recordset(PG_FUNCTION_ARGS)
static JsonParseErrorType populate_array_scalar(void *_state, char *token, JsonTokenType tokentype)
text * transform_json_string_values(text *json, void *action_state, JsonTransformStringValuesAction transform_action)
Datum jsonb_delete(PG_FUNCTION_ARGS)
struct TransformJsonStringValuesState TransformJsonStringValuesState
Datum json_populate_type(Datum json_val, Oid json_type, Oid typid, int32 typmod, void **cache, MemoryContext mcxt, bool *isnull, bool omit_quotes, Node *escontext)
Datum jsonb_delete_array(PG_FUNCTION_ARGS)
static JsonbValue * setPath(JsonbIterator **it, Datum *path_elems, bool *path_nulls, int path_len, JsonbParseState **st, int level, JsonbValue *newval, int op_type)
Datum jsonb_pretty(PG_FUNCTION_ARGS)
struct DomainIOData DomainIOData
static JsonParseErrorType transform_string_values_array_end(void *state)
static JsonParseErrorType populate_recordset_object_start(void *state)
static RecordIOData * allocate_record_info(MemoryContext mcxt, int ncolumns)
static JsonParseErrorType iterate_values_scalar(void *state, char *token, JsonTokenType tokentype)
static text * JsonbValueAsText(JsonbValue *v)
Datum jsonb_insert(PG_FUNCTION_ARGS)
static JsonParseErrorType get_object_start(void *state)
static JsonParseErrorType populate_recordset_object_field_start(void *state, char *fname, bool isnull)
static JsonParseErrorType populate_recordset_object_field_end(void *state, char *fname, bool isnull)
static JsonParseErrorType populate_array_object_start(void *_state)
#define JsObjectIsEmpty(jso)
static void get_record_type_from_argument(FunctionCallInfo fcinfo, const char *funcname, PopulateRecordCache *cache)
Datum json_array_element(PG_FUNCTION_ARGS)
Datum jsonb_delete_idx(PG_FUNCTION_ARGS)
static JsonParseErrorType sn_object_end(void *state)
#define JB_PATH_CREATE_OR_INSERT
Datum jsonb_populate_record_valid(PG_FUNCTION_ARGS)
Datum json_array_elements_text(PG_FUNCTION_ARGS)
struct EachState EachState
static JsonParseErrorType hash_scalar(void *state, char *token, JsonTokenType tokentype)
static JsonParseErrorType sn_array_element_start(void *state, bool isnull)
static Datum populate_record_worker(FunctionCallInfo fcinfo, const char *funcname, bool is_json, bool have_record_arg, Node *escontext)
static HTAB * get_json_object_as_hash(const char *json, int len, const char *funcname, Node *escontext)
static bool populate_array_json(PopulateArrayContext *ctx, const char *json, int len)
struct StripnullState StripnullState
static void setPathArray(JsonbIterator **it, Datum *path_elems, bool *path_nulls, int path_len, JsonbParseState **st, int level, JsonbValue *newval, uint32 nelems, int op_type)
struct IterateJsonStringValuesState IterateJsonStringValuesState
#define JsValueIsString(jsv)
static JsonParseErrorType populate_recordset_object_end(void *state)
static Datum populate_record_field(ColumnIOData *col, Oid typid, int32 typmod, const char *colname, MemoryContext mcxt, Datum defaultval, JsValue *jsv, bool *isnull, Node *escontext, bool omit_scalar_quotes)
Datum jsonb_delete_path(PG_FUNCTION_ARGS)
struct CompositeIOData CompositeIOData
static JsonParseErrorType each_object_field_end(void *state, char *fname, bool isnull)
Datum jsonb_object_field_text(PG_FUNCTION_ARGS)
static Datum each_worker(FunctionCallInfo fcinfo, bool as_text)
static JsonParseErrorType get_array_start(void *state)
static JsonParseErrorType each_scalar(void *state, char *token, JsonTokenType tokentype)
static int report_json_context(JsonLexContext *lex)
Datum json_strip_nulls(PG_FUNCTION_ARGS)
static void push_path(JsonbParseState **st, int level, Datum *path_elems, bool *path_nulls, int path_len, JsonbValue *newval)
struct JsonHashEntry JsonHashEntry
Datum jsonb_set_element(Jsonb *jb, Datum *path, int path_len, JsonbValue *newval)
Datum json_array_elements(PG_FUNCTION_ARGS)
Datum jsonb_concat(PG_FUNCTION_ARGS)
struct ArrayIOData ArrayIOData
static JsonParseErrorType okeys_array_start(void *state)
Datum json_object_field_text(PG_FUNCTION_ARGS)
uint32 parse_jsonb_index_flags(Jsonb *jb)
Datum jsonb_extract_path_text(PG_FUNCTION_ARGS)
Datum json_each(PG_FUNCTION_ARGS)
static JsonParseErrorType alen_scalar(void *state, char *token, JsonTokenType tokentype)
static JsonParseErrorType sn_object_start(void *state)
static JsonParseErrorType sn_array_start(void *state)
static bool populate_array_check_dimension(PopulateArrayContext *ctx, int ndim)
Datum jsonb_get_element(Jsonb *jb, Datum *path, int npath, bool *isnull, bool as_text)
static Datum each_worker_jsonb(FunctionCallInfo fcinfo, const char *funcname, bool as_text)
static JsonParseErrorType sn_array_end(void *state)
Datum json_to_recordset(PG_FUNCTION_ARGS)
static JsonParseErrorType get_scalar(void *state, char *token, JsonTokenType tokentype)
#define JB_PATH_CONSISTENT_POSITION
static bool populate_array_assign_ndims(PopulateArrayContext *ctx, int ndims)
JsonTokenType json_get_first_token(text *json, bool throw_error)
Datum jsonb_set(PG_FUNCTION_ARGS)
#define JsValueIsNull(jsv)
static void update_cached_tupdesc(CompositeIOData *io, MemoryContext mcxt)
struct ColumnIOData ColumnIOData
void iterate_jsonb_values(Jsonb *jb, uint32 flags, void *state, JsonIterateStringValuesAction action)
static JsonParseErrorType populate_array_element_end(void *_state, bool isnull)
Datum jsonb_set_lax(PG_FUNCTION_ARGS)
static JsonParseErrorType elements_array_element_end(void *state, bool isnull)
static JsonParseErrorType sn_object_field_start(void *state, char *fname, bool isnull)
Datum jsonb_each_text(PG_FUNCTION_ARGS)
static JsonParseErrorType elements_scalar(void *state, char *token, JsonTokenType tokentype)
struct ScalarIOData ScalarIOData
static JsonParseErrorType each_object_field_start(void *state, char *fname, bool isnull)
Datum jsonb_strip_nulls(PG_FUNCTION_ARGS)
struct OkeysState OkeysState
struct PopulateArrayState PopulateArrayState
struct PopulateRecordCache PopulateRecordCache
Datum jsonb_extract_path(PG_FUNCTION_ARGS)
static void push_null_elements(JsonbParseState **ps, int num)
void json_categorize_type(Oid typoid, bool is_jsonb, JsonTypeCategory *tcategory, Oid *outfuncoid)
static Datum populate_array(ArrayIOData *aio, const char *colname, MemoryContext mcxt, JsValue *jsv, bool *isnull, Node *escontext)
static JsonParseErrorType okeys_object_field_start(void *state, char *fname, bool isnull)
Datum json_array_length(PG_FUNCTION_ARGS)
struct JHashState JHashState
void json_errsave_error(JsonParseErrorType error, JsonLexContext *lex, Node *escontext)
struct ElementsState ElementsState
Datum jsonb_array_length(PG_FUNCTION_ARGS)
Datum jsonb_object_field(PG_FUNCTION_ARGS)
static Datum elements_worker_jsonb(FunctionCallInfo fcinfo, const char *funcname, bool as_text)
void iterate_json_values(text *json, uint32 flags, void *action_state, JsonIterateStringValuesAction action)
Datum jsonb_populate_record(PG_FUNCTION_ARGS)
Datum json_extract_path(PG_FUNCTION_ARGS)
Datum json_extract_path_text(PG_FUNCTION_ARGS)
static JsonParseErrorType elements_array_element_start(void *state, bool isnull)
static void get_record_type_from_query(FunctionCallInfo fcinfo, const char *funcname, PopulateRecordCache *cache)
Datum json_populate_record(PG_FUNCTION_ARGS)
static JsonParseErrorType populate_recordset_array_element_start(void *state, bool isnull)
#define JB_PATH_FILL_GAPS
Jsonb * transform_jsonb_string_values(Jsonb *jsonb, void *action_state, JsonTransformStringValuesAction transform_action)
static JsonParseErrorType transform_string_values_object_end(void *state)
static bool JsValueToJsObject(JsValue *jsv, JsObject *jso, Node *escontext)
Datum json_object_field(PG_FUNCTION_ARGS)
static JsonParseErrorType okeys_scalar(void *state, char *token, JsonTokenType tokentype)
static Datum get_jsonb_path_all(FunctionCallInfo fcinfo, bool as_text)
static void populate_array_report_expected_array(PopulateArrayContext *ctx, int ndim)
static JsonParseErrorType get_object_end(void *state)
static Datum populate_composite(CompositeIOData *io, Oid typid, const char *colname, MemoryContext mcxt, HeapTupleHeader defaultval, JsValue *jsv, bool *isnull, Node *escontext)
Datum jsonb_to_record(PG_FUNCTION_ARGS)
Datum jsonb_array_element(PG_FUNCTION_ARGS)
Datum json_object_keys(PG_FUNCTION_ARGS)
struct AlenState AlenState
#define JB_PATH_INSERT_BEFORE
static JsonParseErrorType populate_recordset_scalar(void *state, char *token, JsonTokenType tokentype)
static JsonParseErrorType get_object_field_end(void *state, char *fname, bool isnull)
bool pg_parse_json_or_errsave(JsonLexContext *lex, const JsonSemAction *sem, Node *escontext)
static Datum get_path_all(FunctionCallInfo fcinfo, bool as_text)
static Datum populate_recordset_worker(FunctionCallInfo fcinfo, const char *funcname, bool is_json, bool have_record_arg)
static HeapTupleHeader populate_record(TupleDesc tupdesc, RecordIOData **record_p, HeapTupleHeader defaultval, MemoryContext mcxt, JsObject *obj, Node *escontext)
static JsonParseErrorType alen_object_start(void *state)
static bool JsObjectGetField(JsObject *obj, char *field, JsValue *jsv)
static bool populate_array_element(PopulateArrayContext *ctx, int ndim, JsValue *jsv)
static JsonParseErrorType populate_array_element_start(void *_state, bool isnull)
static JsonParseErrorType populate_array_array_end(void *_state)
static void prepare_column_cache(ColumnIOData *column, Oid typid, int32 typmod, MemoryContext mcxt, bool need_scalar)
static JsonParseErrorType get_array_end(void *state)
Datum jsonb_to_recordset(PG_FUNCTION_ARGS)
static JsonParseErrorType sn_scalar(void *state, char *token, JsonTokenType tokentype)
#define JB_PATH_INSERT_AFTER
Datum jsonb_each(PG_FUNCTION_ARGS)
static JsonParseErrorType get_array_element_start(void *state, bool isnull)
static JsonParseErrorType hash_object_field_end(void *state, char *fname, bool isnull)
static void populate_recordset_record(PopulateRecordsetState *state, JsObject *obj)
#define JsObjectFree(jso)
struct PopulateRecordsetState PopulateRecordsetState
static JsonParseErrorType transform_string_values_object_start(void *state)
static JsonParseErrorType transform_string_values_array_element_start(void *state, bool isnull)
static JsonParseErrorType alen_array_element_start(void *state, bool isnull)
static Datum populate_scalar(ScalarIOData *io, Oid typid, int32 typmod, JsValue *jsv, bool *isnull, Node *escontext, bool omit_quotes)
static bool populate_array_dim_jsonb(PopulateArrayContext *ctx, JsonbValue *jbv, int ndim)
Datum jsonb_array_element_text(PG_FUNCTION_ARGS)
@ TYPECAT_COMPOSITE_DOMAIN
Datum json_to_record(PG_FUNCTION_ARGS)
static JsonParseErrorType each_array_start(void *state)
Datum json_array_element_text(PG_FUNCTION_ARGS)
static void setPathObject(JsonbIterator **it, Datum *path_elems, bool *path_nulls, int path_len, JsonbParseState **st, int level, JsonbValue *newval, uint32 npairs, int op_type)
static Datum populate_domain(DomainIOData *io, Oid typid, const char *colname, MemoryContext mcxt, JsValue *jsv, bool *isnull, Node *escontext, bool omit_quotes)
static JsonParseErrorType transform_string_values_scalar(void *state, char *token, JsonTokenType tokentype)
static JsonParseErrorType hash_object_field_start(void *state, char *fname, bool isnull)
Datum jsonb_array_elements_text(PG_FUNCTION_ARGS)
static text * get_worker(text *json, char **tpath, int *ipath, int npath, bool normalize_results)
#define pg_parse_json_or_ereport(lex, sem)
text *(* JsonTransformStringValuesAction)(void *state, char *elem_value, int elem_len)
void(* JsonIterateStringValuesAction)(void *state, char *elem_value, int elem_len)
Oid get_element_type(Oid typid)
bool type_is_rowtype(Oid typid)
void getTypeOutputInfo(Oid type, Oid *typOutput, bool *typIsVarlena)
void getTypeInputInfo(Oid type, Oid *typInput, Oid *typIOParam)
char get_typtype(Oid typid)
Oid getBaseTypeAndTypmod(Oid typid, int32 *typmod)
Oid getBaseType(Oid typid)
int GetDatabaseEncoding(void)
int pg_mblen(const char *mbstr)
void * MemoryContextAlloc(MemoryContext context, Size size)
void MemoryContextReset(MemoryContext context)
void * MemoryContextAllocZero(MemoryContext context, Size size)
char * pstrdup(const char *in)
void * repalloc(void *pointer, Size size)
void pfree(void *pointer)
void * palloc0(Size size)
MemoryContext CurrentMemoryContext
char * pnstrdup(const char *in, Size len)
void MemoryContextDelete(MemoryContext context)
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
#define SOFT_ERROR_OCCURRED(escontext)
#define IsA(nodeptr, _type_)
static Datum NumericGetDatum(Numeric X)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
CoercionPathType find_coercion_pathway(Oid targetTypeId, Oid sourceTypeId, CoercionContext ccontext, Oid *funcid)
FormData_pg_attribute * Form_pg_attribute
FormData_pg_type * Form_pg_type
int pg_strncasecmp(const char *s1, const char *s2, size_t n)
static Datum PointerGetDatum(const void *X)
static Datum BoolGetDatum(bool X)
static Datum ObjectIdGetDatum(Oid X)
static char * DatumGetCString(Datum X)
static Pointer DatumGetPointer(Datum X)
static Datum CStringGetDatum(const char *X)
static chr element(struct vars *v, const chr *startp, const chr *endp)
void check_stack_depth(void)
int strtoint(const char *pg_restrict str, char **pg_restrict endptr, int base)
StringInfo makeStringInfo(void)
void appendStringInfo(StringInfo str, const char *fmt,...)
void appendStringInfoString(StringInfo str, const char *s)
void initStringInfo(StringInfo str)
#define appendStringInfoCharMacro(str, ch)
ColumnIOData * element_info
union ColumnIOData::@24 io
CompositeIOData composite
const char * result_start
Tuplestorestate * tuple_store
Tuplestorestate * tuple_store
const char * function_name
const char * result_start
MemoryContext ecxt_per_query_memory
MemoryContext multi_call_memory_ctx
const char * result_start
JsonIterateStringValuesAction action
const char * save_json_start
const char * function_name
JsonTokenType saved_token_type
JsonbContainer * jsonb_cont
struct JsValue::@25::@26 json
const char * prev_token_terminator
const char * token_terminator
json_struct_action array_end
json_struct_action object_start
json_ofield_action object_field_start
json_aelem_action array_element_start
json_scalar_action scalar
json_aelem_action array_element_end
json_struct_action array_start
json_struct_action object_end
json_ofield_action object_field_end
JsonTokenType element_type
PopulateArrayContext * ctx
const char * element_start
const char * save_json_start
const char * function_name
Tuplestorestate * tuple_store
PopulateRecordCache * cache
JsonTokenType saved_token_type
ColumnIOData columns[FLEXIBLE_ARRAY_MEMBER]
SetFunctionReturnMode returnMode
Tuplestorestate * setResult
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
#define FirstNormalObjectId
void FreeTupleDesc(TupleDesc tupdesc)
TupleDesc CreateTupleDescCopy(TupleDesc tupdesc)
#define ReleaseTupleDesc(tupdesc)
static FormData_pg_attribute * TupleDescAttr(TupleDesc tupdesc, int i)
Tuplestorestate * tuplestore_begin_heap(bool randomAccess, bool interXact, int maxKBytes)
void tuplestore_putvalues(Tuplestorestate *state, TupleDesc tdesc, const Datum *values, const bool *isnull)
void tuplestore_puttuple(Tuplestorestate *state, HeapTuple tuple)
TupleDesc lookup_rowtype_tupdesc(Oid type_id, int32 typmod)
#define VARSIZE_ANY_EXHDR(PTR)
text * cstring_to_text_with_len(const char *s, int len)
text * cstring_to_text(const char *s)
char * text_to_cstring(const text *t)