diff --git a/lib/galaxy/model/migrate/versions/util.py b/lib/galaxy/model/migrate/versions/util.py
index 1e6e8f478cc..6213cea7d6d 100644
--- a/lib/galaxy/model/migrate/versions/util.py
+++ b/lib/galaxy/model/migrate/versions/util.py
@@ -200,4 +200,5 @@ def execute_statements(engine, raw_sql):
     statements = raw_sql if isinstance(raw_sql, list) else [raw_sql]
     for sql in statements:
         cmd = DDL(sql)
-        cmd.execute(bind=engine)
+        with engine.connect() as connection:
+            connection.execute(cmd)