Python 通过pymssql访问查询操作 SQL Server数据库

这篇具有很好参考价值的文章主要介绍了Python 通过pymssql访问查询操作 SQL Server数据库。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

在企业应用开发中,经常用到应用程序访问数据库的开发模式,中小企业使用的数据库中,以ms SQL Server居多。本文就以一个简单的实例模型,简单介绍一下python访问ms sql sever数据库的方法。

一、数据库模型

本文中以下面的本地SQL Server数据库为例进行数据库连接,数据表的查询、增加、删除、修改等操作。
主机地址:localhost(我的是本地服务器,使用localhost,在linx系统下测试时使用了远程的数据库)
端口:默认的1433
用户名:sa
密码:sa1234
数据库名:myTestDb
数据库myTestDb中预设一个表tab_product,表结构如下:
pymssql,python,数据库,python,qt5,sqlserver

Tab_product中已经包括以下5行试验数据:
pymssql,python,数据库,python,qt5,sqlserver

二、pymssql库及简介

python访问ms SQL Server 需要用到Pymssql库,如没有安装,可以在命令行模式下输入:

pip install pymssql

进行下载安装。
1、使用pymssql创建数据连接,需要将SQL Server服务器的参数传给pymssql的connect方法,成功后建立连接。如下:
pymssql,python,数据库,python,qt5,sqlserver

2、查询数据方法:查询数据使用标准的SQL查询语句为作cursor对象execute方法的参数,注意返回值results为一个数据集合,result为集合中的每一行,res为每一行中的相关字段。
pymssql,python,数据库,python,qt5,sqlserver

3、数据操作:包括数据的增加、删除、修改等。也是使用标准的SQL语句。如下为增加一行数据:
pymssql,python,数据库,python,qt5,sqlserver

注意所有操作完成后,需要使用conn.close()关闭和数据库的连接。

三、实例演示

演示界面使用pyqt5开发。界面如下:
pymssql,python,数据库,python,qt5,sqlserver

界面上部为数据连接的主要参数,包括主机名,端口,数据库名称,用户名和密码等参数,设置完成后点击连接,连接成功后。才能进行下面的其它操作。
界面中部为两个文本框,用于输入SQL数据查询命令和SQL操作执行命令(如删除、新增、更新等)
界面下部为一个多行文本框,用于显示、记录查询结果或记录。

三、完整代码
实现的完整代码如下:代码中的注释比较清楚,不再赘述。
需要说明的一点就是关于python和SQL Server 使用的字符集不同,处理不当会出现中文乱码的情况,这个在需要注意和进行转换的代码中注释的非常清楚。

#encoding:utf8

'''
code writing:hnkkfan
本代码用于演示pyqt5访问查询和操作sql sever数据库
布局采用一个盒式布局,一个垂直布局里面包括五个水平布局
第一行为连接参数,包括主机名(地址),端口、数据库名
第二行为:用户名和密码,再加一个连接按钮
第三行为一个文本框,用于输入数据查询命令,后面跟一个查询按询
第四行为一个文本框,用于输入数据执行命令,后面跟一个执行按询
第五行为一个多行文本框,用于显示执行效果和错误信息
'''
import sys
from PyQt5.Qt import (QApplication, QWidget, QPushButton,QThread,pyqtSignal)
import pymssql
from PyQt5.QtWidgets import QTextEdit, QHBoxLayout, QVBoxLayout, QLineEdit, QLabel
from PyQt5.QtWidgets import QMessageBox




