parse_jsonb()

static uint32_t * parse_jsonb ( mvt_agg_context *  ctx, Jsonb *  jb, uint32_t *  tags  )

static

Definition at line 563 of file mvt.c.

{
        JsonbIterator *it;
        JsonbValue v;
        bool skipNested = false;
        JsonbIteratorToken r;
        uint32_t k;
 
        if (!JB_ROOT_IS_OBJECT(jb))
                return tags;
 
        it = JsonbIteratorInit(&jb->root);
 
        while ((r = JsonbIteratorNext(&it, &v, skipNested)) != WJB_DONE)
        {
                skipNested = true;
 
                if (r == WJB_KEY && v.type != jbvNull)
                {
 
                        k = get_key_index_with_size(ctx, v.val.string.val, v.val.string.len);
                        if (k == UINT32_MAX)
                        {
                                char *key;
                                uint32_t newSize = ctx->keys_hash_i + 1;
 
                                key = palloc(v.val.string.len + 1);
                                memcpy(key, v.val.string.val, v.val.string.len);
                                key[v.val.string.len] = '\0';
 
                                tags = repalloc(tags, newSize * 2 * sizeof(*tags));
                                k = add_key(ctx, key);
                        }
 
                        r = JsonbIteratorNext(&it, &v, skipNested);
 
                        if (v.type == jbvString)
                        {
                                char *value;
                                value = palloc(v.val.string.len + 1);
                                memcpy(value, v.val.string.val, v.val.string.len);
                                value[v.val.string.len] = '\0';
                                add_value_as_string(ctx, value, tags, k);
                                ctx->row_columns++;
                        }
                        else if (v.type == jbvBool)
                        {
                                MVT_PARSE_VALUE(v.val.boolean, mvt_kv_bool_value,
                                        bool_values_hash, bool_value, sizeof(protobuf_c_boolean));
                                ctx->row_columns++;
                        }
                        else if (v.type == jbvNumeric)
                        {
                                char *str;
                                double d;
                                long l;
                                str = DatumGetCString(DirectFunctionCall1(numeric_out,
                                        PointerGetDatum(v.val.numeric)));
                                d = strtod(str, NULL);
                                l = strtol(str, NULL, 10);
 
                                if (fabs(d - (double)l) > FLT_EPSILON)
                                {
                                        MVT_PARSE_VALUE(d, mvt_kv_double_value, double_values_hash,
                                                double_value, sizeof(double));
                                }
                                else
                                {
                                        MVT_PARSE_INT_VALUE(l);
                                }
                                ctx->row_columns++;
                        }
                }
        }
 
        return tags;
}

References add_key(), add_value_as_string(), get_key_index_with_size(), mvt_agg_context::keys_hash_i, MVT_PARSE_INT_VALUE, MVT_PARSE_VALUE, r, mvt_agg_context::row_columns, str, and UINT32_MAX.

Referenced by parse_values().

Here is the call graph for this function:

Here is the caller graph for this function: