009_DI-Elec/SWSDBSchemeUpgradeTool/MainWindow.xaml.cs

using Learun.Application.TwoDevelopment.ZZDT_EC;
using MySql.Data.MySqlClient;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.ComponentModel;
using System.Configuration;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Documents.DocumentStructures;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Navigation;
using System.Windows.Shapes;
using System.Xml.Linq;
using System.Xml.Schema;
using Path = System.IO.Path;

namespace SWSDBSchemeUpgradeTool
{
    /// <summary>
    /// Interaction logic for MainWindow.xaml
    /// </summary>
    public partial class MainWindow : Window, INotifyPropertyChanged
    {
        public event PropertyChangedEventHandler PropertyChanged;
        #region binding
        private string _configPath;



        public string configPath
        {
            get { return _configPath; }
            set
            {
                _configPath = value;
            }
        }

        private string _basedb;

        public string basedb
        {
            get { return _basedb; }
            set { _basedb = value; }
        }


        private string _curVersion;

        public string curVersion
        {
            get { return _curVersion; }
            set { _curVersion = value; }
        }
        #endregion
        private string dbName = "";
        /// <summary>
        /// 是否被初始化过。没有的话，就要去执行sws.sql。
        /// </summary>
        private bool bInitialed;
        /// <summary>
        /// (iis文件夹根目录）
        /// </summary>
        private string IISDirectory;
        /// <summary>
        /// exe的目录，会带一个\在后面
        /// </summary>
        private string baseDirectory;

        string logFileName = "sync_errors.log";
        string Initial_Data_sql = "Initial_Data.sql";
        public MainWindow()
        {

            InitializeComponent();
            ContentGrid.DataContext = this;


            ReadDBConfig();
            ConnDB();
            IfInitialed();



        }
        /// <summary>
        /// 读取database.config文件
        /// </summary>
        private void ReadDBConfig()
        {
            baseDirectory = AppDomain.CurrentDomain.BaseDirectory;
            // 获取上一级目录(iis文件夹根目录）
            IISDirectory = Directory.GetParent(baseDirectory.TrimEnd(Path.DirectorySeparatorChar)).FullName;

            configPath = IISDirectory + "/XmlConfig/" + "database.config";
            if (System.IO.File.Exists(configPath))
            {
                XDocument xDoc = XDocument.Load(configPath);
                var node = xDoc.Descendants("connectionStrings").Elements("add").FirstOrDefault();
                if (node == null)
                {
                    //不存在
                    MessageBox.Show("未能在database.config中的connectionStrings - add路径下找到合法的connectionString属性。请确认！");
                    Application.Current.Shutdown();
                }
                basedb = node.Attribute("connectionString").Value;
            }
            else
            {
                //不存在
                MessageBox.Show("未能在同目录XmlConfig文件夹下找到database.config文件。请确认！");
                Application.Current.Shutdown();
            }
        }
        /// <summary>
        /// 连接到数据库
        /// </summary>
        private void ConnDB()
        {
            SqlSugarHelper.Db = new SqlSugarScope(new ConnectionConfig()
            {
                ConfigId = "0",
                ConnectionString = basedb,//连接符字串
                DbType = DbType.MySql,//数据库类型
                IsAutoCloseConnection = true //不设成true要手动close
            },
db =>
{
    //(A)全局生效配置点，一般AOP和程序启动的配置扔这里面 ，所有上下文生效
    //调试SQL事件，可以删掉
    db.Aop.OnLogExecuting = (sql, pars) =>
    {

        //获取原生SQL推荐 5.1.4.63  性能OK
        Console.WriteLine(UtilMethods.GetNativeSql(sql, pars));

        //获取无参数化SQL 对性能有影响，特别大的SQL参数多的，调试使用
        //Console.WriteLine(UtilMethods.GetSqlString(DbType.SqlServer,sql,pars))

    };

    //多个配置就写下面
    //db.Ado.IsDisableMasterSlaveSeparation=true;

    //注意多租户 有几个设置几个
    //db.GetConnection(i).Aop
});



            // 尝试找到database=的部分  
            int startIndex = basedb.IndexOf("database=");
            if (startIndex != -1)
            {
                // 查找下一个分号的位置，以分割出database的值  
                int endIndex = basedb.IndexOf(";", startIndex);
                if (endIndex == -1)
                {
                    // 如果没有找到分号，则取字符串的剩余部分  
                    endIndex = basedb.Length;
                }

                // 提取database的值  
                dbName = basedb.Substring(startIndex + "database=".Length, endIndex - startIndex - "database=".Length);

            }
            else
            {
                MessageBox.Show("Database name not found in the connect string.请确认！");
                Application.Current.Shutdown();
            }
        }

        private void IfInitialed()
        {

            var temp = SqlSugarHelper.Db.Ado.GetDataTable($@"SELECT   
    *   
FROM   
    information_schema.TABLES   
WHERE   
    TABLE_SCHEMA = '{dbName}' AND   
    TABLE_NAME = 'ec_business_table';");

            if (temp.Rows.Count > 0)
            {
                curVersion = $"数据库名：{dbName}";
                bInitialed = true;
            }
            else
            {
                curVersion = "当前数据库还未初始化！";
                bInitialed = false;
            }



        }


        void ExecuteVersionedScripts(string scriptsBasePath)
        {
            // 获取所有版本文件夹，并按版本顺序排序
            var versionFolders = Directory.GetDirectories(scriptsBasePath)
                                          .OrderBy(v => v)
                                          .ToList();

            foreach (var versionFolder in versionFolders)
            {
                //分sub和nonsub2个子文件夹
                // 获取版本号
                string version = new DirectoryInfo(versionFolder).Name;

                var subFolders = Directory.GetDirectories(Path.Combine(scriptsBasePath, version)).ToList();
                foreach (var subFolder in subFolders)
                {
                    // 获取该版本文件夹下的所有脚本
                    string[] sqlFiles = Directory.GetFiles(subFolder, "*.sql").OrderBy(f => f).ToArray();

                    string subFolderName = new DirectoryInfo(subFolder).Name;
                    bool ProjectRelated = true;
                    if (subFolderName.ToLower().Contains("no"))
                    {
                        //和Project无关
                        ProjectRelated = false;
                    }
                    else
                    {
                        ProjectRelated = true;
                        //和Project相关
                    }
                    // 检查该版本的所有脚本是否都已执行
                    if (!AreAllScriptsExecuted(version, sqlFiles))
                    {
                        foreach (var file in sqlFiles)
                        {
                            string scriptName = System.IO.Path.GetFileName(file);

                            // 如果该脚本未执行，则执行它
                            if (!IsScriptExecuted(version, scriptName))
                            {
                                string sql = File.ReadAllText(file);
                                //using MySqlCommand cmd = new MySqlCommand(sql, conn);
                                //cmd.ExecuteNonQuery();


                                try
                                {
                                    CompareSchemas2(sql, ProjectRelated, scriptName);
                                    // 记录该脚本的执行
                                    RecordScriptExecution(version, scriptName);
                                }
                                catch (MySqlException ex)
                                {
                                    LogError(baseDirectory + logFileName, ex, sql);
                                }
                            }
                        }
                    }
                }

            }
        }
        static void LogError(string logFilePath, MySqlException ex, string info)
        {
            StreamWriter log = new StreamWriter(logFilePath, append: true);
            log.WriteLine("Timestamp: " + DateTime.Now);
            log.WriteLine("SQL Error Number: " + ex.Number);
            log.WriteLine("Error Message: " + ex.Message);
            log.WriteLine("SQL involved: " + info);
            log.WriteLine("---------------------------------------------------");
            log.Close();
        }
        static void LogInfo(string logFilePath, string info)
        {
            StreamWriter log = new StreamWriter(logFilePath, append: true);
            log.WriteLine("Timestamp: " + DateTime.Now);
            log.WriteLine("Warning Message: " + info);
            log.WriteLine("---------------------------------------------------");
            log.Close();
        }


        // 检查版本下的所有脚本是否都已执行
        bool AreAllScriptsExecuted(string version, string[] sqlFiles)
        {
            foreach (var file in sqlFiles)
            {
                string scriptName = System.IO.Path.GetFileName(file);
                if (!IsScriptExecuted(version, scriptName))
                {
                    return false; // 如果有一个脚本未执行，则返回false
                }
            }
            return true;
        }

        // 检查单个脚本是否已执行
        bool IsScriptExecuted(string version, string scriptName)
        {
            string query = $"SELECT COUNT(1) FROM SchemaVersion WHERE Version = '{version}' AND ScriptName = '{scriptName}';";
            //using MySqlCommand cmd = new MySqlCommand(query, conn);
            //cmd.Parameters.AddWithValue("@Version", version);
            //cmd.Parameters.AddWithValue("@ScriptName", scriptName);
            var temp = SqlSugarHelper.Db.Ado.GetDataTable(query);
            return Convert.ToInt32(temp.Rows[0][0]) > 0;
        }

        // 记录脚本执行情况
        void RecordScriptExecution(string version, string scriptName)
        {
            string query = $"INSERT INTO SchemaVersion (Version, ScriptName, UpdateTime) VALUES ('{version}', '{scriptName}', NOW());";
            //using MySqlCommand cmd = new MySqlCommand(query, conn);
            //cmd.Parameters.AddWithValue("@Version", version);
            //cmd.Parameters.AddWithValue("@ScriptName", scriptName);
            //cmd.ExecuteNonQuery();
            SqlSugarHelper.Db.Ado.ExecuteCommand(query);
        }
        /// <summary>
        /// 增补更新。去找SQL文件夹下，每个小sql的内容
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Button_Click(object sender, RoutedEventArgs e)
        {
            if (bInitialed)
            {
                if (!Directory.Exists(IISDirectory + "/" + "SQL"))
                {
                    MessageBox.Show($"IIS根目录({IISDirectory})下的SQL文件夹不存在。请检查。");
                    return;
                }
                ExecuteVersionedScripts(IISDirectory + "/" + "SQL");
            }

            MessageBox.Show("SQL synchronization completed. Please check the log file for any errors: " + baseDirectory + logFileName);

        }
        private async Task UpdateProgress(string content, int value)
        {
            StatusText.Content = content;
            ProgressBar.Value = value;
            await Task.Delay(200); // Simulating work

        }
        private async Task UpdateText(string content)
        {
            StatusText2.Text = content.Replace("\n", " ");

        }
        private async void Button_Click_1(object sender, RoutedEventArgs e)
        {
            await UpdateProgress("开始解析原始SQL脚本。。。", 20);
            var allSqlTb = ExtractTables();
            await UpdateProgress("开始查询当前数据库内的状态。。。", 20);
            var allDbTb = GetDatabaseTableStructures();
            await UpdateProgress("开始比较SQL脚本和数据库的差异。。。", 40);
            var diffcontent = CompareSchemas(allSqlTb, allDbTb);
            await UpdateProgress("开始生成需要的SQL语句。。。", 60);
            var fixedSQL = GenerateFixSql(diffcontent, allSqlTb);
            await UpdateProgress("SQL语句已准备好，请预览。。。", 80);
            //预览
            SQLPreview secondWindow = new SQLPreview(fixedSQL);
            secondWindow.ShowDialog();
            var chooseRes = MessageBox.Show("是否要开始进行SQL语句？", "询问", MessageBoxButton.YesNo, MessageBoxImage.Question);
            if (chooseRes == MessageBoxResult.Yes)
            {
                await UpdateProgress("开始进行SQL语句执行。。。", 90);
                await ExecuteComparisonSQL(fixedSQL);
                await UpdateProgress("完成。", 100);
                MessageBox.Show("Initial Database Structure comparison completed. Please check the log file for any errors: ");
            }
            else
            {

            }

            await UpdateProgress("", 0);
        }
        /// <summary>
        /// 解析、抽取初始脚本的SQL（表）
        /// </summary>
        /// <returns></returns>
        List<Table> ExtractTables()
        {
            string sqlFilePath = IISDirectory + "/" + "SQL" + "/" + Initial_Data_sql;  // Update with the correct file path
            string sqlContent = File.ReadAllText(sqlFilePath);
            var tables = new List<Table>();

            // Match each CREATE TABLE statement
            string tablePattern = @"CREATE\s+TABLE\s+`?(?<TableName>\w+)`?\s*\((?<Columns>[\s\S]*?)\)\s*ENGINE";
            var tableMatches = Regex.Matches(sqlContent, tablePattern);

            foreach (Match tableMatch in tableMatches)
            {
                var tableName = tableMatch.Groups["TableName"].Value;
                var columnsDefinition = tableMatch.Groups["Columns"].Value;

                var table = new Table
                {
                    Name = tableName,
                    Columns = ExtractColumns(columnsDefinition)
                };

                tables.Add(table);
            }

            return tables;
        }
        /// <summary>
        /// 解析、抽取初始脚本的SQL（表中的列）
        /// </summary>
        /// <param name="columnsDefinition"></param>
        /// <returns></returns>
        public static List<ColumnInfo> ExtractColumns(string columnsDefinition)
        {
            var columns = new List<ColumnInfo>();
            //string columnPattern = @"`(?<ColumnName>\w+)`\s+(?<DataType>\w+\(\d+\))\s+(CHARACTER\s+SET\s+\w+\s+COLLATE\s+\w+\s+)?(?<Nullability>NOT\s+NULL|NULL)";
            string columnPattern = @"`(?<ColumnName>\w+)`\s+(?<DataType>\w+(\(\d+\))?)(\s+CHARACTER\s+SET\s+\w+\s+COLLATE\s+\w+)?\s+(?<Nullability>NOT\s+NULL|NULL)";

            // Match each column definition inside the CREATE TABLE statement
            // string columnPattern = @"`(?<column>\w+)`\s+\w+";// @"`(?<ColumnName>\w+)`\s+(?<ColumnType>[^,]+),?";
            var columnMatches = Regex.Matches(columnsDefinition, columnPattern);

            foreach (Match match in columnMatches)
            {
                //var columnName = columnMatch.Groups["ColumnName"].Value;
                //var columnType = columnMatch.Groups["ColumnType"].Value;

                //columns.Add($"{columnName} {columnType}");
                var columnInfo = new ColumnInfo
                {
                    ColumnName = match.Groups["ColumnName"].Value,
                    DataType = match.Groups["DataType"].Value,
                    IsNullable = match.Groups["Nullability"].Value != "NOT NULL"
                };
                columns.Add(columnInfo);

                //columns.Add(columnMatch.Groups["column"].Value);
            }

            return columns;
        }

        /// <summary>
        /// 读取当前数据库里的表结构
        /// </summary>
        /// <returns></returns>
        public List<Table> GetDatabaseTableStructures()
        {
            var tableStructures = new List<Table>();


            var tables = SqlSugarHelper.Db.Ado.GetDataTable($@"SELECT   
    *   
FROM   
    information_schema.TABLES   
WHERE   
    TABLE_SCHEMA = '{dbName}';");

            foreach (System.Data.DataRow row in tables.Rows)
            {
                string tableName = row["TABLE_NAME"].ToString();
                //var columns = new List<string>();

                //using (var command = new MySqlCommand($"DESCRIBE {tableName}", connection))
                //using (var reader = command.ExecuteReader())
                //{
                //    while (reader.Read())
                //    {
                //        columns.Add(reader["Field"].ToString());
                //    }
                //}

                //tableStructures.Add(tableName, columns);


                var TbColumns = new List<ColumnInfo>();
                var columns = SqlSugarHelper.Db.Ado.GetDataTable($"DESCRIBE {tableName}");
                foreach (System.Data.DataRow row2 in columns.Rows)
                {
                    TbColumns.Add(new ColumnInfo()
                    {
                        ColumnName = row2["Field"].ToString(),
                        DataType = row2["Type"].ToString(),
                        IsNullable = row2["Null"].ToString() != "NO"
                    });
                }

                tableStructures.Add(new Table()
                {
                    Name = tableName,
                    Columns = TbColumns
                });
            }


            return tableStructures;
        }


        /// <summary>
        /// 比较sql抽取出来的表结构和当前数据库里的（增补sql小文件）
        /// </summary>
        /// <param name="sqlSchema"></param>
        /// <param name="dbSchema"></param>
        /// <returns></returns>
        public List<string> CompareSchemas2(string sql, bool ProjectRelated,string SQLFILENAME)
        {
            var discrepancies = new List<string>();
            #region 拓展出需要的各个项目的 从business table表？
            var bsList = SqlSugarHelper.Db.Queryable<ec_business_tableEntity>().ToList();
            var projList = SqlSugarHelper.Db.Queryable<ec_projectEntity>().ToList();


            var subsql = sql.Split(';');
            #region 处理
            // 正则表达式
            string pattern = @"(?<=ALTER\s+TABLE\s+`)[^`]+";
            string pattern2 = @"(?<=CREATE\s+TABLE\s+`)[^`]+";
            int patternType;//1是create，0是update
            foreach (var sqlstr in subsql)
            {
                if (string.IsNullOrWhiteSpace(sqlstr))
                {
                    continue;
                }
                // 匹配表名
                Match match = Regex.Match(sqlstr, pattern);
                if (string.IsNullOrEmpty(sqlstr))
                {
                    continue;
                }
                if (match.Length == 0)
                {
                    match = Regex.Match(sqlstr, pattern2); patternType = 1;
                }
                else
                {
                    patternType = 0;
                }
                if (match.Length == 0 )
                {
                    //无效的sql
                    LogInfo(baseDirectory + logFileName, $"无法从{SQLFILENAME}.sql文件中解析出正确的create table 或 update table。确保是有效的sql。文本为 {sqlstr}");
                    continue;
                }
                var groupMatch = Regex.Matches(sqlstr, pattern);
                #endregion
                if (match.Success)
                {
                    string tableName = match.Value;
                    Console.WriteLine("Table name: " + tableName);
                    //在Project文件夹下 或者 属于业务表
                    if (ProjectRelated || bsList.Select(x => x.BusinessTableCode.ToUpper()).Contains(tableName.ToUpper()))
                    {
                        //属于Project相关的表，需要重复执行
                        foreach (var proj in projList)
                        {
                            // 替换表名为其他表名
                            string newTableName = tableName + "_" + proj.ProjectIndex;
                            string modifiedSql = "";
                            if (patternType == 0)
                            {
                                modifiedSql     = Regex.Replace(sqlstr,  pattern, newTableName);
                            }
                            else
                            {
                                modifiedSql = Regex.Replace(sqlstr, pattern2, newTableName);
                            }
                    

                            Console.WriteLine("Modified SQL: " + modifiedSql);


                            try
                            {
                                SqlSugarHelper.Db.Ado.ExecuteCommand(modifiedSql);
                            }
                            catch (Exception ex)
                            {
                                LogInfo(baseDirectory + logFileName, tableName + " 项目表更新出现问题，" + ex.Message);
                            }
                        }
                    }

                    //基础表，执行一次就行
                    try
                    {
                        SqlSugarHelper.Db.Ado.ExecuteCommand(sql);
                    }
                    catch (Exception ex)
                    {
                        LogInfo(baseDirectory + logFileName, tableName + " 基础表更新出现问题，" + ex.Message);
                    }



                }
                else
                {
                    Console.WriteLine("Table name not found.");
                }
            }

            #endregion


            return discrepancies;
        }
        /// <summary>
        /// 比较sql抽取出来的表结构和当前数据库里的
        /// </summary>
        /// <param name="sqlSchema"></param>
        /// <param name="dbSchema"></param>
        /// <returns></returns>
        public List<string> CompareSchemas(List<Table> sqlSchema, List<Table> dbSchema)
        {
            var discrepancies = new List<string>();
            #region 拓展出需要的各个项目的 从business table表？
            var bsList = SqlSugarHelper.Db.Queryable<ec_business_tableEntity>().ToList();
            var projList = SqlSugarHelper.Db.Queryable<ec_projectEntity>().ToList();

            //拓展sqlSchema里的记录，比如ec_enginedata，根据项目拓展到若干个
            foreach (var bs in bsList)
            {
                var baseTb = sqlSchema.FirstOrDefault(x => x.Name.ToUpper() == bs.BusinessTableCode.ToUpper());
                if (baseTb != null)
                {
                    foreach (var proj in projList)
                    {
                        var projTb = new Table()
                        {
                            Name = baseTb.Name + "_" + proj.ProjectIndex,
                            Columns = baseTb.Columns
                        };
                        sqlSchema.Add(projTb);
                    }
                }
                else
                {
                    //bus表里有问题
                    LogInfo(baseDirectory + logFileName, "ec_business_table表中的记录有问题 " + bs.BusinessTableID + " " + bs.BusinessTableCode);
                }
            }
            #endregion
            foreach (var table in sqlSchema)
            {
                if (!dbSchema.Any(x => x.Name.ToUpper() == table.Name.ToUpper()))
                {
                    discrepancies.Add($"Table {table.Name} is missing in the database.");
                    continue;
                }

                var sqlColumns = table.Columns.Select(x => x.ColumnName.ToUpper()).ToList();
                var dbColumns = dbSchema.FirstOrDefault(x => x.Name == table.Name).Columns.Select(x => x.ColumnName.ToUpper()).ToList();

                // Find missing columns
                foreach (var column in sqlColumns)
                {
                    if (!dbColumns.Contains(column))
                    {
                        discrepancies.Add($"Column {column} is missing in table {table.Name}.");
                    }
                }
            }

            return discrepancies;
        }
        /// <summary>
        /// 根据比较结果，生成需要的SQL语句
        /// </summary>
        /// <param name="discrepancies"></param>
        /// <param name="sqlSchema"></param>
        /// <returns></returns>
        public List<string> GenerateFixSql(List<string> discrepancies, List<Table> sqlSchema)
        {
            var sqlStatements = new List<string>();

            foreach (var discrepancy in discrepancies)
            {
                var parts = discrepancy.Split(' ');

                if (parts[0] == "Table")
                {
                    // 生成创建表的SQL语句
                    string tableName = parts[1];
                    var columns = sqlSchema.FirstOrDefault(x => x.Name.ToUpper() == tableName.ToUpper())?.Columns;
                    string createTableSql = $"CREATE TABLE {tableName} (\n";
                    if (columns == null)
                    {
                        LogInfo(baseDirectory + logFileName, "GenerateFixSql时有问题 表匹配不到 " + tableName);
                        continue;
                    }
                    foreach (var column in columns)
                    {
                        if (column.IsNullable)
                        {
                            createTableSql += $"{column.ColumnName} {column.DataType} NULL ,\n"; // 简化的列定义，仅示例
                        }
                        else
                        {
                            createTableSql += $"{column.ColumnName} {column.DataType} NOT NULL ,\n"; // 简化的列定义，仅示例
                        }
                    }

                    createTableSql = createTableSql.TrimEnd(',', '\n') + "\n);";
                    sqlStatements.Add(createTableSql);
                }
                else if (parts[0] == "Column")
                {
                    // 生成添加列的SQL语句
                    string columnName = parts[1];
                    string tableName = parts[6].Replace(".", "");
                    var columns = sqlSchema.FirstOrDefault(x => x.Name.ToUpper() == tableName.ToUpper())?.Columns;

                    if (columns == null)
                    {
                        LogInfo(baseDirectory + logFileName, "GenerateFixSql时有问题 表匹配不到 " + tableName);
                        continue;
                    }

                    var column = columns.FirstOrDefault(Y => Y.ColumnName.ToUpper() == columnName.ToUpper());
                    if (column == null)
                    {
                        LogInfo(baseDirectory + logFileName, "GenerateFixSql时有问题 列匹配不到 " + tableName + "." + columnName);
                        continue;
                    }

                    //sqlStatements.Add($"ALTER TABLE {tableName} ADD COLUMN {columnName} TEXT;");
                    if (column.IsNullable)
                    {
                        sqlStatements.Add($"ALTER TABLE {tableName} ADD COLUMN {columnName} {column.DataType} NULL;");
                    }
                    else
                    {
                        sqlStatements.Add($"ALTER TABLE {tableName} ADD COLUMN {columnName} {column.DataType} NOT NULL;");
                    }
                }
            }

            return sqlStatements;
        }
        /// <summary>
        /// 执行SQL
        /// </summary>
        /// <param name="SQLs"></param>
        /// <returns></returns>
        public async Task ExecuteComparisonSQL(List<string> SQLs)
        {
            foreach (var SQL in SQLs)
            {
                try
                {

                    await UpdateText(SQL);

                    SqlSugarHelper.Db.Ado.ExecuteCommand(SQL);

                }
                catch (MySqlException ex)
                {
                    LogError(baseDirectory + logFileName, ex, SQL);
                }
            }
        }
        /// <summary>
        /// 打开日志
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Button_Click_2(object sender, RoutedEventArgs e)
        {
            //打开log

            try
            {
                ProcessStartInfo startInfo = new ProcessStartInfo()
                {
                    FileName = "notepad.exe", // 指定使用记事本打开
                    Verb = "runas", // 使用管理员权限启动
                    Arguments = baseDirectory + logFileName,
                    UseShellExecute = true // 使用操作系统的Shell来执行
                };
                Process.Start(startInfo);
            }
            catch (Exception ex)
            {
                MessageBox.Show("无法打开日志文件: " + ex.Message);
            }
        }
    }

    public class Table
    {
        public string Name { get; set; }
        public List<ColumnInfo> Columns { get; set; }
    }

    public class ColumnInfo
    {
        public string ColumnName { get; set; }
        public string DataType { get; set; }
        public bool IsNullable { get; set; }
    }
}