草庐IT

Python数据库操作【三】—— SQLServer

虚梦年华 2023-07-25 原文

SQLServer简介

以下摘自百度百科：

SQL Server是由Microsoft开发和推广的关系数据库管理系统（DBMS），它最初是由Microsoft、Sybase和Ashton-Tate三家公司共同开发的，并于1988年推出了第一个OS/2版本。Microsoft SQL Server近年来不断更新版本，1996年，Microsoft 推出了SQL Server 6.5版本；1998年，SQL Server 7.0版本和用户见面；SQL Server 2000是Microsoft公司于2000年推出，目前最新版本是2019年份推出的SQL SERVER 2019。

SQL Server是微软推出的重量级的数据库，目前有多个版本，如2000、2008、2012等，这些版本名字均为该版本推出的年份，每个版本的差异并不是特别大。本文使用SQL Server2016。

传送门：

Python数据库操作【一】—— Sqlite

Python数据库操作【二】—— MySQL 

本文代码已上传至GitHub，项目地址如下：

https://github.com/XMNHCAS/SQLServerPythonDemo

安装pymssql

python内未集成SQLServer的操作库，需要安装pymssql库。

pip3 install pymssql

​

安装完成后使用import pymssql导入。

pymssql有官方文档，里面有更详细的使用示例，链接地址如下：

GitHub

pymssql文档

增删改查（CRUD）

数据库远程访问配置

使用pymssql访问SQLServer，需要启用SQLServer的TCP/IP协议。

如下图所示，打开SQLServer配置管理器，选择“SQL Server网络配置”中对应的需要使用的实例，在右侧窗口中启用TCP/IP协议。

​

接着重启SQL Server服务，就可以通过IP的形式访问数据库了。

​

 服务重启完成后，使用Navicat测试，可以看到连接成功。

​ 

新建数据库

新建CreateDatabase.py，使用pymssql创建TestDB数据库。

db.cursor()创建的游标对象，默认返回的是元组，通过设置as_dict=True可以将返回的数据改成字典类型。

如果最后再通过db.commit()来提交事务操作，可能会出现创建数据库失败的情况，故此处设置为autocommit，在游标执行sql的时候就提交操作。

import pymssql

# 打开数据库连接
db = pymssql.connect(server='localhost', user='test', password='123456')

# 创建游标对象,并设置返回数据的类型为字典
cursor = db.cursor(as_dict=True)

# 设置立即操作
db.autocommit(True)

# 查看现有数据库
sql = "SELECT * FROM SYSDATABASES"
cursor.execute(sql)
print("现有数据库：")
while True:
    msg = cursor.fetchone()
    if msg is None:
        break
    print(msg['name'])

# 创建数据库
sql = '''
IF NOT EXISTS(SELECT * FROM SYSDATABASES WHERE NAME = 'TestDB')
CREATE DATABASE TestDB;
'''
cursor.execute(sql)

# 查看现有数据库
sql = "SELECT * FROM SYSDATABASES"
cursor.execute(sql)
print("创建后的数据库：")
while True:
    msg = cursor.fetchone()
    if msg is None:
        break
    print(msg['name'])

# 关闭游标与数据库连接
cursor.close()
db.close()

运行结果如下：

​

新建数据表 

新建CreateTable.py，使用pymssql在TestDB数据库中新建一个Persons表。

import pymssql

# 打开数据库连接
db = pymssql.connect(server='localhost',
                     user='test',
                     password='123456',
                     database='TestDB')

# 创建一个游标对象
cursor = db.cursor()

# 查看现有表
sql = "SELECT NAME FROM TESTDB.SYS.TABLES"
msg = cursor.execute(sql)
print(cursor.fetchall())

# 创建Person表
sql = """
USE TestDB
CREATE TABLE [Persons](
ID INT PRIMARY KEY IDENTITY(1, 1),
Name VARCHAR(50),
Age INT,
)
"""
cursor.execute(sql)

# 查看现有表
sql = "SELECT NAME FROM TESTDB.SYS.TABLES"
cursor.execute(sql)
print(cursor.fetchall())

# 提交事务
db.commit()

# 关闭游标与数据库连接
cursor.close()
db.close()

运行结果如下：

​

新增记录（Create）

使用游标执行插入语句，不同于pymysql，pymssql不会返回游标执行后影响的行数。

而且由于编码问题，pymssql查询出来的中文数据，如果不进行转码则会输出乱码，所以后面均采用循环输出数据，同时将中文数据改成gbk的编码。该乱码问题可以通过设置数据库字段的编码格式的方式来解决，但是会稍微影响数据库存储性能，故此处不进行演示。

此方式支持单条数据插入和批量插入。

import pymssql

# 打开数据库连接
db = pymssql.connect(server='localhost',
                     user='test',
                     password='123456',
                     database='TestDB')

# 创建游标对象,并设置返回数据的类型为字典
cursor = db.cursor(as_dict=True)

# 插入单条数据
cursor.execute("INSERT INTO Persons(Name, Age) VALUES ('张三',18 )")

