Python:通过SSH连接到SQL数据库

import paramiko
from sshtunnel import SSHTunnelForwarder
import pymysql

# SSH连接参数
ssh_host = 'your_ssh_server'
ssh_port = 22
ssh_username = 'your_ssh_username'
ssh_password = 'your_ssh_password'

# 数据库连接参数
db_host = '127.0.0.1'  # 通过SSH隧道连接时，数据库地址应为本地地址
db_port = 3306
db_user = 'your_db_username'
db_password = 'your_db_password'
db_name = 'your_database_name'

# 创建SSH隧道
with SSHTunnelForwarder(
    (ssh_host, ssh_port),
    ssh_username=ssh_username,
    ssh_password=ssh_password,
    remote_bind_address=(db_host, db_port)
) as tunnel:
    # 获取本地转发端口
    local_port = tunnel.local_bind_port

    # 连接到数据库
    conn = pymysql.connect(
        host='127.0.0.1',
        port=local_port,
        user=db_user,
        password=db_password,
        db=db_name
    )

    # 执行SQL查询
    with conn.cursor() as cursor:
        sql = "SELECT * FROM your_table_name"
        cursor.execute(sql)
        result = cursor.fetchall()
        print(result)

    # 关闭数据库连接
    conn.close()