Python使用pyodbc訪問數(shù)據(jù)庫操作方法詳解
本文實(shí)例講述了Python使用pyodbc訪問數(shù)據(jù)庫操作方法。
數(shù)據(jù)庫連接
數(shù)據(jù)庫連接網(wǎng)上大致有兩種方法，一種是使用pyodbc,另一種是使用win32com.client,測(cè)試了很多遍，最終只有pyodbc成功，而且比較好用，所以這里只介紹這種方法
工具庫安裝
在此基礎(chǔ)上安裝pyodbc工具庫，在cmd窗口執(zhí)行如下語句安裝
pip install pyodbc
如果安裝了anaconda也可以使用conda install pyodbc
分享給大家供大家參考，具體如下：
檢驗(yàn)是否可以正常連接數(shù)據(jù)庫檢查是否有一個(gè)Microsoft Access ODBC驅(qū)動(dòng)程序可用于你的Python環(huán)境（在Windows上）的方法：
>>> import pyodbc
>>>[x for x in pyodbc.drivers() if x.startswith('Microsoft Access Driver')]
如果你看到一個(gè)空列表，那么您正在運(yùn)行64位Python，并且需要安裝64位版本的“ACE”驅(qū)動(dòng)程序。如果您只看到['Microsoft Access Driver (*.mdb)']并且需要使用.accdb文件，那么您需要安裝32位版本的“ACE”驅(qū)動(dòng)程序
安裝64位的ODBC 驅(qū)動(dòng)器：
64位ODBC驅(qū)動(dòng)器的下載地址 https://www.microsoft.com/en-us/download/details.aspx?id=13255
直接安裝會(huì)報(bào)錯(cuò)，所以我們需要修改一下文件AccessDatabaseEngine_X64.exe，先對(duì)其進(jìn)行解壓，然后打開AccessDatabaseEngine_X64文件夾，有一個(gè)AceRedist.msi文件。用Orca軟件將AceRedist.msi打開，找到找到LaunchCondition里面的BLOCKINSTALLATION，刪除那一行數(shù)據(jù)并進(jìn)行保存。然后再運(yùn)行AceRedist.msi，就可以把64位的ODBC 驅(qū)動(dòng)器安裝成功。
如果感覺上面的操作比較麻煩，可以直接下載腳本之家小編已經(jīng)處理過的版本。
下載地址：http://www.fzitv.net/softs/695978.html
注意：
1、不用配置數(shù)據(jù)源
2、Orcad的下載地址 http://www.fzitv.net/softs/16217.html
下面是經(jīng)過腳本之家小編測(cè)試過的代碼
access是2000的，理論上2010也可以。
import pyodbc
DBfile = r"F:\python\caiji.mdb" # 數(shù)據(jù)庫文件需要帶路徑
print(DBfile)
conn = pyodbc.connect(r"DRIVER={Microsoft Access Driver (*.mdb, *.accdb)};DBQ="+ DBfile +";Uid=;Pwd=;")
cursor = conn.cursor()
SQL = "SELECT * from sites;"
for row in cursor.execute(SQL):
print(row)
cursor.close()
conn.close()
完整測(cè)試代碼
# -*-coding:utf-8-*-
import pyodbc
# 連接數(shù)據(jù)庫（不需要配置數(shù)據(jù)源）,connect()函數(shù)創(chuàng)建并返回一個(gè) Connection 對(duì)象
cnxn = pyodbc.connect(r'DRIVER={Microsoft Access Driver (*.mdb, *.accdb)};DBQ=.\data\goods.mdb')
# cursor()使用該連接創(chuàng)建（并返回）一個(gè)游標(biāo)或類游標(biāo)的對(duì)象
crsr = cnxn.cursor()
# 打印數(shù)據(jù)庫goods.mdb中的所有表的表名
print('`````````````` goods ``````````````')
for table_info in crsr.tables(tableType='TABLE'):
print(table_info.table_name)
l = crsr.execute("SELECT * from goods WHERE goodsId='0001'")# [('0001', '扇葉', 20, 'A公司', 'B公司', 2000, 2009)]
rows = crsr.execute("SELECT currentStock from goods") # 返回的是一個(gè)元組
for item in rows:
print(item)
l = crsr.execute("UPDATE users SET username='lind' WHERE password='123456'")
print(crsr.rowcount) # 想知道數(shù)據(jù)修改和刪除時(shí)，到底影響了多少條記錄，這個(gè)時(shí)候你可以使用cursor.rowcount的返回值。
# 修改數(shù)據(jù)庫中int類型的值
value = 10
SQL = "UPDATE goods " \
"SET lowestStock=" + str(value) + " " \
"WHERE goodsId='0005'"
# 刪除表users
crsr.execute("DROP TABLE users")
# 創(chuàng)建新表 users
crsr.execute('CREATE TABLE users (login VARCHAR(8),userid INT, projid INT)')
# 給表中插入新數(shù)據(jù)
crsr.execute("INSERT INTO users VALUES('Linda',211,151)")
''''''
# 更新數(shù)據(jù)
crsr.execute("UPDATE users SET projid=1 WHERE userid=211")
# 刪除行數(shù)據(jù)
crsr.execute("DELETE FROM goods WHERE goodNum='0001'")
# 打印查詢的結(jié)果
for row in crsr.execute("SELECT * from users"):
print(row)
# 提交數(shù)據(jù)（只有提交之后，所有的操作才會(huì)對(duì)實(shí)際的物理表格產(chǎn)生影響）
crsr.commit()
crsr.close()
cnxn.close()
1、連接數(shù)據(jù)庫
1）直接連接數(shù)據(jù)庫和創(chuàng)建一個(gè)游標(biāo)（cursor)
cnxn =pyodbc.connect('DRIVER={SQL Server};SERVER=localhost;DATABASE=testdb;UID=me;PWD=pass')
cursor =cnxn.cursor()
2）使用DSN連接。通常DSN連接并不需要密碼，還是需要提供一個(gè)PSW的關(guān)鍵字。
cnxn =pyodbc.connect('DSN=test;PWD=password')
cursor =cnxn.cursor()
關(guān)于連接函數(shù)還有更多的選項(xiàng)，可以在pyodbc文檔中的 connect funtion 和 ConnectionStrings查看更多的細(xì)節(jié)
2、數(shù)據(jù)查詢（SQL語句為 select ...from..where）
1）所有的SQL語句都用cursor.execute函數(shù)運(yùn)行。如果語句返回行，比如一個(gè)查詢語句返回的行，你可以通過游標(biāo)的fetch函數(shù)來獲取數(shù)據(jù)，這些函數(shù)有（fetchone,fetchall,fetchmany）.如果返回空行，fetchone函數(shù)將返回None,而fetchall和fetchmany將返回一個(gè)空列。
cursor.execute("select user_id, user_name from users")
row =cursor.fetchone()
if row:
printrow
2）Row這個(gè)類，類似于一個(gè)元組，但是他們也可以通過字段名進(jìn)行訪問。
cursor.execute("select user_id, user_name from users")
row =cursor.fetchone()
print'name:', row[1] # access by column index
print'name:', row.user_name # or access by name
3）如果所有的行都被檢索完，那么fetchone將返回None.
while 1: row= cursor.fetchone() ifnot row: break print'id:', row.user_id
4)使用fetchall函數(shù)時(shí)，將返回所有剩下的行，如果是空行，那么將返回一個(gè)空列。（如果有很多行，這樣做的話將會(huì)占用很多內(nèi)存。未讀取的行將會(huì)被壓縮存放在數(shù)據(jù)庫引擎中，然后由數(shù)據(jù)庫服務(wù)器分批發(fā)送。一次只讀取你需要的行，將會(huì)大大節(jié)省內(nèi)存空間）
cursor.execute("select user_id, user_name from users")
rows =cursor.fetchall()
for row in rows:
printrow.user_id, row.user_name
5）如果你打算一次讀完所有數(shù)據(jù)，那么你可以使用cursor本身。
cursor.execute("select user_id, user_name from users"):
for row in cursor:
printrow.user_id, row.user_name
6）由于cursor.execute返回一個(gè)cursor，所以你可以把上面的語句簡(jiǎn)化成：
for row in cursor.execute("select user_id, user_name from users"):
printrow.user_id, row.user_name
7）有很多SQL語句用單行來寫并不是很方便，所以你也可以使用三引號(hào)的字符串來寫：
cursor.execute("""
select user_id, user_name
from users
where last_logon < '2001-01-01'
and bill_overdue = 'y'
""")
3、參數(shù)
1）ODBC支持在SQL語句中使用一個(gè)問號(hào)來作為參數(shù)。你可以在SQL語句后面加上值，用來傳遞給SQL語句中的問號(hào)。
cursor.execute("""
select user_id, user_name
from users
where last_logon < ?
and bill_overdue = ?
""",'2001-01-01','y')
這樣做比直接把值寫在SQL語句中更加安全，這是因?yàn)槊總€(gè)參數(shù)傳遞給數(shù)據(jù)庫都是單獨(dú)進(jìn)行的。如果你使用不同的參數(shù)而運(yùn)行同樣的SQL語句，這樣做也更加效率。
3）python DB API明確說明多參數(shù)時(shí)可以使用一個(gè)序列來傳遞。pyodbc同樣支持：
cursor.execute("""
select user_id, user_name
from users
where last_logon < ?
and bill_overdue = ?
""", ['2001-01-01','y'])
cursor.execute("select count(*) as user_count from users where age > ?",21)
row =cursor.fetchone()
print'%d users' %row.user_count
4、數(shù)據(jù)插入
1）數(shù)據(jù)插入，把SQL插入語句傳遞給cursor的execute函數(shù)，可以伴隨任何需要的參數(shù)。
cursor.execute("insert into products(id, name) values ('pyodbc', 'awesome library')")
cnxn.commit()
cursor.execute("insert into products(id, name) values (?, ?)",'pyodbc', 'awesome library')
cnxn.commit()
注意調(diào)用cnxn.commit()函數(shù)：你必須調(diào)用commit函數(shù)，否者你對(duì)數(shù)據(jù)庫的所有操作將會(huì)失效！當(dāng)斷開連接時(shí)，所有懸掛的修改將會(huì)被重置。這很容易導(dǎo)致出錯(cuò)，所以你必須記得調(diào)用commit函數(shù)。
5、數(shù)據(jù)修改和刪除
1）數(shù)據(jù)修改和刪除也是跟上面的操作一樣，把SQL語句傳遞給execute函數(shù)。但是我們常常想知道數(shù)據(jù)修改和刪除時(shí)，到底影響了多少條記錄，這個(gè)時(shí)候你可以使用cursor.rowcount的返回值。
cursor.execute("delete from products where id <> ?",'pyodbc')
printcursor.rowcount, 'products deleted'
cnxn.commit()
2）由于execute函數(shù)總是返回cursor，所以有時(shí)候你也可以看到像這樣的語句：（注意rowcount放在最后面）
deleted =cursor.execute("delete from products where id <> 'pyodbc'").rowcount
cnxn.commit()
同樣要注意調(diào)用cnxn.commit()函數(shù)
6、小竅門
1）由于使用單引號(hào)的SQL語句是有效的，那么雙引號(hào)也同樣是有效的：
deleted =cursor.execute("delete from products where id <> 'pyodbc'").rowcount
2）假如你使用的是三引號(hào)，那么你也可以這樣使用：
deleted =cursor.execute("""
delete
from products
where id <> 'pyodbc'
""").rowcount
3）有些數(shù)據(jù)庫（比如SQL Server）在計(jì)數(shù)時(shí)并沒有產(chǎn)生列名，這種情況下，你想訪問數(shù)據(jù)就必須使用下標(biāo)。當(dāng)然你也可以使用"as"關(guān)鍵字來取個(gè)列名（下面SQL語句的"as name-count"）
row =cursor.execute("select count(*) as user_count from users").fetchone()
print'%s users' %row.user_count
4）假如你只是需要一個(gè)值，那么你可以在同一個(gè)行局中使用fetch函數(shù)來獲取行和第一個(gè)列的所有數(shù)據(jù)。
count =cursor.execute("select count(*) from users").fetchone()[0]
print'%s users' %count
如果列為空，將會(huì)導(dǎo)致該語句不能運(yùn)行。fetchone()函數(shù)返回None，而你將會(huì)獲取一個(gè)錯(cuò)誤:NoneType不支持下標(biāo)。如果有一個(gè)默認(rèn)值，你能常常使用ISNULL,或者在SQL數(shù)據(jù)庫直接合并NULLs來覆蓋掉默認(rèn)值。
maxid =cursor.execute("select coalesce(max(id), 0) from users").fetchone()[0]
在這個(gè)例子里面，如果max(id)返回NULL，coalesce(max(id),0)將導(dǎo)致查詢的值為0。
更多關(guān)于Python相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《Python+MySQL數(shù)據(jù)庫程序設(shè)計(jì)入門教程》、《Python常見數(shù)據(jù)庫操作技巧匯總》、《Python數(shù)學(xué)運(yùn)算技巧總結(jié)》、《Python數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Python函數(shù)使用技巧總結(jié)》、《Python字符串操作技巧匯總》、《Python入門與進(jìn)階經(jīng)典教程》及《Python文件與目錄操作技巧匯總》
希望本文所述對(duì)大家Python程序設(shè)計(jì)有所幫助。
相關(guān)文章
這篇文章主要介紹了Python字符串中刪除特定字符的方法，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-01-01
Django創(chuàng)建一個(gè)后臺(tái)的基本步驟記錄
這篇文章主要給大家介紹了關(guān)于Django創(chuàng)建一個(gè)后臺(tái)的基本步驟，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-10-10
這篇文章主要介紹了Python3?中return和yield的區(qū)別，return和yield都用來返回值；在一次性地返回所有值場(chǎng)景中return和yield的作用是一樣的，但是具體有什么區(qū)別呢，帶著疑問一起進(jìn)入下面文章學(xué)習(xí)詳細(xì)內(nèi)容吧2022-06-06
這篇文章主要為大家介紹了python中的變量，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2021-12-12
Python?Asyncio?庫之同步原語常用函數(shù)詳解
這篇文章主要為大家介紹了Python?Asyncio?庫之同步原語常用函數(shù)詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-03-03
這篇文章主要介紹了Python基于Tensor FLow的圖像處理操作,結(jié)合實(shí)例形式分析了Python基于Tensor FLow操作圖像解碼、縮放、剪切、翻轉(zhuǎn)、調(diào)整對(duì)比度、明度、飽和度等相關(guān)操作技巧,需要的朋友可以參考下2020-01-01
PDoc?是一個(gè)強(qiáng)大的?Python?文檔生成工具,它通過解析?Python?代碼中的注釋和類型注解,自動(dòng)生成格式規(guī)范、內(nèi)容豐富的文檔,下面我們就來看看它的具體使用吧2024-11-11
Python的pywifi無線網(wǎng)絡(luò)庫的具體使用
pywifi是一個(gè)基于Python的用于操作無線網(wǎng)絡(luò)的庫，本文就來介紹一下pywifi的安裝及實(shí)際應(yīng)用場(chǎng)景使用，具有一定的參考價(jià)值，感興趣的可以了解一下2024-02-02
這篇文章主要為大家詳細(xì)介紹了python設(shè)計(jì)模式之單例模式，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2022-03-03
這篇文章主要介紹了Python?迭代器Iterator詳情，迭代器可以幫助我們解決面對(duì)復(fù)雜的數(shù)據(jù)場(chǎng)景時(shí)，快速簡(jiǎn)便的獲取數(shù)據(jù)，下文關(guān)于其詳細(xì)介紹，需要的小伙伴可以參考一下2022-07-07