refactor unit tests.

test/DotNetCore.CAP.MySql.Test/MySqlStorageTest.cs

@@ -29,36 +29,12 @@ namespace DotNetCore.CAP.MySql.Test
             }
         }
 
-        [Fact]
-        public void DatabaseTable_Published_IsExists()
-        {
-            var tableName = "cap.published";
-            using (var connection = ConnectionUtil.CreateConnection(_masterDbConnectionString))
-            {
-                var sql = $"SELECT TABLE_NAME FROM `TABLES` WHERE TABLE_SCHEMA='{_dbName}' AND TABLE_NAME = '{tableName}'";
-                var result = connection.QueryFirstOrDefault<string>(sql);
-                Assert.NotNull(result);
-                Assert.Equal(tableName, result);
-            }
-        }
-
-        [Fact]
-        public void DatabaseTable_Queue_IsExists()
-        {
-            var tableName = "cap.queue";
-            using (var connection = ConnectionUtil.CreateConnection(_masterDbConnectionString))
-            {
-                var sql = $"SELECT TABLE_NAME FROM `TABLES` WHERE TABLE_SCHEMA='{_dbName}' AND TABLE_NAME = '{tableName}'";
-                var result = connection.QueryFirstOrDefault<string>(sql);
-                Assert.NotNull(result);
-                Assert.Equal(tableName, result);
-            }
-        }
-
-        [Fact]
-        public void DatabaseTable_Received_IsExists()
+        [Theory]
+        [InlineData("cap.published")]
+        [InlineData("cap.queue")]
+        [InlineData("cap.received")]
+        public void DatabaseTable_IsExists(string tableName)
         {
-            var tableName = "cap.received";
             using (var connection = ConnectionUtil.CreateConnection(_masterDbConnectionString))
             {
                 var sql = $"SELECT TABLE_NAME FROM `TABLES` WHERE TABLE_SCHEMA='{_dbName}' AND TABLE_NAME = '{tableName}'";

test/DotNetCore.CAP.SqlServer.Test/SqlServerStorageTest.cs

@@ -23,43 +23,16 @@ SELECT 'False'";
             }
         }
 
-        [Fact]
-        public void DatabaseTable_Published_IsExists()
-        {
-            using (var connection = ConnectionUtil.CreateConnection())
-            {
-                var sql = @"
-IF OBJECT_ID(N'[Cap].[Published]',N'U') IS NOT NULL
-SELECT 'True'
-ELSE
-SELECT 'False'";
-                var result = connection.QueryFirst<bool>(sql);
-                Assert.True(result);
-            }
-        }
-
-        [Fact]
-        public void DatabaseTable_Queue_IsExists()
+        [Theory]
+        [InlineData("[Cap].[Published]")]
+        [InlineData("[Cap].[Queue]")]
+        [InlineData("[Cap].[Received]")]
+        public void DatabaseTable_IsExists(string tableName)
         {
             using (var connection = ConnectionUtil.CreateConnection())
             {
-                var sql = @"
-IF OBJECT_ID(N'[Cap].[Queue]',N'U') IS NOT NULL
-SELECT 'True'
-ELSE
-SELECT 'False'";
-                var result = connection.QueryFirst<bool>(sql);
-                Assert.True(result);
-            }
-        }
-
-        [Fact]
-        public void DatabaseTable_Received_IsExists()
-        {
-            using (var connection = ConnectionUtil.CreateConnection())
-            {
-                var sql = @"
-IF OBJECT_ID(N'[Cap].[Received]',N'U') IS NOT NULL
+                var sql = $@"
+IF OBJECT_ID(N'{tableName}',N'U') IS NOT NULL
 SELECT 'True'
 ELSE
 SELECT 'False'";