pymssql怎么实现读写数据库

发布时间：2023-12-22 08:05:00 所属栏目：MsSql 来源：DaWei

导读： 这篇文章主要介绍“pymssql怎么实现读写数据库，具体操作是什么”，有一些人在pymssql怎么实现读写数据库，具体操作是什么的问题上存在疑惑，接下来小编就给大家来介绍一下相关的

这篇文章主要介绍“pymssql怎么实现读写数据库，具体操作是什么”，有一些人在pymssql怎么实现读写数据库，具体操作是什么的问题上存在疑惑，接下来小编就给大家来介绍一下相关的内容，希望对大家解答有帮助，有这个方面学习需要的朋友就继续往下看吧。

pymssql包是Python语言用于连接SQL Server数据库的驱动程序（或者称作DB API），它是最终和数据库进行交互的工具。SQLAlchemy包就是利用pymssql包实现和SQL Server数据库交互的功能的。

一，pymssql包的基本组成
pymssql包由两个模块构成：pymssql 和 _mssql，pymssql 是建立在_mssql模块之上的模块，相对来说，_mssql性能更高。

pymssql模块由Connection和Cursor 两个大类构成：

Connection类代表MS SQL Sever数据库的一个连接，
Cursor类用于向数据库发送查询请求，并获取查询的的结果。
按照惯例，使用pymssql包查询数据库之前，首先创建连接：

import pymssql
conn = pymssql.connect(host='host',database='db_name',user='user',password='pwd',charset='utf8')
通过连接创建游标，通过游标执行SQL语句，查询数据或对数据进行更新操作：

cursor = conn.cursor()
cursor.execute("sql statement")　
如果执行的是修改操作，需要提交事务；如果执行的是查询操作，不需要提交：

conn.commit()
在查询完成之后，关闭连接

conn.close()

二，连接
连接对象用于连接SQL Server引擎，并设置连接的属性，比如连接超时，字符集等。

1，创建连接对象

pymssql通过类函数来构建连接对，在创建连接对象的同时，打开连接：

class pymssql.Connection(user, password, host, database, timeout, login_timeout, charset, as_dict)

2，构建Cursor对象

在创建连接对象之后，创建Cursor对象，使用Cursor对象向数据库引擎发送查询请求，并获取查询的结果：

Connection.cursor(as_dict=False)
as_dict是布尔类型，默认值是False，表示返回的数据是元组（tuple）类型；如果设置为True，返回的数据集是字典(dict)类型。

3，提交查询和自动提交模式

在执行查询之后，必须提交当前的事务，以真正执行Cursor对象的查询请求：

Connection.commit()
默认情况下，自动提交模式是关闭的，用户可以设置自动提交，pymssql自动执行Cursor发送的查询请求：

Connection.autocommit(status)
status是bool值，True表示打开自动提交模式，False表示关闭自动提交模式，默认值是False。

4，关闭连接

在执行完查询之后，关闭连接，通常情况下，使用with 语句来自动关闭连接：

Connection.close()

三，Cursor对象
通过打开的连接对象来创建Cursor对象，通过Cursor对象向数据库引擎发送查询请求，并获取查询的结果。

1，执行查询

Cursor对象调用execute**()函数来执行查询请求，
Cursor.execute(operation)
Cursor.execute(operation, params)
Cursor.executemany(operation, params_seq)

参数注释：

operation：表示执行的sql语句，
params ：表示sql语句的参数，
params_seq：参数序列，用于sql语句包含多个参数的情况。
注意，除设置自动提交模式之外，必须在执行查询之后，通过连接对象来提交查询。

Connection.commit()
如果sql语句只包含一个参数，那么必须在sql语句中显式使用%s或%d作为占位符，分别用于引用字符型的参数和数值型的参数。

cursor.execute('SELECT * FROM persons WHERE salesrep=%s', 'John Doe')
如果sql语句包含多个参数，那么使用list来传递参数：

cursor.executemany(
    "INSERT INTO persons VALUES (%d, %s, %s)",
    [(1, 'John Smith', 'John Doe'),
     (2, 'Jane Doe', 'Joe Dog'),
     (3, 'Mike T.', 'Sarah H.')])

2，获取查询结果

Cursor对象调用fetch**()函数来获取查询的结果：
Cursor.fetchone()
Cursor.fetchmany(size=None)
Cursor.fetchall()

fetch**()函数是迭代的：
fetchone()：表示从查询结果中获取下一行（next row）
fetchmany()：表示从查询结果中获取下面的多行（next batch）
fetchall()：表示从查询结果中获取剩余的所有数据行(all remaining）

3，跳过结果集

当查询的结果包含多个结果集时，可以跳过当前的结果集，跳到下一个结果集：

Cursor.nextset()

如果当前结果集还有数据行未被读取，那么这些剩余的数据行会被丢弃。

四，使用Cursor对象查询数据
游标cursor是由连接创建的对象，可以在游标中执行查询，并设置数据返回的格式。当执行select语句获取数据时，返回的数据行有两种格式：元组和字典，行的默认格式是元组。

cursor = conn.cursor(as_dict=True)

pymssql返回的数据集的格式是在创建游标时设置的，当参数 as_dict为True时，返回的行是字典格式，该参数的默认值是False，因此，默认的行格式是元组。

（编辑：商洛站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!