encode_properties()

static void encode_properties ( flatgeobuf_agg_ctx *  ctx )

static

Definition at line 153 of file flatgeobuf.c.

{
        uint16_t ci = 0;
        size_t offset = 0;
        Datum datum;
        bool isnull;
        Oid typoid;
        uint32_t len;
        uint32_t i;
 
        uint8_t byte_value;
        int16_t short_value;
        int32_t int_value;
        int64_t long_value;
        float float_value;
        double double_value;
        char *string_value;
 
        //Jsonb *jb;
 
        for (i = 0; i < (uint32_t) ctx->tupdesc->natts; i++) {
                if (ctx->geom_index == i)
                        continue;
                datum = GetAttributeByNum(ctx->row, i + 1, &isnull);
                if (isnull)
                        continue;
                ensure_properties_size(ctx, offset + sizeof(ci));
                memcpy(ctx->ctx->properties + offset, &ci, sizeof(ci));
                offset += sizeof(ci);
                typoid = getBaseType(TupleDescAttr(ctx->tupdesc, i)->atttypid);
                switch (typoid) {
                case BOOLOID:
                        byte_value = DatumGetBool(datum) ? 1 : 0;
                        ensure_properties_size(ctx, offset + sizeof(byte_value));
                        memcpy(ctx->ctx->properties + offset, &byte_value, sizeof(byte_value));
                        offset += sizeof(byte_value);
                        break;
                case INT2OID:
                        short_value = DatumGetInt16(datum);
                        ensure_properties_size(ctx, offset + sizeof(short_value));
                        memcpy(ctx->ctx->properties + offset, &short_value, sizeof(short_value));
                        offset += sizeof(short_value);
                        break;
                case INT4OID:
                        int_value = DatumGetInt32(datum);
                        ensure_properties_size(ctx, offset + sizeof(int_value));
                        memcpy(ctx->ctx->properties + offset, &int_value, sizeof(int_value));
                        offset += sizeof(int_value);
                        break;
                case INT8OID:
                        long_value = DatumGetInt64(datum);
                        ensure_properties_size(ctx, offset + sizeof(long_value));
                        memcpy(ctx->ctx->properties + offset, &long_value, sizeof(long_value));
                        offset += sizeof(long_value);
                        break;
                case FLOAT4OID:
                        float_value = DatumGetFloat4(datum);
                        ensure_properties_size(ctx, offset + sizeof(float_value));
                        memcpy(ctx->ctx->properties + offset, &float_value, sizeof(float_value));
                        offset += sizeof(float_value);
                        break;
                case FLOAT8OID:
                        double_value = DatumGetFloat8(datum);
                        ensure_properties_size(ctx, offset + sizeof(double_value));
                        memcpy(ctx->ctx->properties + offset, &double_value, sizeof(double_value));
                        offset += sizeof(double_value);
                        break;
                case TEXTOID:
                        string_value = text_to_cstring(DatumGetTextP(datum));
                        len = strlen(string_value);
                        ensure_properties_size(ctx, offset + sizeof(len));
                        memcpy(ctx->ctx->properties + offset, &len, sizeof(len));
                        offset += sizeof(len);
                        ensure_properties_size(ctx, offset + len);
                        memcpy(ctx->ctx->properties + offset, string_value, len);
                        offset += len;
                        break;
                case TIMESTAMPTZOID: {
                        struct pg_tm tm;
                        fsec_t fsec;
                        int tz;
                        const char *tzn = NULL;
                        TimestampTz timestamp;
                        timestamp = DatumGetTimestampTz(datum);
                        timestamp2tm(timestamp, &tz, &tm, &fsec, &tzn, NULL);
                        string_value = palloc(MAXDATELEN + 1);
                        EncodeDateTime(&tm, fsec, true, tz, tzn, USE_ISO_DATES, string_value);
                        len = strlen(string_value);
                        ensure_properties_size(ctx, offset + sizeof(len));
                        memcpy(ctx->ctx->properties + offset, &len, sizeof(len));
                        offset += sizeof(len);
                        ensure_properties_size(ctx, offset + len);
                        memcpy(ctx->ctx->properties + offset, string_value, len);
                        offset += len;
                        break;
                }
                // TODO: handle date/time types
                // case JSONBOID:
                //      jb = DatumGetJsonbP(datum);
                //      string_value = JsonbToCString(NULL, &jb->root, VARSIZE(jb));
                //      len = strlen(string_value);
                //      memcpy(data + offset, &len, sizeof(len));
                //      offset += sizeof(len);
                //      memcpy(data + offset, string_value, len);
                //      offset += len;
                //      break;
                }
                ci++;
        }
 
        if (offset > 0) {
                POSTGIS_DEBUGF(3, "offset %ld", offset);
                ctx->ctx->properties_len = offset;
        }
}

References flatgeobuf_agg_ctx::ctx, ensure_properties_size(), flatgeobuf_agg_ctx::geom_index, 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: