代码优化，更新表名，支持数据结果写入

Author: jackyzhou

SQLToolkit/SQLToolkit/Business/DatabaseVersion.cs

@@ -9,15 +9,22 @@ public static class DatabaseVersion
         public static int Init()
         {
             return Helper.DapperHelper.Execute(@"
-                IF NOT EXISTS (SELECT * FROM sysobjects WHERE name='DatabaseVersion')
-                CREATE TABLE DatabaseVersion(
-                    [Id] [int]  PRIMARY KEY,
+                IF NOT EXISTS (SELECT * FROM sysobjects WHERE name='ST_DatabaseVersion')
+                CREATE TABLE ST_DatabaseVersion(
+                    ID int IDENTITY(1,1) PRIMARY KEY,
                     [Filename] [nvarchar](MAX)  NULL,
                     [ExecuteResult] [nvarchar](MAX)  NULL,
                     [ExecuteTime] [nvarchar](MAX)  NULL,
                 )");
         }
 
+        public static int UpdateRecord(string filename, string result)
+        {
+            var sql = string.Format(@"INSERT INTO ST_DatabaseVersion (Filename, ExecuteResult, ExecuteTime)
+                VALUES ('{0}', '{1}', '{2}');", filename, "success", DateTime.Now.ToString());
+            return Helper.DapperHelper.Execute(sql);
+        }
+
 
     }
 }

SQLToolkit/SQLToolkit/Helper/DapperHelper.cs

@@ -16,5 +16,7 @@ public static int Execute(string sql)
                 return conn.Execute(sql);
             }
         }
+
+       
     }
 }

SQLToolkit/SQLToolkit/Program.cs

@@ -57,14 +57,19 @@ static void Main(string[] args)
             foreach (string file in sqlFiles)
             {
                 Helper.LogHelper.Log(string.Format("Ready to exec sql script:{0}", file));
+                var filename = Path.GetFileName(file);
 
                 try
                 {
                     server.ConnectionContext.ExecuteNonQuery(File.ReadAllText(file));
+                    Business.DatabaseVersion.UpdateRecord(filename, "success");
+
                 }
                 catch (Exception ex)
                 {
                     Helper.LogHelper.Log(string.Format("Error:{0}", ex.ToString()));
+                    Business.DatabaseVersion.UpdateRecord(filename, "fail");
+
                 }
 
                 Helper.LogHelper.Log(string.Format("Finish to exec sql script:{0}", file));