jdbc通过ssh连接mysql

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;

public class SSHMySQLConnection {
    public static void main(String[] args) {
        String sshUser = "ssh_username";
        String sshHost = "ssh_host";
        int sshPort = 22;
        String mysqlUser = "mysql_username";
        String mysqlHost = "localhost"; // MySQL服务器地址
        int mysqlPort = 3306;
        String database = "database_name";

        try {
            JSch jsch = new JSch();
            Session session = jsch.getSession(sshUser, sshHost, sshPort);
            session.setPassword("ssh_password");
            session.setConfig("StrictHostKeyChecking", "no");
            session.connect();

            int assignedPort = session.setPortForwardingL(mysqlPort, mysqlHost, mysqlPort);
            System.out.println("Forwarded port: " + assignedPort);

            String jdbcUrl = "jdbc:mysql://localhost:" + assignedPort + "/" + database;
            Connection conn = DriverManager.getConnection(jdbcUrl, mysqlUser, "mysql_password");
            System.out.println("Connected to MySQL database!");

            conn.close();
            session.disconnect();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}