Java备份还原Mysql数据库(struts2未测试)

///实体类
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" + getP
a3b1
assword() + " --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;
}
}