python实现ssh通过跳板机连接mysql

# -*- coding: utf-8 -*-

 

import MySQLdb

import os,sys

from sshtunnel import SSHTunnelForwarder

 

def mysql_test(): 

    with SSHTunnelForwarder(    #ssh的地址，端口，用户名，密码

            ('跳转机地址', 22),

            ssh_pkey="秘钥文件",

            ssh_password="密码",

            ssh_username="用户名",

            remote_bind_address=('远程数据库主机', 3306),

            local_bind_address=('0.0.0.0', 3306)) as server:

        server.start() 

        print(server.local_bind_port)

        conn = MySQLdb.connect(host='127.0.0.1',

                               port=3306,

                               user='mysql登录用户名',

                               passwd='mysql登录密码',

                               db='数据库名称',

                               charset='utf8')

        cursor = conn.cursor()    #.cursor()用来获得python执行Mysql命令的方法

        #select = sql

        sql="SELECT * from t_auth_user WHERE `name`=\"qwe5019\";"

        cursor.execute(sql)    #.execute()执行mysql语句       

        data=cursor.fetchall()    #fetchall()则是接收全部的返回结果行

        print data

        server.stop()

    return data                

pass

 

if __name__ == "__main__":

    mysql_test()