開發十年，就只剩下這套架構體系了！ >>>   

資料備份對於經常在運維部署方面的工作者來說，是一件相對簡單的事情，都可以通過某一個SQL工具進行備份，但是如果在專案運行當中，我們需要對資料進行實時，或者是每隔一星期，一個月，等等進行資料的備份，這樣就需要java工具來操作備份SQL檔案，目前可以通過呼叫mysql安裝的命令進行資料備份，另外通過Job任務排程器進行配合使用，這裡技術選型為Quartz。

在下面程式碼當中address為SQL指令碼檔案存放的地址。

其中path為mysql的安裝位置：

D:\mysql\mysql-5.6.35-winx64\bin

public Map<String, Object> exportDatabase(String address) {
Map<String, Object> resultMap = new HashedMap();
try {
String path = PropertiesFileUtil.getInstance("sql").get("path");
String root = PropertiesFileUtil.getInstance("sql").get("sql.jdbc.username");
String dataBase = PropertiesFileUtil.getInstance("sql").get("sql.jdbc.dataBase");
String table = PropertiesFileUtil.getInstance("sql").get("sql.jdbc.table");
String password = PropertiesFileUtil.getInstance("sql").get("sql.jdbc.password");
String sqlName = System.currentTimeMillis() + ".sql";
Runtime rt = Runtime.getRuntime();
Process child = rt.exec(path + "mysqldump -u" + root + " -p" + password + " -R -c --set-charset=utf8 " + dataBase + " " + table + "");
InputStream in = child.getInputStream();
InputStreamReader xx = new InputStreamReader(in, "utf8");
String inStr;
StringBuffer sb = new StringBuffer("");
String outStr;
BufferedReader br = new BufferedReader(xx);
while ((inStr = br.readLine()) != null) {
sb.append(inStr + "\r\n");
}
outStr = sb.toString();

FileOutputStream fout = new FileOutputStream(address + "/" + sqlName);
OutputStreamWriter writer = new OutputStreamWriter(fout, "utf8");
writer.write(outStr);
writer.flush();
in.close();
xx.close();
br.close();
writer.close();
fout.close();
resultMap.put("result", "success");
resultMap.put("data", address + "/" + sqlName);
return resultMap;
} catch (Exception e) {
e.printStackTrace();
}
resultMap.put("result", "fail");
resultMap.put("data", "地址選擇有可能出現問題");
return resultMap;
}
 

 

上述程式碼當中主要的是用到了Runtime，Runtime封裝了執行環境，每一個java執行例項都有一個Runtime類為例項，使程式能夠與其環境相接。

一般不能例項化一個Runtime物件，應用程式不能建立自己的Runtime例項，但是可以通過getRuntime的方法獲取當前Runtime執行時物件的引用。

一旦得到當前的Runtime物件的引用，就可以呼叫Runtime物件的方法去控制java虛擬機器的狀態和行為。

 

執行SQL指令碼，我們可以通過ant來實現，首先我們引入ant的jar包

<!-- https://mvnrepository.com/artifact/org.apache.ant/ant -->
<dependency>
<groupId>org.apache.ant</groupId>
<artifactId>ant</artifactId>
<version>1.7.1</version>
</dependency>
 

 

public Map<String, Object> importDatabase(String filepath) {
Map<String, Object> resultMap = new HashedMap();
try {
String username = PropertiesFileUtil.getInstance("sql").get("sql.jdbc.username");
String password = PropertiesFileUtil.getInstance("sql").get("sql.jdbc.password");
String url = PropertiesFileUtil.getInstance("sql").get("sql.jdbc.url");
String driverClassName =PropertiesFileUtil.getInstance("sql").get("sql.jdbc.driver");
String filepathName = filepath.substring(0, filepath.lastIndexOf("."));
String outputPath = filepathName + ".out";

SQLExec sqlExec = new SQLExec();
//設定資料庫引數
sqlExec.setDriver(driverClassName);
sqlExec.setUrl(url);
sqlExec.setUserid(username);
sqlExec.setPassword(password);
//設定字元編碼
sqlExec.setEncoding("UTF-8");
//要執行的指令碼
sqlExec.setSrc(new File(filepath));
//有出錯的語句該如何處理
sqlExec.setOnerror((SQLExec.OnError) (EnumeratedAttribute.getInstance(
SQLExec.OnError.class, "abort")));
sqlExec.setPrint(true); //設定是否輸出
//輸出到檔案 sql.out 中；不設定該屬性，預設輸出到控制檯
sqlExec.setOutput(new File(outputPath));
sqlExec.setProject(new Project()); // 要指定這個屬性，不然會出錯
sqlExec.execute();
logger.info("執行sql指令碼檔案成功");
resultMap.put("result", "success");
} catch (Exception e) {
logger.info("執行sql指令碼檔案失敗");
e.printStackTrace();
resultMap.put("result", "fail");
return resultMap;
}
return resultMap;
}

 歡迎關注微信公眾號摘星族

相關推薦