parse_column_keys()

static void parse_column_keys ( mvt_agg_context *  ctx )

static

Definition at line 336 of file mvt.c.

{
        uint32_t i, natts;
        bool geom_found = false;
 
        POSTGIS_DEBUG(2, "parse_column_keys called");
 
        ctx->column_cache.tupdesc = get_tuple_desc(ctx);
        natts = ctx->column_cache.tupdesc->natts;
 
        ctx->column_cache.column_keys_index = palloc(sizeof(uint32_t) * natts);
        ctx->column_cache.column_oid = palloc(sizeof(uint32_t) * natts);
        ctx->column_cache.values = palloc(sizeof(Datum) * natts);
        ctx->column_cache.nulls = palloc(sizeof(bool) * natts);
 
        for (i = 0; i < natts; i++)
        {
                Oid typoid = getBaseType(TupleDescAttr(ctx->column_cache.tupdesc, i)->atttypid);
                char *tkey = TupleDescAttr(ctx->column_cache.tupdesc, i)->attname.data;
 
                ctx->column_cache.column_oid[i] = typoid;
 
                if (typoid == JSONBOID)
                {
                        ctx->column_cache.column_keys_index[i] = UINT32_MAX;
                        continue;
                }
 
                if (ctx->geom_name == NULL)
                {
                        if (!geom_found && typoid == postgis_oid(GEOMETRYOID))
                        {
                                ctx->geom_index = i;
                                geom_found = true;
                                continue;
                        }
                }
                else
                {
                        if (!geom_found && strcmp(tkey, ctx->geom_name) == 0)
                        {
                                ctx->geom_index = i;
                                geom_found = true;
                                continue;
                        }
                }
 
                if (ctx->id_name &&
                        (ctx->id_index == UINT32_MAX) &&
                        (strcmp(tkey, ctx->id_name) == 0) &&
                        (typoid == INT2OID || typoid == INT4OID || typoid == INT8OID))
                {
                        ctx->id_index = i;
                }
                else
                {
                        ctx->column_cache.column_keys_index[i] = add_key(ctx, pstrdup(tkey));
                }
        }
 
        if (!geom_found)
                elog(ERROR, "parse_column_keys: no geometry column found");
 
        if (ctx->id_name != NULL && ctx->id_index == UINT32_MAX)
                elog(ERROR, "mvt_agg_transfn: Could not find column '%s' of integer type", ctx->id_name);
}

References add_key(), mvt_agg_context::column_cache, mvt_column_cache::column_keys_index, mvt_column_cache::column_oid, mvt_agg_context::geom_index, mvt_agg_context::geom_name, get_tuple_desc(), mvt_agg_context::id_index, mvt_agg_context::id_name, mvt_column_cache::nulls, 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: