parse_values()

static void parse_values ( mvt_agg_context *  ctx )

static

Definition at line 632 of file mvt.c.

{
        uint32_t n_keys = ctx->keys_hash_i;
        uint32_t *tags = palloc(n_keys * 2 * sizeof(*tags));
        uint32_t i;
        mvt_column_cache cc = ctx->column_cache;
        uint32_t natts = (uint32_t) cc.tupdesc->natts;
 
        HeapTupleData tuple;
 
        POSTGIS_DEBUG(2, "parse_values called");
        ctx->row_columns = 0;
 
        /* Build a temporary HeapTuple control structure */
        tuple.t_len = HeapTupleHeaderGetDatumLength(ctx->row);
        ItemPointerSetInvalid(&(tuple.t_self));
        tuple.t_tableOid = InvalidOid;
        tuple.t_data = ctx->row;
 
        /* We use heap_deform_tuple as it costs only O(N) vs O(N^2) of GetAttributeByNum */
        heap_deform_tuple(&tuple, cc.tupdesc, cc.values, cc.nulls);
 
        POSTGIS_DEBUGF(3, "parse_values natts: %d", natts);
 
        for (i = 0; i < natts; i++)
        {
                char *key;
                Oid typoid;
                uint32_t k;
                Datum datum = cc.values[i];
 
                if (i == ctx->geom_index)
                        continue;
 
                if (i == ctx->id_index)
                {
                        set_feature_id(ctx, datum, cc.nulls[i]);
                        continue;
                }
 
                if (cc.nulls[i])
                {
                        POSTGIS_DEBUG(3, "parse_values isnull detected");
                        continue;
                }
 
                key = TupleDescAttr(cc.tupdesc, i)->attname.data;
                k = cc.column_keys_index[i];
                typoid = cc.column_oid[i];
 
                if (k == UINT32_MAX && typoid != JSONBOID)
                        elog(ERROR, "parse_values: unexpectedly could not find parsed key name '%s'", key);
                if (typoid == JSONBOID)
                {
                        tags = parse_jsonb(ctx, DatumGetJsonbP(datum), tags);
                        continue;
                }
 
                switch (typoid)
                {
                case BOOLOID:
                        MVT_PARSE_DATUM(protobuf_c_boolean,
                                        DatumGetBool,
                                        bool_values_hash,
                                        sizeof(protobuf_c_boolean),
                                        bool_value,
                                        VECTOR_TILE__TILE__VALUE__TEST_ONEOF_BOOL_VALUE);
                        break;
                case INT2OID:
                        MVT_PARSE_INT_DATUM(int16_t, DatumGetInt16);
                        break;
                case INT4OID:
                        MVT_PARSE_INT_DATUM(int32_t, DatumGetInt32);
                        break;
                case INT8OID:
                        MVT_PARSE_INT_DATUM(int64_t, DatumGetInt64);
                        break;
                case FLOAT4OID:
                        MVT_PARSE_DATUM(float,
                                        DatumGetFloat4,
                                        float_values_hash,
                                        sizeof(float),
                                        float_value,
                                        VECTOR_TILE__TILE__VALUE__TEST_ONEOF_FLOAT_VALUE);
                        break;
                case FLOAT8OID:
                        MVT_PARSE_DATUM(double,
                                        DatumGetFloat8,
                                        double_values_hash,
                                        sizeof(double),
                                        double_value,
                                        VECTOR_TILE__TILE__VALUE__TEST_ONEOF_DOUBLE_VALUE);
                        break;
                case TEXTOID:
                        add_value_as_string(ctx, text_to_cstring(DatumGetTextP(datum)), tags, k);
                        break;
                case CSTRINGOID:
                        add_value_as_string(ctx, DatumGetCString(datum), tags, k);
                        break;
                default:
                        parse_datum_as_string(ctx, typoid, datum, tags, k);
                        break;
                }
 
                ctx->row_columns++;
        }
 
 
        ctx->feature->n_tags = ctx->row_columns * 2;
        ctx->feature->tags = tags;
 
        POSTGIS_DEBUGF(3, "parse_values n_tags %zd", ctx->feature->n_tags);
}

References add_value_as_string(), mvt_agg_context::column_cache, mvt_column_cache::column_keys_index, mvt_column_cache::column_oid, DatumGetJsonbP, mvt_agg_context::feature, mvt_agg_context::geom_index, mvt_agg_context::id_index, mvt_agg_context::keys_hash_i, MVT_PARSE_DATUM, MVT_PARSE_INT_DATUM, mvt_column_cache::nulls, parse_datum_as_string(), parse_jsonb(), mvt_agg_context::row, mvt_agg_context::row_columns, set_feature_id(), mvt_column_cache::tupdesc, UINT32_MAX, and mvt_column_cache::values.

Referenced by mvt_agg_transfn().

Here is the call graph for this function:

Here is the caller graph for this function: