38 #define JSONB_MAX_ELEMS (Min(MaxAllocSize / sizeof(JsonbValue), JB_CMASK))
39 #define JSONB_MAX_PAIRS (Min(MaxAllocSize / sizeof(JsonbPair), JB_CMASK))
42 char *base_addr,
uint32 offset,
65 const char *val2,
int len2);
77 val->val.binary.data = &jsonb->
root;
106 scalarArray.
val.array.rawScalar =
true;
107 scalarArray.
val.array.nElems = 1;
124 memcpy(
VARDATA(out),
val->val.binary.data,
val->val.binary.len);
249 if (va.
val.array.rawScalar != vb.
val.array.rawScalar)
250 res = (va.
val.array.rawScalar) ? -1 : 1;
251 if (va.
val.array.nElems != vb.
val.array.nElems)
252 res = (va.
val.array.nElems > vb.
val.array.nElems) ? 1 : -1;
255 if (va.
val.object.nPairs != vb.
val.object.nPairs)
256 res = (va.
val.object.nPairs > vb.
val.object.nPairs) ? 1 : -1;
259 elog(
ERROR,
"unexpected jbvBinary value");
262 elog(
ERROR,
"unexpected jbvDatetime value");
361 char *base_addr = (
char *) (children + count);
365 for (
i = 0;
i < count;
i++)
386 key->val.string.len, NULL);
419 baseAddr = (
char *) (children + count * 2);
422 while (stopLow < stopHigh)
426 const char *candidateVal;
429 stopMiddle = stopLow + (stopHigh - stopLow) / 2;
440 int index = stopMiddle + count;
454 stopLow = stopMiddle + 1;
456 stopHigh = stopMiddle;
480 base_addr = (
char *) &container->
children[nelements];
508 char *base_addr,
uint32 offset,
520 result->
val.string.val = base_addr + offset;
532 result->
val.boolean =
true;
537 result->
val.boolean =
false;
580 for (
i = 0;
i < jbval->
val.object.nPairs;
i++)
592 for (
i = 0;
i < jbval->
val.array.nElems;
i++)
610 if ((jbval->
val.binary.data->header &
JB_FSCALAR) && *pstate)
632 v.
val.array.rawScalar) ? &v : NULL);
650 Assert(!scalarVal || scalarVal->
val.array.rawScalar);
652 result = &(*pstate)->contVal;
654 (*pstate)->contVal.val.array.nElems = 0;
655 (*pstate)->contVal.val.array.rawScalar = (scalarVal &&
656 scalarVal->
val.array.rawScalar);
657 if (scalarVal && scalarVal->
val.array.nElems > 0)
661 (*pstate)->size = scalarVal->
val.array.nElems;
673 result = &(*pstate)->contVal;
675 (*pstate)->contVal.val.object.nPairs = 0;
694 (*pstate)->unique_keys,
695 (*pstate)->skip_nulls);
700 result = &(*pstate)->contVal;
706 *pstate = (*pstate)->
next;
709 switch ((*pstate)->contVal.type)
718 elog(
ERROR,
"invalid jsonb container type");
723 elog(
ERROR,
"unrecognized jsonb sequential processing token");
757 (
errcode(ERRCODE_PROGRAM_LIMIT_EXCEEDED),
758 errmsg(
"number of jsonb object pairs exceeds the maximum allowed (%zu)",
761 if (object->
val.object.nPairs >= pstate->
size)
764 object->val.object.pairs =
repalloc(object->
val.object.pairs,
768 object->val.object.pairs[
object->val.object.nPairs].key = *
string;
769 object->val.object.pairs[
object->val.object.nPairs].order =
object->val.object.nPairs;
783 object->val.object.pairs[
object->val.object.nPairs++].value = *scalarVal;
798 (
errcode(ERRCODE_PROGRAM_LIMIT_EXCEEDED),
799 errmsg(
"number of jsonb array elements exceeds the maximum allowed (%zu)",
802 if (array->
val.array.nElems >= pstate->
size)
809 array->
val.array.elems[array->
val.array.nElems++] = *scalarVal;
867 switch ((*it)->state)
872 val->val.array.nElems = (*it)->nElems;
878 val->val.array.rawScalar = (*it)->isScalar;
880 (*it)->curDataOffset = 0;
881 (*it)->curValueOffset = 0;
887 if ((*it)->curIndex >= (*it)->nElems)
900 (*it)->dataProper, (*it)->curDataOffset,
904 (*it)->children[(*it)->curIndex]);
925 val->val.object.nPairs = (*it)->nElems;
932 (*it)->curDataOffset = 0;
940 if ((*it)->curIndex >= (*it)->nElems)
955 (*it)->dataProper, (*it)->curDataOffset,
958 elog(
ERROR,
"unexpected jsonb type as object key");
970 (*it)->dataProper, (*it)->curValueOffset,
974 (*it)->children[(*it)->curIndex]);
976 (*it)->children[(*it)->curIndex + (*it)->nElems]);
1032 elog(
ERROR,
"unknown type of jsonb container");
1106 if (vval.
val.object.nPairs < vcontained.
val.object.nPairs)
1131 vcontained.
val.string.val,
1132 vcontained.
val.string.len,
1149 if (lhsVal->
type != vcontained.
type)
1198 uint32 nLhsElems = vval.
val.array.nElems;
1213 if (vval.
val.array.rawScalar && !vcontained.
val.array.rawScalar)
1246 if (lhsConts == NULL)
1253 for (
i = 0;
i < nLhsElems;
i++)
1260 lhsConts[
j++] = vval;
1272 for (
i = 0;
i < nLhsElems;
i++)
1287 pfree(nestContained);
1303 elog(
ERROR,
"invalid jsonb container type");
1306 elog(
ERROR,
"unexpectedly fell off end of jsonb container");
1323 switch (scalarVal->
type)
1330 scalarVal->
val.string.len));
1338 tmp = scalarVal->
val.boolean ? 0x02 : 0x04;
1342 elog(
ERROR,
"invalid jsonb scalar type");
1366 switch (scalarVal->
type)
1373 scalarVal->
val.string.len,
1387 tmp = scalarVal->
val.boolean ? 0x02 : 0x04;
1391 elog(
ERROR,
"invalid jsonb scalar type");
1405 if (
a->type ==
b->type)
1418 return a->val.boolean ==
b->val.boolean;
1421 elog(
ERROR,
"invalid jsonb scalar type");
1424 elog(
ERROR,
"jsonb scalar type mismatch");
1437 if (
a->type ==
b->type)
1448 DEFAULT_COLLATION_OID);
1454 if (
a->val.boolean ==
b->val.boolean)
1456 else if (
a->val.boolean >
b->val.boolean)
1461 elog(
ERROR,
"invalid jsonb scalar type");
1464 elog(
ERROR,
"jsonb scalar type mismatch");
1488 offset = buffer->
len;
1497 buffer->
data[buffer->
len] =
'\0';
1540 for (p = 0; p < padlen; p++)
1541 buffer->
data[offset + p] =
'\0';
1613 elog(
ERROR,
"unknown type of jsonb container to convert");
1624 int nElems =
val->val.array.nElems;
1627 base_offset = buffer->
len;
1637 if (
val->val.array.rawScalar)
1650 for (
i = 0;
i < nElems;
i++)
1672 (
errcode(ERRCODE_PROGRAM_LIMIT_EXCEEDED),
1673 errmsg(
"total size of jsonb array elements exceeds the maximum of %d bytes",
1683 jentry_offset +=
sizeof(
JEntry);
1687 totallen = buffer->
len - base_offset;
1692 (
errcode(ERRCODE_PROGRAM_LIMIT_EXCEEDED),
1693 errmsg(
"total size of jsonb array elements exceeds the maximum of %d bytes",
1708 int nPairs =
val->val.object.nPairs;
1711 base_offset = buffer->
len;
1731 for (
i = 0;
i < nPairs;
i++)
1753 (
errcode(ERRCODE_PROGRAM_LIMIT_EXCEEDED),
1754 errmsg(
"total size of jsonb object elements exceeds the maximum of %d bytes",
1764 jentry_offset +=
sizeof(
JEntry);
1766 for (
i = 0;
i < nPairs;
i++)
1788 (
errcode(ERRCODE_PROGRAM_LIMIT_EXCEEDED),
1789 errmsg(
"total size of jsonb object elements exceeds the maximum of %d bytes",
1799 jentry_offset +=
sizeof(
JEntry);
1803 totallen = buffer->
len - base_offset;
1808 (
errcode(ERRCODE_PROGRAM_LIMIT_EXCEEDED),
1809 errmsg(
"total size of jsonb object elements exceeds the maximum of %d bytes",
1822 switch (scalarVal->
type)
1831 *header = scalarVal->
val.string.len;
1844 *header = (scalarVal->
val.boolean) ?
1854 scalarVal->
val.datetime.value,
1855 scalarVal->
val.datetime.typid,
1856 &scalarVal->
val.datetime.tz);
1865 elog(
ERROR,
"invalid jsonb scalar type");
1891 vb->
val.string.val, vb->
val.string.len);
1904 return memcmp(val1, val2, len1);
1906 return len1 > len2 ? 1 : -1;
1928 if (
res == 0 && binequal)
1929 *((
bool *) binequal) =
true;
1947 bool hasNonUniq =
false;
1951 if (object->
val.object.nPairs > 1)
1955 if (hasNonUniq && unique_keys)
1957 errcode(ERRCODE_DUPLICATE_JSON_OBJECT_KEY_VALUE),
1958 errmsg(
"duplicate JSON object key value"));
1960 if (hasNonUniq || skip_nulls)
1965 while (skip_nulls && object->
val.object.nPairs > 0 &&
1966 object->
val.object.pairs->value.type ==
jbvNull)
1969 object->val.object.pairs++;
1970 object->val.object.nPairs--;
1973 if (object->
val.object.nPairs > 0)
1975 ptr =
object->val.object.pairs + 1;
1976 res =
object->val.object.pairs;
1978 while (ptr - object->
val.object.pairs < object->
val.object.nPairs)
1991 object->val.object.nPairs =
res + 1 -
object->val.object.pairs;
Datum hash_numeric(PG_FUNCTION_ARGS)
Datum hash_numeric_extended(PG_FUNCTION_ARGS)
Datum numeric_cmp(PG_FUNCTION_ARGS)
Datum numeric_eq(PG_FUNCTION_ARGS)
static void PGresult * res
elog(ERROR, "%s: %s", p2, msg)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
#define DirectFunctionCall2(func, arg1, arg2)
#define DirectFunctionCall1(func, arg1)
Datum difference(PG_FUNCTION_ARGS)
#define ROTATE_HIGH_AND_LOW_32BITS(v)
static Datum hash_any_extended(const unsigned char *k, int keylen, uint64 seed)
static Datum hash_any(const unsigned char *k, int keylen)
Datum hashcharextended(PG_FUNCTION_ARGS)
if(TABLE==NULL||TABLE_index==NULL)
char * JsonEncodeDateTime(char *buf, Datum value, Oid typid, const int *tzp)
#define JsonContainerIsScalar(jc)
#define JsonContainerIsArray(jc)
#define JsonContainerSize(jc)
#define JBE_ISBOOL_TRUE(je_)
#define IsAJsonbScalar(jsonbval)
#define JENTRY_OFFLENMASK
#define JBE_ISNUMERIC(je_)
#define JBE_ISBOOL_FALSE(je_)
#define JENTRY_ISCONTAINER
#define JBE_ISSTRING(je_)
#define JENTRY_ISBOOL_FALSE
#define JBE_OFFLENFLD(je_)
#define JsonContainerIsObject(jc)
#define JENTRY_ISBOOL_TRUE
#define JBE_ISCONTAINER(je_)
#define JBE_ADVANCE_OFFSET(offset, je)
static int lengthCompareJsonbString(const char *val1, int len1, const char *val2, int len2)
static void appendElement(JsonbParseState *pstate, JsonbValue *scalarVal)
JsonbIterator * JsonbIteratorInit(JsonbContainer *container)
static void convertJsonbScalar(StringInfo buffer, JEntry *header, JsonbValue *scalarVal)
Jsonb * JsonbValueToJsonb(JsonbValue *val)
static void convertJsonbObject(StringInfo buffer, JEntry *header, JsonbValue *val, int level)
static int lengthCompareJsonbStringValue(const void *a, const void *b)
static JsonbIterator * iteratorFromContainer(JsonbContainer *container, JsonbIterator *parent)
static void fillJsonbValue(JsonbContainer *container, int index, char *base_addr, uint32 offset, JsonbValue *result)
static void convertJsonbArray(StringInfo buffer, JEntry *header, JsonbValue *val, int level)
static void uniqueifyJsonbObject(JsonbValue *object, bool unique_keys, bool skip_nulls)
static void appendValue(JsonbParseState *pstate, JsonbValue *scalarVal)
static JsonbValue * pushJsonbValueScalar(JsonbParseState **pstate, JsonbIteratorToken seq, JsonbValue *scalarVal)
int compareJsonbContainers(JsonbContainer *a, JsonbContainer *b)
JsonbValue * getIthJsonbValueFromContainer(JsonbContainer *container, uint32 i)
uint32 getJsonbLength(const JsonbContainer *jc, int index)
static short padBufferToInt(StringInfo buffer)
void JsonbHashScalarValue(const JsonbValue *scalarVal, uint32 *hash)
JsonbValue * getKeyJsonValueFromContainer(JsonbContainer *container, const char *keyVal, int keyLen, JsonbValue *res)
static JsonbParseState * pushState(JsonbParseState **pstate)
void JsonbToJsonbValue(Jsonb *jsonb, JsonbValue *val)
static void appendToBuffer(StringInfo buffer, const char *data, int len)
JsonbIteratorToken JsonbIteratorNext(JsonbIterator **it, JsonbValue *val, bool skipNested)
static int compareJsonbScalarValue(JsonbValue *a, JsonbValue *b)
static void copyToBuffer(StringInfo buffer, int offset, const char *data, int len)
JsonbValue * pushJsonbValue(JsonbParseState **pstate, JsonbIteratorToken seq, JsonbValue *jbval)
static void appendKey(JsonbParseState *pstate, JsonbValue *string)
JsonbValue * findJsonbValueFromContainer(JsonbContainer *container, uint32 flags, JsonbValue *key)
static bool equalsJsonbScalarValue(JsonbValue *a, JsonbValue *b)
uint32 getJsonbOffset(const JsonbContainer *jc, int index)
void JsonbHashScalarValueExtended(const JsonbValue *scalarVal, uint64 *hash, uint64 seed)
static Jsonb * convertToJsonb(JsonbValue *val)
static int lengthCompareJsonbPair(const void *a, const void *b, void *binequal)
bool JsonbDeepContains(JsonbIterator **val, JsonbIterator **mContained)
static JsonbIterator * freeAndGetParent(JsonbIterator *it)
static void convertJsonbValue(StringInfo buffer, JEntry *header, JsonbValue *val, int level)
static int reserveFromBuffer(StringInfo buffer, int len)
Assert(fmt[strlen(fmt) - 1] !='\n')
void pfree(void *pointer)
void * palloc0(Size size)
void * repalloc(void *pointer, Size size)
struct NumericData * Numeric
static Datum NumericGetDatum(Numeric X)
static uint32 pg_rotate_left32(uint32 word, int n)
void qsort_arg(void *base, size_t nel, size_t elsize, qsort_arg_comparator cmp, void *arg)
void check_stack_depth(void)
static uint32 DatumGetUInt32(Datum X)
static uint64 DatumGetUInt64(Datum X)
static bool DatumGetBool(Datum X)
static Datum PointerGetDatum(const void *X)
static Datum UInt64GetDatum(uint64 X)
static Datum BoolGetDatum(bool X)
static int32 DatumGetInt32(Datum X)
static unsigned hash(unsigned *uv, int n)
void enlargeStringInfo(StringInfo str, int needed)
void initStringInfo(StringInfo str)
JEntry children[FLEXIBLE_ARRAY_MEMBER]
struct JsonbIterator * parent
JsonbContainer * container
struct JsonbParseState * next
#define SET_VARSIZE(PTR, len)
int varstr_cmp(const char *arg1, int len1, const char *arg2, int len2, Oid collid)