2021-02-23 15:51发布
如何利用python中sshtunnel和pymssql远程链接Microsoft SQL Server?
有时候(常常是工作中),涉及的数据库都是放在远程服务器上的,这个时候我们不能直接进行访问,得需要一个跳板来进行连接访问。
配置如下:数据库所在远程服务器IP:IP_C数据库所在远程服务器端口:Port_C跳板机(通过ssh通道)所在服务器IP:IP_B跳板机(通过ssh通道)所在服务器I端口:Port_B(22默认)跳板机(通过ssh通道)所在服务器账号:username_B跳板机(通过ssh通道)所在服务器密码:password_B连接数据库的账号:username_sql连接数据库的密码:password_sql
代码如下:
# _*_ coding:utf-8 _*_import pymysqlfrom sshtunnel import SSHTunnelForwarderwith SSHTunnelForwarder( (IP_B, Port_B), # 跳板机(堡垒机)B配置 ssh_password=password_B, ssh_username=username_B, remote_bind_address=(IP_C, Port_C)) as server: # 数据库存放服务器C配置 # 打开数据库连接 db_connect = pymysql.connect(host='127.0.0.1', # 本机主机A的IP(必须是这个) port=server.local_bind_port, user=username_sql, passwd=password_sql, db=dbname) # 需要连接的数据库的名称 1234567891011121314151617
连接远程数据库上面的就完成了,下面介绍下简单的封装,可以方便直接输入数据库名称和查询语句进行查询
# _*_ coding:utf-8 _*_import pymysqlfrom sshtunnel import SSHTunnelForwarderclass ExecuteSQL(object): # 传入需要连接的数据库的名称dbname和待执行的sql语句sql def __init__(self, dbname, sql): self.dbname = dbname self.sql = sql def execute_sql(self): results = '' with SSHTunnelForwarder( (IP_B, Port_B), # 跳板机(堡垒机)B配置 ssh_password=password_B, ssh_username=username_B, remote_bind_address=(IP_C, Port_C)) as server: # 数据库存放服务器C配置 # 打开数据库连接 db_connect = pymysql.connect(host='127.0.0.1', # 本机主机A的IP(必须是这个) port=server.local_bind_port, user=username_sql, passwd=password_sql, db=self.dbname) # 需要连接的数据库的名称 # 使用cursor()方法获取操作游标 cursor = db_connect.cursor() try: # 执行SQL语句 cursor.execute(self.sql) # 获取所有记录列表 results = cursor.fetchall() except Exception as data: print('Error: 执行查询失败,%s' % data) db_connect.close() return resultsif __name__ == '__main__': name = dbname sql = "select * from table " connect = ExecuteSQL(name, sql) print(connect.execute_sql()) 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
运行之后就可以获得查询的结果了,如果需要调用,直接导入ExecuteSQL( )就可以使用了。
最多设置5个标签!
有时候(常常是工作中),涉及的数据库都是放在远程服务器上的,这个时候我们不能直接进行访问,得需要一个跳板来进行连接访问。
配置如下:
数据库所在远程服务器IP:IP_C
数据库所在远程服务器端口:Port_C
跳板机(通过ssh通道)所在服务器IP:IP_B
跳板机(通过ssh通道)所在服务器I端口:Port_B(22默认)
跳板机(通过ssh通道)所在服务器账号:username_B
跳板机(通过ssh通道)所在服务器密码:password_B
连接数据库的账号:username_sql
连接数据库的密码:password_sql
代码如下:
连接远程数据库上面的就完成了,下面介绍下简单的封装,可以方便直接输入数据库名称和查询语句进行查询
运行之后就可以获得查询的结果了,如果需要调用,直接导入ExecuteSQL( )就可以使用了。
一周热门 更多>