devbox
Monodyee
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

mysql定时数据备份工具(c#)_c# mysql数据库自动备份

作者：Monodyee | 2024-06-13 08:18:07

赞

踩

c# mysql数据库自动备份

此博文的出处 为 http://blog.csdn.net/zhujunxxxxx/article/details/40124773如果进行转载请注明出处。本文作者原创，邮箱zhujunxxxxx@163.com，如有问题请联系作者

为了确保数据的安全，我们往往要对数据进行备份。但是为了减少我们的工作量，我写了一个简单的数据备份工具，实现定时备份数据库。

其实程序很简单，数据备份的工作就是几个mysql的命令而已。

先看看程序的运行界面


可以看到界面是十分的简单的

我们使用的是命令行来进行数据备份，所以我们的程序需要一个能够执行命令行的函数

  1. /// <summary>
  2.         /// 执行Cmd命令
  3.         /// </summary>
  4.         /// <param name="workingDirectory">要启动的进程的目录</param>
  5.         /// <param name="command">要执行的命令</param>
  6.         public static void StartCmd(String workingDirectory, String command)
  7.         {
  8.             Process p = new Process();
  9.             p.StartInfo.FileName = "cmd.exe";
  10.             p.StartInfo.WorkingDirectory = workingDirectory;
  11.             p.StartInfo.UseShellExecute = false;
  12.             p.StartInfo.RedirectStandardInput = true;
  13.             p.StartInfo.RedirectStandardOutput = true;
  14.             p.StartInfo.RedirectStandardError = true;
  15.             p.StartInfo.CreateNoWindow = true;
  16.             p.Start();
  17.             p.StandardInput.WriteLine(command);
  18.             p.StandardInput.WriteLine("exit");
  19.         }

接下来是一个备份数据库的函数 

  1. public void bakup_db()
  2.         {
  3.             try
  4.             {
  5.                 //String command = "mysqldump --quick --host=localhost --default-character-set=gb2312 --lock-tables --verbose  --force --port=端口号 --user=用户名 --password=密码 数据库名 -r 备份到的地址";
  6.                 //构建执行的命令
  7.                 StringBuilder sbcommand = new StringBuilder();
  8.  
  9.                 StringBuilder sbfileName = new StringBuilder();
  10.                 sbfileName.AppendFormat("{0}", DateTime.Now.ToShortDateString()).Replace("-", "").Replace(":", "").Replace(" ", "").Replace("/", "");
  11.                 String fileName = sbfileName.ToString();
  12.                 String directory = bakpath + fileName+".bak";
  13.  
  14.                 sbcommand.AppendFormat("mysqldump --quick --host=localhost --default-character-set=utf8 --lock-tables --verbose  --force --port=3306 --user={0} --password={1} {2} -r \"{3}\"", uname, upass, dbname, directory);
  15.                 String command = sbcommand.ToString();
  16.  
  17.                 //获取mysqldump.exe所在路径
  18.                 //String appDirecroty = System.Windows.Forms.Application.StartupPath + "\\";
  19.                 StartCmd(appDirecroty, command);
  20.             }
  21.             catch (Exception ex)
  22.             {
  23.             }
  24.         }

还原数据库 

  1.  public void recovery_db()
  2.         {
  3.             //string s = "mysql --port=端口号 --user=用户名 --password=密码 数据库名<还原文件所在路径";
  4.             try
  5.             {
  6.                 StringBuilder sbcommand = new StringBuilder();
  7.  
  8.                 OpenFileDialog openFileDialog = new OpenFileDialog();
  9.  
  10.                 if (openFileDialog.ShowDialog() == DialogResult.OK)
  11.                 {
  12.                     String directory = openFileDialog.FileName;
  13.  
  14.                     //在文件路径后面加上""避免空格出现异常
  15.                     sbcommand.AppendFormat("mysql --host=localhost --default-character-set=utf8 --port=3306 --user={0} --password={1} {2}<\"{3}\"",uname,upass,dbname,directory);
  16.                     String command = sbcommand.ToString();
  17.  
  18.                     //获取mysql.exe所在路径
  19.                     //String appDirecroty = System.Windows.Forms.Application.StartupPath + "\\";
  20.  
  21.                     DialogResult result = MessageBox.Show("您是否真的想覆盖以前的数据库吗？那么以前的数据库数据将丢失！！！", "警告", MessageBoxButtons.YesNo, MessageBoxIcon.Warning);
  22.                     if (result == DialogResult.Yes)
  23.                     {
  24.                         StartCmd(appDirecroty, command);
  25.                         MessageBox.Show("数据库还原成功！");
  26.                     }
  27.                 }
  28.  
  29.             }
  30.             catch (Exception ex)
  31.             {
  32.                 MessageBox.Show("数据库还原失败！");
  33.             }
  34.         }

为了实现定时备份，我们使用的是一个Timer组件，来实现定时的数据备份 

  1. private void timer1_Tick(object sender, EventArgs e)
  2.         {
  3.             int h = DateTime.Now.Hour;
  4.             if (h == hour)
  5.             {
  6.                 bakup_db();
  7.             }
  8.         }

给出完整的代码 

  1. using System;
  2. using System.Collections.Generic;
  3. using System.ComponentModel;
  4. using System.Data;
  5. using System.Drawing;
  6. using System.Text;
  7. using System.Windows.Forms;
  8. using System.Diagnostics;
  9.  
  10. namespace MysqlBak
  11. {
  12.     public partial class Form1 : Form
  13.     {
  14.         //备份文件的路径
  15.         public String bakpath="d:\\db_bak\\";
  16.         public String appDirecroty = @"C:\Program Files (x86)\MySQL\MySQL Server 6.0\bin";
  17.         public String uname = "root";
  18.         public String upass = "root";
  19.         public String dbname = "losscar_db";
  20.         public int hour=18;
  21.         public Form1()
  22.         {
  23.             InitializeComponent();
  24.             timer1.Interval=1000*10;
  25.             timer1.Start();
  26.             txt_uname.Text = uname;
  27.             txt_upass.Text = upass;
  28.             txt_dbname.Text = dbname;
  29.             txt_bakpath.Text = bakpath;
  30.             txt_mysql.Text = appDirecroty;
  31.             txt_hour.Text = hour.ToString();
  32.         }
  33.  
  34.         /// <summary>
  35.         /// 执行Cmd命令
  36.         /// </summary>
  37.         /// <param name="workingDirectory">要启动的进程的目录</param>
  38.         /// <param name="command">要执行的命令</param>
  39.         public static void StartCmd(String workingDirectory, String command)
  40.         {
  41.             Process p = new Process();
  42.             p.StartInfo.FileName = "cmd.exe";
  43.             p.StartInfo.WorkingDirectory = workingDirectory;
  44.             p.StartInfo.UseShellExecute = false;
  45.             p.StartInfo.RedirectStandardInput = true;
  46.             p.StartInfo.RedirectStandardOutput = true;
  47.             p.StartInfo.RedirectStandardError = true;
  48.             p.StartInfo.CreateNoWindow = true;
  49.             p.Start();
  50.             p.StandardInput.WriteLine(command);
  51.             p.StandardInput.WriteLine("exit");
  52.         }
  53.  
  54.         private void btn_bak_Click(object sender, EventArgs e)
  55.         {
  56.             try
  57.             {
  58.                 //String command = "mysqldump --quick --host=localhost --default-character-set=gb2312 --lock-tables --verbose  --force --port=端口号 --user=用户名 --password=密码 数据库名 -r 备份到的地址";
  59.                 //构建执行的命令
  60.                 StringBuilder sbcommand = new StringBuilder();
  61.  
  62.                 StringBuilder sbfileName = new StringBuilder();
  63.                 sbfileName.AppendFormat("{0}", DateTime.Now.ToShortDateString()).Replace("-", "").Replace(":", "").Replace(" ", "").Replace("/", "");
  64.                 String fileName = sbfileName.ToString();
  65.                 String directory = bakpath + fileName + ".bak";
  66.  
  67.                 sbcommand.AppendFormat("mysqldump --quick --host=localhost --default-character-set=utf8 --lock-tables --verbose  --force --port=3306 --user={0} --password={1} {2} -r \"{3}\"", uname, upass, dbname, directory);
  68.                 String command = sbcommand.ToString();
  69.  
  70.                 //获取mysqldump.exe所在路径
  71.                 //String appDirecroty = System.Windows.Forms.Application.StartupPath + "\\";
  72.                 StartCmd(appDirecroty, command);
  73.  
  74.                 MessageBox.Show(@"数据库已成功备份到 " + directory + " 文件中", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
  75.             }
  76.             catch (Exception ex)
  77.             {
  78.                 MessageBox.Show("数据库备份失败！");
  79.             }
  80.  
  81.         }
  82.  
  83.         public void bakup_db()
  84.         {
  85.             try
  86.             {
  87.                 //String command = "mysqldump --quick --host=localhost --default-character-set=gb2312 --lock-tables --verbose  --force --port=端口号 --user=用户名 --password=密码 数据库名 -r 备份到的地址";
  88.                 //构建执行的命令
  89.                 StringBuilder sbcommand = new StringBuilder();
  90.  
  91.                 StringBuilder sbfileName = new StringBuilder();
  92.                 sbfileName.AppendFormat("{0}", DateTime.Now.ToShortDateString()).Replace("-", "").Replace(":", "").Replace(" ", "").Replace("/", "");
  93.                 String fileName = sbfileName.ToString();
  94.                 String directory = bakpath + fileName+".bak";
  95.  
  96.                 sbcommand.AppendFormat("mysqldump --quick --host=localhost --default-character-set=utf8 --lock-tables --verbose  --force --port=3306 --user={0} --password={1} {2} -r \"{3}\"", uname, upass, dbname, directory);
  97.                 String command = sbcommand.ToString();
  98.  
  99.                 //获取mysqldump.exe所在路径
  100.                 //String appDirecroty = System.Windows.Forms.Application.StartupPath + "\\";
  101.                 StartCmd(appDirecroty, command);
  102.             }
  103.             catch (Exception ex)
  104.             {
  105.             }
  106.         }
  107.  
  108.         private void btn_recovery_Click(object sender, EventArgs e)
  109.         {
  110.             recovery_db();
  111.         }
  112.  
  113.         public void recovery_db()
  114.         {
  115.             //string s = "mysql --port=端口号 --user=用户名 --password=密码 数据库名<还原文件所在路径";
  116.             try
  117.             {
  118.                 StringBuilder sbcommand = new StringBuilder();
  119.  
  120.                 OpenFileDialog openFileDialog = new OpenFileDialog();
  121.  
  122.                 if (openFileDialog.ShowDialog() == DialogResult.OK)
  123.                 {
  124.                     String directory = openFileDialog.FileName;
  125.  
  126.                     //在文件路径后面加上""避免空格出现异常
  127.                     sbcommand.AppendFormat("mysql --host=localhost --default-character-set=utf8 --port=3306 --user={0} --password={1} {2}<\"{3}\"",uname,upass,dbname,directory);
  128.                     String command = sbcommand.ToString();
  129.  
  130.                     //获取mysql.exe所在路径
  131.                     //String appDirecroty = System.Windows.Forms.Application.StartupPath + "\\";
  132.  
  133.                     DialogResult result = MessageBox.Show("您是否真的想覆盖以前的数据库吗？那么以前的数据库数据将丢失！！！", "警告", MessageBoxButtons.YesNo, MessageBoxIcon.Warning);
  134.                     if (result == DialogResult.Yes)
  135.                     {
  136.                         StartCmd(appDirecroty, command);
  137.                         MessageBox.Show("数据库还原成功！");
  138.                     }
  139.                 }
  140.  
  141.             }
  142.             catch (Exception ex)
  143.             {
  144.                 MessageBox.Show("数据库还原失败！");
  145.             }
  146.         }
  147.  
  148.         private void btn_edit_Click(object sender, EventArgs e)
  149.         {
  150.             
  151.             if (btn_edit.Text=="修改")
  152.             {
  153.                 txt_dbname.Enabled = true;
  154.                 txt_uname.Enabled = true;
  155.                 txt_upass.Enabled = true;
  156.                 txt_bakpath.Enabled = true;
  157.                 txt_mysql.Enabled = true;
  158.                 txt_hour.Enabled = true;
  159.                 btn_edit.Text = "确定";
  160.             }
  161.             else if (btn_edit.Text == "确定")
  162.             {
  163.                 uname = txt_uname.Text;
  164.                 upass = txt_upass.Text;
  165.                 dbname = txt_dbname.Text;
  166.                 appDirecroty = txt_mysql.Text;
  167.                 bakpath = txt_bakpath.Text;
  168.                 hour = int.Parse(txt_hour.Text);
  169.  
  170.                 MessageBox.Show("修改成功!");
  171.                 btn_edit.Text = "修改";
  172.  
  173.                 txt_dbname.Enabled = false;
  174.                 txt_uname.Enabled = false;
  175.                 txt_upass.Enabled = false;
  176.                 txt_bakpath.Enabled = false;
  177.                 txt_mysql.Enabled = false;
  178.                 txt_hour.Enabled = false;
  179.             }
  180.  
  181.         }
  182.  
  183.         private void timer1_Tick(object sender, EventArgs e)
  184.         {
  185.             int h = DateTime.Now.Hour;
  186.             if (h == hour)
  187.             {
  188.                 bakup_db();
  189.             }
  190.         }
  191.  
  192.     }
  193. }



声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Monodyee/article/detail/711555
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号