Sqlalchemy插入查询不返回结果

问题描述 投票:0回答:1

我试图从插入查询中选择返回值:

HOST_INSERT_QUERY = (
    Host.__table__.insert()
        .values(
            name=bindparam("name"),
            source=bindparam("source"),
            type=bindparam("type")
                )
        .returning(Host.__table__.c.id)
)
result = db_conn.execute(HOST_INSERT_QUERY, values)

我从db.echo看到的内容:

info sqlalchemy.engine.base.Engine INSERT INTO hosts (name, source, type) VALUES ( %(name)s, %(source)s, %(type)s) RETURNING hosts.id
info sqlalchemy.engine.base.Engine ({ 'name': 'hhh', 'source': '["import"]', 'type': 'host'},{...})
debug:  Added 2 hosts

真的行。主机插入数据库,但我看到调试器有些麻烦;结果(ResultProxy)具有:

rowcount = 2 #right!
is_insert = True #right!
return_rows=False #WHYYYY????????

如果我尝试:

result.fetсhall()

AttributeError: 'ResultProxy' object has no attribute 'fetсhall'

版本:

  • SQLAlchemy 1.3.1
  • psycopg-binary 2.7.7

注意!此代码仅在插入单个记录时有效。插入多行时,无法将值从RETURNING中拉出。

python postgresql sqlalchemy psycopg2
1个回答
1
投票

You cannot get results from executemany,如果你传递一组超过1行的插入,SQLAlchemy在下面使用它。这就是你观察return_rows=False的原因。解决方法是使用一个多VALUES子句“内联”行,而不是使用bindparams和executemany

HOST_INSERT_QUERY = (
    Host.__table__.insert()
        .values(values)
        .returning(Host.__table__.c.id)
)

result = db_conn.execute(HOST_INSERT_QUERY)

这作为单个“多值”语句执行,因此避免使用executemany,并可能返回结果。请注意,返回的ID的顺序可能与插入的行的顺序不匹配。

© www.soinside.com 2019 - 2024. All rights reserved.