java程序 ssh连接mysql数据库

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class SSHMySQLConnection {
    public static void main(String[] args) {
        String sshHost = "your_ssh_host";
        int sshPort = 22;
        String sshUser = "your_ssh_user";
        String sshPassword = "your_ssh_password";
        String mysqlHost = "localhost"; // MySQL服务器地址
        int mysqlPort = 3306; // MySQL服务器端口
        String mysqlUser = "your_mysql_user";
        String mysqlPassword = "your_mysql_password";
        String databaseName = "your_database_name";

        try {
            // 创建SSH隧道
            ProcessBuilder pb = new ProcessBuilder("ssh", "-L", "localhost:" + mysqlPort + ":" + mysqlHost + ":" + mysqlPort, sshUser + "@" + sshHost);
            pb.redirectErrorStream(true);
            Process process = pb.start();

            // 等待SSH隧道建立
            Thread.sleep(2000);

            // 连接MySQL数据库
            String jdbcUrl = "jdbc:mysql://localhost:" + mysqlPort + "/" + databaseName;
            Connection connection = DriverManager.getConnection(jdbcUrl, mysqlUser, mysqlPassword);

            System.out.println("Connected to MySQL database successfully!");

            // 关闭连接
            connection.close();
            process.destroy();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}