java备份数据库，如何用Java实现MySQL数据库的备份和恢复
大家好，java备份数据库相信很多的网友都不是很明白，包括如何用Java实现MySQL数据库的备份和恢复也是一样，不过没有关系，接下来就来为大家分享关于java备份数据库和如何用Java实现MySQL数据库的备份和恢复的一些知识点，大家可以关注收藏，免得下次来找不到哦，下面我们开始吧！
怎么用java备份mysql数据库
首先，设置mysql的环境变量（在path中添加%MYSQL_HOME%\bin），重启电脑。
完整代码：
备份：
public static void main(String[] args){
backup();
load();
}
public static void backup(){
try{
Runtime rt= Runtime.getRuntime();
//调用 mysql的 cmd:
Process child= rt
.exec("mysqldump-u root--set-charset=utf8 bjse act_obj");//设置导出编码为utf8。这里必须是utf8
//把进程执行中的控制台输出信息写入.sql文件，即生成了备份文件。注：如果不对控制台信息进行读出，则会导致进程堵塞无法运行
InputStream in= child.getInputStream();//控制台的输出信息作为输入流
InputStreamReader xx= new InputStreamReader(in,"utf8");//设置输出流编码为utf8。这里必须是utf8，否则从流中读入的是乱码
String inStr;
StringBuffer sb= new StringBuffer("");
String outStr;
//组合控制台输出信息字符串
BufferedReader br= new BufferedReader(xx);
while((inStr= br.readLine())!= null){
sb.append(inStr+"\r\n");
}
outStr= sb.toString();
//要用来做导入用的sql目标文件：
FileOutputStream fout= new FileOutputStream(
"e:/mysql-5.0.27-win32/bin/bjse22.sql");
OutputStreamWriter writer= new OutputStreamWriter(fout,"utf8");
writer.write(outStr);
//注：这里如果用缓冲方式写入文件的话，会导致中文乱码，用flush()方法则可以避免
writer.flush();
//别忘记关闭输入输出流
in.close();
xx.close();
br.close();
writer.close();
fout.close();
System.out.println("");
} catch(Exception e){
e.printStackTrace();
}
}
public static void load(){
try{
String fPath="e:/mysql-5.0.27-win32/bin/bjse22.sql";
Runtime rt= Runtime.getRuntime();
//调用 mysql的 cmd:
Process child= rt.exec("mysql-u root bjse");
OutputStream out= child.getOutputStream();//控制台的输入信息作为输出流
String inStr;
StringBuffer sb= new StringBuffer("");
String outStr;
BufferedReader br= new BufferedReader(new InputStreamReader(
new FileInputStream(fPath),"utf8"));
while((inStr= br.readLine())!= null){
sb.append(inStr+"\r\n");
}
outStr= sb.toString();
OutputStreamWriter writer= new OutputStreamWriter(out,"utf8");
writer.write(outStr);
//注：这里如果用缓冲方式写入文件的话，会导致中文乱码，用flush()方法则可以避免
writer.flush();
//别忘记关闭输入输出流
out.close();
br.close();
writer.close();
System.out.println("");
} catch(Exception e){
e.printStackTrace();
}
}
备份语句：
mysql> SELECT* INTO OUTFILE"D:\\data\\db_testtemp.txt" fields terminated by',
' from db_testtemp where std_state='1';
Query OK, 1 row affected(0.00 sec)
mysql> SELECT* INTO OUTFILE"D:\\data\\db_testtemp.txt" fields terminated by',
' from db_testtemp;
Query OK, 2 rows affected(0.00 sec)
只生成一个只有数据的.txt:SELECT* INTO OUTFILE"D:\\data\\db_testtemp.txt" fields terminated by',' lines terminated by'\r\n' from db_testtemp;
只生成一个只有数据的.txt:mysqldump-uroot-pncae2010-w"std_state='1'"-T D:\data--no-create-info--fields-terminated-by=, exam db_testtemp
生成一个创建数据库语句的.sql,一个只有数据的.txt:mysqldump-uroot-pncae2010-w"std_state='1'"-T D:\data--fields-terminated-by=, exam db_testtemp
只生成insert语句：mysqldump-uroot-pncae2010-w"std_state='1'"-t exam db_testtemp> D:\data\a.sql
如何用Java实现MySQL数据库的备份和恢复
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的
Java怎样进行数据备份功能
现在的各种数据库应用，由于技术、历史等因素，往往在一个大的部门中并存有多个应用系统。这些应用系统可能分散于不同的网络节点、基于不同的操作平台、使用不同的数据库管理系统，且各子系统封闭运行，自成一体，这样给不同部门的信息资源共享带来困难。如何在不改变原来系统的内部信息的前提下，完成不同数据库系统间的数据访问和交换是值得研究的问题。
多数据库系统的Java解决方案
多数据库系统的构成有多种方式，在这些方式中，我们考察这些多数据库的不同点，其主要表现在以下几个方面的异构：
(1)数据库逻辑数据模型的异构：有层次、网状、关系、对象-关系和对象五种数据库。
(2)数据库物理数据模型的异构：物理数据模型反映数据库存储结构，例如物理块、指针、索引等，即使逻辑数据模型相同，如关系数据库的ORACLE、SYBASE、DB2等，其物理数据模型也存在差异。
(3)操作系统的异构：UNIX、WINDOWS系列、MacOS、OS/2、DOS等。
(4)计算机平台的异构：从巨、大、中、小型机到工作站，微机以及手持机。
(5)网络的异构：LAN、WAN、以太总线结构与令牌环结构等。
在这些异构中，有些是数据库历史所造成的，如层次、网状类型的数据库;有些是不同的数据库开发商开发的不同的数据库管理系统造成的;有些是计算机操作系统的不同;而有些是网络结构和计算机平台的原因。对于这些不同，从目前来看，我们认为当前应该着重解决的在关系模式下的不同的操作系统和不同数据库管理系统。
众所周知，Java技术是全新的编程技术，它具有平台无关性、面向对象、安全、高性能、分布式，多线程等特点，使Java成为当前最为类型的编程语言和平台。对于多数据库系统联合访问和数据交换，使用Java技术可以解决不同的操作系统和不同的数据库管理系统之间的数据处理。
好了，本文到此结束，如果可以帮助到大家，还望关注本站哦！