parse_values()

static void parse_values ( mvt_agg_context *  ctx, struct feature_builder *  feature  )

static

Definition at line 669 of file mvt.c.

{
        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");
 
        /* 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, feature, 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)
                {
                        parse_jsonb(ctx, feature, DatumGetJsonbP(datum));
                        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, feature, text_to_cstring(DatumGetTextP(datum)), k);
                        break;
                case CSTRINGOID:
                        add_value_as_string(ctx, feature, DatumGetCString(datum), k);
                        break;
                default:
                        parse_datum_as_string(ctx, feature, typoid, datum, k);
                        break;
                }
        }
}

References add_value_as_string(), mvt_agg_context::column_cache, mvt_column_cache::column_keys_index, mvt_column_cache::column_oid, mvt_agg_context::geom_index, mvt_agg_context::id_index, MVT_PARSE_DATUM, MVT_PARSE_INT_DATUM, mvt_column_cache::nulls, parse_datum_as_string(), parse_jsonb(), mvt_agg_context::row, 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: