您好,欢迎访问一九零五行业门户网

java写的MySQL数据库备份和恢复代码:

1.mysql数据库备份和恢复,java代码实现:详情见下面: package com.spring.util; import java.io.bufferedreader; import java.io.bufferedwriter; import java.io.fileinputstream; import java.io.fileoutputstream; import java.io.ioexception; import
1.mysql数据库备份和恢复,java代码实现:详情见下面:
package com.spring.util;
import java.io.bufferedreader;
import java.io.bufferedwriter;
import java.io.fileinputstream;
import java.io.fileoutputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.io.inputstreamreader;
import java.io.outputstream;
import java.io.outputstreamwriter;
//mysql数据库备份
public class mysqldump {
//备份数据库
public static boolean sqldump(string cmd,string filepath){
boolean falg = false;
try {
runtime run = runtime.getruntime();
process p = run.exec(cmd);
inputstream is = p.getinputstream();// 控制台的输出信息作为输入流
inputstreamreader isr = new inputstreamreader(is,utf-8);//设置输入流编码格式  
bufferedreader br = new bufferedreader(isr);
//将控制台输入信息写入到文件输出流中 
fileoutputstream fos = new fileoutputstream(filepath);
bufferedwriter bw = new bufferedwriter(new outputstreamwriter(fos,utf-8));
string temp = null;
while((temp = br.readline()) != null){
bw.write(temp);
bw.newline();
}
bw.flush();
bw.close();
br.close();
falg = true;
system.out.println(/* dump sql file +filepath+ ok! */);
} catch (ioexception e) {
throw new runtimeexception(请将mysql命令添加到path中!,e);
}
return falg;
}
//恢复数据库
public static void sqlload(string cmd,string sqlpath){
try {
runtime rt = runtime.getruntime();
process child = rt.exec(cmd);
outputstream out = child.getoutputstream();//控制台的输入信息作为输出流 
//输入流
bufferedreader br = new bufferedreader(new inputstreamreader(new fileinputstream(sqlpath),utf-8));
//输出流
outputstreamwriter writer = new outputstreamwriter(out,utf-8);
string instr;
while((instr = br.readline()) != null){
writer.write(instr);
writer.write(\n\r);
}
writer.flush();
//别忘记关闭输出流
out.close();
br.close();
writer.close();
system.out.println(/* load sql file +sqlpath+ ok!*/);
} catch (ioexception e) {
throw new runtimeexception(e);
}
}
public static void main(string[] args){
//备份数据库
sqldump(c:/program files/mysql/mysql server 5.5/bin/mysqldump -uroot -proot itcastoa, d:/itcastoa.sql);
//恢复数据库
sqlload(c:/program files/mysql/mysql server 5.5/bin/mysql.exe -uroot -proot itcastoa, d:/itcastoa.sql);
}
}
其它类似信息

推荐信息