我有一个 Pyramid/SQLAlchemy、MySQL python 应用程序。 当我执行原始 SQL INSERT 查询时，没有任何内容写入数据库。 然而，当使用 ORM 时，我可以写入数据库。我阅读了文档，阅读了有关 ZopeTransactionExtension 的信息，阅读了大量 SO 问题，但都无济于事。 到目前为止还没有奏效的地方:

• transaction.commit() - 没有任何内容写入数据库。我确实意识到这个声明对于 ZopeTransactionExtension 是必要的，但它在这里并没有发挥作用。
• dbsession().commit - 因为我使用的是 ZopeTransactionExtension，所以不起作用
• dbsession().close() - 什么都没写
• dbsession().flush() - 什么都没写
• mark_changed( session ) -

  File "/home/dev/.virtualenvs/sc/local/lib/python2.7/site-packages/zope/sqlalchemy/datamanager.py", line 198, in join_transaction if session.twophase: AttributeError: 'scoped_session' object has no attribute 'twophase'"

• engine.execute(...)

我正在寻找如何使用 scoped_session(我的代码中的 dbsession())执行原始 SQL

这是我的 SQLAlchemy 设置 (models/__init__.py)

def dbsession():
    assert (_dbsession is not None)
    return _dbsession

def init_engines(settings, _testing_workarounds=False):
    import zope.sqlalchemy
    extension = zope.sqlalchemy.ZopeTransactionExtension()
    global _dbsession

    _dbsession = scoped_session(
        sessionmaker(
            autoflush=True,
            expire_on_commit=False,
            extension=extension,
        )
    )

    engine = engine_from_config(settings, 'sqlalchemy.')
    _dbsession.configure(bind=engine)

这是我编写的用于隔离问题的 python 脚本。它类似于发生问题的真实环境。我只想让下面的脚本将数据插入数据库:

# -*- coding: utf-8 -*-
import sys
import transaction

from pyramid.paster import setup_logging, get_appsettings
from sc.models import init_engines, dbsession
from sqlalchemy.sql.expression import text


def __main__():

if len(sys.argv) < 2:
    raise RuntimeError()
config_uri = sys.argv[1]
setup_logging(config_uri)
aa = init_engines(get_appsettings(config_uri))

session = dbsession()
session.execute(text("""INSERT INTO
         operations (description, generated_description)
         VALUES ('hello2', 'world');"""))

print list(session.execute("""SELECT * from operations""").fetchall()) # prints inserted data
transaction.commit()

print list(session.execute("""SELECT * from operations""").fetchall()) # doesn't print inserted data

if __name__ == '__main__':
    __main__()

有趣的是，如果我这样做:

session = dbsession()
session.execute(text("""INSERT INTO
         operations (description, generated_description)
         VALUES ('hello2', 'world');"""))
op = Operation(generated_description='aa', description='oo')
session.add(op)

然后第一个打印输出原始 SQL 插入行('hello2' 'world')，第二个打印打印两个行，实际上两个行都插入到数据库中。

我无法理解为什么将 ORM 插入与原始 SQL 一起“修复”它。

最佳答案

自从我将原始 sql 与 sqlalchemy 混合使用以来已经有一段时间了，但是无论何时混合使用它们，您都需要了解 ORM 在幕后发生的事情。首先，检查 autocommit旗帜。如果 zope 事务配置不正确，ORM 插入可能会触发提交。

实际上，在查看了 zope 文档之后，手动执行语句似乎需要一个额外的步骤。来自他们的 readme :

By default, zope.sqlalchemy puts sessions in an 'active' state when they are first used. ORM write operations automatically move the session into a 'changed' state. This avoids unnecessary database commits. Sometimes it is necessary to interact with the database directly through SQL. It is not possible to guess whether such an operation is a read or a write. Therefore we must manually mark the session as changed when manual SQL statements write to the DB.

>>> session = Session()
>>> conn = session.connection()
>>> users = Base.metadata.tables['test_users']
>>> conn.execute(users.update(users.c.name=='bob'), name='ben')
<sqlalchemy.engine...ResultProxy object at ...>
>>> from zope.sqlalchemy import mark_changed
>>> mark_changed(session)
>>> transaction.commit()
>>> session = Session()
>>> str(session.query(User).all()[0].name)
'ben'
>>> transaction.abort()

您似乎没有这样做，因此 transaction.commit 什么也不做。

关于python - SQLAlchemy，scoped_session - 原始 SQL INSERT 不写入数据库，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/25484451/