如何用Java實(shí)現(xiàn)MySQL數(shù)據(jù)庫(kù)的備份和恢復(fù)

MySQL的一些前臺(tái)工具是有備份恢復(fù)功能的，可是如何在我們的應(yīng)用程序中實(shí)現(xiàn)這一功能呢？本文提供了示例代碼來(lái)說(shuō)明如何使用Java代碼實(shí)現(xiàn)MySQL數(shù)據(jù)庫(kù)的備份恢復(fù)。

成都一家集口碑和實(shí)力的網(wǎng)站建設(shè)服務(wù)商，擁有專業(yè)的企業(yè)建站團(tuán)隊(duì)和靠譜的建站技術(shù)，十多年企業(yè)及個(gè)人網(wǎng)站建設(shè)經(jīng)驗(yàn) ,為成都上千客戶提供網(wǎng)頁(yè)設(shè)計(jì)制作,網(wǎng)站開(kāi)發(fā),企業(yè)網(wǎng)站制作建設(shè)等服務(wù),包括成都營(yíng)銷型網(wǎng)站建設(shè)，品牌網(wǎng)站建設(shè)，同時(shí)也為不同行業(yè)的客戶提供成都做網(wǎng)站、成都網(wǎng)站制作的服務(wù),包括成都電商型網(wǎng)站制作建設(shè),裝修行業(yè)網(wǎng)站制作建設(shè)，傳統(tǒng)機(jī)械行業(yè)網(wǎng)站建設(shè),傳統(tǒng)農(nóng)業(yè)行業(yè)網(wǎng)站制作建設(shè)。在成都做網(wǎng)站,選網(wǎng)站制作建設(shè)服務(wù)商就選創(chuàng)新互聯(lián)。

本次實(shí)現(xiàn)是使用了MySQL數(shù)據(jù)庫(kù)本身提供的備份命令mysqldump和恢復(fù)命令mysql，在java代碼中通過(guò)從命令行調(diào)用這兩條命令來(lái)實(shí)現(xiàn)備份和恢復(fù)。備份和恢復(fù)所使用的文件都是sql文件。

本代碼是參照網(wǎng)上某網(wǎng)友提供的源碼完成的。

[java] view plaincopy

package xxx.utils;

import java.io.BufferedReader;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.io.UnsupportedEncodingException;

/**

* MySQL數(shù)據(jù)庫(kù)的備份與恢復(fù) 缺陷：可能會(huì)被殺毒軟件攔截

*

* @author xxx

* @version xxx

*/

