【问题标题】:pyramid transaction manager not committing on update金字塔事务管理器未提交更新
【发布时间】:2014-10-05 14:12:46
【问题描述】:

对不起,我之前没说清楚,

编辑: 我正在使用带有 sqlalchemy(后端:postgresql)的默认金字塔应用程序,使用

生成
pcreate -s alchemy

所以我有所有与 DBSession、pyramid_tm 等相关的设置。我有这个代码

class User(Base):
    id = Column(Integer, primary_key=True)
    connection = relationship("UserConnection", uselist=False, backref="user")

class UserConnection(Base):
    userid = Column(Integer, ForeignKey('user.id'), primary_key=True)
    friends = Column(JSON)

def add_connection(user, friend):
    with transaction.manager:
        if not user.connection:
            user_conn = UserConnection(userid=user.id, friends=[])
        else:
            user_conn = user.connection

        user_conn.friends.append(friend)
        print(user_connection.friends)
        session.add(user_conn)

当我第一次运行 add_connection() 时,user.connection 不存在。新记录被创建,但在下次运行时(以防万一)记录不会更新,在控制台上我只能看到 ROLLBACK/COMMIT 但看不到其他语句。

那里的 print 语句显示更新的结果,但 db 没有更新。

【问题讨论】:

  • 了解到我不需要每次都使用transaction.manager,反正都是由pyramid_tm完成的。

标签: python postgresql sqlalchemy pyramid


【解决方案1】:

您应该在请求范围内使用事务。

zope.sqlalchemy 和 pyramid_tm 可以为您做到这一点。 你可以使用我的代码:

pyramid_sqlalchemy.py

​​>
# -*- coding: utf-8 -*-

""" Pyramid sqlalchemy lib.

Session will be available as dbsession attribute on request.

! Do not close session on your own.

"""

import sqlalchemy
from sqlalchemy.orm import sessionmaker, scoped_session
from zope.sqlalchemy import ZopeTransactionExtension

Session = scoped_session(sessionmaker(
    extension=ZopeTransactionExtension()
))


def includeme(config):
    """ Setup sqlalchemy session connection for pyramid app.

    :param config: Pyramid configuration

    """
    config.include('pyramid_tm')
    # creates database engine from ini settings passed to pyramid wsgi
    engine = sqlalchemy.engine_from_config(
        config.get_settings(), connect_args={
            'charset': 'utf8'
        }
    )
    # scoped session gives us thread safe session
    Session.configure(bind=engine)
    # make database session available in every request
    config.add_request_method(
        callable=lambda request: Session, name='dbsession', property=True
    )

使用 pip 安装 zope.sqlalchemy 和 pyramid_tm 并调用 config.include(pyramid_sqlalchemy)

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2013-01-27
    • 1970-01-01
    • 2015-10-20
    • 2014-01-17
    • 1970-01-01
    • 1970-01-01
    • 2021-04-10
    相关资源
    最近更新 更多