python - 在 SQLAlchemy 中，列属性上的 group_by 在 1.0.0b1 中不再有效

Question

查询功能从 0.9.9 到 1.0.0b1 的变化让我有些心痛。我有一个使用 column_property 的 group_by 子句。

在 0.9.9 中，生成的查询通过再次实际计算值来重现 GROUP BY 中的计算值。在 1.0.0b1 中，计算包含在 anon_1 中，MSSQL 不允许您对计算字段的命名值进行分组。

是否有某种方法可以在不需要特定版本的情况下恢复到旧行为？

以下代码在 0.9.9 中生成以下 SQL:

SELECT 
    count(cdr_extended.[UniqueID]) AS [CallCount],
    sum(cdr_extended.[Duration]) AS [TotalSeconds], 
    ext_map.[FName] + ' ' + ext_map.[LName] AS anon_1 
FROM cdr_extended, ext_map 
WHERE 
    (ext_map.exten = cdr_extended.[Extension] 
        OR ext_map.prev_exten = cdr_extended.[Extension]) 
    AND cdr_extended.[StartTime] > '2015-01-01' 
    AND cdr_extended.[Extension] IN ('8297') 
GROUP BY ext_map.[FName] + ' ' + ext_map.[LName]
DESC

但是，在 1.0.0 中，它会生成以下代码:

SELECT 
    count(cdr_extended.[UniqueID]) AS [CallCount],
    sum(cdr_extended.[Duration]) AS [TotalSeconds], 
    ext_map.[FName] + ' ' + ext_map.[LName] AS anon_1 
FROM cdr_extended, ext_map 
WHERE 
    (ext_map.exten = cdr_extended.[Extension] 
        OR ext_map.prev_exten = cdr_extended.[Extension]) 
    AND cdr_extended.[StartTime] > '2015-01-01' 
    AND cdr_extended.[Extension] IN ('8297') 
GROUP BY anon_1 
DESC

这是模型:

class EMap(Base):
    FName = Column(String(length=45))
    LName = Column(String(length=45))
    AssociateName = column_property(FName + " " + LName)

有问题的代码:

   DBSession.query(func.count(ExtendedCDR.UniqueID)
.label("CallCount"),func.sum(ExtendedCDR.Duration)
.label("TotalSeconds"))
.filter(or_(ExtensionMap.exten == ExtendedCDR.Extension,ExtensionMap.prev_exten == ExtendedCDR.Extension))
.filter(ExtendedCDR.StartTime>jan1)
.filter(ExtendedCDR.Extension.in_(extensions))
.group_by(ExtensionMap.AssociateName)
.order_by(func.count(ExtendedCDR.UniqueID).desc())

最后，这是 group_by 失败时的实际堆栈跟踪:

Traceback (most recent call last):
  File "/usr/local/lib/python2.7/site-packages/pyramid_exclog-0.7-py2.7.egg/pyramid_exclog/__init__.py", line 111, in exclog_tween
    return handler(request)
  File "/usr/local/lib/python2.7/site-packages/pyramid-1.5.4-py2.7.egg/pyramid/router.py", line 163, in handle_request
    response = view_callable(context, request)
  File "/usr/local/lib/python2.7/site-packages/pyramid-1.5.4-py2.7.egg/pyramid/config/views.py", line 245, in _secured_view
    return view(context, request)
  File "/usr/local/lib/python2.7/site-packages/pyramid-1.5.4-py2.7.egg/pyramid/config/views.py", line 355, in rendered_view
    result = view(context, request)
  File "/usr/local/lib/python2.7/site-packages/pyramid-1.5.4-py2.7.egg/pyramid/config/views.py", line 501, in _requestonly_view
    response = view(request)
  File "/opt/cedar/cedar/views/ViewMyDashboard.py", line 51, in MyDashboardView
    YearList = ObstinateDatabaseQueryAll(DBSession.query(func.count(ExtendedCDR.UniqueID).label("CallCount"),func.sum(ExtendedCDR.Duration).label("TotalSeconds"),ExtensionMap.AssociateName).filter(or_(ExtensionMap.exten == ExtendedCDR.Extension,ExtensionMap.prev_exten == ExtendedCDR.Extension)).filter(ExtendedCDR.StartTime>year_today).filter(ExtendedCDR.Extension.in_(extensions)).group_by(ExtensionMap.AssociateName).order_by(func.count(ExtendedCDR.UniqueID).desc()))
  File "/opt/cedar/cedar/controllers/db.py", line 40, in ObstinateDatabaseQueryAll
    ret=query.all()
  File "build/bdist.linux-x86_64/egg/sqlalchemy/orm/query.py", line 2408, in all
    return list(self)
  File "build/bdist.linux-x86_64/egg/sqlalchemy/orm/query.py", line 2525, in __iter__
    return self._execute_and_instances(context)
  File "build/bdist.linux-x86_64/egg/sqlalchemy/orm/query.py", line 2540, in _execute_and_instances
    result = conn.execute(querycontext.statement, self._params)
  File "build/bdist.linux-x86_64/egg/sqlalchemy/engine/base.py", line 914, in execute
    return meth(self, multiparams, params)
  File "build/bdist.linux-x86_64/egg/sqlalchemy/sql/elements.py", line 323, in _execute_on_connection
    return connection._execute_clauseelement(self, multiparams, params)
  File "build/bdist.linux-x86_64/egg/sqlalchemy/engine/base.py", line 1010, in _execute_clauseelement
    compiled_sql, distilled_params
  File "build/bdist.linux-x86_64/egg/sqlalchemy/engine/base.py", line 1146, in _execute_context
    context)
  File "build/bdist.linux-x86_64/egg/sqlalchemy/engine/base.py", line 1332, in _handle_dbapi_exception
    exc_info
  File "build/bdist.linux-x86_64/egg/sqlalchemy/util/compat.py", line 199, in raise_from_cause
    reraise(type(exception), exception, tb=exc_tb)
  File "build/bdist.linux-x86_64/egg/sqlalchemy/engine/base.py", line 1139, in _execute_context
    context)
  File "build/bdist.linux-x86_64/egg/sqlalchemy/engine/default.py", line 442, in do_execute
    cursor.execute(statement, parameters)
ProgrammingError: (pyodbc.ProgrammingError) ('42S22', "[42S22] [FreeTDS][SQL Server]Invalid column name 'anon_1'. (207) (SQLExecDirectW)") [SQL: 'SELECT count(cdr_extended.[UniqueID]) AS [CallCount], sum(cdr_extended.[Duration]) AS [TotalSeconds], ext_map.[FName] + ? + ext_map.[LName] AS anon_1 \nFROM cdr_extended, ext_map \nWHERE (ext_map.exten = cdr_extended.[Extension] OR ext_map.prev_exten = cdr_extended.[Extension]) AND cdr_extended.[StartTime] > ? AND cdr_extended.[Extension] IN (?) GROUP BY anon_1 ORDER BY count(cdr_extended.[UniqueID]) DESC'] [parameters: (' ', datetime.datetime(2015, 1, 1, 0, 0), '8297')]

Answer 1

这已被开发人员确定为错误，其修复将在 1.0.0b4 里程碑中发布。