# -*- coding: UTF-8 -*-#安裝 MYSQL DB for pythonimport MySQLdb as mdbcon = Nonetry:  #連接 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 " % datafinally:  if con:    #無(wú)論如何，連接記得關(guān)閉    con.close()

import MySQLdb as mdbimport sys#將 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')")

import MySQLdb as mdbimport sys#連接 mysql，獲取連接的對(duì)象con = mdb.connect('localhost', 'root', 'root', 'test');with con:#仍然是，第一步要獲取連接的 cursor 對(duì)象，用于執(zhí)行查詢cur = con.cursor()#類似于其他語(yǔ)言的 query 函數(shù)， execute 是 python 中的執(zhí)行查詢函數(shù)cur.execute("SELECT * FROM Writers")#使用 fetchall 函數(shù)，將結(jié)果集（多維元組）存入 rows 里面rows = cur.fetchall()#依次遍歷結(jié)果集，發(fā)現(xiàn)每個(gè)元素，就是表中的一條記錄，用一個(gè)元組來(lái)顯示for row in rows:print row

import MySQLdb as mdbimport sys#獲取 mysql 的鏈接對(duì)象con = mdb.connect('localhost', 'root', 'root', 'test');with con:#獲取執(zhí)行查詢的對(duì)象cur = con.cursor()#執(zhí)行那個(gè)查詢，這里用的是 select 語(yǔ)句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]

import MySQLdb as mdbimport sys#獲得 mysql 查詢的鏈接對(duì)象con = mdb.connect('localhost', 'root', 'root', 'test')with con:#獲取連接上的字典 cursor，注意獲取的方法，#每一個(gè) cursor 其實(shí)都是 cursor 的子類cur = con.cursor(mdb.cursors.DictCursor)#執(zhí)行語(yǔ)句不變cur.execute("SELECT * FROM Writers")#獲取數(shù)據(jù)方法不變r(jià)ows = cur.fetchall()#遍歷數(shù)據(jù)也不變（比上一個(gè)更直接一點(diǎn)）for row in rows:#這里，可以使用鍵值對(duì)的方法，由鍵名字來(lái)獲取數(shù)據(jù)print "%s %s" % (row["Id"], row["Name"])

import MySQLdb as mdbimport sys#獲取數(shù)據(jù)庫(kù)的鏈接對(duì)象con = mdb.connect('localhost', 'root', 'root', 'test')with con:#獲取普通的查詢 cursorcur = con.cursor()cur.execute("SELECT * FROM Writers")rows = cur.fetchall()#獲取連接對(duì)象的描述信息desc = cur.descriptionprint 'cur.description:',desc#打印表頭，就是字段名字print "%s %3s" % (desc[0][0], desc[1][0])for row in rows:#打印結(jié)果print "%2s %3s" % row

import MySQLdb as mdbimport syscon = mdb.connect('localhost', 'root', 'root', 'test')with con:cur = con.cursor()#我們看到，這里可以通過(guò)寫一個(gè)可以組裝的 sql 語(yǔ)句來(lái)進(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

import MySQLdb as mdbimport systry:#用讀文件模式打開(kāi)圖片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í)行 cursorcursor = conn.cursor()#直接將數(shù)據(jù)作為字符串，插入數(shù)據(jù)庫(kù)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)

import MySQLdb as mdbimport systry:#連接 mysql，獲取連接的對(duì)象conn = mdb.connect('localhost', 'root', 'root', 'test');cursor = conn.cursor()#執(zhí)行查詢?cè)搱D片字段的 SQLcursor.execute("SELECT Data FROM Images LIMIT 1")#使用二進(jìn)制寫文件的方法，打開(kāi)一個(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)

import MySQLdb as mdbimport systry:#連接 mysql，獲取連接的對(duì)象conn = mdb.connect('localhost', 'root', 'root', 'test');cursor = conn.cursor()#如果某個(gè)數(shù)據(jù)庫(kù)支持事務(wù)，會(huì)自動(dòng)開(kāi)啟#這里用的是 MYSQL，所以會(huì)自動(dòng)開(kāi)啟事務(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ò)誤，那么可以回滾，就是上面的三條語(yǔ)句要么執(zhí)行，要么都不執(zhí)行conn.rollback()print "Error %d: %s" % (e.args[0],e.args[1])