24

当我使用 session.query 时，我能够将结果转换为 dicts 列表：

my_query = session.query(table1,table2).filter(all_filters)
result_dict = [u.__dict__ for u in my_query.all()]

但是现在我必须使用该SELECT()操作，如何将结果转换为看起来像的字典，对于每一行结果：

[{'Row1column1Name' : 'Row1olumn1Value', 'Row1column2Name' :'Row1Column2Value'},{'Row2column1Name' : 'Row2olumn1Value', 'Row2column2Name' : 'Row2Column2Value'},etc....].

这是我的 SELECT() 代码：

select = select([table1,table2]).where(all_filters)
res = conn.execute(select)
row = res.fetchone() #I have to use fetchone() because the query returns lots of rows
resultset=[]
while row is not None:
    row = res.fetchone()
    resultset.append(row)

print resultset

结果是：

[('value1', 'value2', 'value3', 'value4'),(.....),etc for each row]

我是 Python 新手，任何帮助将不胜感激。

4

5 回答 5

31

这似乎是一个 RowProxy 对象。尝试：

row = dict(zip(row.keys(), row))
于 2013-10-16T22:42:31.630 回答
18

您可以将选择结果中的每一行类型转换为字典或元组。您所看到的是默认行为，即将每一行表示为一个元组。要将类型转换为 dict，请修改您的代码，如下所示：

select = select([table1, table2]).where(all_filters)
res = conn.execute(select)
resultset = []
for row in res:
    resultset.append(dict(row))
print resultset

如果您需要一次处理一行结果，这很有效。

如果您乐于一次性将所有行放入一个列表中，那么列表理解会更简洁一些：

select = select([table1, table2]).where(all_filters)
res = conn.execute(select)
resultset = [dict(row) for row in res]
print resultset
于 2013-11-19T18:16:09.193 回答
3

根据 Fanti 的回答，如果您使用 List Comprehension，则可以在一行中生成所有 dicts 列表。这results是我的查询结果。

records = [dict(zip(row.keys(), row)) for row in results]
于 2019-07-22T16:18:33.113 回答
2

对于第一个查询，最好将这种方法用于 sqlalchemy KeyedTuple：

# Convert an instance of `sqlalchemy.util._collections.KeyedTuple`
# to a dictionary
my_query = session.query(table1,table2).filter(all_filters)
result_dict = map(lambda q: q._asdict(), my_query)

或者

result_dict = map(lambda obj: dict(zip(obj.keys(), obj)), my_query)

对于前面提到的 ResultProxy：

result_dict = dict(zip(row.keys(), row))
于 2017-08-24T21:06:12.487 回答
1

做一个功能 -

def resultToDict(result):
    ds = []
    for rows in result:
        d = {}
        for row in rows:
            for col in row.__table__.columns:
                d[col.name] = str(getattr(row, col.name))
        ds.append(d)
    return ds

像这样执行 -

resultToDict(my_query.all())

结果 -

[
{'Row1column1Name' : 'Row1column1Value', 'Row1column2Name' : 'Row1Column2Value'},
{'Row2column1Name' : 'Row2column1Value', 'Row2column2Name' : 'Row2Column2Value'},
{'Row3column1Name' : 'Row3column1Value', 'Row3column2Name' : 'Row3Column2Value'},
etc....
]
于 2020-07-29T12:55:41.807 回答