8

此 python 代码应该在数据库上运行语句，但不执行 sql 语句：

from sqlalchemy import *
sql_file = open("test.sql","r")
sql_query = sql_file.read()
sql_file.close()
engine = create_engine(
    'postgresql+psycopg2://user:password@localhost/test', echo=False)

conn = engine.connect()
print sql_query
result = conn.execute(sql_query)
conn.close()

该test.sql文件包含创建 89 个表的 SQL 语句。

如果我指定 89 个表，则不会创建表，但如果我将表数减少到 2 个，则它可以工作。

conn.execute 中可以执行的查询数量是否有限制？如何运行任意数量的这样的原始查询？

4

2 回答 2

8

也许，强制自动提交：

conn.execute(RAW_SQL).execution_options(autocommit=True))

其他方法是使用事务并进行提交：

t = conn.begin()
try:
    conn.execute(RAW_SQL)
    t.commit()
except:
    t.rollback()

PD：您也可以将 execution_options 放在 create_engine 参数中。

于 2012-06-27T09:30:32.647 回答
-1

为什么将原始 SQL 与 SQLAlchemy 一起使用？如果你没有充分的理由，你应该使用其他方法：

http://docs.sqlalchemy.org/en/rel_0_7/orm/tutorial.html

http://docs.sqlalchemy.org/en/rel_0_7/core/schema.html#metadata-describing

于 2012-06-27T10:18:17.713 回答