///實體類
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()+"
相關文章
相關視頻
--入門)
...)
)
