java代码实现mysql导入导出

注意实现mysql导入导出必须配制好环境变量，例如：C:\Program Files\MySQL\MySQL Server 5.1\bin;否则将无法正常运行。

package cn.com;

import java.io.BufferedReader;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;

public class MySQLTest {

	public static void main(String[] args) {
        String config[] =new String[7];
        config[0] = "-uroot";        //用户名
        config[1] = "-proot";        //密码
        config[2] = "-hlocalhost";   //主机
        config[3] = "takoocomcn";    //数据库名
        config[4] = "f:/bjse22.sql"; //导出数据库路征 
        config[5] = "f:/bjse22.sql"; //导入数据库路征
        config[6] = "my";            //导入数据库名称
		backup(config);
	    load(config);
	}

	private static void backup(String config[]) {
		try    {
			               Runtime rt  =  Runtime.getRuntime();
			   
			                //  调用 mysql 的 cmd: 
			              Process child  =  rt
			                       .exec("mysqldump " + config[0] + " "+config[1]+" "+config[2]+" "+config[3]+" --set-charset=utf8"); //  --add-drop-table设置导出编码为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(config[4]);
			               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(" /* Output OK! */ ");
			   
			            }   catch  (Exception e)   {
			               e.printStackTrace();
			           } 
	}	
	private static void load(String[] config) {
		              try {
		            	  String fPath = config[5];
		                  Runtime rt = Runtime.getRuntime();

		                  // 调用 mysql 的 cmd:
		                  Process child = rt.exec("mysql " + config[0] + " "+config[1]+" "+config[2]+" "+config[3]);

		            	  OutputStream out = child.getOutputStream();//控制台的输入信息作为输出流
		                  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");
//		                  }
		                  sb.append("use " + config[6] + ";\r\n");
		                  sb.append("source "+fPath);
		                  outStr = sb.toString();

		                  OutputStreamWriter writer = new OutputStreamWriter(out, "utf8");
		                  writer.write(outStr);
		                  // 注：这里如果用缓冲方式写入文件的话，会导致中文乱码，用flush()方法则可以避免
		                  writer.flush();
		                  // 别忘记关闭输入输出流
		                  out.close();
//		                  br.close();
		                  writer.close();
						  System.out.println( " /* Load OK! */ " );
					} catch (Exception e) {
						e.printStackTrace();
					}
	   }
}