print("插入单条数据后的数据")
cursor.execute("SELECT * FROM Persons")
for item in cursor.fetchall():
    item["Name"] = item["Name"].encode("latin1").decode("gbk")
    print(item)


# 批量插入数据
sql = "INSERT INTO Persons(Name, Age) VALUES (%s,%s)"
cursor.executemany(sql, [('李四', 20), ('王五', 10)])

print("批量插入后的数据")
cursor.execute("SELECT * FROM Persons")
for item in cursor.fetchall():
    item["Name"] = item["Name"].encode("latin1").decode("gbk")
    print(item)

# 提交事务
db.commit()

# 关闭游标与数据库连接
cursor.close()
db.close()

运行结果如下：

检索记录（Retrieve）

执行查询语句后，可以使用游标的fetchone方法获取单条数据，也可以使用fetchmany获取指定数量的数据，还可以用fetchall直接获取全部数据。为了结果显示得更加清晰，此处全部使用循环进行数据输出。

import pymssql

# 打开数据库连接
db = pymssql.connect(server='localhost',
                     user='test',
                     password='123456',
                     database='TestDB')

# 创建游标对象,并设置返回数据的类型为字典
cursor = db.cursor(as_dict=True)

# 获取全部记录
cursor.execute("SELECT * FROM Persons")
allData = cursor.fetchall()
print("直接获取全部记录：")
for item in allData:
    item["Name"] = item["Name"].encode("latin1").decode("gbk")
    print(item)

# 获取前N条记录
cursor.execute("SELECT * FROM Persons")
manyData = cursor.fetchmany(2)
print("获取部分结果：")
for item in manyData:
    item["Name"] = item["Name"].encode("latin1").decode("gbk")
    print(item)

# 一次读取一条结果，循环获取所有记录
cursor.execute("SELECT * FROM Persons")
print("一次读取一条结果，循环获取所有记录：")
while True:
    singleData = cursor.fetchone()
    if singleData is None:
        break
    singleData["Name"] = singleData["Name"].encode("latin1").decode("gbk")
    print(singleData)

# 关闭游标
cursor.close()

# 提交事务
db.commit()

# 关闭数据库连接
db.close()

运行结果如下：

更新记录（Update）

使用游标执行update语句。此方法支持单条数据修改及批量修改。

import pymssql


# 打开数据库连接
db = pymssql.connect(server='localhost',
                     user='test',
                     password='123456',
                     database='TestDB')

# 创建游标对象,并设置返回数据的类型为字典
cursor = db.cursor(as_dict=True)

cursor.execute("SELECT * FROM Persons")
print("修改前的数据：")
cursor.execute("SELECT * FROM Persons")
for item in cursor.fetchall():
    item["Name"] = item["Name"].encode("latin1").decode("gbk")
    print(item)

# 执行单条数据修改
cursor.execute("UPDATE Persons SET Age = 20 WHERE Name = '张三'")

print("修改单条数据后的数据：")
cursor.execute("SELECT * FROM Persons")
for item in cursor.fetchall():
    item["Name"] = item["Name"].encode("latin1").decode("gbk")
    print(item)

# 执行批量修改
sql = "UPDATE Persons SET Age = %s WHERE Name = %s"
batchUpdate = cursor.executemany(sql, [(25, '李四'), (35, '王五')])

print("批量修改后的数据：")
cursor.execute("SELECT * FROM Persons")
for item in cursor.fetchall():
    item["Name"] = item["Name"].encode("latin1").decode("gbk")
    print(item)

# 关闭游标
cursor.close()

# 提交事务
db.commit()

# 关闭数据库连接
db.close()

运行结果如下：

删除数据（Delete）

使用游标执行delete语句。此方法也支持单条数据删除以及批量删除。

import pymssql

# 打开数据库连接
db = pymssql.connect(server='localhost',
                     user='test',
                     password='123456',
                     database='TestDB')

# 创建游标对象,并设置返回数据的类型为字典
cursor = db.cursor(as_dict=True)

print("删除前的数据：")
cursor.execute("SELECT * FROM Persons")
data = cursor.fetchall()
if len(data) == 0:
    print(data)
else:
    for item in data:
        item["Name"] = item["Name"].encode("latin1").decode("gbk")
        print(item)

# 执行单条数据删除
cursor.execute("DELETE FROM Persons WHERE ID = 1")

print("删除单条数据后的数据：")
cursor.execute("SELECT * FROM Persons")
data = cursor.fetchall()
if len(data) == 0:
    print(data)
else:
    for item in data:
        item["Name"] = item["Name"].encode("latin1").decode("gbk")
        print(item)

# 执行批量删除
sql = "DELETE FROM Persons WHERE ID = %s"
cursor.executemany(sql, [('2'), ('3')])

print("批量删除后的的数据：")
cursor.execute("SELECT * FROM Persons")
data = cursor.fetchall()
if len(data) == 0:
    print(data)
else:
    for item in data:
        item["Name"] = item["Name"].encode("latin1").decode("gbk")
        print(item)

# 关闭游标
cursor.close()

# 提交事务
db.commit()

# 关闭数据库连接
db.close()

运行结果如下：

mdashSQLServer34cursorxff数据库python

