【mysql】备份篇2：使用java程序定期备份mysql数据库

时间：2023-03-09 04:53:44
【mysql】备份篇2：使用java程序定期备份mysql数据库

承接备份篇1，

在备份篇1中，使用dat文件加+系统计划任务程序完成mysql定期备份任务

在这一篇，备份使用java程序定期备份mysql数据库。

下面代码和程序思想给出：

 package com.agen.util;

 import java.io.BufferedReader;

 import java.io.File;

 import java.io.FileOutputStream;

 import java.io.IOException;

 import java.io.InputStream;

 import java.io.InputStreamReader;

 import java.io.OutputStreamWriter;

 import java.sql.Time;

 import java.util.Date;

 import java.util.Timer;

 import java.util.TimerTask;

 /**

  * java程序实现mysql定期备份功能

  * 主体思想：

  * 1.runtime.exec(DOS命令)执行DOS命令，得到mysql备份文件

  * 2.OutputStreamWriter将读取到的备份文件，写出到本地磁盘

  * 3.设置定时任务TimerTask

  * 4.timer.schedule(task, nowTime,1000*3);设置定时器相关参数并执行定时任务

  * @author sxd

  *

  */

 public class MysqlBak {

     private static String sqlUrl = "\"C://Program Files//MySQL//MySQL Server 5.5//bin//mysqldump\" -u root --password=root performance";

     private static String targetUrl = "D:\\db_backup\\performance_";

     public MysqlBak() throws IOException{

         backUp();

     }

     public static void main(String[] args) {

         Date nowTime = new Date();

         TimerTask task = new TimerTask() {

             @Override

             public void run() {

                 try {

                     System.out.println("mysql备份开始时间："+nowTime.toLocaleString());

                     MysqlBak bak = new MysqlBak();

                 } catch (IOException e) {

                     System.out.println("异常如下："+e);

                 }

             }

         };

         //java自带 定时器

         Timer timer = new Timer();

         //参数1 要干的事情

         //参数2 任务开始执行的时间【这里将时间定为 任务启动的时间】

         //参数3 隔多长时间执行一次任务【毫秒为单位】

         timer.schedule(task, nowTime,1000*3);

     }

     /**

      * mysql数据库的备份

      * @throws IOException

      */

     public static void backUp() throws IOException{

         //每个java程序都有自己的一个Runtime类实例，使应用程序与其运行的环境相连接，

         //应用程序不能自己创建自己的Runtime实例，只能通过getRuntime()获得

         Runtime runtime = Runtime.getRuntime();

         //调用mysql安装目录的命令

         Process child = runtime.exec(sqlUrl);

         //读取到此子进程的输出流

         InputStream in = child.getInputStream();

         //把进程执行中的控制台输出信息写入.sql文件，这就是完成了备份文件

         //如果不对控制台信息进行读出，会导致进程堵塞无法运行

         //设置编码为UTF-8，否则会乱码

         InputStreamReader inputStreamReader = new InputStreamReader(in,"utf-8");

         //用来存储 从子进程读取到程序的每一行的数据

         String inStr;

         //将每一行的数据追加至stringBuffer

         StringBuffer sb = new StringBuffer("");

         BufferedReader br = new BufferedReader(inputStreamReader);

         System.out.println("操作命令执行首行："+(inStr = br.readLine()));

         while((inStr = br.readLine()) != null){

             sb.append(inStr+"\r\n");

         }

         //获取当前时间，用于拼接备份文件的文件名

         String nowTime = new Time(System.currentTimeMillis()).toLocaleString();

         //备份文件的输出流

         FileOutputStream out = new FileOutputStream(new File(targetUrl+nowTime.replace(" ", "_").replace(":", "_")+".sql"));

         OutputStreamWriter outputStreamWriter = new OutputStreamWriter(out,"utf-8");

         outputStreamWriter.write(sb.toString());

         outputStreamWriter.flush();

         in.close();

         inputStreamReader.close();

         br.close();

         out.close();

         outputStreamWriter.close();

         System.out.println("备份成功");

         System.out.println("mysql备份完成的时间："+new Date().toLocaleString());

     }

 }

这样，将此类放置在你的项目中运行起来即可，只要项目不被停止，它会一直工作下去的。

相关文章