java实现postgres备份功能

package postgre_dump;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;

import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.Session;
import ch.ethz.ssh2.StreamGobbler;

public class Test_dump {

public static void main(String[] args) {
String host = "192.168.5.11";
Connection conn = null;
Session session = null;
BufferedReader br = null;
try {
//建立连接
conn = new Connection(host);
conn.connect();
//用户名和密码
boolean status = conn.authenticateWithPassword("postgres", "123456");
//链接是否成功
if(status){
session = conn.openSession();
//运行的命令
//pg_dump -U postgres oesv11 -t oes.poi -f /home/share/01.数据备份/poi.sql
session.execCommand("pg_dump -U postgres oesv11 -t oes.poi -f /home/share/01.数据备份/poi.sql");
InputStream stdout = new StreamGobbler(session.getStdout());
br = new BufferedReader(new InputStreamReader(stdout));
String line = null;
while((line = br.readLine()) != null){
System.out.println(line);
System.out.println();
}
}
} catch (IOException e) {
e.printStackTrace();
}finally{
if(br != null){
try {
br.close();
session.close();
conn.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}