Guest User

Untitled

a guest
Mar 12th, 2018
105
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.04 KB | None | 0 0
  1. import java.sql.DriverManager;
  2. import java.sql.PreparedStatement;
  3. import java.sql.ResultSet;
  4. import java.sql.SQLException;
  5.  
  6. import com.jcraft.jsch.JSch;
  7. import com.jcraft.jsch.Session;
  8. import java.sql.Connection;
  9.  
  10.  
  11. public class DatabaseTest {
  12.  
  13. /**
  14. * Java Program to connect to remote database through SSH using port forwarding
  15. * @author Pankaj@JournalDev
  16. * @throws SQLException
  17. */
  18. public static void main(String[] args) throws SQLException {
  19.  
  20. int lport=5656;
  21. String rhost="some.url.uk";
  22. String host="some.url.uk"; //
  23. int rport=3306;
  24. String user="REDACTED";
  25. String password="REDACTED";
  26. String dbuserName = "REDACTED";
  27. String dbpassword = "REDACTED";
  28. String url = "jdbc:mysql://localhost:"+lport+"/MYDB";
  29. String driverName="com.mysql.jdbc.Driver";
  30. Connection conn = null;
  31. Session session= null;
  32. try{
  33. //Set StrictHostKeyChecking property to no to avoid UnknownHostKey issue
  34. java.util.Properties config = new java.util.Properties();
  35. config.put("StrictHostKeyChecking", "no");
  36. JSch jsch = new JSch();
  37. session=jsch.getSession(user, host, 22);
  38. session.setPassword(password);
  39. session.setConfig(config);
  40. session.connect();
  41. System.out.println("Connected");
  42. int assinged_port=session.setPortForwardingL(lport, rhost, rport);
  43. System.out.println("localhost:"+assinged_port+" -> "+rhost+":"+rport);
  44. System.out.println("Port Forwarded");
  45.  
  46. //mysql database connectivity
  47. Class.forName(driverName).newInstance();
  48. conn = DriverManager.getConnection (url, dbuserName, dbpassword);
  49. System.out.println ("Database connection established");
  50. System.out.println("DONE");
  51. }catch(Exception e){
  52. e.printStackTrace();
  53. }finally{
  54. if(conn != null && !conn.isClosed()){
  55. System.out.println("Closing Database Connection");
  56. conn.close();
  57. }
  58. if(session !=null && session.isConnected()){
  59. System.out.println("Closing SSH Connection");
  60. session.disconnect();
  61. }
  62. }
  63. }
  64.  
  65. }
  66.  
  67. com.jcraft.jsch.JSchException: java.net.ConnectException: Connection refused (Connection refused)
  68. at com.jcraft.jsch.Util.createSocket(Util.java:349)
  69. at com.jcraft.jsch.Session.connect(Session.java:215)
  70. at com.jcraft.jsch.Session.connect(Session.java:183)
  71. at DatabaseTest.main(DatabaseTest.java:40)
  72. Caused by: java.net.ConnectException: Connection refused (Connection refused)
  73. at java.net.PlainSocketImpl.socketConnect(Native Method)
  74. at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
  75. at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
  76. at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
  77. at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
  78. at java.net.Socket.connect(Socket.java:589)
  79. at java.net.Socket.connect(Socket.java:538)
  80. at java.net.Socket.<init>(Socket.java:434)
  81. at java.net.Socket.<init>(Socket.java:211)
  82. at com.jcraft.jsch.Util.createSocket(Util.java:343)
  83. ... 3 more
Add Comment
Please, Sign In to add comment