我正在使用sqlalchemy引擎创建表,但是即使我的create语句执行没有错误,当我尝试预先设置角色时,这些表也不会出现在数据库中。
url = 'postgresql://{}:{}@{}:{}/{}'
url = url.format(user, password, host, port, db)
engine = sqlalchemy.create_engine(url)
# works fine
engine.execute("CREATE TABLE testpublic (id int, val text); \n\nINSERT INTO testpublic VALUES (1,'foo'), (2,'bar'), (3,'baz');")
r = engine.execute("select * from testpublic")
r.fetchall() # returns expected tuples
engine.execute("DROP TABLE testpublic;")
# appears to succeed/does NOT throw any error
engine.execute("SET ROLE read_write; CREATE table testpublic (id int, val text);")
# throws error "relation testpublic does not exist"
engine.execute("select * FROM testpublic")
对于上下文,我使用的是python3.6,sqlalchemy版本1.2.17和postgres11.1,角色"read_write“绝对存在,并且拥有在公共环境中创建表的所有必要权限(在pgadmin中运行上面的顺序没有任何问题)。
有人知道为什么会出现这种情况吗?知道如何修复吗?
发布于 2019-05-16 11:42:59
这里的问题是sqlalchemy如何决定在每条语句之后发出commit。
如果将文本传递给engine.execute
,sqlalchemy将尝试使用以下正则表达式确定该文本是DML还是DDL。You can find it in the sources here
AUTOCOMMIT_REGEXP = re.compile(
r"\s*(?:UPDATE|INSERT|CREATE|DELETE|DROP|ALTER)", re.I | re.UNICODE
)
这只检测位于文本开头的单词,忽略任何前导空格。因此,虽然您第一次尝试提交,但第二个示例未能识别出在执行语句后需要发出# works fine
,因为第一个单词是SET
。
相反,sqlalchemy会发出回滚,因此它会执行# appears to succeed/does NOT throw any error
。
最简单的解决方案是手动提交。
示例:
engine.execute("SET ROLE read_write; CREATE table testpublic (id int, val text); COMMIT;")
或者,将sql包装在text
中并设置autocommit=True
、as shown in the documentation
stmt = text('set role read_write; create table testpublic (id int, val text);').execution_options(autocommit=True)
e.execute(stmt)
https://stackoverflow.com/questions/56156329
复制相似问题