ssh mysql读取数据库

import paramiko
import pymysql

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

# MySQL连接参数
mysql_host = '127.0.0.1'  # 本地地址，通过SSH隧道转发
mysql_port = 3306
mysql_user = 'your_mysql_user'
mysql_password = 'your_mysql_password'
mysql_db = 'your_database'

# 创建SSH客户端
ssh_client = paramiko.SSHClient()
ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())

# 连接SSH服务器
ssh_client.connect(ssh_host, ssh_port, ssh_username, ssh_password)

# 创建SSH隧道
transport = ssh_client.get_transport()
local_port = transport.request_port_forward('', 0)
channel = transport.accept(1000)

# 创建MySQL连接
mysql_conn = pymysql.connect(host='127.0.0.1', port=local_port, user=mysql_user, password=mysql_password, db=mysql_db)

# 执行SQL查询
cursor = mysql_conn.cursor()
cursor.execute('SELECT * FROM your_table')
results = cursor.fetchall()

# 关闭连接
cursor.close()
mysql_conn.close()
channel.close()
ssh_client.close()

# 输出结果
for row in results:
    print(row)