--- /dev/null
+DO $$DECLARE r text;
+BEGIN
+ FOR r IN
+ SELECT
+'CREATE TRIGGER "' || r.name || '_640_dbtran_trig"
+ AFTER INSERT OR UPDATE OR DELETE ON "' || r.name || '"
+ FOR EACH ROW EXECUTE PROCEDURE dbtran.capture_replication_data();' as stmt
+ FROM "Relation" r
+ JOIN pg_class c on (c.relname = r.name)
+ WHERE r."isExportEnabled"
+ AND c.relkind = 'r'
+ LOOP
+ EXECUTE r;
+ END LOOP;
+END$$;
+
+
+DO $$DECLARE r text;
+BEGIN
+ FOR r IN
+ SELECT 'DROP TRIGGER "' || r.name || '_640_dbtran_trig" ON "' || r.name || '";'
+ FROM "Relation" r
+ JOIN pg_class c on (c.relname = r.name)
+ WHERE r."isExportEnabled"
+ AND c.relkind = 'r'
+ LOOP
+ EXECUTE r;
+ END LOOP;
+END$$;