SpringBoot 通过 SSH 通道连接远程数据库

时间:2021-08-13 17:15:03   收藏:0   阅读:72



public static void main(String[] args) {
try {
//go();

JSch jsch = new JSch();
Session session = jsch.getSession("", "", 22); //ssh用户 ssh地址 ssh端口
// lport = 3307;
// rhost = "MYSQL_ADDRESS_YRL";
// rport = 3306;
session.setPassword(""); //ssh密码
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
System.out.println("Establishing Connection...");
session.connect();
session.setPortForwardingL(REMOTE_PORT, "pc-bp174h1knw4hjtzvk.pg.polardb.rds.aliyuncs.com", LOCAl_PORT);
System.out.println("localhost:" );
} catch (Exception ex) {
ex.printStackTrace();
}
System.out.println("An example for updating a Row from Mysql Database!");
Connection con = null;
String driver = "org.postgresql.Driver";
String url = "jdbc:postgresql://localhost:" + REMOTE_PORT + "/";//" + rhost +"
String db = "";
String dbUser = "";
String dbPasswd = "";
try {
Class.forName(driver);
con = DriverManager.getConnection(url + db, dbUser, dbPasswd);
try {
Statement st = con.createStatement();
String sql = "select * from gxg.byl ";
System.out.println("st:"+st.toString());
ResultSet result = st.executeQuery(sql);
System.out.println("result:"+result.toString());
while (result.next()) {
System.out.println(result.getString("mobile") + " ");
}
} catch (SQLException s) {
System.out.println("SQL statement is not executed!");
}
} catch (Exception e) {
e.printStackTrace();
}
}

  添加 Maven 依赖

      
  com.jcraft jsch 0.1.55

原文:https://www.cnblogs.com/nbkoo/p/15137519.html

评论(0
© 2014 bubuko.com 版权所有 - 联系我们:wmxa8@hotmail.com
打开技术之扣,分享程序人生!