mysql blob hex_数据库的完整备份与恢复 quot;--hex-blobquot; - - ITeye博客
閑言少絮，這個(gè)程序利用MySql數(shù)據(jù)庫自帶小程序進(jìn)行數(shù)據(jù)庫的備份和還原。這兩個(gè)程序分別是：mysql.exe和mysqldump.exe。這兩個(gè)程序在您安裝Mysql數(shù)據(jù)庫的時(shí)候會(huì)自動(dòng)安裝到數(shù)據(jù)庫的bin目錄。這兩個(gè)程序存在的目錄為：C:\Program File\MySQL\MySQL Server 5.5\bin這個(gè)目錄下。在這個(gè)目錄下您還可以看到很多MySql自帶的工具程序，他們都很方便和實(shí)用。
數(shù)據(jù)庫安裝程序信息：mysql- 5.5.25a-win32.msi。
安裝路徑：程序默認(rèn)路徑。
應(yīng)用程序：Navicat_for_Mysql.exe，默認(rèn)安裝。
依賴項(xiàng)：mysql-connector-java-5.1.10-bin.jar
服務(wù)器地址：192.168.0.100
核心語句：
備份："cmd.exe /C C:\\mysqldump -uroot -p123456 -h
192.168.0.100 "+ database +" >"+ path +"";
還原："cmd.exe /C
C:\\mysql -uroot -p123456 -h 192.168.0.100 "+ database +"
其他說明：建立的數(shù)據(jù)庫名稱為：qqwe，數(shù)據(jù)庫建立在遠(yuǎn)程服務(wù)器上。mysql.exe和mysqldump.exe從bin目錄下取出來，放入到
C:\\下。
這個(gè)程序通過讀取*.properties配置文件來獲取外界傳遞進(jìn)來的信息。這個(gè)文件是自己定義的。其中定義的內(nèi)容如下：
OK，簡要說明結(jié)束，看代碼！
package DatabaseRR;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.lang.Process;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
import java.sql.Statement;
public class EasyRecovery
{
Connection conn = null;
public Connection getConnection(String fileNameAndURL)
{
Properties prop = new Properties();
FileInputStream fis;
try{
fis = new FileInputStream(fileNameAndURL);
prop.load(fis);
fis.close();
String userName = prop.getProperty("userName");
String password = prop.getProperty("password");
String localHost = prop.getProperty("localHost");//主機(jī)名或主機(jī)地址IP，如 192.168.0.100
String database = prop.getProperty("database");//數(shù)據(jù)庫名稱
String jdbcDriver = prop.getProperty("jdbcDriver");//加載數(shù)據(jù)庫驅(qū)動(dòng)的名稱
String port = prop.getProperty("port");//端口
String dataBaseCompany = prop.getProperty("dataBaseCompany");
String pathUrl = "jdbc:"+dataBaseCompany+"://"+localHost+":"+port+"/"+database;
Class.forName(jdbcDriver); // 加載MySQL數(shù)據(jù)庫驅(qū)動(dòng)
String url = pathUrl; // 定義與連接數(shù)據(jù)庫的url
String user = userName; // 定義連接數(shù)據(jù)庫的用戶名
String passWord = password; // 定義連接數(shù)據(jù)庫的密碼
conn = DriverManager.getConnection(url, user, passWord); // 連接連接
}
catch (Exception e)
{
e.printStackTrace();
}
return conn;
}
/**
* 獲取MySQL所有數(shù)據(jù)庫方法
SCHEMATA 這是MySql記錄數(shù)據(jù)庫中一共建立了多少個(gè)數(shù)據(jù)庫，并保存他們表名的一個(gè)數(shù)據(jù)庫表
* @param fileNameAndURL
* @return list
*/
public List getDatabase(String fileNameAndURL)
{
List list = new ArrayList(); // 定義List集合對(duì)象
Connection con = getConnection(fileNameAndURL); // 獲取數(shù)據(jù)庫連接
Statement st; // 定義Statement對(duì)象
try
{
st = con.createStatement(); // 實(shí)例化Statement對(duì)象
ResultSet rs = st.executeQuery("select schema_name from SCHEMATA");// 指定查詢所有數(shù)據(jù)庫方法
while (rs.next()) // 循環(huán)遍歷查詢結(jié)果集
{
list.add(rs.getString(1)); // 將查詢數(shù)據(jù)添加到List集合中
}
}
catch (Exception e)
{
e.printStackTrace();
}
return list; // 返回查詢結(jié)果
}
/**
* 備份數(shù)據(jù)庫
*
* @param fileNameAndURL 配置文件和他的路徑
*
* @param database 數(shù)據(jù)庫名
* @param path文件保存路徑
* @param userName創(chuàng)建數(shù)據(jù)庫時(shí)設(shè)定的用戶名
* @param password數(shù)據(jù)庫用戶密碼
* @param localHost主機(jī)名或主機(jī)地址IP，如 192.168.0.100
* @param CmdDiskmysql.exe、mysqldump.exe這兩個(gè)文件存放的目錄
*/
private void mysqldump(String fileNameAndURL)
{
Connection con = getConnection(fileNameAndURL);
Properties prop = new Properties();
try {
FileInputStream fis = new FileInputStream(fileNameAndURL);
prop.load(fis);
fis.close();
String userName = prop.getProperty("userName");
String password = prop.getProperty("password");
String localHost = prop.getProperty("localHost");//主機(jī)名或主機(jī)地址IP，如 192.168.0.100
String database = prop.getProperty("database");//數(shù)據(jù)庫名稱
String saveDisk = prop.getProperty("saveDisk");//要保存的盤符
String fileName = prop.getProperty("fileName");//要保存成的文件名稱
String fileType = prop.getProperty("fileType");//要保存成的文件格式
String CmdDisk = prop.getProperty("CmdDisk");//
String path = saveDisk + fileName + fileType;//構(gòu)成了完整路徑
String Cmd = "cmd.exe /C " + CmdDisk + "mysqldump --hex-blob -u" + userName + " -p" + password + " -h " + localHost + " " + database + " >" + path + "";
//String asd = "cmd.exe /C C:\\mysqldump -uroot -p123456 -h 192.168.0.100 " + database + " >" + path + ""; 原始格式，不要?jiǎng)h除該語句
Process p = Runtime.getRuntime().exec(Cmd);//定義進(jìn)行數(shù)據(jù)備份的語句
StringBuffer out1 = new StringBuffer(); //定義字符串緩沖對(duì)象
byte[] b = new byte[1024]; //定義字節(jié)數(shù)組
for (int i; ((i = p.getInputStream().read(b)) != -1);) // 將數(shù)據(jù)寫入到指定文件中 mysqldump.exe
{
out1.append(new String(b, 0, i)); //向流中追加數(shù)據(jù)
}
}
catch (IOException e)
{
e.printStackTrace();
}
}
/**
* 恢復(fù)數(shù)據(jù)庫
*
* @param fileNameAndURL 配置文件和他的路徑
*
* @param database 數(shù)據(jù)庫名
* @param path文件保存路徑
* @param userName創(chuàng)建數(shù)據(jù)庫時(shí)設(shè)定的用戶名
* @param password數(shù)據(jù)庫用戶密碼
* @param localHost主機(jī)名或主機(jī)地址IP，如 192.168.0.100
* @param CmdDiskmysql.exe、mysqldump.exe這兩個(gè)文件存放的目錄
*/
private void mysqlresume(String fileNameAndURL)
{
Connection con = getConnection(fileNameAndURL);
Properties prop = new Properties();
try
{
FileInputStream fis = new FileInputStream(fileNameAndURL);
prop.load(fis);
fis.close();
String userName = prop.getProperty("userName");
String password = prop.getProperty("password");
String localHost = prop.getProperty("localHost");//主機(jī)名或主機(jī)地址IP，如 192.168.0.100
String database = prop.getProperty("database");//數(shù)據(jù)庫名稱
String saveDisk = prop.getProperty("saveDisk");//要保存的盤符
String fileName = prop.getProperty("fileName");//要保存成的文件名稱
String fileType = prop.getProperty("fileType");//要保存成的文件格式
String CmdDisk = prop.getProperty("CmdDisk");//mysql.exe、mysqldump.exe這兩個(gè)文件存放的目錄
String path = saveDisk + fileName + fileType;//構(gòu)成了完整路徑
String Cmd = "cmd.exe /C " + CmdDisk + "mysql -u" + userName + " -p" + password + " -h " + localHost + " " + database + "
Process p = Runtime.getRuntime().exec(Cmd);
StringBuffer out1 = new StringBuffer(); // 定義字符串緩沖對(duì)象
byte[] b = new byte[1024]; // 定義字節(jié)數(shù)組
for (int i; ((i = p.getInputStream().read(b)) != -1);) // 將數(shù)據(jù)寫入到指定文件中
{
out1.append(new String(b, 0, i)); // 向流中追加數(shù)據(jù)
}
}
catch (IOException e)
{
e.printStackTrace();
}
}
/**
* 編輯屬性文件，向配置文件中寫入新的信息
* @param fileNameAndURL
* @param Key
* @param Value
*/
public void propertyEditor(String fileNameAndURL , String Key , String Value)
{
Properties prop = new Properties();
try
{
InputStream fis = new FileInputStream(fileNameAndURL);
prop.load(fis);
prop.setProperty(Key, Value);
OutputStream fos = new FileOutputStream(fileNameAndURL);
prop.store(fos , Key);
fos.flush();
fis.close();
}
catch(IOException e)
{
e.getStackTrace();
}
}
//################################################//
/**
* 備份 可供外界調(diào)用的方法
* @param fileNameAndURL
*/
public void dataBaseReserve(String fileNameAndURL)
{
EasyRecovery mc = new EasyRecovery();
mc.mysqldump(fileNameAndURL);
}
/**
* 恢復(fù) 可供外界調(diào)用的方法
* @param fileNameAndURL
*/
public void dataBaseRecovery(String fileNameAndURL)
{
EasyRecovery mc = new EasyRecovery();
mc.mysqlresume(fileNameAndURL);
}
public static void main(String args[])
{
EasyRecovery mc = new EasyRecovery();
String fileNameAndURL = "E:\\propertiesConfig\\EasyRecoveryConfig.properties";
mc.dataBaseReserve(fileNameAndURL);
mc.propertyEditor(fileNameAndURL, "userName", "Doctor Lee");
mc.dataBaseRecovery(fileNameAndURL);
}
}
--hex-blob；這個(gè)命令是用于將導(dǎo)出的內(nèi)容處理成為2進(jìn)制流的形式。因?yàn)橛行r(shí)候你會(huì)發(fā)現(xiàn)，導(dǎo)出的數(shù)據(jù)庫文件大小與數(shù)據(jù)庫本身真實(shí)內(nèi)容的大小存在沖突，往往是小于真實(shí)的大小。加入這個(gè)命令你就可以解決這個(gè)問題了。這個(gè)命令加在備份數(shù)據(jù)庫的時(shí)候。
這個(gè)程序適用于任何Mis系統(tǒng)、ERP系統(tǒng)等，在您的界面中只需要添加兩個(gè)按鈕然后完成相應(yīng)的事件即可。這個(gè)程序也可以將他改成一個(gè)Action(EasyRecoveryAction.java),幫助您完成相應(yīng)的后臺(tái)請(qǐng)求。初學(xué)者，不足之處請(qǐng)您多多指點(diǎn)。相應(yīng)的項(xiàng)目工程和依賴程序在下面，您可以拿來直接運(yùn)行。希望對(duì)您有所幫助。開源萬歲！轉(zhuǎn)載請(qǐng)您注明出處。
分享到：
2012-11-27 19:39
瀏覽 4870
分類:數(shù)據(jù)庫
評(píng)論
總結(jié)
以上是生活随笔為你收集整理的mysql blob hex_数据库的完整备份与恢复 quot;--hex-blobquot; - - ITeye博客的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： IIS调试技术之 Debug Diagn
- 下一篇： mysql c api 封装_封装MyS