数据库的完整备份与恢复 "--hex-blob"

闲言少絮，这个程序利用MySql 数据库自带小程序进行数据库的备份和还原。这两个程序分别是：mysql.exe和mysqldump.exe。这两个程序在您安装Mysql数据库的时候会自动安装到数据库的bin目录。这两个程序存在的目录为：C:\Program File\MySQL\MySQL Server 5.5\bin 这个目录下。在这个目录下您还可以看到很多MySql自带的工具程序，他们都很方便和实用。

数据库安装程序信息：mysql- 5.5.25a-win32.msi。

安装路径：程序默认路径。

应用程序：Navicat_for_Mysql.exe，默认安装。

依赖项：mysql-connector-java-5.1.10-bin.jar

服务器地址：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 + " <" + path + "";

其他说明：建立的数据库名称为：qqwe，数据库建立在远程服务器上。mysql.exe和mysqldump.exe从bin目录下取出来，放入到 C:\\ 下。

 

这个程序通过读取*.properties配置文件来获取外界传递进来的信息。这个文件是自己定义的。其中定义的内容如下：

 

图片连接地址：http://my.iteye.com/admin/picture/120930

 

OK，简要说明结束，看代码！

 

 

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");//主机名或主机地址IP，如 192.168.0.100
	    	String database  = prop.getProperty("database");//数据库名称
	    	
	    	String jdbcDriver = prop.getProperty("jdbcDriver");//加载数据库驱动的名称
	    	String port = prop.getProperty("port");				//端口
	    	String dataBaseCompany = prop.getProperty("dataBaseCompany");
	    	
	    	String pathUrl = "jdbc:"+dataBaseCompany+"://"+localHost+":"+port+"/"+database;
	    	
            Class.forName(jdbcDriver); 			 					// 加载MySQL数据库驱动
            String url = pathUrl; 									// 定义与连接数据库的url
            String user = userName; 								// 定义连接数据库的用户名
            String passWord = password; 						 	// 定义连接数据库的密码
            conn = DriverManager.getConnection(url, user, passWord); // 连接连接
        } 
		catch (Exception e) 
        {
            e.printStackTrace();
        }
        return conn;
    }
    
    /**
     * 获取MySQL所有数据库方法 
SCHEMATA 这是MySql记录数据库中一共建立了多少个数据库，并保存他们表名的一个数据库表
* @param fileNameAndURL
     * @return list
     */
    public List<String> getDatabase(String fileNameAndURL) 
    {
        List<String> list = new ArrayList<String>(); 		// 定义List集合对象
        Connection con = getConnection(fileNameAndURL); 	// 获取数据库连接
        Statement st; 						// 定义Statement对象
        try 
        {
            st = con.createStatement(); 	// 实例化Statement对象
            ResultSet rs = st.executeQuery("select schema_name from SCHEMATA");// 指定查询所有数据库方法
            while (rs.next()) 				// 循环遍历查询结果集
            { 			
                list.add(rs.getString(1)); 	// 将查询数据添加到List集合中
            }
        }
        catch (Exception e) 
        {
            e.printStackTrace();
        }
        return list; 						// 返回查询结果
    }
    
    /**
     * 备份数据库
     * 
     * @param fileNameAndURL 配置文件和他的路径
     * 
     * @param database 	数据库名
     * @param path		文件保存路径
     * @param userName	创建数据库时设定的用户名 
     * @param password	数据库用户密码 
     * @param localHost	主机名或主机地址IP，如 192.168.0.100 
     * @param CmdDisk	mysql.exe、mysqldump.exe这两个文件存放的目录
     */
    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");//主机名或主机地址IP，如 192.168.0.100
	    	String database  = prop.getProperty("database");//数据库名称
	    	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;//构成了完整路径
	    	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 + ""; 原始格式，不要删除该语句
	    	
    		Process p = Runtime.getRuntime().exec(Cmd);				//定义进行数据备份的语句
    		StringBuffer out1 = new StringBuffer(); 				//定义字符串缓冲对象
    		byte[] b = new byte[1024];              				//定义字节数组
    		for (int i; ((i = p.getInputStream().read(b)) != -1);)  // 将数据写入到指定文件中   mysqldump.exe
    		{
    			out1.append(new String(b, 0, i));   				//向流中追加数据
    		}
    	}
    	catch (IOException e) 
    	{
    		e.printStackTrace();
    	}
    }
    
    /**
     * 恢复数据库
     * 
     * @param fileNameAndURL 配置文件和他的路径
     * 
     * @param database 	数据库名
     * @param path		文件保存路径
     * @param userName	创建数据库时设定的用户名 
     * @param password	数据库用户密码 
     * @param localHost	主机名或主机地址IP，如 192.168.0.100 
     * @param CmdDisk	mysql.exe、mysqldump.exe这两个文件存放的目录
     */
    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");	//主机名或主机地址IP，如 192.168.0.100
	    	String database  = prop.getProperty("database");	//数据库名称
	    	String saveDisk  = prop.getProperty("saveDisk");	//要保存的盘符
	    	String fileName  = prop.getProperty("fileName");	//要保存成的文件名称
	    	String fileType  = prop.getProperty("fileType");	//要保存成的文件格式
	    	String CmdDisk	 = prop.getProperty("CmdDisk");		//mysql.exe、mysqldump.exe这两个文件存放的目录
	    	
	    	String path = saveDisk + fileName + fileType;		//构成了完整路径
	    	String Cmd = "cmd.exe /C " + CmdDisk + "mysql -u" + userName + " -p" + password + " -h " + localHost + " " + database + " <" + path + "";
            Process p = Runtime.getRuntime().exec(Cmd);
            
            StringBuffer out1 = new StringBuffer(); 				// 定义字符串缓冲对象
            byte[] b = new byte[1024]; 								// 定义字节数组
            
            for (int i; ((i = p.getInputStream().read(b)) != -1);) 	// 将数据写入到指定文件中
            { 
                out1.append(new String(b, 0, i)); 					// 向流中追加数据
            }
        } 
    	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();
		}
	}
    //################################################//
    /**
     * 备份  可供外界调用的方法
     * @param fileNameAndURL
     */
    public void dataBaseReserve(String fileNameAndURL)
    {
        EasyRecovery mc = new EasyRecovery();
    	mc.mysqldump(fileNameAndURL);
    }
    
    /**
     * 恢复  可供外界调用的方法
     * @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；这个命令是用于将导出的内容处理成为2进制流的形式。因为有些时候你会发现，导出的数据库文件大小与数据库本身真实内容的大小存在冲突，往往是小于真实的大小。加入这个命令你就可以解决这个问题了。这个命令加在备份数据库的时候。

 

 这个程序适用于任何Mis系统、ERP系统等，在您的界面中只需要添加两个按钮然后完成相应的事件即可。这个程序也可以将他改成一个Action(EasyRecoveryAction.java),帮助您完成相应的后台请求。初学者，不足之处请您多多指点。相应的项目工程和依赖程序在下面，您可以拿来直接运行。希望对您有所帮助。开源万岁！转载请您注明出处。