diff --git a/src/pg/sql/41_observatory_augmentation.sql b/src/pg/sql/41_observatory_augmentation.sql index 0a6a043..ac3472e 100644 --- a/src/pg/sql/41_observatory_augmentation.sql +++ b/src/pg/sql/41_observatory_augmentation.sql @@ -837,19 +837,11 @@ BEGIN USING (SELECT ARRAY(SELECT json_array_elements_text(params))::json[]); RETURN QUERY EXECUTE format($query$ - WITH _geoms AS ( - SELECT - (UNNEST($1)).val as id, - (UNNEST($1)).geom AS geom - ), _simple_geoms AS ( - SELECT id, - CASE WHEN ST_GeometryType(geom) = 'ST_Point' THEN geom - ELSE ST_Subdivide(geom) - END AS geom - FROM _geoms - ) + WITH _geoms AS (SELECT + (UNNEST($1)).val as id, + (UNNEST($1)).geom AS geom) SELECT _geoms.id::INT, %s - FROM %s, _simple_geoms _geoms + FROM %s, _geoms WHERE %s AND %s GROUP BY _geoms.id