Java备份Oracle数据库

时间：2023-03-08 23:55:06
Java备份Oracle数据库

Java备份Oracle数据库

Java线程、Process、ProcessBuilder

2010 年 6 月 20 日

文章内容描述了使用Java执行外部Oracle导出命令备份数据库功能的示例，依据此例子进行修改制造一些bug，然后将会对Java外部命令这块会有一个更加清晰的认知(个人观点仅供参考，不许拍砖，哈)

小细节
·试着把innerTh.start()这段给注释掉，然后再把用户名或密码写错。
·有些程序是不会在命令行有输出的，比如最直接的plsqldev.exe、MindManager.exe
·试着把将要执行的命令改成我们本地相关.exe程序，如上面所例或干脆TM.exe试试。
Java备份Oracle数据库
Java备份Oracle数据库
Java备份Oracle数据库 回页首

代码示例:

  1. package org.ybygjy.basic.oracle;
  2. import java.io.File;
  3. import java.io.FileOutputStream;
  4. import java.io.IOException;
  5. import java.io.InputStream;
  6. import java.nio.ByteBuffer;
  7. import java.nio.channels.Channels;
  8. import java.nio.channels.FileChannel;
  9. import java.nio.channels.ReadableByteChannel;
  10. import java.util.ArrayList;
  11. import java.util.List;
  12. import java.util.Map;
  13. /**
  14. * java外部系统命令模式备份数据库
  15. * @author WangYanCheng
  16. * @version 2010-6-19
  17. */
  18. public class BackupOracleDatabase {
  19. /**
  20. * 封装执行入口
  21. */
  22. public void doWork() {
  23. InnerClass innerInst =
  24. new InnerClass("DB_USER", "DB_PASS", "127.0.0.1:1521/ORCL", "E:/dbback/BACK201006.DMP");
  25. Thread thInst = new Thread(innerInst);
  26. thInst.start();
  27. }
  28. /**
  29. * 用于分担执行命令
  30. * @author WangYanCheng
  31. * @version 2010-6-19
  32. */
  33. class InnerClass implements Runnable {
  34. /** 用户名 */
  35. private String userName;
  36. /** 密码 */
  37. private String userPass;
  38. /** 服务地址 */
  39. private String serverAddr;
  40. /** 输出文件路径 */
  41. private String outFilePath;
  42. /**
  43. * constructor
  44. * @param userName userName
  45. * @param userPass userPass
  46. * @param serverAddr 服务地址必须带<strong>端口</strong>/<strong>SID</strong>
  47. * @param outFilePath outPath
  48. */
  49. public InnerClass(String userName, String userPass, String serverAddr, String outFilePath) {
  50. this.userName = userName;
  51. this.userPass = userPass;
  52. this.serverAddr = serverAddr;
  53. this.outFilePath = outFilePath;
  54. }
  55. /**
  56. * 提供执行的命令串
  57. * @return commStr 命令串
  58. */
  59. private List doBuildCommand() {
  60. List rtnList = new ArrayList();
  61. rtnList.add("EXP");
  62. rtnList.add("@USER@/@PASSWORD@@@SERVER@".replaceAll("@USER@", this.userName)
  63. .replaceAll("@PASSWORD@", this.userPass).replaceAll("@SERVER@", this.serverAddr));
  64. rtnList.add("FILE=/"@FILE@/"".replaceAll("@FILE@", this.outFilePath));
  65. rtnList.add("TABLES=(SY_TABLE_DEF)");
  66. return rtnList;
  67. }
  68. /**
  69. * 构建ProcessBuilder实例
  70. * @param workDir 当前进程工作目录
  71. * @return pbInst ProcessBuilder实例
  72. * @see ProcessBuilder
  73. */
  74. private ProcessBuilder buildProcessBuilder(File workDir) {
  75. new ProcessBuilder();
  76. List commandArray = (doBuildCommand());
  77. ProcessBuilder pbInst = new ProcessBuilder(commandArray);
  78. pbInst.command(commandArray);
  79. Map envMap = pbInst.environment();
  80. envMap.clear();
  81. envMap.putAll(System.getenv());
  82. pbInst.directory(workDir);
  83. pbInst.redirectErrorStream(true);
  84. return pbInst;
  85. }
  86. /**
  87. * 线程执行入口
  88. */
  89. public void run() {
  90. File tmpOutFile = new File(this.outFilePath);
  91. File outDir = tmpOutFile.getParentFile();
  92. ProcessBuilder pbInst = buildProcessBuilder(outDir);
  93. try {
  94. Process proInst = pbInst.start();
  95. final InputStream ins = proInst.getInputStream();
  96. File outFile = new File(outDir, "exp.log");
  97. outFile.createNewFile();
  98. final FileChannel focInst = new FileOutputStream(outFile).getChannel();
  99. Thread innerTh = new Thread() {
  100. ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
  101. public void run() {
  102. ReadableByteChannel rbcObj = Channels.newChannel(ins);
  103. try {
  104. while (rbcObj.read(byteBuffer) != -1) {
  105. byteBuffer.flip();
  106. focInst.write(byteBuffer);
  107. byteBuffer.clear();
  108. }
  109. } catch (IOException ioe) {
  110. ioe.printStackTrace();
  111. }
  112. }
  113. };
  114. // innerTh.setDaemon(true);
  115. innerTh.start();
  116. } catch (IOException ioe) {
  117. ioe.printStackTrace();
  118. }
  119. }
  120. }
  121. /**
  122. * 测试入口
  123. * @param args 参数列表
  124. */
  125. public static void main(String[] args) {
  126. new BackupOracleDatabase().doWork();
  127. }
  128. }

相关文章