One-arg version of bucardo_purge_delta

diff --git a/bucardo.schema b/bucardo.schema
index c229bfde02b7db6aaf03b72d8653edf0df8b5cef..95d3c1bff3218808b778eebb7e1e7bd70ce42952 100644 (file)
--- a/bucardo.schema
+++ b/bucardo.schema
@@ -1609,7 +1609,7 @@ SELECT 'Fixme'::TEXT;
 
         } ## end of bucardo_compress_delta creations
 
-        ## Create the bucardo_purge_delta function as needed
+        ## Create the bucardo_purge_delta functions as needed
         $newschema and goto PURGE;
         $sth = $sth{hazfunc};
         $count = $sth->execute('bucardo', 'bucardo_purge_delta');
@@ -1688,18 +1688,52 @@ SELECT 'Fixme'::TEXT;
                     
                       GET DIAGNOSTICS trows := row_count;
                     
-                    RETURN 'Rows deleted from bucardo_delta: '||drows||
-                    ' Rows deleted from bucardo_track: '||trows;
+                    RETURN 'Rows deleted from '
+                      || deltatable
+                      || ': '
+                                         || drows
+                      || ' Rows deleted from '
+                      || tracktable
+                      || ': '
+                      || trows;
                     
-                    RETURN 'Rows deleted from bucardo_delta: '||drows||
-                    ' Rows deleted from bucardo_track: '||trows;
+                    END;
+                    \$clone\$;
+                };
+            run_sql($SQL,$dbh);
+
+            $SQL = qq{
+                    CREATE OR REPLACE FUNCTION bucardo.bucardo_purge_delta(text)
+                    RETURNS TEXT
+                    LANGUAGE plpgsql
+                    VOLATILE
+                    SECURITY DEFINER
+                    AS
+                    \$clone\$
+                    DECLARE
+                      myrec RECORD;
+                      myrez TEXT;
+                      total INTEGER = 0;
+                    BEGIN
                     
+                      SET LOCAL search_path = pg_catalog;
+                    
+                     -- Grab all potential tables to be vacuumed by looking at bucardo_delta_targets
+                      FOR myrec IN SELECT DISTINCT tablename::regclass::text
+                        FROM bucardo.bucardo_delta_targets LOOP
+                        SELECT INTO myrez
+                          bucardo.bucardo_purge_delta(\$1, myrec.tablename);
+                        RAISE NOTICE '%', myrez;
+                        total = total + 1;
+                      END LOOP;
+                    
+                    RETURN 'Tables processed: ' || total;
                     END;
                     \$clone\$;
                 };
             run_sql($SQL,$dbh);
         }
-
+                    
         $newschema and goto SEQUENCE;
         $sth = $sth{haztable};
         $count = $sth->execute('bucardo', 'bucardo_sequences');