我试图从插入查询中选择返回值:
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'
版本:
注意!此代码仅在插入单个记录时有效。插入多行时,无法将值从RETURNING中拉出。
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的顺序可能与插入的行的顺序不匹配。