class MyWin(QWidget):
    conn=False
    def __init__(self):
        super().__init__()

        self.btn_conn = QPushButton('连接', self)#定义一个按钮
        self.btn_conn.clicked.connect(self.btnClick_conn)  # 给按钮绑定连接函数

        hbox_line1 = QHBoxLayout()
        hbox_line1.addWidget(QLabel("服务器主机名(IP地址):"))
        self.txt_host = QLineEdit("localhost")#数据库服务器主机本地为localhost

        hbox_line1.addWidget(self.txt_host)
        hbox_line1.addWidget(QLabel("端口:"))
        self.txt_port = QLineEdit("1433")#数据库服务器端口,默认为1433
        self.txt_port.setMaximumWidth(100)
        self.txt_port.setMinimumWidth(100)
        hbox_line1.addWidget(self.txt_port)

        hbox_line2 = QHBoxLayout()
        hbox_line2.addWidget(QLabel("数据库:"))
        self.txt_dbname = QLineEdit("myTestDb")#数据库名
        hbox_line2.addWidget(self.txt_dbname)
        hbox_line2.addWidget(QLabel("用户名:"))
        self.txt_user = QLineEdit("sa")#连接数据库的用户名
        self.txt_user.setMaximumWidth(160)
        self.txt_user.setMinimumWidth(160)

        hbox_line2.addWidget(self.txt_user)
        hbox_line2.addWidget(QLabel("密码:"))
        self.txt_pass = QLineEdit("SQL2008r2")#连接数据库的用户密码
        self.txt_pass.setMaximumWidth(160)
        self.txt_pass.setMinimumWidth(160)
        self.txt_pass.setEchoMode(QLineEdit.Password)#设置密码内容用点代替
        hbox_line2.addWidget(self.txt_pass)
        hbox_line2.addWidget(self.btn_conn)

        hbox_line3=QHBoxLayout()
        hbox_line3.addWidget(QLabel("查询语句:"))
        self.txt_selelct=QLineEdit("SELECT * FROM tab_product")#示例的查询语句
        self.btn_select = QPushButton('查询', self)  # 查询按钮
        self.btn_select.clicked.connect(self.btnClick_select)  # 给查询绑定函数
        self.btn_select.setEnabled(False)
        hbox_line3.addWidget(self.txt_selelct)
        hbox_line3.addWidget(self.btn_select)

        hbox_line4 = QHBoxLayout()
        hbox_line4.addWidget(QLabel("操作语句:"))
        #示例的操作语句,可以使用标准的SLQ 删除、更新及插入语句
        self.txt_do = QLineEdit("update tab_product set p_name='' where p_id=")
        self.btn_do = QPushButton('执行', self)  # 执行按钮
        self.btn_do.clicked.connect(self.btnClick_do)  # 给执行按钮绑定函数
        self.btn_do.setEnabled(False)
        hbox_line4.addWidget(self.txt_do)
        hbox_line4.addWidget(self.btn_do)

        hbox_line5=QHBoxLayout()
        self.txt_PressInfo = QTextEdit()#定义一个显示操作信息的多行文本框
        hbox_line5.addWidget(self.txt_PressInfo)

        vbox = QVBoxLayout()
        vbox.addLayout(hbox_line1)
        vbox.addLayout(hbox_line2)
        vbox.addLayout(hbox_line3)
        vbox.addLayout(hbox_line4)
        vbox.addLayout(hbox_line5)

        self.setLayout(vbox)  # 把垂直布局器添加到窗口

    def btnClick_conn(self):#连接按钮的点击事件
        #建立与数据库的连接,参数分别为主机名,端口,用户名,用户密码和连接的数据库
        # 注意:这里字符集使用的python文本常用的utf8(也可不加,因为默认就是utf8)
        try:
            self.conn = pymssql.connect(host=self.txt_host.text(),
                                    port=self.txt_port.text(),
                                    user=self.txt_user.text(),
                                    password=self.txt_pass.text(),
                                    database=self.txt_dbname.text(),
                                    charset='utf8')

            self.btn_select.setEnabled(True)
            self.btn_do.setEnabled(True)
            self.txt_PressInfo.append("数据库已经连接!")

        except:#如不能连接上则让查询和执行按钮不可以用并进行提示
            self.txt_PressInfo.append("数据库连接失败!")
    def btnClick_select(self):#查询按钮的点击事件
        cursor=self.conn.cursor()#建立游标
        try:#用一个try来进行查询,成功则返回查询结果,不成功则提示查询失败
            cursor.execute(self.txt_selelct.text())
            results=cursor.fetchall()
            for result in results:#对数据集合中的每行进行操作
                showTxt=""
                for col in range(len(result)):#对每行中每列数据进行操作
                    # 因为SQL Server返回的是GBK字符串,在uft8下中文会出现乱码,
                    # 通过.encode('latin-1').decode('gbk')转码解决问题
                    # strip()用于清除字符串前后的空格,
                    # ljust()用于将所有字段长度固定(不足时补齐)
                    showTxt=showTxt+str(result[col]).strip().ljust(20).encode('latin-1').decode('gbk')
                self.txt_PressInfo.append(showTxt)#把本行查询结果追加到多行文本框中显示
        except:
            self.txt_PressInfo.append("查询数据记录时发生错误!")

    def btnClick_do(self):#数据操作按钮的点击事件
        cursor = self.conn.cursor()
        try:#通过一个try对数据进行操作,成功则提示操作成功,否则提示操作错误。
            sqldo=self.txt_do.text()
            cursor.execute(sqldo)
            self.conn.commit()
            self.txt_PressInfo.append("执行数据操作完成!")

        except:
            self.txt_PressInfo.append("执行数据操作时发生错误!")
            
    #定义一个关闭窗口时的对话框,如确定退出,则关闭conn的连接。
    def closeEvent(self, event):  # 关闭窗口触发以下事件
        a = QMessageBox.question(self, '退出', '你确定要退出吗?', QMessageBox.Yes | QMessageBox.No,
                                 QMessageBox.No)  # "退出"代表的是弹出框的标题,"你确认退出.."表示弹出框的内容
        if a == QMessageBox.Yes:
            if self.conn:
                self.conn.close()
            event.accept()  # 接受关闭事件
        else:
            event.ignore()  # 忽略关闭事件



