PostGIS  3.1.6dev-r@@SVN_REVISION@@

◆ parse_values()

static void parse_values ( mvt_agg_context ctx)
static

Definition at line 630 of file mvt.c.

631 {
632  uint32_t n_keys = ctx->keys_hash_i;
633  uint32_t *tags = palloc(n_keys * 2 * sizeof(*tags));
634  uint32_t i;
635  mvt_column_cache cc = ctx->column_cache;
636  uint32_t natts = (uint32_t) cc.tupdesc->natts;
637 
638  HeapTupleData tuple;
639 
640  POSTGIS_DEBUG(2, "parse_values called");
641  ctx->row_columns = 0;
642 
643  /* Build a temporary HeapTuple control structure */
644  tuple.t_len = HeapTupleHeaderGetDatumLength(ctx->row);
645  ItemPointerSetInvalid(&(tuple.t_self));
646  tuple.t_tableOid = InvalidOid;
647  tuple.t_data = ctx->row;
648 
649  /* We use heap_deform_tuple as it costs only O(N) vs O(N^2) of GetAttributeByNum */
650  heap_deform_tuple(&tuple, cc.tupdesc, cc.values, cc.nulls);
651 
652  POSTGIS_DEBUGF(3, "parse_values natts: %d", natts);
653 
654  for (i = 0; i < natts; i++)
655  {
656  char *key;
657  Oid typoid;
658  uint32_t k;
659  Datum datum = cc.values[i];
660 
661  if (i == ctx->geom_index)
662  continue;
663 
664  if (i == ctx->id_index)
665  {
666  set_feature_id(ctx, datum, cc.nulls[i]);
667  continue;
668  }
669 
670  if (cc.nulls[i])
671  {
672  POSTGIS_DEBUG(3, "parse_values isnull detected");
673  continue;
674  }
675 
676  key = TupleDescAttr(cc.tupdesc, i)->attname.data;
677  k = cc.column_keys_index[i];
678  typoid = cc.column_oid[i];
679 
680  if (k == UINT32_MAX && typoid != JSONBOID)
681  elog(ERROR, "parse_values: unexpectedly could not find parsed key name '%s'", key);
682  if (typoid == JSONBOID)
683  {
684  tags = parse_jsonb(ctx, DatumGetJsonbP(datum), tags);
685  continue;
686  }
687 
688  switch (typoid)
689  {
690  case BOOLOID:
691  MVT_PARSE_DATUM(protobuf_c_boolean,
692  DatumGetBool,
693  bool_values_hash,
694  sizeof(protobuf_c_boolean),
695  bool_value,
696  VECTOR_TILE__TILE__VALUE__TEST_ONEOF_BOOL_VALUE);
697  break;
698  case INT2OID:
699  MVT_PARSE_INT_DATUM(int16_t, DatumGetInt16);
700  break;
701  case INT4OID:
702  MVT_PARSE_INT_DATUM(int32_t, DatumGetInt32);
703  break;
704  case INT8OID:
705  MVT_PARSE_INT_DATUM(int64_t, DatumGetInt64);
706  break;
707  case FLOAT4OID:
708  MVT_PARSE_DATUM(float,
709  DatumGetFloat4,
710  float_values_hash,
711  sizeof(float),
712  float_value,
713  VECTOR_TILE__TILE__VALUE__TEST_ONEOF_FLOAT_VALUE);
714  break;
715  case FLOAT8OID:
716  MVT_PARSE_DATUM(double,
717  DatumGetFloat8,
718  double_values_hash,
719  sizeof(double),
720  double_value,
721  VECTOR_TILE__TILE__VALUE__TEST_ONEOF_DOUBLE_VALUE);
722  break;
723  case TEXTOID:
724  add_value_as_string(ctx, text_to_cstring(DatumGetTextP(datum)), tags, k);
725  break;
726  case CSTRINGOID:
727  add_value_as_string(ctx, DatumGetCString(datum), tags, k);
728  break;
729  default:
730  parse_datum_as_string(ctx, typoid, datum, tags, k);
731  break;
732  }
733 
734  ctx->row_columns++;
735  }
736 
737 
738  ctx->feature->n_tags = ctx->row_columns * 2;
739  ctx->feature->tags = tags;
740 
741  POSTGIS_DEBUGF(3, "parse_values n_tags %zd", ctx->feature->n_tags);
742 }
#define UINT32_MAX
Definition: lwin_wkt_lex.c:343
static void parse_datum_as_string(mvt_agg_context *ctx, Oid typoid, Datum datum, uint32_t *tags, uint32_t k)
Definition: mvt.c:495
#define MVT_PARSE_DATUM(type, datumfunc, hash, size, pfvaluefield, pftype)
Definition: mvt.c:445
static void set_feature_id(mvt_agg_context *ctx, Datum datum, bool isNull)
Sets the feature id.
Definition: mvt.c:594
#define MVT_PARSE_INT_DATUM(type, datumfunc)
Definition: mvt.c:451
static uint32_t * parse_jsonb(mvt_agg_context *ctx, Jsonb *jb, uint32_t *tags)
Definition: mvt.c:507
#define DatumGetJsonbP
Definition: mvt.c:39
static void add_value_as_string(mvt_agg_context *ctx, char *value, uint32_t *tags, uint32_t k)
Definition: mvt.c:486
uint32_t geom_index
Definition: mvt.h:72
uint32_t keys_hash_i
Definition: mvt.h:94
VectorTile__Tile__Feature * feature
Definition: mvt.h:75
uint32_t id_index
Definition: mvt.h:68
HeapTupleHeader row
Definition: mvt.h:74
mvt_column_cache column_cache
Definition: mvt.h:97
uint32_t row_columns
Definition: mvt.h:96
bool * nulls
Definition: mvt.h:53
TupleDesc tupdesc
Definition: mvt.h:54
uint32_t * column_keys_index
Definition: mvt.h:50
Datum * values
Definition: mvt.h:52
uint32_t * column_oid
Definition: mvt.h:51

References add_value_as_string(), 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::id_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, 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: