jsonb_plperl.c File Reference

#include "postgres.h"
#include <math.h>
#include "fmgr.h"
#include "plperl.h"
#include "utils/fmgrprotos.h"
#include "utils/jsonb.h"

Include dependency graph for jsonb_plperl.c:

Go to the source code of this file.

Functions
static SV *	Jsonb_to_SV (JsonbContainer *jsonb)
static JsonbValue *	SV_to_JsonbValue (SV *obj, JsonbParseState **ps, bool is_elem)
static SV *	JsonbValue_to_SV (JsonbValue *jbv)
static JsonbValue *	AV_to_JsonbValue (AV *in, JsonbParseState **jsonb_state)
static JsonbValue *	HV_to_JsonbValue (HV *obj, JsonbParseState **jsonb_state)
	PG_FUNCTION_INFO_V1 (jsonb_to_plperl)
Datum	jsonb_to_plperl (PG_FUNCTION_ARGS)
	PG_FUNCTION_INFO_V1 (plperl_to_jsonb)
Datum	plperl_to_jsonb (PG_FUNCTION_ARGS)

Variables
	PG_MODULE_MAGIC

Function Documentation

AV_to_JsonbValue()

static JsonbValue* AV_to_JsonbValue ( AV *  in, JsonbParseState **  jsonb_state  )

static

Definition at line 128 of file jsonb_plperl.c.

{
    dTHX;
    SSize_t     pcount = av_len(in) + 1;
    SSize_t     i;
 
    pushJsonbValue(jsonb_state, WJB_BEGIN_ARRAY, NULL);
 
    for (i = 0; i < pcount; i++)
    {
        SV        **value = av_fetch(in, i, FALSE);
 
        if (value)
            (void) SV_to_JsonbValue(*value, jsonb_state, true);
    }
 
    return pushJsonbValue(jsonb_state, WJB_END_ARRAY, NULL);
}

References dTHX, i, pushJsonbValue(), SV_to_JsonbValue(), value, WJB_BEGIN_ARRAY, and WJB_END_ARRAY.

Referenced by SV_to_JsonbValue().

HV_to_JsonbValue()

static JsonbValue* HV_to_JsonbValue ( HV *  obj, JsonbParseState **  jsonb_state  )

static

Definition at line 148 of file jsonb_plperl.c.

{
    dTHX;
    JsonbValue  key;
    SV         *val;
    char       *kstr;
    I32         klen;
 
    key.type = jbvString;
 
    pushJsonbValue(jsonb_state, WJB_BEGIN_OBJECT, NULL);
 
    (void) hv_iterinit(obj);
 
    while ((val = hv_iternextsv(obj, &kstr, &klen)))
    {
        key.val.string.val = pnstrdup(kstr, klen);
        key.val.string.len = klen;
        pushJsonbValue(jsonb_state, WJB_KEY, &key);
        (void) SV_to_JsonbValue(val, jsonb_state, false);
    }
 
    return pushJsonbValue(jsonb_state, WJB_END_OBJECT, NULL);
}

References dTHX, jbvString, sort-test::key, pnstrdup(), pushJsonbValue(), SV_to_JsonbValue(), val, WJB_BEGIN_OBJECT, WJB_END_OBJECT, and WJB_KEY.

Referenced by SV_to_JsonbValue().

jsonb_to_plperl()

Datum jsonb_to_plperl

(

PG_FUNCTION_ARGS

)

Definition at line 273 of file jsonb_plperl.c.

{
    dTHX;
    Jsonb      *in = PG_GETARG_JSONB_P(0);
    SV         *sv = Jsonb_to_SV(&in->root);
 
    return PointerGetDatum(sv);
}

References dTHX, Jsonb_to_SV(), PG_GETARG_JSONB_P, PointerGetDatum(), and Jsonb::root.

Jsonb_to_SV()

static SV * Jsonb_to_SV ( JsonbContainer *  jsonb )

static

Definition at line 59 of file jsonb_plperl.c.

