diff --git a/store/sqlstore/thread_store.go b/store/sqlstore/thread_store.go index 9592a1eee9..a12854e31c 100644 --- a/store/sqlstore/thread_store.go +++ b/store/sqlstore/thread_store.go @@ -200,12 +200,12 @@ func (s *SqlThreadStore) GetThreadsForUser(userId, teamId string, opts model.Get }() go func() { mentionsQuery, mentionsQueryArgs, _ := s.getQueryBuilder(). - Select("COALESCE(SUM(ThreadMemberships.UnreadMentions),0)"). - From("ThreadMemberships"). - LeftJoin("Threads ON Threads.PostId = ThreadMemberships.PostId"). - LeftJoin("Posts ON Posts.Id = ThreadMemberships.PostId"). - LeftJoin("Channels ON Threads.ChannelId = Channels.Id"). + Select("COALESCE(SUM(ThreadMemberships.UnreadMentions), 0)"). + From("ThreadMemberships, Posts, Channels"). + Where("Posts.Id = ThreadMemberships.PostId"). + Where("Posts.ChannelId = Channels.Id"). Where(fetchConditions).ToSql() + totalUnreadMentions, err := s.GetMaster().SelectInt(mentionsQuery, mentionsQueryArgs...) totalUnreadMentionsChan <- store.StoreResult{Data: totalUnreadMentions, NErr: err} close(totalUnreadMentionsChan)