有关Python数据库操作【三】—— SQLServer的更多相关文章

  1. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声？ - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题？更新问题，以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点？我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等)，但我确实想创建一个输出文件。

  2. ruby - 解析 RDFa、微数据等的最佳方式是什么，使用统一的模式/词汇(例如 schema.org)存储和显示信息 - 2

    我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i

  3. ruby - Ruby 有 `Pair` 数据类型吗？ - 2

    有时我需要处理键/值数据。我不喜欢使用数组，因为它们在大小上没有限制(很容易不小心添加超过2个项目，而且您最终需要稍后验证大小)。此外，0和1的索引变成了魔数(MagicNumber)，并且在传达含义方面做得很差(“当我说0时，我的意思是head...”)。散列也不合适，因为可能会不小心添加额外的条目。我写了下面的类来解决这个问题:classPairattr_accessor:head,:taildefinitialize(h,t)@head,@tail=h,tendend它工作得很好并且解决了问题，但我很想知道:Ruby标准库是否已经带有这样一个类？ 最佳

  4. Python 相当于 Perl/Ruby ||= - 2

    这个问题在这里已经有了答案:关闭10年前。PossibleDuplicate:Pythonconditionalassignmentoperator对于这样一个简单的问题表示歉意，但是谷歌搜索||=并不是很有帮助；)Python中是否有与Ruby和Perl中的||=语句等效的语句？例如:foo="hey"foo||="what"#assignfooifit'sundefined#fooisstill"hey"bar||="yeah"#baris"yeah"另外，类似这样的东西的通用术语是什么？条件分配是我的第一个猜测，但Wikipediapage跟我想的不太一样。

  5. java - 什么相当于 ruby​​ 的 rack 或 python 的 Java wsgi？ - 2

    什么是ruby​​的rack或python的Java的wsgi？还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht

  6. ruby - 我如何添加二进制数据来遏制 POST - 2

    我正在尝试使用Curbgem执行以下POST以解析云curl-XPOST\-H"X-Parse-Application-Id:PARSE_APP_ID"\-H"X-Parse-REST-API-Key:PARSE_API_KEY"\-H"Content-Type:image/jpeg"\--data-binary'@myPicture.jpg'\https://api.parse.com/1/files/pic.jpg用这个:curl=Curl::Easy.new("https://api.parse.com/1/files/lion.jpg")curl.multipart_form_

  7. 世界前沿3D开发引擎HOOPS全面讲解——集3D数据读取、3D图形渲染、3D数据发布于一体的全新3D应用开发工具 - 2

    无论您是想搭建桌面端、WEB端或者移动端APP应用，HOOPSPlatform组件都可以为您提供弹性的3D集成架构，同时，由工业领域3D技术专家组成的HOOPS技术团队也能为您提供技术支持服务。如果您的客户期望有一种在多个平台（桌面/WEB/APP，而且某些客户端是“瘦”客户端）快速、方便地将数据接入到3D应用系统的解决方案，并且当访问数据时，在各个平台上的性能和用户体验保持一致，HOOPSPlatform将帮助您完成。利用HOOPSPlatform，您可以开发在任何环境下的3D基础应用架构。HOOPSPlatform可以帮您打造3D创新型产品，HOOPSSDK包含的技术有：快速且准确的CAD

  8. 华为OD机试用Python实现 -【明明的随机数】 2023Q1A - 2

    华为OD机试题本篇题目：明明的随机数题目输入描述输出描述：示例1输入输出说明代码编写思路最近更新的博客华为od2023|什么是华为od，od薪资待遇，od机试题清单华为OD机试真题大全，用Python解华为机试题|机试宝典【华为OD机试】全流程解析+经验分享,题型分享,防作弊指南华为o

  9. FOHEART H1数据手套驱动Optitrack光学动捕双手运动(Unity3D) - 2

    本教程将在Unity3D中混合Optitrack与数据手套的数据流，在人体运动的基础上，添加双手手指部分的运动。双手手背的角度仍由Optitrack提供，数据手套提供双手手指的角度。 01  客户端软件分别安装MotiveBody与MotionVenus并校准人体与数据手套。MotiveBodyMotionVenus数据手套使用、校准流程参照：https://gitee.com/foheart_1/foheart-h1-data-summary.git02  数据转发打开MotiveBody软件的Streaming，开始向Unity3D广播数据；MotionVenus中设置->选项选择Unit

  10. 使用canal同步MySQL数据到ES - 2

    文章目录一、概述简介原理模块二、配置Mysql使用版本环境要求1.操作系统2.mysql要求三、配置canal-server离线下载在线下载上传解压修改配置单机配置集群配置分库分表配置1.修改全局配置2.实例配置垂直分库水平分库3.修改group-instance.xml4.启动监听四、配置canal-adapter1修改启动配置2配置映射文件3启动ES数据同步查询所有订阅同步数据同步开关启动4.验证五、配置canal-admin一、概述简介canal是Alibaba旗下的一款开源项目，Java开发。基于数据库增量日志解析，提供增量数据订阅&消费。Git地址：https://github.co

随机推荐