mysql sqlserver2008 备份 +还原代码,Java代码库,德仔网

代码语言
代码分类
【Java】 mysql sqlserver2008 备份 +还原
作者:asdf544265772 / 发布于2013/10/23/ 481

	package com.java.util;

	import java.io.BufferedReader;
	import java.io.FileInputStream;
	import java.io.FileOutputStream;
	import java.io.InputStream;
	import java.io.InputStreamReader;
	import java.io.OutputStream;
	import java.io.OutputStreamWriter;
	import java.sql.*;

	public class DbLoadAndBack {

	public static void main(String[] args) {
	 //backup("FanWang");
	 //load();
	 loadSqlServer();
	}
	
	
	/**
	 * mysql数据库备份
	 * @param dbName
	 */
	public static void backupMysql(String dbName) {
	 System.out.println(dbName+"数据库备份开始。。。");
	 try {
	 Runtime rt = Runtime.getRuntime();
	 // 调用 mysql 的 cmd:
	 Process child = rt.exec("mysqldump -uroot -p123 --set-charset=utf8 "+dbName+" ");// 设置导出编码为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 + "rn");
	 }
	 outStr = sb.toString();
	 // 要用来做导入用的sql目标文件：
	 FileOutputStream fout = new FileOutputStream(
	 "d:/mysqlBack/backTest.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();
	 }

	}
	/**
	 * mysql数据库还原
	 */
	public static void loadMysql() {
	 try {
	 String fPath = "d:/mysqlBack/backTest.sql";
	 Runtime rt = Runtime.getRuntime();
	 // 调用 mysql 的 cmd:
	 Process child = rt.exec("mysql -uroot -p123 test2 ");
	 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 + "rn");
	 }
	 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();
	 }
	}
	
	
	/**
	 * sqlserver数据库备份
	 */
	public static void backSqlServer() {
	 Connection conn=DbConnection.getConn();
	 String bakupname="d:/sqlserverBack/test.bak";
	 try {
	 Statement stmt=conn.createStatement();
	 String sql="backup database Test to disk = '"+bakupname+"'";
	 stmt.executeUpdate(sql);
	 if(stmt!=null) stmt.close();
	 if(conn!=null) conn.close();
	 } catch (SQLException e) {
	 // TODO Auto-generated catch block
	 e.printStackTrace();
	 }
	}
	/**
	 * sqlserver数据库还原
	 */
	public static void loadSqlServer() {
	 Connection conn=DbConnection.getConn();
	 String restrename="d:/sqlserverBack/test.bak";
	 try {
	 Statement stmt=conn.createStatement();
	 String sql="";
	 sql = "alter database Test set offline with rollback immediate;";
	 sql += "restore database Test from disk='" + restrename + "'";
	 sql += "with replace "; //解决备尚未备份数据库 数据库 的日志尾部
	 sql += "alter database Test set onLine with rollback immediate;";
	 stmt.executeUpdate(sql);
	 if(stmt!=null) stmt.close();
	 if(conn!=null) conn.close();
	 } catch (SQLException e) {
	 // TODO Auto-generated catch block
	 e.printStackTrace();
	 }
	}

	}
试试其它关键字
　备份　
同语言下
可能有用的
asdf544265772贡献的其它代码(1)
.mysql sqlserver2008 备份 +还原