pymysql連接數據庫及通過SSH跳板機連接數據庫

參考資料：

sshtunnel官方文檔   https://pypi.org/project/sshtunnel/

pymysql 通過ssh連接 mysql服務器   https://hacpai.com/article/1573725286491

SSHTunnelForwarder隧道連接mysql  https://blog.csdn.net/helloxiaozhe/article/details/77850367

 

通過賬號密碼直接連接：

 

# 打開數據庫連接 主機地址 端口號3306 用戶名 密碼 數據庫名
db = pymysql.connect(host="10.12.102.202", port=3309, user="qa_dev", passwd="xxx", db="wechat_test", charset="utf8")
# 創建一個游標對象 cursor()
cursor = db.cursor()
# SQL查詢語句
sql = "SELECT * FROM city WHERE city_id = '336'"
try:
    cursor.execute(sql)
    results = cursor.fetchall()
except:
    print("語句執行錯誤")
# 關閉數據庫
db.close()

 

通過ssh跳板機連接數據庫：

 

1、出於安全考慮，數據庫服務器只允許堡壘機通過ssh訪問，MySQL數據庫安裝在A機器上，只允許服務器B訪問，而我在C機器上可以通過SSH連接B服務器

如圖所示：    

 

 2、代碼示例      A：mysql 服務   B：跳板機  C：本地訪問機器

import pymysql
from sshtunnel import SSHTunnelForwarder

with SSHTunnelForwarder(
    ssh_address_or_host=('sa.xxxx.cn', 22),       # ssh 目標服務器 ip 和 port
    ssh_username="zhaoxxx",     # ssh 目標服務器用戶名
    #ssh_password= "",           # ssh 目標服務器用戶密碼
    ssh_pkey="C:\\Users\\Administrator\\.ssh\\id_rsa",   # ssh 目標服務器證書
    #ssh_private_key_password="",  # ssh 目標服務器證書密碼
    remote_bind_address=('10.10.xx.xxx', 3306),     # mysql 服務ip 和 part
    local_bind_address=('127.0.0.1', 5143)                     # ssh 目標服務器的用於連接 mysql 或 redis 的端口，該 ip 必須為 127.0.0.1
) as server:
    conn = pymysql.connect(
        host=server.local_bind_host,                # server.local_bind_host 是 參數 local_bind_address 的 ip
        port=server.local_bind_port,                # server.local_bind_host 是 參數 local_bind_address 的 port
        user="name",
        password="password",
        db="test_data",
        charset="utf8"
    )
    cursor = conn.cursor()
    sql = "SELECT * FROM satel_report WHERE id = 1"
    try:
        cursor.execute(sql)
        data = cursor.fetchall()
        print(data)
    except:
        print("SQL執行失敗")

3、注意事項

    (0) charset是要跟數據庫的編碼一樣

    (1) ssh_pkey="C:\Users\XXXX\.ssh\證書"SSH 連接使用密鑰證書登錄，該參數必須該路徑為目標服務器的公鑰證書。window 秘鑰ppk不能識別，需要id_rsa

    (2) local_bind_address=('127.0.0.1', 5141)該參數必須SSH 目標服務器的用於連接 MySQL 或 Redis 的端口該 ip 必須為 127.0.0.1