ICode9

精准搜索请尝试: 精确搜索
首页 > 数据库> 文章详细

python3使用ssh隧道连接mysql

2022-01-22 23:32:12  阅读:137  来源: 互联网

标签:db host ssh mysql password config port python3


参考文章:https://blog.csdn.net/qq_33385691/article/details/105249507?spm=1001.2101.3001.6661.1&utm_medium=distribute.pc_relevant_t0.none-task-blog-2%7Edefault%7ECTRLIST%7ERate-1.pc_relevant_default&depth_1-utm_source=distribute.pc_relevant_t0.none-task-blog-2%7Edefault%7ECTRLIST%7ERate-1.pc_relevant_default&utm_relevant_index=1

 

对原代码进行了整理

基本功能:填好SSH与MYSQL信息与SQL语句,直接以数组的形式出结果

 

 1 import pymysql
 2 from sshtunnel import SSHTunnelForwarder
 3 import pymysql.cursors
 4 
 5 def querySQL(ssh_config, db_config, sql):
 6     with SSHTunnelForwarder(
 7             (ssh_config['host'], ssh_config['port']),
 8             ssh_password = ssh_config['password'],
 9             ssh_username = ssh_config['username'],
10             remote_bind_address=(db_config['host'], db_config['port'])
11     ) as server:
12         db = pymysql.connect(
13             host = '127.0.0.1',
14             port = server.local_bind_port,
15             user = db_config['username'],
16             passwd = db_config['password'],
17             db = db_config['db_name'],
18             charset = "utf8",
19             cursorclass = pymysql.cursors.DictCursor)
20         cursor = db.cursor()
21         try:
22             cursor.execute(sql)
23             data = cursor.fetchall()
24             db.commit()
25         except:
26             db.rollback()
27 
28         collect = []
29         for result in data:
30             collect.append(result)
31         db.close()
32         cursor.close()
33         return collect
34 
35 if __name__ == "__main__":
36     # 远程登录配置信息
37     ssh_config = {
38         'host': '',
39         'port': 22,
40         'username': '',
41         'password': ''
42     }
43     # 数据库配置信息
44     db_config = {
45         'host': 'localhost',
46         'port': 3306,
47         'username': '',
48         'password': '',
49         'db_name': ''
50     }
51     # 查询语句
52     sql = 'show tables'
53     # 查询
54     result = querySQL(ssh_config, db_config, sql)
55     print (result)

 

标签:db,host,ssh,mysql,password,config,port,python3
来源: https://www.cnblogs.com/zbit/p/15835463.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有