本文實例講述了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程序設計有所幫助。