from PyMySQL import pymysql
from sshtunnel import SSHTunnelForwarder
import sshtunnel
# DEV测试环境
# db=pymysql.connect(host='',
# user='sa',
# password='Sa',
# database='ub')
# #UAT环境
server = SSHTunnelForwarder(
ssh_address_or_host="f.s.com", #堡垒机
ssh_port=60022, #端口号
ssh_username='zhn',
ssh_pkey='~.sshid_rsa',
ssh_password="wW0O", #密码验证太慢,私钥验证代码链接不上 ,链接ssh网关有多种方式,最后使用密码,链接数据库很慢,注释掉了其他链接网关方式
remote_bind_address=("12.6.0.10", 3306), #服务器
local_bind_address=('0.0.0.0',10022))
server.start()
print(server.local_bind_port)
db=pymysql.connect(host='127.0.0.1',
user='root',
password='1o9pSWmgo',
database='ubm',
port=server.local_bind_port,
charset='gbk')
cursor=db.cursor()
sql="SELECt COMPANY_NAME FROM `ub`.`company_info` where C_ID='00226d9f09184f'"
cursor.execute(sql)
#单个数据
data = cursor.fetchone()
#多个数据
#results = cursor.fetchall()
print(data)
db.close()
server.stop()