parse_jsonb()

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

static

Definition at line 492 of file mvt.c.

References add_key(), add_value_as_string(), mvt_agg_context::c, FP_NEQUALS, get_key_index(), mvt_agg_context::keys_hash_i, MVT_PARSE_INT_VALUE, MVT_PARSE_VALUE, r, and genraster::value.

Referenced by parse_values().

{
        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) {
                        char *key;
                        key = palloc(v.val.string.len + 1 * sizeof(char));
                        memcpy(key, v.val.string.val, v.val.string.len);
                        key[v.val.string.len] = '\0';

                        k = get_key_index(ctx, key);
                        if (k == -1) {
                                uint32_t newSize = ctx->keys_hash_i + 1;
                                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 * sizeof(char));
                                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->c++;
                        } 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->c++;
                        } else if (v.type == jbvNumeric) {
                                char *str;
                                str = DatumGetCString(DirectFunctionCall1(numeric_out,
                                        PointerGetDatum(v.val.numeric)));
                                double d = strtod(str, NULL);
                                long l = strtol(str, NULL, 10);
                                if (FP_NEQUALS(d, (double)l)) {
                                        MVT_PARSE_VALUE(d, mvt_kv_double_value, double_values_hash,
                                                double_value, sizeof(double));
                                } else {
                                        MVT_PARSE_INT_VALUE(l);
                                }
                                ctx->c++;
                        }
                }
        }

        return tags;
}

Here is the call graph for this function:

Here is the caller graph for this function: