WinForm下DevExpress透视表：通过SQL文件导入数据替换原有数据

看你现在的代码已经迈出了选择SQL文件的第一步，接下来咱们把剩下的关键步骤补全——读取SQL内容、执行脚本、刷新透视表，这样就能实现替换原有数据的需求了。我假设你用的是MySQL（因为连接字符串里是root账号），下面是完整的可行方案：

1. 完善SQL文件选择与读取逻辑 #

你之前只获取了文件名，还需要把文件里的SQL内容完整读出来。注意SQL文件可能用不同编码保存，尽量做兼容处理：

private void btnSelectFile_ItemClick(object sender, DevExpress.XtraBars.ItemClickEventArgs e)
{
    OpenFileDialog dlg = new OpenFileDialog();
    dlg.Filter = "SQL files (*.sql)|*.sql|All files (*.*)|*.*";
    if (dlg.ShowDialog() == DialogResult.OK)
    {
        // 读取SQL文件内容，优先用UTF8，乱码的话换成Encoding.Default试试
        string sqlContent = File.ReadAllText(dlg.FileName, Encoding.UTF8);
        // 执行SQL脚本并刷新透视表
        ExecuteSqlScript(sqlContent);
        RefreshPivotTableData();
    }
}

2. 编写SQL脚本执行方法 #

这里要注意，.sql文件里通常包含多条SQL语句，需要正确拆分（避免把字符串里的分号当成语句分隔符），同时用事务保证数据一致性，防止执行一半出错导致数据混乱：

private void ExecuteSqlScript(string sqlContent)
{
    string connString = "server=localhost;user id=root;password=;database=db;persist security info=True;";
    using (MySqlConnection conn = new MySqlConnection(connString))
    {
        try
        {
            conn.Open();
            // 开启事务，确保脚本要么全执行成功，要么全回滚
            using (MySqlTransaction tran = conn.BeginTransaction())
            {
                try
                {
                    // 基础拆分SQL语句（复杂场景比如字符串含分号的话，需要更严谨的解析）
                    string[] sqlCommands = sqlContent.Split(new[] { ";" }, StringSplitOptions.RemoveEmptyEntries);
                    foreach (string cmdText in sqlCommands)
                    {
                        string cleanCmd = cmdText.Trim();
                        if (!string.IsNullOrEmpty(cleanCmd))
                        {
                            using (MySqlCommand cmd = new MySqlCommand(cleanCmd, conn, tran))
                            {
                                cmd.ExecuteNonQuery();
                            }
                        }
                    }
                    tran.Commit();
                    MessageBox.Show("SQL脚本执行成功，数据已更新！");
                }
                catch (Exception ex)
                {
                    tran.Rollback();
                    MessageBox.Show($"执行SQL出错：{ex.Message}");
                }
            }
        }
        catch (Exception ex)
        {
            MessageBox.Show($"数据库连接失败：{ex.Message}");
        }
    }
}

小提示：如果你的SQL脚本里有包含分号的文本（比如INSERT语句里的描述字段），基础拆分逻辑会出错，这种情况可以手动处理脚本里的特殊语句，或者用专门的SQL解析库（比如SqlParser）来拆分。

3. 刷新DevExpress透视表数据 #

执行完SQL脚本后，需要重新从数据库拉取最新数据，替换透视表的原有数据源：

private void RefreshPivotTableData()
{
    string connString = "server=localhost;user id=root;password=;database=db;persist security info=True;";
    // 替换成你绑定透视表的实际查询语句
    string query = "SELECT * FROM 你的透视表数据源表"; 
    DataTable freshData = new DataTable();
    
    using (MySqlDataAdapter adapter = new MySqlDataAdapter(query, connString))
    {
        adapter.Fill(freshData);
    }
    
    // 绑定到PivotGridControl并强制刷新
    pivotGridControl1.DataSource = freshData;
    pivotGridControl1.RefreshData();
}

额外注意事项 #

• 确保你已经安装了MySQL的.NET驱动（比如NuGet包MySqlConnector或者MySQL.Data），不然会出现数据库相关的编译错误。
• 如果你的SQL脚本是用来清空原有数据再插入新数据，一定要放在事务里执行，避免出现数据残缺的情况。
• 处理大体积SQL文件时，建议用File.ReadLines逐行读取处理，避免一次性读取占用过多内存。

内容的提问来源于stack exchange，提问作者lalaland