if __name__ == "__main__":
    app = QApplication(sys.argv)
    myshow = MyWin()
    myshow.setWindowTitle("Pyqt5连接SQL Server 演示")
    myshow.setMinimumHeight(640)
    myshow.setMinimumWidth(720)
    myshow.show()
    sys.exit(app.exec_())

四、运行效果:

1、数据库连接成功时:
pymssql,python,数据库,python,qt5,sqlserver

2、数据库连接失败时:
pymssql,python,数据库,python,qt5,sqlserver

3、查询数据成功时:
pymssql,python,数据库,python,qt5,sqlserver

4、查询数据失败时:
pymssql,python,数据库,python,qt5,sqlserver

5、执行数据操作成功时:
pymssql,python,数据库,python,qt5,sqlserver

6、执行数据操作失败时:

pymssql,python,数据库,python,qt5,sqlserver

7 、关闭窗口时提示:
pymssql,python,数据库,python,qt5,sqlserver

五、测试环境:
这段代码在windows和linux下都测试通过。
1、windows下:windows11家庭版+python3.11.1+PyCharm2022.3.2(Community Edition)
2、linux下:deepin os 20.8+python 3.7.1+PyCharm Community 2022.3。(数据库采用公司服务器上远程的SQL Server进行测试)。文章来源地址https://www.toymoban.com/news/detail-690472.html

到了这里,关于Python 通过pymssql访问查询操作 SQL Server数据库的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • python连接并简单操作SQL server数据库

    环境: pycharm 、SQLserver版本2019 1.首先,在pycharm中点击File,找到setting——project:***,点击”+“,引入pymssql库 2.编写代码连接数据库,并对数据库进行查询等简单操作(此处仅展示查询)  3.在sql server中由于之前使用windows验证模式进入数据库管理器,所以要身份验证修改,

    2024年02月08日
    浏览(35)
  • 什么是T-SQL编程?T-SQL是Transact-SQL的缩写,是一种扩展了SQL(结构化查询语言)的编程语言,用于Microsoft SQL Server数据库管理系统中的数据管理和操作。T-

    什么是T-SQL编程? T-SQL是Transact-SQL的缩写,是一种 扩展了SQL(结构化查询语言) 的编程语言,用于Microsoft SQL Server数据库管理系统中的数据管理和操作。T-SQL支持创建 存储过程、触发器、函数 等高级特性,能够更加灵活地进行数据操作和处理。基本的T-SQL语法与标准SQL很相

    2024年01月21日
    浏览(65)
  • SQL Server数据库 -- 表的高级查询

      一、子查询 嵌套子查询 相关子查询 二、查询运算 并运算union 交运算intersect 差运算except 三、函数的使用 if语句 while语句 case语句 四、总结 高级子查询是对查询更灵活的运用,学会了高级查询将对数据库使用有很大的帮助。       在SQL语言中,一个select-from-where语句称为一

    2024年02月13日
    浏览(33)
  • SQL Server数据库 -- 表的基础查询

    一、单表查询基本结构 二、单表查询结构语法 select 聚合函数 where 模糊查询 order by group by having 三、多表查询基本结构 四、多表查询结构语法 内连接 自连接 外连接 五、总结         学习了数据库,在以后公司等地方,你可能不会用到创建数据库或者表格,但是你一定会使

    2024年02月11日
    浏览(74)
  • sql server 数据库访问端口配置

    1、选择sql server 配置管理器 2、选择SQL Server 网络配置- MSSQLSERVER 的协议 - 右键TCP/IP属性 3、选择IP地址最下面的IPALL 下面的TCP端口 这个端口就是我们访问数据库设置的访问端口,默认端口为1433,如果在不更改的情况下,本地根据IP访问时可不设置端口号,如果更改了,则在访

    2024年02月11日
    浏览(36)
  • SQL server数据库端口访问法

    最近数据库连接,也是无意中发现了这个问题,数据库可根据端口来连接 网址:yii666.com 我用的是sql2014测试的,在安装其他程序是默认安装了sql(sql的tcp/ip端口为xxx),服务也不相同,但是由于比较不全,我又重装了sql2014的完整安装包,默认安装的端口是1433,所以就导致了数据

    2024年02月05日
    浏览(39)
  • 通过Java连接Sql Server数据库

    JDBC是Java DateBase Connectivity的简写,翻译过来就是java连接数据库,或者更通俗地说就是java语言操作数据库。JDBC的本质其实是官方定义的一套操作所有关系型数据库的规则,也就是接口。 微软官方jdbc下载地址:https://www.microsoft.com/zh-cn/download/details.aspx?id=11774 下载之后解压到相

    2024年01月17日
    浏览(34)
  • [SQL Server]数据库入门之多表查询

    🎬 博客主页:博主链接 🎥 本文由 M malloc 原创,首发于 CSDN🙉 🎄 学习专栏推荐:LeetCode刷题集! 🏅 欢迎点赞 👍 收藏 ⭐留言 📝 如有错误敬请指正! 📆 未来很长,值得我们全力奔赴更美好的生活✨ ------------------❤️分割线❤️------------------------- —————————

    2024年02月08日
    浏览(34)
  • 数据库SQL Server实验报告 之 SQL语言进行简单查询(3/8)

    实验名称          SQL语言进行简单查询 注意:原版word在下载资源里面(免费下载) 实验目的及要求: 掌握各种查询的SQL脚本写法,包括SELECT、FROM、WHERE、GROUP BY、HAVING子句的用法,特别要求比较内连接、外连接的结果 在XSGL数据库中,使用各种查询条件完成指定的查询

    2024年02月02日
    浏览(31)
  • 如何通过navicat连接SQL Server数据库

           本文介绍如何通过Navicat 连接SQL Server数据库。如果想了解如何连接Oracle数据库,可以参考下边这篇文章。 如何通过Navicat连接Oracle数据库 https://sgknight.blog.csdn.net/article/details/132064235 1、新建SQL Server连接配置         打开Navicat软件,点击连接,选择SQL server,进入配置页

    2024年02月04日
    浏览(38)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包