{
    dTHX;
    JsonbValue  v;
    JsonbIterator *it;
    JsonbIteratorToken r;
 
    it = JsonbIteratorInit(jsonb);
    r = JsonbIteratorNext(&it, &v, true);
 
    switch (r)
    {
        case WJB_BEGIN_ARRAY:
            if (v.val.array.rawScalar)
            {
                JsonbValue  tmp;
 
                if ((r = JsonbIteratorNext(&it, &v, true)) != WJB_ELEM ||
                    (r = JsonbIteratorNext(&it, &tmp, true)) != WJB_END_ARRAY ||
                    (r = JsonbIteratorNext(&it, &tmp, true)) != WJB_DONE)
                    elog(ERROR, "unexpected jsonb token: %d", r);
 
                return JsonbValue_to_SV(&v);
            }
            else
            {
                AV         *av = newAV();
 
                while ((r = JsonbIteratorNext(&it, &v, true)) != WJB_DONE)
                {
                    if (r == WJB_ELEM)
                        av_push(av, JsonbValue_to_SV(&v));
                }
 
                return newRV((SV *) av);
            }
 
        case WJB_BEGIN_OBJECT:
            {
                HV         *hv = newHV();
 
                while ((r = JsonbIteratorNext(&it, &v, true)) != WJB_DONE)
                {
                    if (r == WJB_KEY)
                    {
                        /* json key in v, json value in val */
                        JsonbValue  val;
 
                        if (JsonbIteratorNext(&it, &val, true) == WJB_VALUE)
                        {
                            SV         *value = JsonbValue_to_SV(&val);
 
                            (void) hv_store(hv,
                                            v.val.string.val, v.val.string.len,
                                            value, 0);
                        }
                    }
                }
 
                return newRV((SV *) hv);
            }
 
        default:
            elog(ERROR, "unexpected jsonb token: %d", r);
            return NULL;
    }
}

References av, dTHX, elog, ERROR, JsonbIteratorInit(), JsonbIteratorNext(), JsonbValue_to_SV(), JsonbValue::val, val, value, WJB_BEGIN_ARRAY, WJB_BEGIN_OBJECT, WJB_DONE, WJB_ELEM, WJB_END_ARRAY, WJB_KEY, and WJB_VALUE.

Referenced by jsonb_to_plperl(), and JsonbValue_to_SV().

JsonbValue_to_SV()

static SV* JsonbValue_to_SV ( JsonbValue *  jbv )

static

Definition at line 17 of file jsonb_plperl.c.

{
    dTHX;
 
    switch (jbv->type)
    {
        case jbvBinary:
            return Jsonb_to_SV(jbv->val.binary.data);
 
        case jbvNumeric:
            {
                char       *str = DatumGetCString(DirectFunctionCall1(numeric_out,
                                                                      NumericGetDatum(jbv->val.numeric)));
                SV         *result = newSVnv(SvNV(cstr2sv(str)));
 
                pfree(str);
                return result;
            }
 
        case jbvString:
            {
                char       *str = pnstrdup(jbv->val.string.val,
                                           jbv->val.string.len);
                SV         *result = cstr2sv(str);
 
                pfree(str);
                return result;
            }
 
        case jbvBool:
            return newSVnv(SvNV(jbv->val.boolean ? &PL_sv_yes : &PL_sv_no));
 
        case jbvNull:
            return newSV(0);
 
        default:
            elog(ERROR, "unexpected jsonb value type: %d", jbv->type);
            return NULL;
    }
}

References cstr2sv(), DatumGetCString(), DirectFunctionCall1, dTHX, elog, ERROR, jbvBinary, jbvBool, jbvNull, jbvNumeric, jbvString, Jsonb_to_SV(), numeric_out(), NumericGetDatum(), pfree(), PL_sv_no, PL_sv_yes, pnstrdup(), str, JsonbValue::type, and JsonbValue::val.

Referenced by Jsonb_to_SV().

PG_FUNCTION_INFO_V1() [1/2]

PG_FUNCTION_INFO_V1

(

jsonb_to_plperl

)

PG_FUNCTION_INFO_V1() [2/2]

PG_FUNCTION_INFO_V1

(

plperl_to_jsonb

)

plperl_to_jsonb()

Datum plperl_to_jsonb

(

PG_FUNCTION_ARGS

)

Definition at line 286 of file jsonb_plperl.c.

{
    dTHX;
    JsonbParseState *jsonb_state = NULL;
    SV         *in = (SV *) PG_GETARG_POINTER(0);
    JsonbValue *out = SV_to_JsonbValue(in, &jsonb_state, true);
    Jsonb      *result = JsonbValueToJsonb(out);
 
    PG_RETURN_JSONB_P(result);
}

References dTHX, JsonbValueToJsonb(), PG_GETARG_POINTER, PG_RETURN_JSONB_P, and SV_to_JsonbValue().

SV_to_JsonbValue()

static JsonbValue * SV_to_JsonbValue ( SV *  obj, JsonbParseState **  ps, bool  is_elem  )

static

Definition at line 174 of file jsonb_plperl.c.

{
    dTHX;
    JsonbValue  out;            /* result */
 
    /* Dereference references recursively. */
    while (SvROK(in))
        in = SvRV(in);
 
    switch (SvTYPE(in))
    {
        case SVt_PVAV:
            return AV_to_JsonbValue((AV *) in, jsonb_state);
 
        case SVt_PVHV:
            return HV_to_JsonbValue((HV *) in, jsonb_state);
 
        default:
            if (!SvOK(in))
            {
                out.type = jbvNull;
            }
            else if (SvUOK(in))
            {
                /*
                 * If UV is >=64 bits, we have no better way to make this
                 * happen than converting to text and back.  Given the low
                 * usage of UV in Perl code, it's not clear it's worth working
                 * hard to provide alternate code paths.
                 */
                const char *strval = SvPV_nolen(in);
 
                out.type = jbvNumeric;
                out.val.numeric =
                    DatumGetNumeric(DirectFunctionCall3(numeric_in,
                                                        CStringGetDatum(strval),
                                                        ObjectIdGetDatum(InvalidOid),
                                                        Int32GetDatum(-1)));
            }
            else if (SvIOK(in))
            {
                IV          ival = SvIV(in);
 
                out.type = jbvNumeric;
                out.val.numeric = int64_to_numeric(ival);
            }
            else if (SvNOK(in))
            {
                double      nval = SvNV(in);
 
                /*
                 * jsonb doesn't allow infinity or NaN (per JSON
                 * specification), but the numeric type that is used for the
                 * storage accepts those, so we have to reject them here
                 * explicitly.
                 */
                if (isinf(nval))
                    ereport(ERROR,
                            (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
                             errmsg("cannot convert infinity to jsonb")));
                if (isnan(nval))
                    ereport(ERROR,
                            (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
                             errmsg("cannot convert NaN to jsonb")));
 
                out.type = jbvNumeric;
                out.val.numeric =
                    DatumGetNumeric(DirectFunctionCall1(float8_numeric,
                                                        Float8GetDatum(nval)));
            }
            else if (SvPOK(in))
            {
                out.type = jbvString;
                out.val.string.val = sv2cstr(in);
                out.val.string.len = strlen(out.val.string.val);
            }
            else
            {
                /*
                 * XXX It might be nice if we could include the Perl type in
                 * the error message.
                 */
                ereport(ERROR,
                        (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
                         errmsg("cannot transform this Perl type to jsonb")));
                return NULL;
            }
    }
 
    /* Push result into 'jsonb_state' unless it is a raw scalar. */
    return *jsonb_state
        ? pushJsonbValue(jsonb_state, is_elem ? WJB_ELEM : WJB_VALUE, &out)
        : memcpy(palloc(sizeof(JsonbValue)), &out, sizeof(JsonbValue));
}

References AV_to_JsonbValue(), CStringGetDatum(), DatumGetNumeric(), DirectFunctionCall1, DirectFunctionCall3, dTHX, ereport, errcode(), errmsg(), ERROR, float8_numeric(), Float8GetDatum(), HV_to_JsonbValue(), Int32GetDatum(), int64_to_numeric(), InvalidOid, jbvNull, jbvNumeric, jbvString, numeric_in(), ObjectIdGetDatum(), palloc(), pushJsonbValue(), sv2cstr(), SvPV_nolen, JsonbValue::type, JsonbValue::val, WJB_ELEM, and WJB_VALUE.

Referenced by AV_to_JsonbValue(), HV_to_JsonbValue(), and plperl_to_jsonb().

Variable Documentation

PG_MODULE_MAGIC

PG_MODULE_MAGIC

Definition at line 10 of file jsonb_plperl.c.