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;
}
}</pre>