diff --git a/airflow/hooks/dbapi_hook.py b/airflow/hooks/dbapi_hook.py
index 82bedbf9b6e7d..422a2be00f9ba 100644
--- a/airflow/hooks/dbapi_hook.py
+++ b/airflow/hooks/dbapi_hook.py
@@ -97,8 +97,8 @@ def run(self, sql, autocommit=False, parameters=None):
         cur = conn.cursor()
         for s in sql:
             cur.execute(s, parameters)
-        conn.commit()
         cur.close()
+        conn.commit()
         conn.close()
 
     def set_autocommit(self, conn, autocommit):