java通过ssh连接mysql数据库

<dependencies>
    <dependency>
        <groupId>com.jcraft</groupId>
        <artifactId>jsch</artifactId>
        <version>0.1.55</version>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.26</version>
    </dependency>
</dependencies>

import com.jcraft.jsch.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class SSHMySQLConnector {
    public static void main(String[] args) {
        String sshHost = "your_ssh_host";
        int sshPort = 22;
        String sshUser = "your_ssh_username";
        String sshPassword = "your_ssh_password";
        String remoteHost = "127.0.0.1"; // 远程数据库主机地址
        int remotePort = 3306; // 远程数据库端口
        String dbUser = "your_db_username";
        String dbPassword = "your_db_password";
        String dbName = "your_db_name";

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

            int assignedPort = session.setPortForwardingL(remotePort, remoteHost, remotePort);
            System.out.println("SSH Tunnel established. Forwarded port: " + assignedPort);

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

            // 进行数据库操作...

            conn.close();
            session.disconnect();
        } catch (JSchException | SQLException e) {
            e.printStackTrace();
        }
    }
}