java調用mysqldump（java調用mysql執行sql腳本）

• 1、JAVA調用CMD 導出MYSQL的SQL文件為空，同樣的語句在CMD直接調用下可以正確生成文件。
• 2、怎麼從Java客戶端調用mysqldump導出資料庫
• 3、如何用java實現mysql資料庫的導入導出
• 4、如何用Java實現MySQL資料庫的備份和恢復
• 5、java mysqldump導出到對應文件夾下，程序執行未報錯，但是對應目錄下為空？

Runtime.getRuntime().exec(“目錄/bin/mysqldump -h localhost -u root -padmin rois2 d:/wewe.sql”);

不寫cmd 直接用mysqldump的絕對路徑

如這個 Runtime.getRuntime().exec(“d:/mysql/bin/mysqldump -h localhost -u root -padmin rois2 d:/wewe.sql”);

該是一些特殊符被轉義了，你可以把mysqldump -u root -proot –opt mysql C:/Users/success/ak.sql 這句寫到一個bat文件裡面，然後java中就直接調用這個bat文件就可以避免了！

MySql導出資料庫的命令如下：

Sql代碼

mysqldump -uusername -ppassword -hhost -Pport exportDatabaseName exportPath

mysqldump -uusername -ppassword -hhost -Pport exportDatabaseName exportPath

利用Java調用命令窗口執行命令來進行MySql導入資料庫一般分三步走：

第一步：登錄Mysql資料庫，在登錄資料庫的時候也可以指定登錄到哪個資料庫，如果指定了則可以跳過第二步；

第二步：切換資料庫到需要導入的目標資料庫

第三步：利用命令開始導入

在進行導出的時候，需要注意命令語句的運行環境，如果已經將mysql安裝路徑下的bin加入到

系統的path變數中，那麼在導出的時候可以直接使用命令語句，否則，就需要在執行命令語句的

時候加上命令所在位置的路徑，即mysql安裝路徑想的bin下的mysqldump命令。

MySQL的一些前台工具是有備份恢復功能的，可是如何在我們的應用程序中實現這一功能呢？本文提供了示例代碼來說明如何使用Java代碼實現MySQL資料庫的備份恢復。

本次實現是使用了MySQL資料庫本身提供的備份命令mysqldump和恢復命令mysql，在java代碼中通過從命令行調用這兩條命令來實現備份和恢復。備份和恢復所使用的文件都是sql文件。

本代碼是參照網上某網友提供的源碼完成的。

[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資料庫的備份與恢復 缺陷：可能會被殺毒軟體攔截

*

* @author xxx

* @version xxx

*/

public class DatabaseBackup {

/** MySQL安裝目錄的Bin目錄的絕對路徑 */

private String mysqlBinPath;

/** 訪問MySQL資料庫的用戶名 */

private String username;

/** 訪問MySQL資料庫的密碼 */

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;

}

/**

* 備份資料庫

*

* @param output

* 輸出流

* @param dbname

* 要備份的資料庫名

*/

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();

}

}

}

/**

* 備份資料庫，如果指定路徑的文件不存在會自動生成

*

* @param dest

* 備份文件的路徑

* @param dbname

* 要備份的資料庫

*/

public void backup(String dest, String dbname) {

try {

OutputStream out = new FileOutputStream(dest);

backup(out, dbname);

} catch (FileNotFoundException e) {

e.printStackTrace();

}

}

/**

* 恢復資料庫

*

* @param input

* 輸入流

* @param dbname

* 資料庫名

*/

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();

}

}

/**

* 恢復資料庫

*

* @param dest

* 備份文件的路徑

* @param dbname

* 資料庫名

*/

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方法只是一個簡單的使用方法的示例代碼。

本人所做的項目是使用了hibernate的，而這裡需要提供MySQL的bin路徑和用戶名、密碼，而hibernate.cfg.xml中本身就是需要配置資料庫的用戶名和密碼，所以我把MySQL的bin路徑也直接配置到了這個文件裡面，也不需要創建專門的配置文件，不需要寫讀取配置文件的介面了。

如果不明白，可以去看hibernate.cfg.xml的說明，裡面是可以配置其他的property的

把Process的結果讀出來，才能看到是否導出錯誤，執行語句成功，不等於導出成功。