Winform中实现连接Mysql8使用mysqldump实现备份表的数据

场景

Winform中连接Mysql8并查询表中数据进行显示：

https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/120395988

在上面实现连接Mysql8的基础上，怎样借助于mysqldump实现数据备份。

注：

博客：
https://blog.csdn.net/badao_liumang_qizhi

关注公众号
霸道的程序猿
获取编程相关电子书、教程推送与免费下载。

实现

1、继续上面的winform的布局，设计布局如下

2、获取需要的参数

通过TextBox来获取备份单表的按钮的表名输入，通过Button"选择备份文件路径"以及后面的TextBox来选择要进行备份的路径。

其中选择备份文件的路径的点击事件为

private void button_select_path_Click(object sender, EventArgs e)
{
FolderBrowserDialog path = new FolderBrowserDialog();
path.ShowDialog();
this.textBox_bak_path.Text = path.SelectedPath;
}

然后通过一个TextBox来获取本机(即需要运行Winform的机器)的mysqldump.exe的路径，记得要带双引号。

3、实现单表的备份

然后再备份单表的按钮的点击事件中

private void button4_Click(object sender, EventArgs e)
{
PassForm passForm = new PassForm();
passForm.ShowDialog();
//密码验证通过
if (passForm.DialogResult == DialogResult.OK)
{
string mysqlDumpPath = this.text_mysqldump_path.Text.Trim();
string tableName = this.text_one_table.Text.Trim();
if (String.IsNullOrEmpty(tableName))
{
MessageBox.Show("表名不能为空！！！");
}
else if (String.IsNullOrEmpty(mysqlDumpPath))
{
MessageBox.Show("mysqldump的路径不能为空！！！");
}
else
{
string cmdStr = mysqlDumpPath + " -h " + this.host.Text.Trim() + " -u" + this.username.Text.Trim() + " -p" + this.password.Text.Trim() + " " + this.database.Text.Trim() + " " + this.text_one_table.Text.Trim() + " > " + "\"" + this.textBox_bak_path.Text.Trim() + "\\" + "bus_area.sql\"";
CmdHelper.ExeCommand(cmdStr);
}
}
else
{
MessageBox.Show("密码不正确");
}
}

 

这里首先加了一个密码验证的逻辑，防止误操作乱点按钮，通过后，获取到表名和mysqldump的路径然后进行拼接成cmdStr，

在拼接之后需要打断点到这步获取完整的cmd命令，然后再cmd中先手动执行一下试试。

这里在执行cmd时调用了一个帮助类CmdHelper

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace mysqldatabak
{
using System;
using System.Collections.Generic;
using System.Text;
using System.Diagnostics;
namespace Helper
{
///

/// 执行命令
///

public class CmdHelper
{
///
/// 执行cmd.exe命令
///
///命令文本
/// 命令输出文本
public static string ExeCommand(string commandText)
{
return ExeCommand(new string[] { commandText });
}
///
/// 执行多条cmd.exe命令
///
///命令文本数组
/// 命令输出文本
public static string ExeCommand(string[] commandTexts)
{
Process p = new Process();
p.StartInfo.FileName = "cmd.exe";
p.StartInfo.UseShellExecute = false;
p.StartInfo.RedirectStandardInput = true;
p.StartInfo.RedirectStandardOutput = true;
p.StartInfo.RedirectStandardError = true;
p.StartInfo.CreateNoWindow = true;
string strOutput = null;
try
{
p.Start();
foreach (string item in commandTexts)
{
p.StandardInput.WriteLine(item);
}
p.StandardInput.WriteLine("exit");
strOutput = p.StandardOutput.ReadToEnd();
//strOutput = Encoding.UTF8.GetString(Encoding.Default.GetBytes(strOutput));
p.WaitForExit();
p.Close();
}
catch (Exception e)
{
strOutput = e.Message;
}
return strOutput;
}
///
/// 启动外部Windows应用程序，隐藏程序界面
///
///应用程序路径名称
/// true表示成功，false表示失败
public static bool StartApp(string appName)
{
return StartApp(appName, ProcessWindowStyle.Hidden);
}
///
/// 启动外部应用程序
///
///应用程序路径名称
///进程窗口模式
/// true表示成功，false表示失败
public static bool StartApp(string appName, ProcessWindowStyle style)
{
return StartApp(appName, null, style);
}
///
/// 启动外部应用程序，隐藏程序界面
///
///应用程序路径名称
///启动参数
/// true表示成功，false表示失败
public static bool StartApp(string appName, string arguments)
{
return StartApp(appName, arguments, ProcessWindowStyle.Hidden);
}
///
/// 启动外部应用程序
///
///应用程序路径名称
///启动参数
///进程窗口模式
/// true表示成功，false表示失败
public static bool StartApp(string appName, string arguments, ProcessWindowStyle style)
{
bool blnRst = false;
Process p = new Process();
p.StartInfo.FileName = appName;//exe,bat and so on
p.StartInfo.WindowStyle = style;
p.StartInfo.Arguments = arguments;
try
{
p.Start();
p.WaitForExit();
p.Close();
blnRst = true;
}
catch
{
}
return blnRst;
}
}
}
}

 

3、测试单表效果

在建立连接成功并配置各项参数后，点击备份单表

验证通过后到指定路径下查看结果

4、备份所有表实现

在备份所有表的点击事件中

private void button_bak_all_Click(object sender, EventArgs e)
{
PassForm passForm = new PassForm();
passForm.ShowDialog();
if (passForm.DialogResult == DialogResult.OK)
{
DataTable tbName = mySqlConnection.GetSchema("Tables");
if (tbName.Columns.Contains("TABLE_NAME"))
{
foreach (DataRow dr in tbName.Rows)
{
string mysqlDumpPath = this.text_mysqldump_path.Text.Trim();
string tableName = (string)dr["TABLE_NAME"];
string cmdStr = mysqlDumpPath + " -h " + this.host.Text.Trim() + " -u" + this.username.Text.Trim() + " -p" + this.password.Text.Trim() + " " + this.database.Text.Trim() + " " + tableName + " > " + "\"" + this.textBox_bak_path.Text.Trim() + "\\" + tableName + ".sql\"";
CmdHelper.ExeCommand(cmdStr);
this.log_text.AppendText((string)dr["TABLE_NAME"] + "--备份完成");
this.log_text.AppendText("\r\n");
}
}
}
else
{
MessageBox.Show("密码不正确");
}
}

逻辑是获取所有的表名然后循环拼接表名进行导出sql

效果