本文实例讲述了Python基于Pymssql模块实现连接SQL Server数据库的方法。分享给大家供大家参考,具体如下:
数据库版本:SQL Server 2012。
按照Python版本来选择下载pymssql模块,这样才能连接上sql server。
我安装的python版本是3.5 ,64位的,所以下载的pymssql模块是:pymssql-2.1.3-cp35-cp35m-win_amd64.whl
我把文件下载后放到E盘,安装pymssql模块:
1
2
3
4
|
C:\Users\Administrator>pip install e:\pymssql-2.1.3-cp35-cp35m-win_amd64.whl
Processing e:\pymssql-2.1.3-cp35-cp35m-win_amd64.whl
Installing collected packages: pymssql
Successfully installed pymssql-2.1.3
|
一、创建数据库Test、表tb、插入数据
特别需要注意的是:为了避免乱码问题,这里Name列是nvarchar类型的(适合中文),不会出现乱码现象,一开始用的varchar类型出现了乱码。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
create database Test;
go
use test;
go
if object_id( 'tb' ) is not null
drop table tb;
go
CREATE TABLE TB(ID INT , NAME NVARCHAR(20),SCORE NUMERIC (10,2));
INSERT INTO TB(ID, NAME ,SCORE)
VALUES (1, '语文' ,100),
(2, '数学' ,80),
(3, '英语' ,900),
(4, '政治' ,65),
(5, '物理' ,65),
(6, '化学' ,85),
(7, '生物' ,55),
(8, '地理' ,100)
|
二、连接数据库、查询、增加、更新数据
connect的参数:
user:用户名
password:密码
trusted:布尔值,指定是否使用windows身份认证登陆
host :主机名
database:数据库
timeout:查询超时
login_timeout:登陆超时
charset:数据库的字符集
as_dict:布尔值,指定返回值是字典还是元组
max_conn:最大连接数
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
# -*- coding:gbk -*-
import pymssql
#数据库连接
conn = pymssql.connect(host = 'wc-pc' ,user = 'sa' ,password = 'ggg' ,database = 'Test' )
#打开游标
cur = conn.cursor();
if not cur:
raise Exception( '数据库连接失败!' )
sSQL = 'SELECT * FROM TB'
#执行sql,获取所有数据
cur.execute(sSQL)
result = cur.fetchall()
#1.result是list,而其中的每个元素是 tuple
print ( type (result), type (result[ 0 ]))
#2.
print ( '\n\n总行数:' + str (cur.rowcount))
#3.通过enumerate返回行号
for i,( id ,name,v) in enumerate (result):
print ( '第 ' + str (i + 1 ) + ' 行记录->>> ' + str ( id ) + ':' + name + ':' + str (v) )
#4.修改数据
cur.execute( "insert into tb(id,name,score) values(9,'历史',75)" )
cur.execute( "update tb set score=95 where id=7" )
conn.commit() #修改数据后提交事务
#再查一次
cur.execute(sSQL)
#5.一次取一条数据,cur.rowcount为-1
r = cur.fetchone()
i = 1
print ( '\n' )
while r:
id ,name,v = r #r是一个元祖
print ( '第 ' + str (i) + ' 行记录->>> ' + str ( id ) + ':' + name + ':' + str (v) )
r = cur.fetchone()
i + = 1
conn.close()
|
基本的步骤就是:
(1)连接数据库,指定连接参数
(2)打开cursor,执行sql
(3)通过cursor获取数据,具体可以是一次获取所有数据,也可以是一次获取一行。
整个结果集是元组列表,就是list类型的,而每一条记录是一个tuple,也就是元祖。
(4)如果是增、改数据,必须就要调用commit()函数来提交事务,否则程序已退出,数据库里的数据不会有变化。
(5)最后要用close关闭连接。
运行效果:
希望本文所述对大家Python程序设计有所帮助。