Python基于Pymssql模塊實現連接SQL Server數據庫的方法詳解

更新時間：2017年07月20日 11:59:29 作者：不想長大啊

這篇文章主要介紹了Python基于Pymssql模塊實現連接SQL Server數據庫的方法,較為詳細的分析了pymssql模塊的下載、安裝及連接、操作SQL Server數據庫的相關實現技巧,需要的朋友可以參考下

本文實例講述了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模塊：

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

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

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

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：最大連接數

# -*- 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'
#執(zhí)行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，執(zhí)行sql
（3）通過cursor獲取數據，具體可以是一次獲取所有數據，也可以是一次獲取一行。
整個結果集是元組列表，就是list類型的，而每一條記錄是一個tuple，也就是元祖。
（4）如果是增、改數據，必須就要調用commit()函數來提交事務，否則程序已退出，數據庫里的數據不會有變化。
（5）最后要用close關閉連接。

運行效果：