實(shí)例1、取得MYSQL的版本
在windows環(huán)境下安裝mysql模塊用于python開發(fā)
MySQL-python Windows下EXE安裝文件下載
#安裝MYSQL DB for python
import MySQLdb as mdb
con = None
try:
#連接mysql的方法:connect('ip','user','password','dbname')
con = mdb.connect('localhost', 'root',
'root', 'test');
#所有的查詢,都在連接con的一個(gè)模塊cursor上面運(yùn)行的
cur = con.cursor()
#執(zhí)行一個(gè)查詢
cur.execute("SELECT VERSION()")
#取得上個(gè)查詢的結(jié)果,是單個(gè)結(jié)果
data = cur.fetchone()
print "Database version : %s " % data
finally:
if con:
#無論如何,連接記得關(guān)閉
con.close()
實(shí)例2、創(chuàng)建一個(gè)表并且插入數(shù)據(jù)
主要還是在cursor上面執(zhí)行execute方法來進(jìn)行,請(qǐng)見源碼:
#將con設(shè)定為全局連接
con = mdb.connect('localhost', 'root', 'root', 'test');
with con:
#獲取連接的cursor,只有獲取了cursor,我們才能進(jìn)行各種操作
cur = con.cursor()
#創(chuàng)建一個(gè)數(shù)據(jù)表 writers(id,name)
cur.execute("CREATE TABLE IF NOT EXISTS /
Writers(Id INT PRIMARY KEY AUTO_INCREMENT, Name VARCHAR(25))")
#以下插入了5條數(shù)據(jù)
cur.execute("INSERT INTO Writers(Name) VALUES('Jack London')")
cur.execute("INSERT INTO Writers(Name) VALUES('Honore de Balzac')")
cur.execute("INSERT INTO Writers(Name) VALUES('Lion Feuchtwanger')")
cur.execute("INSERT INTO Writers(Name) VALUES('Emile Zola')")
cur.execute("INSERT INTO Writers(Name) VALUES('Truman Capote')")

這個(gè)恐怕是用的最多的了,請(qǐng)速看代碼:
#連接mysql,獲取連接的對(duì)象
con = mdb.connect('localhost', 'root', 'root', 'test');
with con:
#仍然是,第一步要獲取連接的cursor對(duì)象,用于執(zhí)行查詢
cur = con.cursor()
#類似于其他語言的query函數(shù),execute是python中的執(zhí)行查詢函數(shù)
cur.execute("SELECT * FROM Writers")
#使用fetchall函數(shù),將結(jié)果集(多維元組)存入rows里面
rows = cur.fetchall()
#依次遍歷結(jié)果集,發(fā)現(xiàn)每個(gè)元素,就是表中的一條記錄,用一個(gè)元組來顯示
for row in rows:
print row
上面的代碼,用來將所有的結(jié)果取出,不過打印的時(shí)候是每行一個(gè)元祖打印,現(xiàn)在我們使用方法,取出其中的單個(gè)數(shù)據(jù):
import MySQLdb as mdb
import sys
#獲取mysql的鏈接對(duì)象
con = mdb.connect('localhost', 'root', 'root', 'test');
with con:
#獲取執(zhí)行查詢的對(duì)象
cur = con.cursor()
#執(zhí)行那個(gè)查詢,這里用的是select語句
cur.execute("SELECT * FROM Writers")
#使用cur.rowcount獲取結(jié)果集的條數(shù)
numrows = int(cur.rowcount)
#循環(huán)numrows次,每次取出一行數(shù)據(jù)
for i in range(numrows):
#每次取出一行,放到row中,這是一個(gè)元組(id,name)
row = cur.fetchone()
#直接輸出兩個(gè)元素
print row[0], row[1]
numrows = int(cur.rowcount)用于獲取結(jié)果集的數(shù)目
row = cur.fetchone()每次取出一行數(shù)據(jù),同時(shí)記錄集的指針執(zhí)行下一行
實(shí)例4、使用字典cursor取得結(jié)果集(可以使用表字段名字訪問值)
import MySQLdb as mdb
import sys
#獲得mysql查詢的鏈接對(duì)象
con = mdb.connect('localhost', 'root', 'root', 'test')
with con:
#獲取連接上的字典cursor,注意獲取的方法,
#每一個(gè)cursor其實(shí)都是cursor的子類
cur = con.cursor(mdb.cursors.DictCursor)
#執(zhí)行語句不變
cur.execute("SELECT * FROM Writers")
#獲取數(shù)據(jù)方法不變
rows = cur.fetchall()
#遍歷數(shù)據(jù)也不變(比上一個(gè)更直接一點(diǎn))
for row in rows:
#這里,可以使用鍵值對(duì)的方法,由鍵名字來獲取數(shù)據(jù)
print "%s %s" % (row["Id"], row["Name"])
實(shí)例5、獲取單個(gè)表的字段名和信息的方法
import MySQLdb as mdb
import sys
#獲取數(shù)據(jù)庫的鏈接對(duì)象
con = mdb.connect('localhost', 'root', 'root', 'test')
with con:
#獲取普通的查詢cursor
cur = con.cursor()
cur.execute("SELECT * FROM Writers")
rows = cur.fetchall()
#獲取連接對(duì)象的描述信息
desc = cur.description
print 'cur.description:',desc
#打印表頭,就是字段名字
print "%s %3s" % (desc[0][0], desc[1][0])
for row in rows:
#打印結(jié)果
print "%2s %3s" % row
實(shí)例6、使用Prepared statements執(zhí)行查詢(更安全方便)
con = mdb.connect('localhost', 'root', 'root', 'test')
with con:
cur = con.cursor()
#我們看到,這里可以通過寫一個(gè)可以組裝的sql語句來進(jìn)行
cur.execute("UPDATE Writers SET Name = %s WHERE Id = %s",
("Guy de Maupasant", "4"))
#使用cur.rowcount獲取影響了多少行
print "Number of rows updated: %d" % cur.rowcount
結(jié)果:
實(shí)例7、把圖片用二進(jìn)制存入MYSQL
有人喜歡把圖片存入MYSQL(這種做法貌似很少吧),我看大部分的程序,圖片都是存放在服務(wù)器上的文件,數(shù)據(jù)庫中存的只是圖片的地址而已,不過MYSQL是支持把圖片存入數(shù)據(jù)庫的,也相應(yīng)的有一個(gè)專門的字段BLOB (Binary Large Object),即較大的二進(jìn)制對(duì)象字段,請(qǐng)看如下程序,注意測(cè)試圖片自己隨便找一個(gè),地址要正確:
首先,在數(shù)據(jù)庫中創(chuàng)建一個(gè)表,用于存放圖片:
然后運(yùn)行如下PYTHON代碼進(jìn)行:
try:
#用讀文件模式打開圖片
fin = open("../web.jpg")
#將文本讀入img對(duì)象中
img = fin.read()
#關(guān)閉文件
fin.close()
except IOError, e:
#如果出錯(cuò),打印錯(cuò)誤信息
print "Error %d: %s" % (e.args[0],e.args[1])
sys.exit(1)
try:
#鏈接mysql,獲取對(duì)象
conn = mdb.connect(host='localhost',user='root',passwd='root', db='test')
#獲取執(zhí)行cursor
cursor = conn.cursor()
#直接將數(shù)據(jù)作為字符串,插入數(shù)據(jù)庫
cursor.execute("INSERT INTO Images SET Data='%s'" % mdb.escape_string(img))
#提交數(shù)據(jù)
conn.commit()
#提交之后,再關(guān)閉cursor和鏈接
cursor.close()
conn.close()
except mdb.Error, e:
#若出現(xiàn)異常,打印信息
print "Error %d: %s" % (e.args[0],e.args[1])
sys.exit(1)

escape_string函數(shù)將插入數(shù)據(jù)庫的字符串進(jìn)行轉(zhuǎn)義,這會(huì)指一些SQL注入的攻擊
實(shí)例8、從數(shù)據(jù)庫中把圖片讀出來
try:
#連接mysql,獲取連接的對(duì)象
conn = mdb.connect('localhost', 'root', 'root', 'test');
cursor = conn.cursor()
#執(zhí)行查詢?cè)搱D片字段的SQL
cursor.execute("SELECT Data FROM Images LIMIT 1")
#使用二進(jìn)制寫文件的方法,打開一個(gè)圖片文件,若不存在則自動(dòng)創(chuàng)建
fout = open('image.png','wb')
#直接將數(shù)據(jù)如文件
fout.write(cursor.fetchone()[0])
#關(guān)閉寫入的文件
fout.close()
#釋放查詢數(shù)據(jù)的資源
cursor.close()
conn.close()
except IOError, e:
#捕獲IO的異常 ,主要是文件寫入會(huì)發(fā)生錯(cuò)誤
print "Error %d: %s" % (e.args[0],e.args[1])
sys.exit(1)
try:
#連接mysql,獲取連接的對(duì)象
conn = mdb.connect('localhost', 'root', 'root', 'test');
cursor = conn.cursor()
#如果某個(gè)數(shù)據(jù)庫支持事務(wù),會(huì)自動(dòng)開啟
#這里用的是MYSQL,所以會(huì)自動(dòng)開啟事務(wù)(若是MYISM引擎則不會(huì))
cursor.execute("UPDATE Writers SET Name = %s WHERE Id = %s",
("Leo Tolstoy", "1"))
cursor.execute("UPDATE Writers SET Name = %s WHERE Id = %s",
("Boris Pasternak", "2"))
cursor.execute("UPDATE Writer SET Name = %s WHERE Id = %s",
("Leonid Leonov", "3"))
#事務(wù)的特性1、原子性的手動(dòng)提交
conn.commit()
cursor.close()
conn.close()
except mdb.Error, e:
#如果出現(xiàn)了錯(cuò)誤,那么可以回滾,就是上面的三條語句要么執(zhí)行,要么都不執(zhí)行
conn.rollback()
print "Error %d: %s" % (e.args[0],e.args[1])
1、因?yàn)椴淮嬖趙riter表(SQL第三條語句),所以出現(xiàn)錯(cuò)誤:
Error 1146: Table ‘test.writer' doesn't exist
2、出現(xiàn)錯(cuò)誤,出發(fā)異常處理,3條語句的前兩條會(huì)自動(dòng)變成了沒有執(zhí)行,結(jié)果不變
3、如果本代碼放到一個(gè)MyISAM引擎表,前兩句會(huì)執(zhí)行,第三句不會(huì);如果是INNDB引擎,則都不會(huì)執(zhí)行。
為方便大家本地瀏覽特提供一個(gè)pdf版本下載
全文完,本文翻譯自:http://zetcode.com/databases/mysqlpythontutorial/
新聞熱點(diǎn)
疑難解答
圖片精選