Guest User

Untitled

a guest
Jun 13th, 2012
77
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1.  
  2.     import java.sql.DriverManager;  
  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.PreparedStatement;  
  9.      
  10.     import java.sql.Connection;  
  11.      
  12.     public class MySqlConnOverSSH {  
  13.        
  14.         private static Connection dbConnAlfresco = null;  
  15.      
  16.         public static void main(String[] args) throws SQLException {  
  17.             int lport=50000;  
  18.             String host="lucia.cs.unibo.it";  
  19.             String rhost="localhost";
  20.             int rport=5432;  
  21.             String user="user_lab";  
  22.             String password="pass_user_lab";
  23.             String dbuserNameAlfresco = "ingsw12_03";
  24.             String dbpasswordAlfresco = null;
  25.             String urlAlfresco = "jdbc:postgresql://localhost:"+rport+"/ingsw12_03";
  26.             String driverName="org.postgresql.Driver";  
  27.             Session session= null;  
  28.              
  29.             try{  
  30.                 //Set StrictHostKeyChecking property to no to avoid UnknownHostKey issue  
  31.                 java.util.Properties config = new java.util.Properties();  
  32.                 config.put("StrictHostKeyChecking", "no");  
  33.                 JSch jsch = new JSch();  
  34.                 session=jsch.getSession(user, host, 22);  
  35.                 session.setPassword(password);  
  36.                 session.setConfig(config);  
  37.                 session.connect();  
  38.                 System.out.println("Connected");  
  39.                 int assinged_port=session.setPortForwardingL(lport, rhost, rport);  
  40.                 System.out.println("localhost:"+assinged_port+" -> "+rhost+":"+rport);  
  41.                 System.out.println("Port Forwarded");  
  42.        
  43.                 //mysql database connectivity  
  44.                 Class.forName(driverName).newInstance();  
  45.                 dbConnAlfresco = DriverManager.getConnection (urlAlfresco, dbuserNameAlfresco, dbpasswordAlfresco);  
  46.                  
  47.                 System.out.println ("Database connection established");  
  48.                 System.out.println("DONE");  
  49.      
  50.                 dbConnAlfresco.setAutoCommit(false);  
  51.          String qnameSQL = "SELECT * FROM alf_node;";  
  52.            
  53.          PreparedStatement prepStmnt = dbConnAlfresco.prepareStatement(qnameSQL);  
  54.          ResultSet rs = prepStmnt.executeQuery();  
  55.          while (rs.next()){  
  56.           System.out.println("*** "+rs.getString("uuid")+" ***");  
  57.          }  
  58.      
  59.                  
  60.             }catch(Exception e){  
  61.                 e.printStackTrace();              
  62.             }finally{  
  63.                 if(dbConnAlfresco != null && !dbConnAlfresco.isClosed()){  
  64.                     System.out.println("Closing ALFRESCO Database Connection");  
  65.                     dbConnAlfresco.close();  
  66.                 }  
  67.                 if(session !=null && session.isConnected()){  
  68.                     System.out.println("Closing SSH Connection");  
  69.                     session.disconnect();  
  70.                 }  
  71.             }  
  72.         }  
  73.     }
RAW Paste Data