public class DatabaseBackup {

/** MySQL安裝目錄的Bin目錄的絕對(duì)路徑 */

private String mysqlBinPath;

/** 訪問(wèn)MySQL數(shù)據(jù)庫(kù)的用戶名 */

private String username;

/** 訪問(wèn)MySQL數(shù)據(jù)庫(kù)的密碼 */

private String password;

public String getMysqlBinPath() {

return mysqlBinPath;

}

public void setMysqlBinPath(String mysqlBinPath) {

this.mysqlBinPath = mysqlBinPath;

}

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 DatabaseBackup(String mysqlBinPath, String username, String password) {

if (!mysqlBinPath.endsWith(File.separator)) {

mysqlBinPath = mysqlBinPath + File.separator;

}

this.mysqlBinPath = mysqlBinPath;

this.username = username;

this.password = password;

}

/**

* 備份數(shù)據(jù)庫(kù)

*

* @param output

* 輸出流

* @param dbname

* 要備份的數(shù)據(jù)庫(kù)名

*/

public void backup(OutputStream output, String dbname) {

String command = "cmd /c " + mysqlBinPath + "mysqldump -u" + username

+ " -p" + password + " --set-charset=utf8 " + dbname;

PrintWriter p = null;

BufferedReader reader = null;

try {

p = new PrintWriter(new OutputStreamWriter(output, "utf8"));

Process process = Runtime.getRuntime().exec(command);

InputStreamReader inputStreamReader = new InputStreamReader(process

.getInputStream(), "utf8");

reader = new BufferedReader(inputStreamReader);

String line = null;

while ((line = reader.readLine()) != null) {

p.println(line);

}

p.flush();

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

try {

if (reader != null) {

reader.close();

}

if (p != null) {

p.close();

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

/**

* 備份數(shù)據(jù)庫(kù)，如果指定路徑的文件不存在會(huì)自動(dòng)生成

*

* @param dest

* 備份文件的路徑

* @param dbname

* 要備份的數(shù)據(jù)庫(kù)

*/

public void backup(String dest, String dbname) {

try {

OutputStream out = new FileOutputStream(dest);

backup(out, dbname);

} catch (FileNotFoundException e) {

e.printStackTrace();

}

}

/**

* 恢復(fù)數(shù)據(jù)庫(kù)

*

* @param input

* 輸入流

* @param dbname

* 數(shù)據(jù)庫(kù)名

*/

public void restore(InputStream input, String dbname) {

String command = "cmd /c " + mysqlBinPath + "mysql -u" + username

+ " -p" + password + " " + dbname;

try {

Process process = Runtime.getRuntime().exec(command);

OutputStream out = process.getOutputStream();

String line = null;

String outStr = null;

StringBuffer sb = new StringBuffer("");

BufferedReader br = new BufferedReader(new InputStreamReader(input,

"utf8"));

while ((line = br.readLine()) != null) {

sb.append(line + "/r/n");

}

outStr = sb.toString();

OutputStreamWriter writer = new OutputStreamWriter(out, "utf8");

writer.write(outStr);

writer.flush();

out.close();

br.close();

writer.close();

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

}

/**

* 恢復(fù)數(shù)據(jù)庫(kù)

*

* @param dest

* 備份文件的路徑

* @param dbname

* 數(shù)據(jù)庫(kù)名

*/

public void restore(String dest, String dbname) {

try {

InputStream input = new FileInputStream(dest);

restore(input, dbname);

} catch (FileNotFoundException e) {

e.printStackTrace();

}

}

public static void main(String[] args) {

Configuration config = HibernateSessionFactory.getConfiguration();

String binPath = config.getProperty("mysql.binpath");

String userName = config.getProperty("connection.username");

String pwd = config.getProperty("connection.password");

DatabaseBackup bak = new DatabaseBackup(binPath, userName, pwd);

bak.backup("c:/ttt.sql", "ttt");

bak.restore("c:/ttt.sql", "ttt");

}

}

最后的main方法只是一個(gè)簡(jiǎn)單的使用方法的示例代碼。

本人所做的項(xiàng)目是使用了hibernate的，而這里需要提供MySQL的bin路徑和用戶名、密碼，而hibernate.cfg.xml中本身就是需要配置數(shù)據(jù)庫(kù)的用戶名和密碼，所以我把MySQL的bin路徑也直接配置到了這個(gè)文件里面，也不需要?jiǎng)?chuàng)建專門(mén)的配置文件，不需要寫(xiě)讀取配置文件的接口了。

如果不明白，可以去看hibernate.cfg.xml的說(shuō)明，里面是可以配置其他的property的

java里面的sql數(shù)據(jù)庫(kù)備份代碼怎么寫(xiě)的?

直接用SQL語(yǔ)句(完全備份):

backup

database

數(shù)據(jù)庫(kù)

to

disk='c:\你的備份文件名'

java中 sql數(shù)據(jù)庫(kù)備份代碼怎么寫(xiě)

最簡(jiǎn)單的SQL語(yǔ)句：備份與還原SQL Server自帶的數(shù)據(jù)庫(kù)

在服務(wù)器上備份：

use Northwind

Backup database Northwind to disk='d:\Northwind_bak.dat' with init

RESTORE DATABASE NorthNwind FROM DISK = 'd:\Northwind_bak.dat'

備份數(shù)據(jù)庫(kù)這一操作在客戶機(jī)上實(shí)現(xiàn)

客戶機(jī)：machine

共享目錄：share （要完全共享，可寫(xiě)權(quán)限）

backup:

bakcup database dbname to disk='\\machine\share\data.bak' with init

\\machine\share目錄要有寫(xiě)權(quán)限。

restore:

restore database dbname from disk='\\machine\share\data.bak'

//

備注：restore 語(yǔ)句有很多的選項(xiàng)，可以查看企業(yè)管理器的在線幫助。如下

with replace, move 'dbname_dat' to 'c:\mssql7\data\dbname.mdf',

move 'dbname_log' to 'c:\mssql7\data\dbname.log'

其中'c:\mssql7\data\'是服務(wù)器的目錄，這點(diǎn)要注意

備份與還原數(shù)據(jù)庫(kù)的相關(guān)內(nèi)容：

SQL Server 7.0數(shù)據(jù)庫(kù)備份有四種：完全數(shù)據(jù)庫(kù)備份、增量數(shù)據(jù)庫(kù)備份、事務(wù)日志備份、數(shù)據(jù)庫(kù)文件或文件組備份。在數(shù)據(jù)庫(kù)崩潰時(shí)，應(yīng)該首先嘗試備份事務(wù)日志（這一點(diǎn)很重要），然后恢復(fù)最后的數(shù)據(jù)庫(kù)備份、該次數(shù)據(jù)庫(kù)備份后的所有增量備份，最后恢復(fù)事務(wù)日志備份，這樣可以將數(shù)據(jù)庫(kù)恢復(fù)到崩潰前的狀態(tài)。

備份是定期的，而不是實(shí)時(shí)的，所以利用備份并不能完全恢復(fù)數(shù)據(jù)庫(kù)，它只能將數(shù)據(jù)庫(kù)恢復(fù)到制作備份的那一刻 ...... 數(shù)據(jù)庫(kù)日志是實(shí)時(shí)的，他忠實(shí)的記錄下所有對(duì)數(shù)據(jù)庫(kù)的更新操作。因此，當(dāng)磁盤(pán)出現(xiàn)故障造成數(shù)據(jù)庫(kù)損壞時(shí)，就可以首先利用備份恢復(fù)數(shù)據(jù)庫(kù)（大部分?jǐn)?shù)據(jù)），然后運(yùn)行數(shù)據(jù)庫(kù)日志，即將備份后所做的操作重新在做一遍，從而將數(shù)據(jù)庫(kù)完全恢復(fù)。

--備份完整的數(shù)據(jù)庫(kù)---------------------------------------------------------------

//創(chuàng)建一個(gè)備份設(shè)備：

1. Create the backup device for the full MyNwind backup.///

USE master

EXEC sp_addumpdevice 'disk', 'MyNwind_2', 'c:\mssql7\backup\MyNwind_2.dat'

2. Back up the full MyNwind database.

BACKUP DATABASE MyNwind TO MyNwind_2

--備份數(shù)據(jù)庫(kù)的日志---------------------------------------------------------------

--1. Create the log backup device.

USE master

EXEC sp_addumpdevice 'disk', 'MyNwindLog1', 'c:\mssql7\backup\MyNwindLog1.dat'

--2. Update activity has occurred before this point. Back up the log of the MyNwind database.

BACKUP LOG MyNwind TO MyNwindLog1

try

AdoQuery1.Close;

AdoQuery1.SQL.Clear;

AdoQuery1.SQL.Add('backup database pubs');

AdoQuery1.SQL.Add('to disk='+''''+edtPath.Text+'''');

AdoQuery1.ExecSQL;

except

ShowMessage('備份數(shù)據(jù)庫(kù)失??！');

exit;

end;

SQL server的備份

=========================================================================

=========================================================================

備份：

with adocommand_restore do//用ADocommand控件

begin

CommandText:='use Master';//

Execute;

CommandText:='execute sp_helpdevice';//系統(tǒng)存儲(chǔ)過(guò)程

Execute ;

CommandText:='backup database '+'db_name'+' to disk='''+FileName+''' with init';//這行應(yīng)當(dāng)是這樣

Execute ;

CommandText:='Use '+'db_name';//這行應(yīng)當(dāng)是這樣

Execute ;

application.MessageBox('已經(jīng)成功備份數(shù)據(jù)庫(kù)','數(shù)據(jù)庫(kù)備份',MB_OK + MB_ICONINFORMATION);

end;

恢復(fù)：

with adocommand1 do//用AdoCommand控件

begin

CommandText:='use Master';

Execute;

CommandText:='execute sp_helpdevice';

Execute ;

CommandText:='Restore database '+'db_name'+' From disk='''+'c:\data1.bak'+''' with replace';//這行應(yīng)當(dāng)是這樣

Execute ;

CommandText:='Use '+'db_name';//這行應(yīng)當(dāng)是這樣

Execute ;

application.MessageBox('已經(jīng)成功恢復(fù)數(shù)據(jù)庫(kù)','數(shù)據(jù)庫(kù)恢復(fù)',MB_OK + MB_ICONINFORMATION);

end;

*注：db_name指數(shù)據(jù)庫(kù)的名稱