discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

comments-stat-subquery

Browse Source
This commit is contained in:
Untone 2024-03-01 09:56:36 +03:00
parent b0136fd9bc
commit c41ae4ba98
1 changed files with 20 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
resolvers/stat.py
View File

@ -57,38 +57,31 @@ def add_author_stat_columns(q):
aliased_author_followers = aliased(AuthorFollower) aliased_author_followers = aliased(AuthorFollower)
# aliased_reaction = aliased(Reaction) # aliased_reaction = aliased(Reaction)
q = ( q = q.outerjoin(aliased_shout_author, aliased_shout_author.author == Author.id)
q.outerjoin(aliased_shout_author, aliased_shout_author.author == Author.id) q = q.add_columns(func.count(distinct(aliased_shout_author.shout)).label('shouts_stat'))
.add_columns(
func.count(distinct(aliased_shout_author.shout)).label('shouts_stat') q = q.outerjoin(aliased_author_authors, aliased_author_authors.follower == Author.id)
q = q.add_columns(func.count(distinct(aliased_author_authors.author)).label('authors_stat'))
q = q.outerjoin(aliased_author_followers, aliased_author_followers.author == Author.id)
q = q.add_columns(func.count(distinct(aliased_author_followers.follower)).label('followers_stat'))
# Create a subquery for comments count
subquery = (
select(Reaction.created_by, func.count(Reaction.id).label('comments_stat'))
.filter(
and_(
Reaction.kind == ReactionKind.COMMENT.value,
Reaction.deleted_at.is_(None),
)
)
.group_by(Reaction.created_by)
.subquery()
) )
.outerjoin(aliased_author_authors, aliased_author_authors.follower == Author.id) q = q.outerjoin(subquery, subquery.c.created_by == Author.id)
.add_columns( q = q.add_columns(subquery.c.comments_count)
func.count(distinct(aliased_author_authors.author)).label('authors_stat')
)
.outerjoin(
aliased_author_followers, aliased_author_followers.author == Author.id
)
.add_columns(
func.count(distinct(aliased_author_followers.follower)).label(
'followers_stat'
)
)
)
# .outerjoin(
# aliased_reaction,
# and_(
# aliased_reaction.created_by == Author.id,
# aliased_reaction.kind == ReactionKind.COMMENT.value,
# aliased_reaction.deleted_at.is_(None),
# ),
# )
# .add_columns(
# func.count(distinct(aliased_reaction.id)).label('comments_stat')
# )
q = q.group_by(Author.id) q = q.group_by(Author.id)
return q return q