parse_jsonb()

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

static

Definition at line 507 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 = 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(bool_values_hash,
                                                v.val.boolean,
                                                sizeof(protobuf_c_boolean),
                                                bool_value,
                                                VECTOR_TILE__TILE__VALUE__TEST_ONEOF_BOOL_VALUE);
                                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(double_values_hash,
                                                        d,
                                                        sizeof(double),
                                                        double_value,
                                                        VECTOR_TILE__TILE__VALUE__TEST_ONEOF_DOUBLE_VALUE);
                                }
                                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, UINT32_MAX, and genraster::value.

Referenced by parse_values().

Here is the call graph for this function:

Here is the caller graph for this function: