3

全部,

我最初有一个名为 SQLLoader(Oracles 数据上传工具)的 shell 脚本。

问题是 SQLLoader 将纯文本密码作为输入,因此我决定构建一个 Java 应用程序以在内部调用 SQLLoader,将解密的密码传递给命令字符串。

例如

sqlldr user/pass@DBServer control=../sqlloader.ctl log=sqlloader.log data=mydata.csv

所以用我的java包装器它在我的shell脚本中变成了这个

java -jar sqlloader.jar sqlloader.ctl mydata.csv

然而,当 SQLLoader 抱怨没有要加载的文件时,出现了一个新问题。经过一番摸索后,我发现我的 shell 脚本中的后续命令似乎正在执行,而我的 java 应用程序仍在运行。因此它的行为是异步的。

下一个命令是在 sqlloader 有机会使用它之前移动它正在使用的输入文件。所以我在 20 秒内放了一个 sleep 命令,让我的 java 应用程序有时间运行。

java -jar sqlloader.jar sqlloader.ctl mydata.csv
echo $?
sleep 20
if [ $? -ne 0 ]
    then
        echo "SQLLoader failed during execution, please check the log : " 
        mv mydata.csv

else
    echo "SQLLoader successfully processed file : "
    mv mydata.csv
fi

有谁知道为什么unix会这样,Java是否将我的SQLLoader作为不同的用户/线程执行?

这是我的java代码:

    Runtime Rt;
Process Prc;
    Prc = Rt.exec("sqlldr user/decryptedpass@DBServer control=../sqlloader.ctl log=sqlloader.log data=mydata.csv);
system.exit(0);

我检查了运行时类是否有任何关于它是异步的但找不到任何东西

http://docs.oracle.com/javase/7/docs/api/java/lang/Runtime.html

有什么理论或建议吗?

谢谢

4

2 回答 2

3

是的。如果您再次查看 Runtime.exec,它确实指定它将在指定的环境中启动一个新进程(例如,独立于当前的“环境”或您将其异步放置)。您应该使用ProcessBuilder创建一个Process,然后在调用 System.exit 之前等待该 Process 完成 - 这当然不是强制性的。像这样的东西

public static void main(String[] args) {
    // String command = "/usr/bin/sleep 5";
    List<String> command = new ArrayList<String>();
    command.add("c:/cygwin/bin/sleep");
    command.add("5");
    ProcessBuilder pb = new ProcessBuilder(command);
    BufferedReader is = null;
    try {
        System.out.println("Starting command " + command);
        Process p = pb.start();

        int ret = p.waitFor();
        is = new BufferedReader(new InputStreamReader(p.getInputStream()));
        String line;
        while ((line = is.readLine()) != null) {
            System.out.println(line);
        }
        if (ret == 0) {
            System.out.println("Command has completed.");
            System.exit(ret);
        } else {
            System.out.println("Command completed with return code " + ret);
            System.exit(ret);
        }
    } catch (Exception e) {
        System.out.println("Caught Exception " + e.getMessage()
                + " running command " + command);
        e.printStackTrace();
    } finally {
        if (is != null) {
            try {
                is.close();
            } catch (IOException e) {
            }
        }
    }
    System.out.println("COMMAND FAILED");
    System.exit(1);
}
于 2013-11-10T03:17:37.920 回答
2

您需要等待进程完成,您还应该从正在启动的进程中读取所有输出(stdoutstderr)。

如果你在 exec() 之后调用 exit(),Java 就会这样做——立即退出。

这是一篇解释 Runtime.exec 陷阱的文章:http ://www.javaworld.com/javaworld/jw-12-2000/jw-1229-traps.html?page=4 (也可以考虑其他页面)。

于 2013-11-07T12:05:18.947 回答