SQLAlchemy使用merge n更新PostgreSQL数组

2024-04-29 18:38:20 发布

您现在位置:Python中文网/ 问答频道 /正文

我使用SQLAlchemy访问PostgreSQL数据库,我定义了如下对象:

class SessionLog(Base):
    __tablename__ = 'session_log'

    id = Column(Integer, primary_key=True)
    recordFile = Column('record_file', String(128))
    appSrcPorts = Column('app_src_ports', ARRAY(Integer))
    info5 = Column('info5', String(100))

我选择并更新会话日志表如下:

^{pr2}$

但奇怪的是,在我调用merge()和commit()之后,“app_src_ports”列没有更新。 我找到了一个很难看的方法,在append()行之前,添加以下内容:

sessionLog.appSrcPorts = list(sessionLog.appSrcPorts)

有人能告诉我为什么吗?在


Tags: 对象src数据库appstring定义sqlalchemypostgresql
2条回答

找到了对我帮助很大的this gist。我添加了一个自定义的__setitem__,以便能够更改列表中的一个项,__delitem__以删除一个:

from sqlalchemy.ext.mutable import Mutable
from sqlalchemy.dialects.postgresql import ARRAY

class MutableList(Mutable, list):

    def __setitem__(self, key, value):
        list.__setitem__(self, key, value)
        self.changed()

    def __delitem__(self, key):
        list.__delitem__(self, key)
        self.changed()

    def append(self, value):
        list.append(self, value)
        self.changed()

    def pop(self, index=0):
        value = list.pop(self, index)
        self.changed()
        return value

    @classmethod
    def coerce(cls, key, value):
        if not isinstance(value, MutableList):
            if isinstance(value, list):
                return MutableList(value)
            return Mutable.coerce(key, value)
        else:
            return value

然后在您的模型中:

^{pr2}$

SQLAlchemy ORM依赖于事件的检测来判断某些数据何时发生了更改,因此何时需要刷新数据。在本例中,您将就地更改Python数组值,默认情况下不会生成任何事件。为了使其工作,您需要将mutable extension与数组类型(以及发送这些事件的list子类)结合使用,以便将更改作为与父SessionLog对象相关的事件发送。在

相关问题 更多 >