package atest;

import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.sql.Connection;


import web.db.DBConnector;

/**
 * @author 朱言信
 * @desc 备份oracle
 */
public class DadaBackup4Oracle {
	public  void doWork(){
		//执行该数据备份线程
		innerBackupClass ibc = new innerBackupClass("这里输入oracle的用户名", "密码", "192.168.0.66:1521/orcl", "输出的地址", "输出的文件名", "要备份的表名");
        Thread td = new Thread(ibc);
        td.start();
	}
	
	class innerBackupClass implements Runnable {
		private String user; //用户名
		private String password; //密码
		private String url; //链接地址
		private String outFilePath; //输出的文件路径
//		private String outZipFilePath; //输出的zip文件路径
		private String filename; //文件名
		private String tableNames; //表名
		
//		Sys_databackup databackup = null;

		/**
		 * 构造方法
		 */
		public innerBackupClass(String user, String password, String url, String outFilePath, 
//				String outZipFilePath, 
				String filename, 
				String tableNames
//				Sys_databackup databackup
				) {
			this.user = user;
			this.password = password;
			this.tableNames = tableNames;
			this.url = url;  
			this.outFilePath = outFilePath;
//			this.outZipFilePath = outZipFilePath;
			this.filename = filename;
//			this.databackup = databackup;
		}

		/**
		 * 线程执行入口
		 */
		public void run() {
			Connection con = DBConnector.getconecttion(); // 取得一个数据库连接
			Runtime rt = Runtime.getRuntime();
			Process processexp = null;
			checkCreatDir(outFilePath);
			
			//这里拼装的是exp导出  当然还可以使用其它的 你懂得
			String exp = "exp " + user + "/" + password + "@" + url + " file="
			+ outFilePath + "/" + filename + ".dmp";
			if(!"".equals(tableNames)){
				exp += " tables=(" + tableNames + ")";
			}
			try {
				processexp = rt.exec(exp);

				new Thread(new StreamDrainer(processexp.getInputStream())).start();
				new Thread(new StreamDrainer(processexp.getErrorStream())).start();
				processexp.getOutputStream().close();
				int exitValue = processexp.waitFor();
//				databackup.setBackupstate("1"); //1为成功 0为失败
				if(exitValue != 0){
//					databackup.setBackupstate("0");
				}
				//将备份DMP文件压缩为zip
				//删除dmp文件及所在的文件夹
				//将备份的结果持久化
			} catch (IOException e) {
				e.printStackTrace();
			} catch (InterruptedException e) {
				e.printStackTrace();
			} finally {
				DBConnector.freecon(con); // 释放数据库连接
			}
		}

		public void checkCreatDir(String dirPath) { // 目录是否存在
			File file = new File(dirPath);
			if (!file.exists()) {
				file.mkdirs();
			}
		}
	}
	
	/**
	 *输出控制台信息
	 */
	class StreamDrainer implements Runnable {
		private InputStream ins;

		public StreamDrainer(InputStream ins) {
			this.ins = ins;
		}

		public void run() {
			try {
				BufferedReader reader = new BufferedReader(
						new InputStreamReader(ins));
				String line = null;
				while ((line = reader.readLine()) != null) {
					System.out.println(line);
				}
			} catch (Exception e) {
				e.printStackTrace();
			}
		}

	}
}