Consulta de filtro SQLAlchemy por objeto relacionado

Question

Utilizando SQLAlchemy, tengo una relación uno a muchos con dos tablas: usuarios y puntajes. Intento consultar a los 10 mejores usuarios ordenados por su puntaje agregado durante los últimos X días.

users: 
    id 
    user_name 
    score 

scores: 
    user 
    score_amount 
    created 

Mi consulta actual es:

top_users = DBSession.query(User).options(eagerload('scores')).filter_by(User.scores.created > somedate).order_by(func.sum(User.scores).desc()).all() 

Sé que esto claramente no es correcta, es sólo mi mejor conjetura. Sin embargo, después de mirar la documentación y buscar en Google, no puedo encontrar una respuesta.

EDIT: Tal vez que sería útil que he esbozado lo que la consulta MySQL se vería así:

SELECT user.*, SUM(scores.amount) as score_increase 
FROM user LEFT JOIN scores ON scores.user_id = user.user_id 
WITH scores.created_at > someday 
ORDER BY score_increase DESC 

Answer 1

La forma fila unidos a una sola, con un group_by añadido en para todas las columnas de usuario aunque MySQL le permiten agrupar en un solo la columna "ID" si lo desea:

sess.query(User, func.sum(Score.amount).label('score_increase')).\ 
       join(User.scores).\ 
       filter(Score.created_at > someday).\ 
       group_by(User).\ 
       order_by("score increase desc") 

O si lo que desea los usuarios en el resultado:

sess.query(User).\ 
      join(User.scores).\ 
      filter(Score.created_at > someday).\ 
      group_by(User).\ 
      order_by(func.sum(Score.amount)) 

los dos anteriores tienen una ineficiencia en el que está agrupando en todas las columnas de "usuario" (o se están usando "grupo de sólo unas pocas columnas" de MySQL cosa, que es solo MySQL). Para minimizar esto, el enfoque subconsulta:

subq = sess.query(Score.user_id, func.sum(Score.amount).label('score_increase')).\ 
        filter(Score.created_at > someday).\ 
        group_by(Score.user_id).subquery() 
sess.query(User).join((subq, subq.c.user_id==User.user_id)).order_by(subq.c.score_increase) 

Un ejemplo del escenario idéntico está en el tutorial ORM en: http://docs.sqlalchemy.org/en/latest/orm/tutorial.html#selecting-entities-from-subqueries

Answer 2

Usted tendrá que usar una sub consulta con el fin de calcular la puntuación total de cada usuario. Las subconsultas se describen aquí: http://www.sqlalchemy.org/docs/05/ormtutorial.html?highlight=subquery#using-subqueries

Answer 3

Supongo que la columna (no la relación) que está utilizando para la unión se llama Score.user_id, así que cámbiela si no es el caso.

Usted tendrá que hacer algo como esto:

DBSession.query(Score.user_id, func.sum(Score.score_amount).label('total_score')).group_by(Score.user_id).filter(Score.created > somedate).order_by('total_score DESC')[:10] 

Sin embargo, esto se traducirá en tuplas de (user_id, total_score). No estoy seguro de si la puntuación computarizada es realmente importante para ti, pero si lo es, es probable que desee hacer algo como esto:

users_scores = [] 
q = DBSession.query(Score.user_id, func.sum(Score.score_amount).label('total_score')).group_by(Score.user_id).filter(Score.created > somedate).order_by('total_score DESC')[:10] 
for user_id, total_score in q: 
    user = DBSession.query(User) 
    users_scores.append((user, total_score)) 

Esto dará lugar a 11 consultas en ejecución, sin embargo. Es posible hacerlo todo en una sola consulta, pero debido a varias limitaciones en SQLAlchemy, es probable que cree una consulta o subconsulta de combinación múltiple muy fea (en función del motor) y no será muy eficaz.

Si planea hacer algo como esto a menudo y tiene una gran cantidad de puntajes, considere desnormalizar el puntaje actual en la tabla de usuarios. Es más trabajo para el mantenimiento, pero resultará en una sola consulta no unirse como:

DBSession.query(User).order_by(User.computed_score.desc()) 

Espero que ayude.