SQLAlchemy将SELECT查询结果转换为dict列表

Question

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

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

但是现在我必须使用SELECT()操作，如何将结果转换为一个dict，对于每一行结果：

[{'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新手，如果有任何帮助，我将不胜感激。

Answer 1

这似乎是RowProxy对象。尝试：

row = dict(zip(row.keys(), row))

Answer 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))

Answer 3

可以将选定结果中的每一行类型转换为dict或tuple。您看到的是默认行为，即将每一行表示为一个元组。要将类型转换为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