Java备份还原Mysql数据库

///实体类
package com.ews.util;
/**
 * 系统备份展示对象
 * 
 * */
public class DataFile {
 private String fileName;//备份文件的名称
 private String fileDate;//备份文件的日期
 private String filePath;//备份文件的地址
 private String fileSize;//备份文件的大小
 public String getFileSize() {
  return fileSize;
 }
 public void setFileSize(String fileSize) {
  this.fileSize = fileSize;
 }
 public String getFileName() {
  return fileName;
 }
 public void setFileName(String fileName) {
  this.fileName = fileName;
 }
 public String getFileDate() {
  return fileDate;
 }
 public void setFileDate(String fileDate) {
  this.fileDate = fileDate;
 }
 public String getFilePath() {
  return filePath;
 }
 public void setFilePath(String filePath) {
  this.filePath = filePath;
 }
}
  
///实现备份代码
package com.ews.action;
  
import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.sql.Date;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
  
import org.apache.commons.dbcp.BasicDataSource;
import org.apache.commons.fileupload.FileItem;
import org.apache.struts2.ServletActionContext;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
  
import com.ews.util.DataFile;
  
public class DataAction extends EwsAction{
 private String username;
 private String password;
 private String host;
 private String PORT;
 private String dbname;
 private List dataFiles = new ArrayList();
 private File reductionFile;
 public File getReductionFile() {
  return reductionFile;
 }
 public void setReductionFile(File reductionFile) {
  this.reductionFile = reductionFile;
 }
 public List getDataFiles() {
  return dataFiles;
 }
 public void setDataFiles(List dataFiles) {
  this.dataFiles = dataFiles;
 }
 public String getHost() {
  return host;
 }
 public void setHost(String host) {
  this.host = host;
 }
 public String getPORT() {
  return PORT;
 }
 public void setPORT(String pORT) {
  PORT = pORT;
 }
 public String getUsername() {
  return username;
 }
 public void setUsername(String username) {
  this.username = username;
 }
 public String getPassword() {
  return password;
 }
 public void setPassword(String password) {
  this.password = password;
 }
 public String getDbname() {
  return dbname;
 }
 public void setDbname(String dbname) {
  this.dbname = dbname;
 }
 /**
  * 删除
  * */
 public String delete(){
  String fileName = request.getParameter("fileName");
  System.out.println(fileName);
  String backPath = ServletActionContext.getServletContext().getRealPath("/")+"ewssite/back/"+fileName;
  File file = new File(backPath);
  file.delete();
  return "delete";
 }
 /**
  * 得到备份文件的List集合
  * 
  * */
 public String findList(){
  String backPath = ServletActionContext.getServletContext().getRealPath("/")+"ewssite/back/";
  File file = new File(backPath);
  if (!file.exists())
   return "findListData";
  File[] file1 = file.listFiles();
  for (int i = 0; i < file1.length; i++) {
   if(file1[i].getName().equals("ramdit.txt")) continue;
   SimpleDateFormat sdf= new SimpleDateFormat("MM/dd/yyyy HH:mm:ss");
   //前面的lSysTime是秒数，先乘1000得到毫秒数，再转为java.util.Date类型
   java.util.Date dt = new Date(file1[i].lastModified());  
   String sDateTime = sdf.format(dt);  //得到精确到秒的表示：08/31/2006 21:08:00
   DataFile dataFile = new DataFile();
   dataFile.setFileName(file1[i].getName());
   dataFile.setFileDate(sDateTime);
   String path = request.getContextPath();
   String filePath = request.getScheme() + "://"+ request.getServerName() + ":" + request.getServerPort()+ path + "/ewssite/back/"+file1[i].getName();
   dataFile.setFilePath(filePath);
   DecimalFormat   df   =   new   DecimalFormat( ".## "); 
   dataFile.setFileSize(df.format(file1[i].length()/1024000f));
   dataFiles.add(dataFile);
  }
  return "findListData";
 }
 /**
  * 配置  Mysql bin目录
  * */
 public void getConfig(){
  ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  BasicDataSource ba = (BasicDataSource)context.getBean("dataSource");
  setUsername(ba.getUsername());
  setPassword(ba.getPassword());
  String url = ba.getUrl();
  url = url.substring(13, url.length());
  String[] temp = url.split("/");
  String[] temp1 = temp[0].split(":");
  setHost(temp1[0]);
  setPORT(temp1[1]);
  for (int i = 0; i < temp[1].length(); i++) {
   String temp2 = temp[1].charAt(i)+"";
   if(temp2.equals("?")){
    setDbname(temp[1].substring(0,5));
   }
  }
 }
 /**
  * 备份
  * */
 public String backup(){
  getConfig();
  //得到配置文件
  try {
   Runtime rt = Runtime.getRuntime();
   String backPath = ServletActionContext.getServletContext().getRealPath("/")+"ewssite/back/"+System.currentTimeMillis()+".sql";   
   String mysql = "mysqldump -u" + getUsername()+ " -p" + getPassword() + " --default-character-set=utf8 -h"+getHost()+" -P"+getPORT()+" " + getDbname() +" >"+"\""+backPath+"\"";   
   Process proc = rt.exec("cmd.exe /c "+mysql);// 设置导出编码为utf8。这里必须是utf8
   //String backExe = ServletActionContext.getServletContext().getRealPath("/")+"bin/mysqldump.exe"; 
   //String mysql = getDbname()+ " -u" + getUsername()+ " -p" + getPassword() + " --default-character-set=utf8 -h"+getHost()+" -P"+getPORT()+" >"+"\""+backPath+"\""; 
   int tag = proc.waitFor();// 等待进程终止  
  } catch (Exception e) {
   e.printStackTrace();
  }
  return "backup";
 }
 /**
  * 还原
  * */
 public String load(){
  String sqlPath="";
  if(request.getParameter("selectName")!=null)
   sqlPath = request.getParameter("selectName");
  if(reductionFile!=null){
   String name = upload(reductionFile);
   sqlPath = ServletActionContext.getServletContext().getRealPath("/")+"ewssite/back/" + name;
  }
//  System.out.println(sqlPath);
  if(sqlPath.substring(sqlPath.lastIndexOf(".")+1).equals("sql")){
   getConfig();
   setHost("127.0.0.1");
   setUsername("root");
   setPassword("root");
   setDbname("test");
   //得到配置文件
   try {
    Runtime rt = Runtime.getRuntime();
    String createDb = "mysqladmin -u" + getUsername()+ " -p" + getPassword() + " create "+getDbname();
    String mysql = "mysql -u" + getUsername()+ " -p" + getPassword() + " "+getDbname()+" <"+"\""+ sqlPath+"\"";//+"\""+backPath+"\""
    rt.exec("cmd.exe /c "+createDb);
    Process proc  = rt.exec("cmd.exe /c "+mysql);
    int tag = proc.waitFor();// 等待进程终止
   } catch (Exception e) {
    e.printStackTrace();
   }
  }
  return "load";
 }
 /**
  * 把本地的数据库备份文件上传到服务器上
  * file:从前台获取的file
  * */
 public String upload(File file ){
  String name = "";
  try {
   DataInputStream in = new DataInputStream(new FileInputStream(file));
//   FileInputStream in = new FileInputStream(file);
     
   String backPath = ServletActionContext.getServletContext().getRealPath("/")+"ewssite/back/";
   name = System.currentTimeMillis()+".sql";
   backPath = backPath + name;
//   FileOutputStream out = new FileOutputStream(new File(backPath));
   DataOutputStream out = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(backPath)));
   int b = -1;
   while ((b = in.read()) != -1) {
    out.write(b);
   }
   out.close();
   in.close();
  } catch (Exception e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  return name;
 }
}