Python基于Pymssql模塊實(shí)現(xiàn)連接SQL Server數(shù)據(jù)庫的方法詳解

2020-01-04 17:02:01

字體：大中小

來源：轉(zhuǎn)載

供稿：網(wǎng)友

本文實(shí)例講述了Python基于Pymssql模塊實(shí)現(xiàn)連接 SQL Server數(shù)據(jù)庫的方法。分享給大家供大家參考，具體如下：

數(shù)據(jù)庫版本：SQL Server 2012。

按照Python版本來選擇下載pymssql模塊，這樣才能連接上sql server。

我安裝的python版本是3.5 ，64位的，所以下載的pymssql模塊是：pymssql-2.1.3-cp35-cp35m-win_amd64.whl

我把文件下載后放到E盤，安裝pymssql模塊：

C:/Users/Administrator>pip install e:/pymssql-2.1.3-cp35-cp35m-win_amd64.whlProcessing e:/pymssql-2.1.3-cp35-cp35m-win_amd64.whlInstalling collected packages: pymssqlSuccessfully installed pymssql-2.1.3

一、創(chuàng)建數(shù)據(jù)庫Test、表tb、插入數(shù)據(jù)

特別需要注意的是：為了避免亂碼問題，這里Name列是nvarchar類型的（適合中文），不會(huì)出現(xiàn)亂碼現(xiàn)象，一開始用的varchar類型出現(xiàn)了亂碼。

create database Test;gouse test;goif object_id('tb') is not null  drop table tb;goCREATE TABLE TB(ID INT,NAME NVARCHAR(20),SCORE NUMERIC(10,2));INSERT INTO TB(ID,NAME,SCORE)VALUES(1,'語文',100),   (2,'數(shù)學(xué)',80),   (3,'英語',900),   (4,'政治',65),   (5,'物理',65),   (6,'化學(xué)',85),   (7,'生物',55),   (8,'地理',100)

二、連接數(shù)據(jù)庫、查詢、增加、更新數(shù)據(jù)

connect的參數(shù)：

user：用戶名
password：密碼
trusted：布爾值,指定是否使用windows身份認(rèn)證登陸
host :主機(jī)名
database：數(shù)據(jù)庫
timeout：查詢超時(shí)
login_timeout：登陸超時(shí)
charset：數(shù)據(jù)庫的字符集
as_dict：布爾值,指定返回值是字典還是元組
max_conn：最大連接數(shù)

# -*- coding:gbk -*-import pymssql#數(shù)據(jù)庫連接conn=pymssql.connect(host='wc-pc',user='sa',password='ggg',database='Test')#打開游標(biāo)cur=conn.cursor();if not cur:  raise Exception('數(shù)據(jù)庫連接失敗！')sSQL = 'SELECT * FROM TB'#執(zhí)行sql，獲取所有數(shù)據(jù)cur.execute(sSQL)result=cur.fetchall()#1.result是list，而其中的每個(gè)元素是 tupleprint(type(result),type(result[0]))#2.print('/n/n總行數(shù)：'+ str(cur.rowcount))#3.通過enumerate返回行號(hào)for i,(id,name,v) in enumerate(result):  print('第 '+str(i+1)+' 行記錄->>> '+ str(id) +':'+ name+ ':' + str(v) )#4.修改數(shù)據(jù)cur.execute("insert into tb(id,name,score) values(9,'歷史',75)")cur.execute("update tb set score=95 where id=7")conn.commit() #修改數(shù)據(jù)后提交事務(wù)#再查一次cur.execute(sSQL)#5.一次取一條數(shù)據(jù),cur.rowcount為-1r=cur.fetchone()i=1print('/n')while r:  id,name,v =r #r是一個(gè)元祖  print('第 '+str(i)+' 行記錄->>> '+ str(id) +':'+ name+ ':' + str(v) )  r=cur.fetchone()  i+= 1conn.close()

基本的步驟就是：

（1）連接數(shù)據(jù)庫，指定連接參數(shù)
（2）打開cursor，執(zhí)行sql
（3）通過cursor獲取數(shù)據(jù)，具體可以是一次獲取所有數(shù)據(jù)，也可以是一次獲取一行。
整個(gè)結(jié)果集是元組列表，就是list類型的，而每一條記錄是一個(gè)tuple，也就是元祖。
（4）如果是增、改數(shù)據(jù)，必須就要調(diào)用commit()函數(shù)來提交事務(wù)，否則程序已退出，數(shù)據(jù)庫里的數(shù)據(jù)不會(huì)有變化。
（5）最后要用close關(guān)閉連接。

運(yùn)行效果：

Python,Pymssql模塊,連接,SQL,Server數(shù)據(jù)庫