Fix

Author: k2bd

poetry.lock

@@ -40,6 +40,7 @@ toml = "^0.10.2"
 aiopg = { version = "^1.4.0", optional = true }
 databases = { version = "^0.9.0", optional = true }
 asyncpg = { version = "^0.29.0", optional = true }
+sqlparse = { version = "^0.5.1", optional = true }
 
 [tool.poetry.group.dev.dependencies]
 black = "^24.4.2"
@@ -52,7 +53,7 @@ pytest-cov = "^5.0.0"
 pytest-asyncio = "^0.23.6"
 
 [tool.poetry.extras]
-postgres = ["aiopg", "databases", "asyncpg"]
+postgres = ["aiopg", "databases", "asyncpg", "sqlparse"]
 
 
 [tool.isort]

pyproject.toml

@@ -3,6 +3,7 @@
 from dataclasses import dataclass, field
 
 try:
+    import sqlparse
     from databases import Database
     from databases.core import Connection, Transaction
 except ImportError as e:
@@ -193,7 +194,9 @@ async def apply_migration(self, content: str):
         up and down migrations so should not register or unregister the
         migration hash.
         """
-        await self._conn.execute(content)
+        statements = sqlparse.split(content)
+        for statement in statements:
+            await self._conn.execute(statement.strip())
 
     async def get_applied_migrations(self) -> set[AppliedMigration]:
         """