?

數(shù)據(jù)備份對于經(jīng)常在運維部署方面的工作者來說，是一件相對簡單的事情，都可以通過某一個SQL工具進(jìn)行備份，但是如果在項目運行當(dāng)中，我們需要對數(shù)據(jù)進(jìn)行實時，或者是每隔一星期，一個月，等等進(jìn)行數(shù)據(jù)的備份，這樣就需要java工具來操作備份SQL文件，目前可以通過調(diào)用mysql安裝的命令進(jìn)行數(shù)據(jù)備份，另外通過Job任務(wù)調(diào)度器進(jìn)行配合使用，這里技術(shù)選型為Quartz。

在下面代碼當(dāng)中address為SQL腳本文件存放的地址。

其中path為mysql的安裝位置：

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

public MapexportDatabase(String address) {

Map resultMap = newHashedMap();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= newBufferedReader(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);returnresultMap;

}catch(Exception e) {

e.printStackTrace();

}

resultMap.put("result", "fail");

resultMap.put("data", "地址選擇有可能出現(xiàn)問題");returnresultMap;

}

上述代碼當(dāng)中主要的是用到了Runtime，Runtime封裝了運行環(huán)境，每一個java運行實例都有一個Runtime類為實例，使程序能夠與其環(huán)境相接。

一般不能實例化一個Runtime對象，應(yīng)用程序不能創(chuàng)建自己的Runtime實例，但是可以通過getRuntime的方法獲取當(dāng)前Runtime運行時對象的引用。

一旦得到當(dāng)前的Runtime對象的引用，就可以調(diào)用Runtime對象的方法去控制java虛擬機(jī)的狀態(tài)和行為。

執(zhí)行SQL腳本，我們可以通過ant來實現(xiàn)，首先我們引入ant的jar包

org.apache.ant

ant

1.7.1

public MapimportDatabase(String filepath) {

Map resultMap = newHashedMap();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= newSQLExec();//設(shè)置數(shù)據(jù)庫參數(shù)

sqlExec.setDriver(driverClassName);

sqlExec.setUrl(url);

sqlExec.setUserid(username);

sqlExec.setPassword(password);//設(shè)置字符編碼

sqlExec.setEncoding("UTF-8");//要執(zhí)行的腳本

sqlExec.setSrc(newFile(filepath));//有出錯的語句該如何處理

sqlExec.setOnerror((SQLExec.OnError) (EnumeratedAttribute.getInstance(

SQLExec.OnError.class, "abort")));

sqlExec.setPrint(true); //設(shè)置是否輸出//輸出到文件 sql.out 中；不設(shè)置該屬性，默認(rèn)輸出到控制臺

sqlExec.setOutput(newFile(outputPath));

sqlExec.setProject(new Project()); //要指定這個屬性，不然會出錯

sqlExec.execute();

logger.info("執(zhí)行sql腳本文件成功");

resultMap.put("result", "success");

}catch(Exception e) {

logger.info("執(zhí)行sql腳本文件失敗");

e.printStackTrace();

resultMap.put("result", "fail");returnresultMap;

}returnresultMap;

}

歡迎關(guān)注微信公眾號：摘星族，我們在等待您的加入。

?

總結(jié)

以上是生活随笔為你收集整理的数据库备份 java jar_Java实现数据库备份并利用ant导入SQL脚本的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。