JAVA实现数据库备份与还原

  • 格式:doc
  • 大小:45.00 KB
  • 文档页数:7

下载文档原格式

  / 7
  1. 1、下载文档前请自行甄别文档内容的完整性,平台不提供额外的编辑、内容补充、找答案等附加服务。
  2. 2、"仅部分预览"的文档,不可在线预览部分如存在完整性等问题,可反馈申请退款(可完整预览的文档不适用该条件!)。
  3. 3、如文档侵犯您的权益,请联系客服反馈,我们会尽快为您处理(人工客服工作时间:9:00-18:30)。

JAVA实现数据库备份与还原[MYSQL为例]

数据库数据的备份与还原最好是使用数据库自带的客户端软件来实现,JAVA可以通过调用mysqldump、mysql客户端软件分别进行mysql数据库的备份还原,当然前提是JAVA服务器必须安装mysql客户端软件,但是也可以通过java telnet登陆数据库服务器实现备份,关于telnet的相关资料请Google.

MYSQL支持的备份方式:

1.使用SELECT INTO ...OUTFILE,例如

SQL代码

1SELECT * INTO OUTFILE "D:\\test.sql" fields terminatedby ',' lines terminatedby '' from category ;

生成的文件会存放在数据库服务器上面

SELECT INTO只备份了数据库表中的数据:如下为category备份后的文件内容

XML/HTML代码

21,ELECTRONICS,\N

32,TELEVISIONS,1

43,TUBE,2

54,LCD,2

65,PLASMA,2

76,PORTABLE ELECTRONICS,1

87,MP3 PLAYERS,6

98,FLASH,7

109,CD PLAYERS,6

1110,2 WAY RADIOS,6

2.使用BACKUP TABLE,例如

SQL代码

12BACKUPTABLE test_tableto 'D:\backup';

BACKUP只针对MyISAM表格,且在MYSQL 5.1的参考手册中“注释:本语句不理想”; BACKUP语句效果为拷贝数据库表中的.frm文件到数据库服务器目标目录

3.使用mysqldump程序或mysqlhotcopy脚本

MYSQL 5.1的参考手册中关于mysqldump的说明:“可用来转储数据库或搜集数据库进行备份或将数据转移到另一个SQL服务器(不一定是一个MySQL服务器)。转储包含创建表和/或装载表的SQL语句。“

JAVA可以运用Process类的exec(String str)方法调用系统命令,所以需要在服务器上安装mysqldump程序已完成备份,可以对远程的数据库服务器进行备份(配置hostname参数),备份语句具体参数参考MYSQL参考手册

MYSQL备份命令行:

SQL代码

13mysqldump -hhostname -uusername -ppassword databasename > ‘backupfile’JAVA代码如下:

Java代码

14public final String BACKUP_COMMAND ="mysqldump";

15public final String ENCODING ="utf8";

16

17public boolean backup(String file) {

18 boolean isSuccess =true;

19 try {

20 Runtime rt = Runtime.getRuntime();

21 String backupStr =this.getBackupStr();

22 T(backupStr);

23 Process process = rt.exec(backupStr);

24

25 BufferedReader br =new BufferedReader(new

InputStreamReader(process.getInputStream(), ENCODING));

26

27 String inStr ="";

28 StringBuffer sb =new StringBuffer("");

29 while ((inStr = br.readLine()) !=null) {

30 sb.append(inStr).append("");

31 }

32 String outStr = sb.toString();

33

34 OutputStreamWriter writer =new OutputStreamWriter(new

FileOutputStream(file), ENCODING);

35 writer.write(outStr);

36 writer.flush();

37

38 br.close();

39 writer.close();

40 }catch (Exception e) {

41 e.printStackTrace();

42 isSuccess =false;

43 }

44 return isSuccess;

45}

46

47private String getBackupStr() {

48 String backupStr = BACKUP_COMMAND +" -u" + db.getUserName() +" -p" +

db.getPassword() +" -h" + db.getHost() +" --set-charset=" + db.getEncoding() +"

" + db.getName();

49 return backupStr;

50}

51

MYSQL还原命令行:

SQL代码

52mysql -hhostname -uusername -ppassword databasename < ‘backupfile’JAVA代码如下:

Java代码

53public final String REVERT_COMMAND ="mysql";

54

55public boolean revert(String file) {

56 try {

57 Runtime rt = Runtime.getRuntime();

58 String revertStr =this.getRevertStr();

59 Process process = rt.exec(revertStr);

60

61 String inStr;

62 StringBuffer sb =new StringBuffer("");

63 BufferedReader br =new BufferedReader(new InputStreamReader(

64 new FileInputStream(file), ENCODING));

65 while ((inStr = br.readLine()) !=null) {

66 sb.append(inStr).append("");

67 }

68 String outStr = sb.toString();

69

70 OutputStreamWriter writer =new

OutputStreamWriter(process.getOutputStream(), ENCODING);

71 writer.write(outStr);

72 writer.flush();

73 br.close();

74 writer.close();

75 }catch (Exception e) {

76 e.printStackTrace();

77 return false;

78 }

79 return true;

80}

81

82private String getRevertStr() {

83 String backupStr = REVERT_COMMAND +" -u" + db.getUserName() +" -p" +

db.getPassword() +" -h" + db.getHost() +" " + db.getName();