inspect_table()

static void inspect_table ( struct flatgeobuf_agg_ctx *  ctx )

static

Definition at line 69 of file flatgeobuf.c.

{
        flatgeobuf_column *c;
        flatgeobuf_column **columns;
        uint32_t columns_size = 0;
        Oid tupType = HeapTupleHeaderGetTypeId(ctx->row);
        int32 tupTypmod = HeapTupleHeaderGetTypMod(ctx->row);
        TupleDesc tupdesc = lookup_rowtype_tupdesc(tupType, tupTypmod);
        int natts = tupdesc->natts;
        bool geom_found = false;
 
        POSTGIS_DEBUG(2, "calling inspect_table");
 
        columns = palloc(sizeof(flatgeobuf_column *) * natts);
        ctx->tupdesc = tupdesc;
 
        // inspect columns
        // NOTE: last element will be unused if geom attr is found
        for (int i = 0; i < natts; i++) {
                Oid typoid = getBaseType(TupleDescAttr(tupdesc, i)->atttypid);
                const char *key = TupleDescAttr(tupdesc, i)->attname.data;
                POSTGIS_DEBUGF(2, "inspecting column definition for %s with oid %d", key, typoid);
                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(key, ctx->geom_name) == 0) {
                                ctx->geom_index = i;
                                geom_found = true;
                                continue;
                        }
                }
                POSTGIS_DEBUGF(2, "creating column definition for %s with oid %d", key, typoid);
 
                c = (flatgeobuf_column *) palloc0(sizeof(flatgeobuf_column));
                c->name = pstrdup(key);
                c->type = get_column_type(typoid);
                columns[columns_size] = c;
                columns_size++;
        }
 
        if (!geom_found)
                elog(ERROR, "no geom column found");
 
        if (columns_size > 0) {
                ctx->ctx->columns = columns;
                ctx->ctx->columns_size = columns_size;
        }
}

References flatgeobuf_agg_ctx::ctx, flatgeobuf_agg_ctx::geom_index, flatgeobuf_agg_ctx::geom_name, get_column_type(), flatgeobuf_agg_ctx::row, and flatgeobuf_agg_ctx::tupdesc.

Referenced by flatgeobuf_agg_transfn().

Here is the call graph for this function:

Here is the caller graph for this function: