Adding a GroupBy specification example

jspjayalath · Apr 21, 2019 · 468df47 · 468df47
1 parent 1632f7f
commit 468df47
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 3 deletions.
diff --git a/src/ApplicationCore/Interfaces/ISpecification.cs b/src/ApplicationCore/Interfaces/ISpecification.cs
@@ -11,6 +11,7 @@ public interface ISpecification<T>
         List<string> IncludeStrings { get; }
         Expression<Func<T, object>> OrderBy { get; }
         Expression<Func<T, object>> OrderByDescending { get; }
+        Expression<Func<T, object>> GroupBy { get; }
 
         int Take { get; }
         int Skip { get; }

diff --git a/src/ApplicationCore/Specifications/BaseSpecification.cs b/src/ApplicationCore/Specifications/BaseSpecification.cs
@@ -16,6 +16,7 @@ protected BaseSpecification(Expression<Func<T, bool>> criteria)
         public List<string> IncludeStrings { get; } = new List<string>();
         public Expression<Func<T, object>> OrderBy { get; private set; }
         public Expression<Func<T, object>> OrderByDescending { get; private set; }
+        public Expression<Func<T, object>> GroupBy { get; private set; }
 
         public int Take { get; private set; }
         public int Skip { get; private set; }
@@ -43,5 +44,11 @@ protected virtual void ApplyOrderByDescending(Expression<Func<T, object>> orderB
         {
             OrderByDescending = orderByDescendingExpression;
         }
+
+        protected virtual void ApplyGroupBy(Expression<Func<T, object>> groupByExpression)
+        {
+            GroupBy = groupByExpression;
+        }
+
     }
 }
diff --git a/src/ApplicationCore/Specifications/CatalogFilterPaginatedSpecification.cs b/src/ApplicationCore/Specifications/CatalogFilterPaginatedSpecification.cs
@@ -9,6 +9,7 @@ public CatalogFilterPaginatedSpecification(int skip, int take, int? brandId, int
                 (!typeId.HasValue || i.CatalogTypeId == typeId))
         {
             ApplyPaging(skip, take);
+            ApplyGroupBy(i => new { i.CatalogType });
         }
     }
 }
diff --git a/src/Infrastructure/Data/SpecificationEvaluator.cs b/src/Infrastructure/Data/SpecificationEvaluator.cs
@@ -1,10 +1,7 @@
 using Microsoft.EntityFrameworkCore;
 using Microsoft.eShopWeb.ApplicationCore.Entities;
 using Microsoft.eShopWeb.ApplicationCore.Interfaces;
-using System;
-using System.Collections.Generic;
 using System.Linq;
-using System.Text;
 
 namespace Microsoft.eShopWeb.Infrastructure.Data
 {
@@ -38,6 +35,11 @@ public static IQueryable<T> GetQuery(IQueryable<T> inputQuery, ISpecification<T>
                 query = query.OrderByDescending(specification.OrderByDescending);
             }
 
+            if (specification.GroupBy != null)
+            {
+                query = query.GroupBy(specification.GroupBy).SelectMany(x => x);
+            }
+
             // Apply paging if enabled
             if (specification.isPagingEnabled)
             {