ssh连接mysql数据库代码实现

import paramiko
import pymysql

# SSH连接配置
ssh_host = "ssh.example.com"
ssh_port = 22
ssh_username = "your_username"
ssh_password = "your_password"

# MySQL数据库配置
mysql_host = "localhost"
mysql_port = 3306
mysql_username = "mysql_username"
mysql_password = "mysql_password"
mysql_database = "your_database"

# SSH连接
ssh_client = paramiko.SSHClient()
ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh_client.connect(ssh_host, port=ssh_port, username=ssh_username, password=ssh_password)

# 创建SSH隧道
ssh_tunnel = ssh_client.get_transport().open_channel("direct-tcpip", (mysql_host, mysql_port), ("127.0.0.1", 0))

# 连接MySQL数据库
mysql_connection = pymysql.connect(host='127.0.0.1', port=ssh_tunnel.getpeername()[1], user=mysql_username,
                                   passwd=mysql_password, db=mysql_database, charset='utf8', cursorclass=pymysql.cursors.DictCursor)

# 执行SQL查询
try:
    with mysql_connection.cursor() as cursor:
        sql = "SELECT * FROM your_table"
        cursor.execute(sql)
        result = cursor.fetchall()
        print(result)
finally:
    mysql_connection.close()
    ssh_client.close()

import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;

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

public class SSHConnectMySQL {
    public static void main(String[] args) {
        // SSH连接配置
        String sshHost = "ssh.example.com";
        int sshPort = 22;
        String sshUsername = "your_username";
        String sshPassword = "your_password";

        // MySQL数据库配置
        String mysqlHost = "localhost";
        int mysqlPort = 3306;
        String mysqlUsername = "mysql_username";
        String mysqlPassword = "mysql_password";
        String mysqlDatabase = "your_database";

        try {
            // SSH连接
            JSch jsch = new JSch();
            Session session = jsch.getSession(sshUsername, sshHost, sshPort);
            session.setPassword(sshPassword);
            session.setConfig("StrictHostKeyChecking", "no");
            session.connect();

            // 创建SSH隧道
            int assignedPort = session.setPortForwardingL(0, mysqlHost, mysqlPort);

            // 连接MySQL数据库
            String mysqlUrl = "jdbc:mysql://localhost:" + assignedPort + "/" + mysqlDatabase;
            Connection connection = DriverManager.getConnection(mysqlUrl, mysqlUsername, mysqlPassword);

            // 执行SQL查询
            Statement statement = connection.createStatement();
            String sql = "SELECT * FROM your_table";
            ResultSet resultSet = statement.executeQuery(sql);
            while (resultSet.next()) {
                // 处理查询结果
                // ...
            }

            // 关闭连接
            resultSet.close();
            statement.close();
            connection.close();
            session.disconnect();
        } catch (JSchException | SQLException e) {
            e.printStackTrace();
        }
    }
}