如何利用python中sshtunnel远程链接Microsoft SQL Server?

2021-02-23 15:51发布

如何利用python中sshtunnel和pymssql远程链接Microsoft SQL Server?

如何利用python中sshtunnel和pymssql远程链接Microsoft SQL Server?

7条回答
studentaaa
2楼-- · 2021-02-24 10:06

有时候(常常是工作中),涉及的数据库都是放在远程服务器上的,这个时候我们不能直接进行访问,得需要一个跳板来进行连接访问。

配置如下:
数据库所在远程服务器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( )就可以使用了。

aijingda
3楼-- · 2021-02-24 11:52

下载paramiko

首先,我的windows系统上有python2和python3。使用下面命令切换到python3:

activate py3

接着使用下面命令下载相关模块:

pip install ecdsa
pip install Crypto
pip install paramiko

连接服务器操作:

# -*- coding: utf-8 -*-
import paramiko
# 服务器相关信息,下面输入你个人的用户名、密码、ip等信息
ip = ""  
port =  22
user = ""
password = ""
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 建立连接
ssh.connect(ip,port,user,password,timeout = 10)
#输入linux命令
stdin,stdout,stderr = ssh.exec_command("pwd")
# 输出命令执行结果
result = stdout.read()
print(result)
#关闭连接
ssh.close()

如下,运行该程序,可以看到控制台输出的结果:

在这里插入图片描述

buzuofa100
4楼-- · 2021-02-24 18:50

有时候(常常是工作中),涉及的数据库都是放在远程服务器上的,这个时候我们不能直接进行访问,得需要一个跳板来进行连接访问。

配置如下:
数据库所在远程服务器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楼-- · 2021-02-25 14:52

有时候(常常是工作中),涉及的数据库都是放在远程服务器上的,这个时候我们不能直接进行访问,得需要一个跳板来进行连接访问。

配置如下:
数据库所在远程服务器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


ablabla
6楼-- · 2021-02-25 15:45

有时候(常常是工作中),涉及的数据库都是放在远程服务器上的,这个时候我们不能直接进行访问,得需要一个跳板来进行连接访问。

配置如下:
数据库所在远程服务器IP:IP_C
数据库所在远程服务器端口:Port_C
跳板机(通过ssh通道)所在服务器IP:IP_B
跳板机(通过ssh通道)所在服务器I端口:Port_B(22默认)
跳板机(通过ssh通道)所在服务器账号:username_B
跳板机(通过ssh通道)所在服务器密码:password_B
连接数据库的账号:username_sql
连接数据库的密码:password_sql


善良的人
7楼-- · 2021-02-25 16:06

数据库所在远程服务器IP:IP_C
数据库所在远程服务器端口:Port_C
跳板机(通过ssh通道)所在服务器IP:IP_B
跳板机(通过ssh通道)所在服务器I端口:Port_B(22默认)
跳板机(通过ssh通道)所在服务器账号:username_B
跳板机(通过ssh通道)所在服务器密码:password_B
连接数据库的账号:username_sql
连接数据库的密码:password_sql

py大白
8楼-- · 2021-02-25 16:12

有时候(常常是工作中),涉及的数据库都是放在远程服务器上的,这个时候我们不能直接进行访问,得需要一个跳板来进行连接访问。

配置如下:
数据库所在远程服务器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( )就可以使用了。