Use schema from constant in tests (HangfireIO#1532)

I made these changes while working through HangfireIO#1531 if you want to include them.

Author: kendaleiv

tests/Hangfire.SqlServer.Tests/CountersAggregatorFacts.cs

@@ -14,8 +14,8 @@ public class CountersAggregatorFacts
         [Fact, CleanDatabase]
         public void CountersAggregatorExecutesProperly()
         {
-            const string createSql = @"
-insert into HangFire.Counter ([Key], [Value], ExpireAt) 
+            var createSql = $@"
+insert into [{Constants.DefaultSchema}].Counter ([Key], [Value], ExpireAt) 
 values ('key', 1, @expireAt)";
 
             using (var connection = CreateConnection())
@@ -31,7 +31,7 @@ insert into HangFire.Counter ([Key], [Value], ExpireAt)
                 aggregator.Execute(cts.Token);
 
                 // Assert
-                Assert.Equal(1, connection.Query<int>(@"select count(*) from HangFire.AggregatedCounter").Single());
+                Assert.Equal(1, connection.Query<int>($"select count(*) from [{Constants.DefaultSchema}].AggregatedCounter").Single());
             }
         }
 

tests/Hangfire.SqlServer.Tests/ExpirationManagerFacts.cs

@@ -67,8 +67,8 @@ public void Execute_Processes_AggregatedCounterTable()
             using (var connection = CreateConnection())
             {
                 // Arrange
-                const string createSql = @"
-insert into HangFire.AggregatedCounter ([Key], [Value], ExpireAt) 
+                var createSql = $@"
+insert into [{Constants.DefaultSchema}].AggregatedCounter ([Key], [Value], ExpireAt) 
 values ('key', 1, @expireAt)";
                 connection.Execute(createSql, new { expireAt = DateTime.UtcNow.AddMonths(-1) });
 
@@ -78,7 +78,7 @@ insert into HangFire.AggregatedCounter ([Key], [Value], ExpireAt)
                 manager.Execute(_cts.Token);
 
                 // Assert
-                Assert.Equal(0, connection.Query<int>(@"select count(*) from HangFire.Counter").Single());
+                Assert.Equal(0, connection.Query<int>($"select count(*) from [{Constants.DefaultSchema}].Counter").Single());
             }
         }
 
@@ -88,8 +88,8 @@ public void Execute_Processes_JobTable()
             using (var connection = CreateConnection())
             {
                 // Arrange
-                const string createSql = @"
-insert into HangFire.Job (InvocationData, Arguments, CreatedAt, ExpireAt) 
+                var createSql = $@"
+insert into [{Constants.DefaultSchema}].Job (InvocationData, Arguments, CreatedAt, ExpireAt) 
 values ('', '', getutcdate(), @expireAt)";
                 connection.Execute(createSql, new { expireAt = DateTime.UtcNow.AddMonths(-1) });
 
@@ -99,7 +99,7 @@ insert into HangFire.Job (InvocationData, Arguments, CreatedAt, ExpireAt)
                 manager.Execute(_cts.Token);
 
                 // Assert
-                Assert.Equal(0, connection.Query<int>(@"select count(*) from HangFire.Job").Single());
+                Assert.Equal(0, connection.Query<int>($"select count(*) from [{Constants.DefaultSchema}].Job").Single());
             }
         }
 
@@ -109,8 +109,8 @@ public void Execute_Processes_ListTable()
             using (var connection = CreateConnection())
             {
                 // Arrange
-                const string createSql = @"
-insert into HangFire.List ([Key], ExpireAt) 
+                var createSql = $@"
+insert into [{Constants.DefaultSchema}].List ([Key], ExpireAt) 
 values ('key', @expireAt)";
                 connection.Execute(createSql, new { expireAt = DateTime.UtcNow.AddMonths(-1) });
 
@@ -120,7 +120,7 @@ insert into HangFire.List ([Key], ExpireAt)
                 manager.Execute(_cts.Token);
 
                 // Assert
-                Assert.Equal(0, connection.Query<int>(@"select count(*) from HangFire.List").Single());
+                Assert.Equal(0, connection.Query<int>($"select count(*) from [{Constants.DefaultSchema}].List").Single());
             }
         }
 
@@ -130,8 +130,8 @@ public void Execute_Processes_SetTable()
             using (var connection = CreateConnection())
             {
                 // Arrange
-                const string createSql = @"
-insert into HangFire.[Set] ([Key], [Score], [Value], ExpireAt) 
+                var createSql = $@"
+insert into [{Constants.DefaultSchema}].[Set] ([Key], [Score], [Value], ExpireAt) 
 values ('key', 0, '', @expireAt)";
                 connection.Execute(createSql, new { expireAt = DateTime.UtcNow.AddMonths(-1) });
 
@@ -141,7 +141,7 @@ insert into HangFire.[Set] ([Key], [Score], [Value], ExpireAt)
                 manager.Execute(_cts.Token);
 
                 // Assert
-                Assert.Equal(0, connection.Query<int>(@"select count(*) from HangFire.[Set]").Single());
+                Assert.Equal(0, connection.Query<int>($"select count(*) from [{Constants.DefaultSchema}].[Set]").Single());
             }
         }
 
@@ -151,8 +151,8 @@ public void Execute_Processes_HashTable()
             using (var connection = CreateConnection())
             {
                 // Arrange
-                const string createSql = @"
-insert into HangFire.Hash ([Key], [Field], [Value], ExpireAt) 
+                var createSql = $@"
+insert into [{Constants.DefaultSchema}].Hash ([Key], [Field], [Value], ExpireAt) 
 values ('key', 'field', '', @expireAt)";
                 connection.Execute(createSql, new { expireAt = DateTime.UtcNow.AddMonths(-1) });
 
@@ -162,14 +162,14 @@ insert into HangFire.Hash ([Key], [Field], [Value], ExpireAt)
                 manager.Execute(_cts.Token);
 
                 // Assert
-                Assert.Equal(0, connection.Query<int>(@"select count(*) from HangFire.Hash").Single());
+                Assert.Equal(0, connection.Query<int>($"select count(*) from [{Constants.DefaultSchema}].Hash").Single());
             }
         }
 
         private static void CreateExpirationEntry(SqlConnection connection, DateTime? expireAt)
         {
-            const string insertSql = @"
-insert into HangFire.AggregatedCounter ([Key], [Value], [ExpireAt])
+            var insertSql = $@"
+insert into [{Constants.DefaultSchema}].AggregatedCounter ([Key], [Value], [ExpireAt])
 values (N'key', 1, @expireAt)";
 
             connection.Execute(insertSql, new { expireAt });
@@ -178,7 +178,7 @@ insert into HangFire.AggregatedCounter ([Key], [Value], [ExpireAt])
         private static bool IsEntryExpired(SqlConnection connection)
         {
             var count = connection.Query<int>(
-                    "select count(*) from HangFire.AggregatedCounter where [Key] = N'key'").Single();
+                    $"select count(*) from [{Constants.DefaultSchema}].AggregatedCounter where [Key] = N'key'").Single();
             return count == 0;
         }