java 操作执行 imp、exp命令

package com.pm360.pip.sys.web;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.HashMap;
import com.pm360.mda.platform.util.StringUtil;

/**
* @author XuFaXi
*
*/
public class ProjectExpAndImpTest {

/**
* 从数据库导出项目数据
* @param map
* @return
*/
public static String expFile(HashMap<String, Object> map) {
String info="";
String filename=StringUtil.formatDbColumn(map.get("FILENAME"));
String proj_id=StringUtil.formatDbColumn(map.get("PROJ_ID"));
String[] cmds = new String[3];
//表导出语句 如果要导出多表则在 tables参数里添加 例如 tables=(KM_DOC,KM_FOLDER,……,……)
String commandBuf = "exp pip_jk/pip@orcl file=E://"+filename+".dmp tables=(KM_DOC,KM_FOLDER) query=/"/"/" where PROJ_ID='"+proj_id+"'/"/"/"";
cmds[0] = "cmd";
cmds[1] = "/C";
cmds[2] = commandBuf.toString();
Process process = null;
try {
process = Runtime.getRuntime().exec(cmds);
} catch (IOException e) {

e.printStackTrace();
info="导入出错";
}
boolean shouldClose = false;
try {
InputStreamReader isr = new InputStreamReader(process
.getErrorStream());
BufferedReader br = new BufferedReader(isr);
String line = null;
while ((line = br.readLine()) != null) {
System.out.println(line);
if (line.indexOf("????") != -1) {
shouldClose = true;
break;
}
}
} catch (IOException ioe) {
shouldClose = true;
info="导入出错";
}
if (shouldClose)
process.destroy();
int exitVal;
try {
exitVal = process.waitFor();
System.out.print(exitVal);
} catch (InterruptedException e) {
e.printStackTrace();
info="导入出错";
}
return info;
}

/**
* 导入数据库文件
* @param map
*/
public static String impFile(HashMap<String, Object> map) {
String info="";
String filepath=StringUtil.formatDbColumn(map.get("FILEPATH"));
String[] cmds = new String[3];
String commandBuf = "imp pip_jk/pip@orcl fromuser=pip_jk touser=dms file="+filepath+" ignore=y";
cmds[0] = "cmd";
cmds[1] = "/C";
cmds[2] = commandBuf.toString();
Process process = null;
try {
process = Runtime.getRuntime().exec(cmds);
} catch (IOException e) {
e.printStackTrace();
info="导入出错";
}
boolean shouldClose = false;
try {
InputStreamReader isr = new InputStreamReader(process
.getErrorStream());
BufferedReader br = new BufferedReader(isr);
String line = null;
while ((line = br.readLine()) != null) {
System.out.println(line);
if (line.indexOf("????") != -1) {
shouldClose = true;
break;
}
}
} catch (IOException ioe) {
shouldClose = true;
info="导入出错";
}
if (shouldClose)
process.destroy();
int exitVal;
try {
exitVal = process.waitFor();
System.out.print(exitVal);
} catch (InterruptedException e) {
e.printStackTrace();
info="导入出错";
}
return info;
}

}