SQLalchemy在设置角色时未提交更改
SQLalchemy在设置角色时未提交更改
提问于 2019-05-16 03:23:43
我正在使用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中运行上面的顺序没有任何问题)。
有人知道为什么会出现这种情况吗?知道如何修复吗？
回答 1
Stack Overflow用户
回答已采纳
发布于 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)页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/56156329
复制相关文章
相似问题