stuff

migrations/2023-12-25-034523_replaceable-schema/up.sql

@@ -18,24 +18,25 @@ SET
     comments = counted.comments
 FROM (
     SELECT
-        community.id AS community_id,
+        community_id,
         count(*) AS comments
     FROM
         comment,
+        LATERAL (
+            SELECT
+                *
+            FROM
+                post
+            WHERE
+                post.id = comment.post_id
+            LIMIT 1) AS post
     WHERE
         NOT (comment.deleted
             OR comment.removed
-            OR EXISTS (
+            OR post.deleted
-                SELECT
+            OR post.removed)
-                    1
+    GROUP BY
-                FROM
+        community_id) AS counted
-                    post
-                WHERE
-                    post.id = comment.post_id
-                    AND (post.deleted
-                        OR post.removed)))
-        GROUP BY
-            community.id) AS counted
 WHERE
     community_aggregates.community_id = counted.community_id;
 

replaceable_schema.sql

@@ -33,14 +33,16 @@ BEGIN
             upvotes::float / downvotes::float
         END;
     END IF;
-END;
+END
 $$;
 
 -- Selects both old and new rows in a trigger and allows using `sum(count_diff)` to get the number to add to a count
 CREATE FUNCTION r.combine_transition_tables ()
     RETURNS SETOF record
-    LANGUAGE sql
+    LANGUAGE plpgsql
     AS $$
+BEGIN
+    RETURN QUERY
     SELECT
         -1 AS count_diff,
         *
@@ -52,24 +54,22 @@ CREATE FUNCTION r.combine_transition_tables ()
         *
     FROM
         new_table;
+END
 $$;
 
 -- Define functions
 CREATE FUNCTION r.creator_id_from_post_aggregates (agg post_aggregates)
-    RETURNS int
+    RETURNS int RETURN agg.creator_id;
-    SELECT
-        creator_id
-    FROM
-        agg;
 
 CREATE FUNCTION r.creator_id_from_comment_aggregates (agg comment_aggregates)
-    RETURNS int
+    RETURNS int RETURN (
-    SELECT
+        SELECT
-        creator_id
+            creator_id
-    FROM
+        FROM
-        comment
+            comment
-    WHERE
+        WHERE
-        comment.id = agg.comment_id LIMIT 1;
+            comment.id = agg.comment_id LIMIT 1
+);
 
 -- Create triggers for both post and comments
 CREATE PROCEDURE r.post_or_comment (thing_type text)
@@ -148,7 +148,7 @@ BEGIN
     CREATE TRIGGER aggregates
         AFTER INSERT OR DELETE OR UPDATE OF score ON thing_like REFERENCING OLD TABLE AS old_table NEW TABLE AS new_table
         FOR EACH STATEMENT
-        EXECUTE FUNCTION r.thing_aggregates_from_like;
+        EXECUTE FUNCTION r.thing_aggregates_from_like ( );
         $b$,
         'thing',
         thing_type);