Added specification maximum rows implementation.

Author: eben-roux

Shuttle.Access.Sql/Permission/PermissionQueryFactory.cs

@@ -24,22 +24,22 @@ public IQuery Registered(Guid id, Registered domainEvent)
         Guard.AgainstNull(domainEvent);
 
         return new Query(@"
-if not exists
+IF NOT EXISTS
 (
-    select
-        null
-    from
+    SELECT
+        NULL
+    FROM
         [dbo].[Permission]
-    where
+    WHERE
         [Name] = @Name
 )
-    insert into [dbo].[Permission]
+    INSERT INTO [dbo].[Permission]
     (
 	    [Id],
 	    [Name],
         [Status]
     )
-    values
+    VALUES
     (
 	    @Id,
 	    @Name,
@@ -77,29 +77,29 @@ public IQuery Contains(DataAccess.Query.Permission.Specification specification)
         Guard.AgainstNull(specification);
 
         return new Query($@"
-if exists
+IF EXISTS
 (
-select
-    null
-from
-    Permission p
+    SELECT
+        NULL
+    FROM
+        Permission p
 {Where(specification)}
 )
-    select 1
-else
-    select 0
+    SELECT 1
+ELSE
+    SELECT 0
 ")
             .AddParameter(Columns.NameMatch, specification.NameMatch);
     }
 
     public IQuery NameSet(Guid id, NameSet domainEvent)
     {
         return new Query(@"
-update
-    Permission
-set
+UPDATE
+    PERMISSION
+SET
     [Name] = @Name
-where
+WHERE
     Id = @Id
 ")
             .AddParameter(Columns.Id, id)
@@ -109,11 +109,11 @@ public IQuery NameSet(Guid id, NameSet domainEvent)
     private static IQuery SetStatus(Guid id, int status)
     {
         return new Query(@"
-update
+UPDATE
     Permission
-set
+SET
     Status = @Status
-where
+WHERE
     Id = @Id
 ")
             .AddParameter(Columns.Id, id)
@@ -133,13 +133,13 @@ public IQuery Specification(DataAccess.Query.Permission.Specification specificat
             : "count(*)";
 
         return new Query($@"
-select distinct
+SELECT DISTINCT {(columns && specification.MaximumRows > 0 ? $"TOP {specification.MaximumRows}" : string.Empty)}
 {what}
-from
+FROM
     Permission p
 {(!specification.RoleIds.Any() ? string.Empty : @"
-inner join
-    RolePermission rp on (rp.PermissionId = p.Id)
+INNER JOIN
+    RolePermission rp ON (rp.PermissionId = p.Id)
 ")}
 {Where(specification)}
 ")
@@ -149,23 +149,23 @@ RolePermission rp on (rp.PermissionId = p.Id)
     private string Where(DataAccess.Query.Permission.Specification specification)
     {
         return $@"
-where
+WHERE
 (
     isnull(@NameMatch, '') = ''
-    or
-    p.[Name] like '%' + @NameMatch + '%'
+    OR
+    p.[Name] LIKE '%' + @NameMatch + '%'
 )
 {(!specification.Names.Any() ? string.Empty : $@"
-and
-    p.[Name] in ({string.Join(",", specification.Names.Select(item => $"'{item}'"))})
+AND
+    p.[Name] IN ({string.Join(",", specification.Names.Select(item => $"'{item}'"))})
 ")}
 {(!specification.Ids.Any() ? string.Empty : $@"
-and
-    p.Id in ({string.Join(",", specification.Ids.Select(item => $"'{item}'"))})
+AND
+    p.Id IN ({string.Join(",", specification.Ids.Select(item => $"'{item}'"))})
 ")}
 {(!specification.RoleIds.Any() ? string.Empty : $@"
-and
-    rp.RoleId in ({string.Join(",", specification.RoleIds.Select(item => $"'{item}'"))})
+AND
+    rp.RoleId IN ({string.Join(",", specification.RoleIds.Select(item => $"'{item}'"))})
 ")}
 ";
     }

Shuttle.Access.Sql/Role/RoleQueryFactory.cs

@@ -120,7 +120,7 @@ public IQuery Permissions(DataAccess.Query.Role.Specification specification)
         Guard.AgainstNull(specification);
 
         return new Query($@"
-SELECT 
+SELECT {(specification.MaximumRows > 0 ? $"TOP {specification.MaximumRows}" : string.Empty)}
     rp.RoleId,
     p.Id,
     p.Name,
@@ -185,7 +185,7 @@ private static IQuery Specification(DataAccess.Query.Role.Specification specific
             : "COUNT(*)";
 
         return new Query($@"
-SELECT
+SELECT {(columns && specification.MaximumRows > 0 ? $"TOP {specification.MaximumRows}" : string.Empty)}
 {what}
 FROM
     Role

Shuttle.Access.Sql/Session/SessionQueryFactory.cs

@@ -131,7 +131,7 @@ public IQuery Search(DataAccess.Query.Session.Specification specification)
         Guard.AgainstNull(specification);
 
         return new Query($@"
-SELECT DISTINCT
+SELECT DISTINCT {(specification.MaximumRows > 0 ? $"TOP {specification.MaximumRows}" : string.Empty)}
 {SelectedColumns}
 FROM
 	[dbo].[Session]