将ResultProxy作为元组返回，而不是命令

Question

我有以下代码：

query = """
SELECT Coalesce((SELECT sp.param_value
                 FROM   sites_params sp
                 WHERE  sp.param_name = 'ci'
                        AND sp.site_id = s.id
                 ORDER  BY sp.id DESC
                 LIMIT  1), -1) AS ci
FROM   sites s
WHERE  s.deleted = 0
       AND s.id = 10 

"""

site = db_session.execute(query)
# print site 
# <sqlalchemy.engine.result.ResultProxy object at 0x033E63D0>

site = db_session.execute(query).fetchone()
print site  # (u'375')
print list(site) # [u'375']

为什么SQLAlchemy为这个查询返回元组而不是dicts？我想使用以下样式访问查询结果：

print site.ci
# u'375'

Answer 1

我构建了一个简单的类，在我们的流程中像数据库接口一样工作。在这里，它去：

from sqlalchemy import create_engine
class DBConnection:
    def __init__(self, db_instance):
        self.db_engine = create_engine('your_database_uri_string')
        self.db_engine.connect()

    def read(self, statement):
        """Executes a read query and returns a list of dicts, whose keys are column names."""
        data = self.db_engine.execute(statement).fetchall()
        results = []

        if len(data)==0:
            return results

        # results from sqlalchemy are returned as a list of tuples; this procedure converts it into a list of dicts
        for row_number, row in enumerate(data):
            results.append({})
            for column_number, value in enumerate(row):
                results[row_number][row.keys()[column_number]] = value

        return results        

Answer 2

你看了结果代理文档了吗？它准确地描述了@Gryphius和@Syed Habib M的建议，即使用site['ci']。

ResultProxy并不像您声称的那样返回元组-它是一个代理，其行为（例如打印）类似元组，但也支持类似字典的访问：

从文档中：

可以通过整数位置、不区分大小写的列名或模式访问各个列。列对象。例如：

row=fetchone（）

col1=row[0]#通过整数位置访问

col2=行['col2']#通过名称访问

Col3=row[mytable.c.mycol]#通过ColVIII对象进行访问。

Answer 3

这是一个老生常谈的问题，但在今天仍然相关。让SQL Alchemy返回字典非常有用，特别是在使用返回JSON的基于RESTful的API时。

下面是我如何在Python 3中使用db\u会话实现的：

resultproxy = db_session.execute(query)

d, a = {}, []
for rowproxy in resultproxy:
    # rowproxy.items() returns an array like [(key0, value0), (key1, value1)]
    for column, value in rowproxy.items():
        # build up the dictionary
        d = {**d, **{column: value}}
    a.append(d)

最终结果是数组a现在包含字典格式的查询结果。

至于这在SQL炼金术中是如何工作的：

• db\u session.execute（query）返回一个ResultProxy对象
• ResultProxy对象由RowProxy对象组成
• RowProxy对象具有一个.items（）方法，该方法返回行中所有项的键、值元组，该元组可以在for操作中解包为键、值

这里有一个简单的选择：

[{column: value for column, value in rowproxy.items()} for rowproxy in resultproxy]

从文档中：

类sqlalchemy.engine.RowProxy（父，行，处理器，键映射）

来自单个游标行的代理值。

主要遵循“有序字典”行为，将结果值映射到基于字符串的列名、结果在行中的整数位置，以及可以映射到生成此结果集的原始列的列实例（对于对应于构造的结果SQL表达式）。

has_key（key）如果此RowProxy包含给定的密钥，则返回True。

项目（）返回元组列表，每个元组包含一个键/值对。

keys（）以该RowProxy表示的字符串形式返回键列表。

链接：http://docs.sqlalchemy.org/en/latest/core/connections.html#sqlalchemy.engine.RowProxy.items