Python基于ssh远程怎么连接Mysql数据库

这篇文章主要介绍“Python基于ssh远程怎么连接Mysql数据库”，在日常操作中，相信很多人在Python基于ssh远程怎么连接Mysql数据库问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Python基于ssh远程怎么连接Mysql数据库”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

背景

如果需要访问远程服务器的Mysql数据库，但是该Mysql数据库为了安全期间，安全措施设置为只允许本地连接（也就是你需要登录到该台服务器才能使用），其他远程连接是不可以直接访问，并且相应的端口也做了修改，那么就需要基于ssh来连接该数据库。这种方式连接数据库与Navicat里面界面化基于ssh连接一样。

Navicat

连接数据库

安装支持库

• 如果要连接Mysql，首先需要安装pymysql

pip install pymysql

• 安装基于ssh的库sshtunnel

pip install sshtunnel    #当前最新 0.3.1版

建议安装最新的sshtunnel库，旧版本库有一些bug

连接Mysql

基于ssh连接Mysql可以查看sshtunnel的文档，里面有一些案例

with SSHTunnelForwarder(
        (&＃39;192.168.1.1&＃39;, 2222),
        ssh_password=&＃39;123456&＃39;,
        ssh_username=&＃39;root&＃39;,
        remote_bind_address=(&＃39;127.0.0.1&＃39;, 3306)) as server:
    print(&＃39;SSH连接成功&＃39;)
    conn = pymysql.connect(host=&＃39;127.0.0.1&＃39;,
                           port=server.local_bind_port,
                           user=&＃39;root&＃39;,
                           database=&＃39;data&＃39;,
                           charset=&＃39;utf8&＃39;)
    print(&＃39;mysql数据库连接成功&＃39;)
    cursor = conn.cursor()
    ...  #获取数据操作，此处省略
    cursor.close()
    conn.close()

自定义查询函数

可以对上面的连接进行封装为一个函数，方便其他地方使用

def mysql_ssh(sql,args=None):
    with SSHTunnelForwarder(
            (&＃39;192.168.1.1&＃39;, 2222),
            ssh_password=&＃39;123456&＃39;,
            ssh_username=&＃39;root&＃39;,
            remote_bind_address=(&＃39;127.0.0.1&＃39;, 3306)) as server:
        print(&＃39;SSH连接成功&＃39;)
        conn = pymysql.connect(host=&＃39;127.0.0.1&＃39;,
                               port=server.local_bind_port,
                               user=&＃39;root&＃39;,
                               database=&＃39;data&＃39;,
                               charset=&＃39;utf8&＃39;)
        print(&＃39;mysql数据库连接成功&＃39;)
        cursor = conn.cursor()
        print(&＃39;游标获取成功&＃39;)
        try:
            print(f&＃39;执行查询语句：{sql}  参数：{args}&＃39;)
            cursor.execute(sql,args)
            print(&＃39;数据查询成功&＃39;)
            conn.commit()
            print(&＃39;事务提交成功&＃39;)
            datas = cursor.fetchall()
            success = True
        except:
            print(&＃39;数据查询失败&＃39;)
            datas = None
            success = False
        print(&＃39;正在关闭数据库连接&＃39;)
        cursor.close()
        conn.close()
    return datas, success

注意点：

• 在使用数据库时，conn.commit()、cursor.close()、conn.close()这些一定要规范使用，防止不必要的bug

• 传入参数时建议用这种方式cursor.execute(sql,args)，防止sql注入的风险

到此，关于“Python基于ssh远程怎么连接Mysql数据库”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注编程笔记网站，小编会继续努力为大家带来更多实用的文章！