Как перенаправить стандартный ввод в Java Runtime.exec? - PullRequest
Новая
       39

Как перенаправить стандартный ввод в Java Runtime.exec?

5 голосов
/ 02 апреля 2010

Я хочу выполнить некоторые сценарии sql, используя Java-метод Runtime.exec. Я намереваюсь вызвать mysql.exe / mysql.sh и перенаправить файл сценария к этому процессу. Из командной строки я могу запустить команду 

<mysqInstallDir\/bin\mysql.exe -u <userName> -p <password> < scripts\create_tables.sql

Я могу вызвать mysql.exe с помощью Runtime.exec, но как мне перенаправить данные из файла sql в mysql.exe?

Я прочитал статью в http://www.javaworld.com/javaworld/jw-12-2000/jw-1229-traps.html?page=4 и использовал механизм StreamGobbler для получения ошибок и выходных потоков. Нет проблем там. Проблема заключается в чтении файла "scripts \ create_tables.sql" с использованием BufferedReader и передаче содержимого в выходной поток prcess. Я ожидал, что процесс передаст данные в mysql.exe. Но я вижу, что только первая строка читается из этого файла sql. 

OutputStream outputstream = proc.getOutputStream();
OutputStreamWriter outputstreamwriter = new OutputStreamWriter(outputstream);
BufferedWriter bufferedwriter = new BufferedWriter(outputstreamwriter);
  while ( (line = br.readLine()) != null)
  {
bufferedwriter.write(line);
bufferedwriter.flush();
System.out.println(line);
  }
  bufferedwriter.flush();
  bufferedwriter.close();
  proc.waitFor()

Когда я делаю это, я вижу, что выполняется только первая строка в create_tables.sql. Код выхода для процесса - 0, и нет других ошибок или выходных данных.

Ответы [ 2 ]

5 голосов
/ 02 апреля 2010

Exec возвращает вам объект Process.

Процесс имеет методы getInputStream и getOutputStream.

Просто используйте их, чтобы захватить поток ввода и начать вставлять в него байты. Не забудьте прочитать выходной поток, иначе процесс может заблокироваться.

1 голос
/ 07 мая 2010

Перенаправление - это функциональность оболочки OS / cmd. Для правильного их вызова мы должны использовать Runtime.exec (String []) вместо Runtime.exec (String). Вот код. 

public Result executeCmd(String[] cmds, boolean waitForResult)
{
    Result result = new Result();
    result.output = "";
    try
    {
        for(int i=0;i<cmds.length;i++)
        {
            System.out.println("CMD["+i+"]::"+cmds[i]);
        }
        System.out.println("");
        Process process = null;
        if(cmds.length > 1)
            process=Runtime.getRuntime().exec(cmds);
        else
            process=Runtime.getRuntime().exec(cmds[0]);
        if (waitForResult)
        {
            StreamGobbler errordataReader = new StreamGobbler(process
                    .getErrorStream(), "ERROR");

            StreamGobbler outputdataReader = new StreamGobbler(process
                    .getInputStream(), "OUTPUT");

            errordataReader.start();
            outputdataReader.start();

            int exitVal = process.waitFor();
            errordataReader.join();
            outputdataReader.join();
            result.returnCode = exitVal;
            result.output = outputdataReader.output;
            result.error = errordataReader.output;
        }
    }
    catch (Exception exp)
    {
        result.exp = exp;
        result.returnCode = -1;
    }
    return result;
}

И вызвать этот метод, используя 

Result result = executeCmd(cmds, true);

, где 

CMD[0]::cmd
CMD[1]::/c
CMD[2]::.\mysql\bin\mysql --host=<hostname> --port=<portNum> -u <userName>  < .\scripts\create_tables.sql
...