parse_values()

static void parse_values ( mvt_agg_context *  ctx )

static

Definition at line 630 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 (cc.nulls[i])
                {
                        POSTGIS_DEBUG(3, "parse_values isnull detected");
                        continue;
                }
 
#if POSTGIS_PGSQL_VERSION < 110
                key = cc.tupdesc->attrs[i]->attname.data;
#else
                key = cc.tupdesc->attrs[i].attname.data;
#endif
                k = cc.column_keys_index[i];
                typoid = cc.column_oid[i];
 
#if POSTGIS_PGSQL_VERSION >= 94
                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;
                }
#else
                if (k == UINT32_MAX)
                        elog(ERROR, "parse_values: unexpectedly could not find parsed key name '%s'", key);
#endif
 
                switch (typoid)
                {
                case BOOLOID:
                        MVT_PARSE_DATUM(protobuf_c_boolean, mvt_kv_bool_value,
                                bool_values_hash, bool_value,
                                DatumGetBool, sizeof(protobuf_c_boolean));
                        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, mvt_kv_float_value,
                                float_values_hash, float_value,
                                DatumGetFloat4, sizeof(float));
                        break;
                case FLOAT8OID:
                        MVT_PARSE_DATUM(double, mvt_kv_double_value,
                                double_values_hash, double_value,
                                DatumGetFloat8, sizeof(double));
                        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 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::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, 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: