Java 调用bat执行的备份Oracle数据库类 - 数据库编程

\BuckupParfile.par");
//生成空白的bat临时文件
File Bfile=new File(StringUtil.formatDbColumn(map.get("Paths"))+"\\BuckupParfile.par");
try {
//申明读取缓冲器 //设置读取缓冲器文件指向
BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(Afile)));

//设定写数据缓冲器文件指向
PrintWriter pw= new PrintWriter(new OutputStreamWriter(new FileOutputStream(Bfile)),true);

try {
while(br.ready())//判断是否还有可读信息
{
//读取一行数据
String str=br.readLine().toString();
str=str.replace("%proj_id%", proj_id);
pw.println(str);
}
br.close();
pw.close();
} catch (IOException e) {
e.printStackTrace();
}
} catch (FileNotFoundException e) {
e.printStackTrace();
}
return "";
}

/**
* 生成导入配置bat文件
* @param map
* @return
*/
private static String productionImpBat(Map map)
{
//获取 rar 备份文件的名字
String FilePath=StringUtil.formatDbColumn(map.get("FilePath"));
String FileName = FilePath.substring(FilePath.lastIndexOf('\\')+1);

//生成导入前清理 sql 文件
productionClearSql(map);

Map ConnInfoMap =getConnInfo();

//设置一个标志
String flag="";
//创建个缓存数据集
List tmpBat=new ArrayList();
//获取模板文件
File Afile=new File(StringUtil.formatDbColumn(map.get("Paths"))+"\\processBat\\dp\\impdpDB.bat");
//生成空白的bat临时文件
File Bfile=new File(StringUtil.formatDbColumn(map.get("Paths"))+"\\temp.bat");
//申明读取缓冲器
BufferedReader br=null;
try {
//设置读取缓冲器文件指向
br = new BufferedReader(new InputStreamReader(new FileInputStream(Afile)));
} catch (FileNotFoundException e1) {
e1.printStackTrace();
}

try {
try {
while(br.ready())//判断是否还有可读信息
{
//读取一行数据
String str=br.readLine().toString();

//设置数据库的实例
if(str.startsWith("set sid")){
str="set sid="+ConnInfoMap.get("sid");
}
//设置数据登录名
else if(str.startsWith("set user")){
str="set user="+ConnInfoMap.get("user");
}
//设置数据登密码
else if(str.startsWith("set pwd")){
str="set pwd="+ConnInfoMap.get("pwd");
}
//设置备份文件路径
else if(str.startsWith("set FilePath")){
str="set FilePath="+FilePath;
}
//dump路径
else if(str.startsWith("set Dumpfile")){
str="set Dumpfile="+getDumpPath();
}
//文件名
else if(str.startsWith("set FileName")){
str="set FileName="+FileName;
}
tmpBat.add(str);
}
//关闭缓冲器
br.close();
} catch (IOException e) {
try {
br.close();
} catch (IOException e1) {
e1.printStackTrace();
}
e.printStackTrace();
}

//设定写数据缓冲器文件指向
PrintWriter pw = new PrintWriter(new OutputStreamWriter(new FileOutputStream(Bfile)),true);
for(String str : tmpBat)
{
//按行写入
pw.println(str);
}
pw.println("ECHO watting …………………………");
pw.println("sqlplus %user%/%pwd%@%sid% @UpdateParentId.sql ");
pw.println("del /q UpdateParentId.sql");
pw.println("del /q impClearing.sql");
pw.println("del /q temp.bat");
//关闭缓冲器
pw.close();
flag="good";
} catch (FileNotFoundException e) {
flag="error";
e.printStackTrace();
}

return flag;
}

/**
* 生成导入前sql清理文件
* @param map
* @return
*/
private static String productionClearSql(Map map)
{
//获取项目id
//StringUtil

Java 调用bat执行的备份Oracle数据库 类(二)

Java 调用bat执行的备份Oracle数据库类(二)