本文實(shí)例講述了python中MySQLdb模塊用法。分享給大家供大家參考。具體用法分析如下：
MySQLdb其實(shí)有點(diǎn)像php或asp中連接數(shù)據(jù)庫的一個(gè)模式了，只是MySQLdb是針對(duì)mysql連接了接口，我們可以在python中連接MySQLdb來實(shí)現(xiàn)數(shù)據(jù)的各種操作。
python連接mysql的方案有oursql、PyMySQL、 myconnpy、MySQL Connector 等，不過本篇要說的確是另外一個(gè)類庫MySQLdb，MySQLdb 是用于Python鏈接Mysql數(shù)據(jù)庫的接口，它實(shí)現(xiàn)了 Python 數(shù)據(jù)庫 API 規(guī)范 V2.0，基于 MySQL C API 上建立的。可以從：https://pypi.python.org/pypi/MySQL-python 進(jìn)行獲取和安裝，而且很多發(fā)行版的linux源里都有該模塊，可以直接通過源安裝。
一、數(shù)據(jù)庫連接
MySQLdb提供了connect方法用來和數(shù)據(jù)庫建立連接,接收數(shù)個(gè)參數(shù),返回連接對(duì)象：
比較常用的參數(shù)包括:
host:數(shù)據(jù)庫主機(jī)名.默認(rèn)是用本地主機(jī)
user:數(shù)據(jù)庫登陸名.默認(rèn)是當(dāng)前用戶
passwd:數(shù)據(jù)庫登陸的秘密.默認(rèn)為空
db:要使用的數(shù)據(jù)庫名.沒有默認(rèn)值
port:MySQL服務(wù)使用的TCP端口.默認(rèn)是3306
charset:數(shù)據(jù)庫編碼
更多關(guān)于參數(shù)的信息可以查這里 http://mysql-python.sourceforge.net/MySQLdb.html
然后,這個(gè)連接對(duì)象也提供了對(duì)事務(wù)操作的支持,標(biāo)準(zhǔn)的方法:
commit() 提交
rollback() 回滾
看一個(gè)簡(jiǎn)單的查詢示例如下：
# encoding: utf-8
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost","root","361way","test" )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# 使用execute方法執(zhí)行SQL語句
cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法獲取一條數(shù)據(jù)庫。
data = cursor.fetchone()
print "Database version : %s " % data
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
腳本執(zhí)行結(jié)果如下：
Database version : 5.5.40
二、cursor方法執(zhí)行與返回值
cursor方法提供兩類操作：1.執(zhí)行命令,2.接收返回值 。
cursor用來執(zhí)行命令的方法
callproc(self, procname, args)
//執(zhí)行單條sql語句,接收的參數(shù)為sql語句本身和使用的參數(shù)列表,返回值為受影響的行數(shù)
execute(self, query, args)
//執(zhí)行單挑sql語句,但是重復(fù)執(zhí)行參數(shù)列表里的參數(shù),返回值為受影響的行數(shù)
executemany(self, query, args)
//移動(dòng)到下一個(gè)結(jié)果集
nextset(self)
cursor用來接收返回值的方法
//接收全部的返回結(jié)果行.
fetchall(self)
//接收size條返回結(jié)果行.如果size的值大于返回的結(jié)果行的數(shù)量,則會(huì)返回cursor.arraysize條數(shù)據(jù)
fetchmany(self, size=None)
//返回一條結(jié)果行
fetchone(self)
//移動(dòng)指針到某一行.如果mode='relative',則表示從當(dāng)前所在行移動(dòng)value條,如果mode='absolute',則表示從結(jié)果集的第一行移動(dòng)value條
scroll(self, value, mode='relative')
//這是一個(gè)只讀屬性，并返回執(zhí)行execute()方法后影響的行數(shù)
rowcount
三、數(shù)據(jù)庫操作
1、創(chuàng)建database tables
如果數(shù)據(jù)庫連接存在我們可以使用execute()方法來為數(shù)據(jù)庫創(chuàng)建表，如下所示創(chuàng)建表EMPLOYEE：
# encoding: utf-8
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost","root","361way","test" )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# 如果數(shù)據(jù)表已經(jīng)存在使用 execute() 方法刪除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
# 創(chuàng)建數(shù)據(jù)表SQL語句
sql = """CREATE TABLE EMPLOYEE (
???????? FIRST_NAME? CHAR(20) NOT NULL,
???????? LAST_NAME? CHAR(20),
???????? AGE INT,
???????? SEX CHAR(1),
???????? INCOME FLOAT )"""
cursor.execute(sql)
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
2、數(shù)據(jù)庫插入操作
# encoding: utf-8
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost","root","361way","test" )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# SQL 插入語句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
???????? LAST_NAME, AGE, SEX, INCOME)
???????? VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
?? # 執(zhí)行sql語句
?? cursor.execute(sql)
?? # 提交到數(shù)據(jù)庫執(zhí)行
?? db.commit()
except:
?? # Rollback in case there is any error
?? db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
這里是一個(gè)單sql 執(zhí)行的示例，cursor.executemany的用法感興趣的讀者可以參看相關(guān)的aws主機(jī)資產(chǎn)管理系統(tǒng)示例。
上例也可以寫成通過占位符傳參的方式進(jìn)行執(zhí)行，如下：
# encoding: utf-8
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# SQL 插入語句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
?????? LAST_NAME, AGE, SEX, INCOME) \
?????? VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
?????? ('Mac', 'Mohan', 20, 'M', 2000)
try:
?? # 執(zhí)行sql語句
?? cursor.execute(sql)
?? # 提交到數(shù)據(jù)庫執(zhí)行
?? db.commit()
except:
?? # 發(fā)生錯(cuò)誤時(shí)回滾
?? db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
也可以以變量的方式傳遞參數(shù)，如下：
user_id = "test"
password = "password123"
con.execute('insert into Login values("%s", "%s")' % \
???????????? (user_id, password))
..................................
3、數(shù)據(jù)庫查詢操作
以查詢EMPLOYEE表中salary（工資）字段大于1000的所有數(shù)據(jù)為例：
# encoding: utf-8
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost","root","361way","test" )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# SQL 查詢語句
sql = "SELECT * FROM EMPLOYEE \
?????? WHERE INCOME > '%d'" % (1000)
try:
?? # 執(zhí)行SQL語句
?? cursor.execute(sql)
?? # 獲取所有記錄列表
?? results = cursor.fetchall()
?? for row in results:
????? fname = row[0]
????? lname = row[1]
????? age = row[2]
????? sex = row[3]
????? income = row[4]
????? # 打印結(jié)果
????? print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
???????????? (fname, lname, age, sex, income )
except:
?? print "Error: unable to fecth data"
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
以上腳本執(zhí)行結(jié)果如下：
fname=Mac, lname=Mohan, age=20, sex=M, income=2000
4、數(shù)據(jù)庫更新操作
更新操作用于更新數(shù)據(jù)表的的數(shù)據(jù)，以下實(shí)例將 test表中的 SEX 字段全部修改為 'M'，AGE 字段遞增1：
#!/usr/bin/python
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost","root","361way","test" )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# SQL 更新語句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1
????????????????????????? WHERE SEX = '%c'" % ('M')
try:
?? # 執(zhí)行SQL語句
?? cursor.execute(sql)
?? # 提交到數(shù)據(jù)庫執(zhí)行
?? db.commit()
except:
?? # 發(fā)生錯(cuò)誤時(shí)回滾
?? db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
5、執(zhí)行事務(wù)
事務(wù)機(jī)制可以確保數(shù)據(jù)一致性。
事務(wù)應(yīng)該具有4個(gè)屬性：原子性、一致性、隔離性、持久性。這四個(gè)屬性通常稱為ACID特性。
① 原子性（atomicity）。一個(gè)事務(wù)是一個(gè)不可分割的工作單位，事務(wù)中包括的諸操作要么都做，要么都不做。
② 一致性（consistency）。事務(wù)必須是使數(shù)據(jù)庫從一個(gè)一致性狀態(tài)變到另一個(gè)一致性狀態(tài)。一致性與原子性是密切相關(guān)的。
③ 隔離性（isolation）。一個(gè)事務(wù)的執(zhí)行不能被其他事務(wù)干擾。即一個(gè)事務(wù)內(nèi)部的操作及使用的數(shù)據(jù)對(duì)并發(fā)的其他事務(wù)是隔離的，并發(fā)執(zhí)行的各個(gè)事務(wù)之間不能互相干擾。
④ 持久性（durability）。持續(xù)性也稱永久性（permanence），指一個(gè)事務(wù)一旦提交，它對(duì)數(shù)據(jù)庫中數(shù)據(jù)的改變就應(yīng)該是永久性的。接下來的其他操作或故障不應(yīng)該對(duì)其有任何影響。
Python DB API 2.0 的事務(wù)提供了兩個(gè)方法 commit 或 rollback。實(shí)例：
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
?? # 執(zhí)行SQL語句
?? cursor.execute(sql)
?? # 向數(shù)據(jù)庫提交
?? db.commit()
except:
?? # 發(fā)生錯(cuò)誤時(shí)回滾
?? db.rollback()
對(duì)于支持事務(wù)的數(shù)據(jù)庫， 在Python數(shù)據(jù)庫編程中，當(dāng)游標(biāo)建立之時(shí)，就自動(dòng)開始了一個(gè)隱形的數(shù)據(jù)庫事務(wù)。commit()方法游標(biāo)的所有更新操作，rollback（）方法回滾當(dāng)前游標(biāo)的所有操作。每一個(gè)方法都開始了一個(gè)新的事務(wù)。
希望本文所述對(duì)大家的Python程序設(shè)計(jì)有所幫助。
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號(hào)聯(lián)系： 360901061
您的支持是博主寫作最大的動(dòng)力，如果您喜歡我的文章，感覺我的文章對(duì)您有幫助，請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點(diǎn)擊下面給點(diǎn)支持吧，站長(zhǎng)非常感激您！手機(jī)微信長(zhǎng)按不能支付解決辦法：請(qǐng)將微信支付二維碼保存到相冊(cè)，切換到微信，然后點(diǎn)擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
