diff --git a/ddl/000001_initial.down.sql b/ddl/000001_initial.down.sql
index b1b46c70eaa..e0779dfc4be 100644
--- a/ddl/000001_initial.down.sql
+++ b/ddl/000001_initial.down.sql
@@ -1,3 +1,5 @@
+BEGIN;
+
 DROP TABLE IF EXISTS auth_credentials;
 DROP TABLE IF EXISTS auth_group_policies;
 DROP TABLE IF EXISTS auth_user_policies;
@@ -19,4 +21,6 @@ DROP TABLE IF EXISTS catalog_repositories;
 DROP SEQUENCE IF EXISTS catalog_repositories_id_seq;
 DROP SEQUENCE IF EXISTS catalog_branches_id_seq;
 DROP SEQUENCE IF EXISTS catalog_commit_id_seq;
-DROP FUNCTION IF EXISTS catalog_max_commit_id;
\ No newline at end of file
+DROP FUNCTION IF EXISTS catalog_max_commit_id;
+
+COMMIT;
diff --git a/ddl/000001_initial.up.sql b/ddl/000001_initial.up.sql
index 501fe38a790..0e0c6f9839c 100644
--- a/ddl/000001_initial.up.sql
+++ b/ddl/000001_initial.up.sql
@@ -1,3 +1,5 @@
+BEGIN;
+
 -- auth schema, containing information about lakeFS authentication and authorization
 CREATE TABLE IF NOT EXISTS auth_users (
     id serial NOT NULL PRIMARY KEY,
@@ -244,3 +246,4 @@ ALTER TABLE ONLY catalog_object_dedup
 ALTER TABLE ONLY catalog_repositories
     ADD CONSTRAINT catalog_repositories_branches_id_fk FOREIGN KEY (default_branch) REFERENCES catalog_branches(id) DEFERRABLE INITIALLY DEFERRED NOT VALID;
 
+COMMIT;
diff --git a/ddl/000002_retention.up.sql b/ddl/000002_retention.up.sql
index 2f4cad82da0..f876cb19fa3 100644
--- a/ddl/000002_retention.up.sql
+++ b/ddl/000002_retention.up.sql
@@ -1,3 +1,5 @@
+BEGIN;
+
 ALTER TABLE catalog_object_dedup
     DROP CONSTRAINT IF EXISTS catalog_object_dedup_pk,
     ADD COLUMN IF NOT EXISTS deleting boolean DEFAULT false NOT NULL,
@@ -8,3 +10,5 @@ Set before deleting an object to indicate it is going to be
 removed by an AWS S3 batch operation and cannot be used for new
 dedupes.
 $$;
+
+END;