java备份还原mysql数据库_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 &＃61; fileSize;

}

public String getFileName() {

return fileName;

}

public void setFileName(String fileName) {

this.fileName &＃61; fileName;

}

public String getFileDate() {

return fileDate;

}

public void setFileDate(String fileDate) {

this.fileDate &＃61; fileDate;

}

public String getFilePath() {

return filePath;

}

public void setFilePath(String filePath) {

this.filePath &＃61; 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 &＃61; new ArrayList();

private File reductionFile;

public File getReductionFile() {

return reductionFile;

}

public void setReductionFile(File reductionFile) {

this.reductionFile &＃61; reductionFile;

}

public List getDataFiles() {

return dataFiles;

}

public void setDataFiles(List dataFiles) {

this.dataFiles &＃61; dataFiles;

}

public String getHost() {

return host;

}

public void setHost(String host) {

this.host &＃61; host;

}

public String getPORT() {

return PORT;

}

public void setPORT(String pORT) {

PORT &＃61; pORT;

}

public String getUsername() {

return username;

}

public void setUsername(String username) {

this.username &＃61; username;

}

public String getPassword() {

return password;

}

public void setPassword(String password) {

this.password &＃61; password;

}

public String getDbname() {

return dbname;

}

public void setDbname(String dbname) {

this.dbname &＃61; dbname;

}

/**

* 删除

* */

public String delete(){

String fileName &＃61; request.getParameter("fileName");

System.out.println(fileName);

String backPath &＃61; ServletActionContext.getServletContext().getRealPath("/")&＃43;"ewssite/back/"&＃43;fileName;

File file &＃61; new File(backPath);

file.delete();

return "delete";

}

/**

* 得到备份文件的List集合

*

* */

public String findList(){

String backPath &＃61; ServletActionContext.getServletContext().getRealPath("/")&＃43;"ewssite/back/";

File file &＃61; new File(backPath);

if (!file.exists())

return "findListData";

File[] file1 &＃61; file.listFiles();

for (int i &＃61; 0; i

if(file1[i].getName().equals("ramdit.txt")) continue;

SimpleDateFormat sdf&＃61; new SimpleDateFormat("MM/dd/yyyy HH:mm:ss");

//前面的lSysTime是秒数&＃xff0c;先乘1000得到毫秒数&＃xff0c;再转为java.util.Date类型

java.util.Date dt &＃61; new Date(file1[i].lastModified());

String sDateTime &＃61; sdf.format(dt); //得到精确到秒的表示&＃xff1a;08/31/2006 21:08:00

DataFile dataFile &＃61; new DataFile();

dataFile.setFileName(file1[i].getName());

dataFile.setFileDate(sDateTime);

String path &＃61; request.getContextPath();

String filePath &＃61; request.getScheme() &＃43; "://"&＃43; request.getServerName() &＃43; ":" &＃43; request.getServerPort()&＃43; path &＃43; "/ewssite/back/"&＃43;file1[i].getName();

dataFile.setFilePath(filePath);

DecimalFormat df &＃61; new DecimalFormat( ".## ");

dataFile.setFileSize(df.format(file1[i].length()/1024000f));

dataFiles.add(dataFile);

}

return "findListData";

}

/**

* 配置 Mysql bin目录

* */

public void getConfig(){

ApplicationContext context &＃61; new ClassPathXmlApplicationContext("applicationContext.xml");

BasicDataSource ba &＃61; (BasicDataSource)context.getBean("dataSource");

setUsername(ba.getUsername());

setPassword(ba.getPassword());

String url &＃61; ba.getUrl();

url &＃61; url.substring(13, url.length());

String[] temp &＃61; url.split("/");

String[] temp1 &＃61; temp[0].split(":");

setHost(temp1[0]);

setPORT(temp1[1]);

for (int i &＃61; 0; i

String temp2 &＃61; temp[1].charAt(i)&＃43;"";

if(temp2.equals("?")){

setDbname(temp[1].substring(0,5));

}

}

}

/**

* 备份

* */

public String backup(){

getConfig();

//得到配置文件

try {

Runtime rt &＃61; Runtime.getRuntime();

String backPath &＃61; ServletActionContext.getServletContext().getRealPath("/")&＃43;"ewssite/back/"&＃43;System.currentTimeMillis()&＃43;".sql";

String mysql &＃61; "mysqldump -u" &＃43; getUsername()&＃43; " -p" &＃43; getPassword() &＃43; " --default-character-set&＃61;utf8 -h"&＃43;getHost()&＃43;" -P"&＃43;getPORT()&＃43;" " &＃43; getDbname() &＃43;" >"&＃43;"\""&＃43;backPath&＃43;"\"";

Process proc &＃61; rt.exec("cmd.exe /c "&＃43;mysql);// 设置导出编码为utf8。这里必须是utf8

//String backExe &＃61; ServletActionContext.getServletContext().getRealPath("/")&＃43;"bin/mysqldump.exe";

//String mysql &＃61; getDbname()&＃43; " -u" &＃43; getUsername()&＃43; " -p" &＃43; getPassword() &＃43; " --default-character-set&＃61;utf8 -h"&＃43;getHost()&＃43;" -P"&＃43;getPORT()&＃43;" >"&＃43;"\""&＃43;backPath&＃43;"\"";

int tag &＃61; proc.waitFor();// 等待进程终止

} catch (Exception e) {

e.printStackTrace();

}

return "backup";

}

/**

* 还原

* */

public String load(){

String sqlPath&＃61;"";

if(request.getParameter("selectName")!&＃61;null)

sqlPath &＃61; request.getParameter("selectName");

if(reductionFile!&＃61;null){

String name &＃61; upload(reductionFile);

sqlPath &＃61; ServletActionContext.getServletContext().getRealPath("/")&＃43;"ewssite/back/" &＃43; name;

}

// System.out.println(sqlPath);

if(sqlPath.substring(sqlPath.lastIndexOf(".")&＃43;1).equals("sql")){

getConfig();

setHost("127.0.0.1");

setUsername("root");

setPassword("root");

setDbname("test");

//得到配置文件

try {

Runtime rt &＃61; Runtime.getRuntime();

String createDb &＃61; "mysqladmin -u" &＃43; getUsername()&＃43; " -p" &＃43; getPassword() &＃43; " create "&＃43;getDbname();

String mysql &＃61; "mysql -u" &＃43; getUsername()&＃43; " -p" &＃43; getPassword() &＃43; " "&＃43;getDbname()&＃43;"

相关文章

相关视频