通过堡垒机连接sqlservice

import pyodbc
import paramiko

# 配置SSH隧道
ssh_host = 'your_bastion_host'
ssh_port = 22
ssh_user = 'your_ssh_username'
ssh_password = 'your_ssh_password'

# SQL Server配置
sql_server = 'your_sql_server_address'
sql_database = 'your_database_name'
sql_user = 'your_sql_username'
sql_password = 'your_sql_password'

# 创建SSH客户端
ssh_client = paramiko.SSHClient()
ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh_client.connect(ssh_host, ssh_port, ssh_user, ssh_password)

# 创建SSH隧道
transport = ssh_client.get_transport()
local_port = 14330
remote_port = 1433
transport.request_port_forward('', local_port)

# 连接SQL Server
conn_str = (
    f'DRIVER={{ODBC Driver 17 for SQL Server}};'
    f'SERVER=localhost,{local_port};'
    f'DATABASE={sql_database};'
    f'UID={sql_user};'
    f'PWD={sql_password}'
)
conn = pyodbc.connect(conn_str)

# 执行查询
cursor = conn.cursor()
cursor.execute('SELECT * FROM your_table')
rows = cursor.fetchall()

for row in rows:
    print(row)

# 关闭连接
cursor.close()
conn.close()
ssh_client.close()