Python操做Mysql實例代碼教程（查詢手冊）

本文介紹了Python操做MYSQL、執行SQL語句、獲取結果集、遍歷結果集、取得某個字段、獲取表字段名、將圖片插入數據庫、執行事務等各類代碼實例和詳細介紹，代碼居多，是一桌豐盛惟美的代碼大餐。

實例一、取得MYSQL的版本

在windows環境下安裝mysql模塊用於python開發，請見另外一篇文章：

MySQL-python Windows下EXE安裝文件下載

# -*- coding: UTF-8 -*-

#安裝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的一個模塊cursor上面運行的
    cur = con.cursor()

    #執行一個查詢
    cur.execute("SELECT VERSION()")

    #取得上個查詢的結果，是單個結果
    data = cur.fetchone()
    print "Database version : %s " % data
finally:
    if con:
        #不管如何，鏈接記得關閉
        con.close()

執行結果：

Database version : 5.5.25

實例二、建立一個表而且插入數據

主要仍是在cursor上面執行execute方法來進行，請見源碼：

# -*- coding: UTF-8 -*-
# 來源於www.crazyant.net總結整理
import MySQLdb as mdb
import sys

#將con設定爲全局鏈接
con = mdb.connect('localhost', 'root', 'root', 'test');

with con:

    #獲取鏈接的cursor，只有獲取了cursor，咱們才能進行各類操做
    cur = con.cursor()
    #建立一個數據表 writers(id,name)
    cur.execute("CREATE TABLE IF NOT EXISTS \
        Writers(Id INT PRIMARY KEY AUTO_INCREMENT, Name VARCHAR(25))")
    #如下插入了5條數據
    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')")

運行結果（在phpmyadmin中查看，在mysql命令行查看結果是同樣的）：

實例三、python使用slect獲取mysql的數據並遍歷

這個恐怕是用的最多的了，請速看代碼：

# -*- coding: UTF-8 -*-
# 來源：www.crazyant.net整理總結
import MySQLdb as mdb
import sys

#鏈接mysql，獲取鏈接的對象
con = mdb.connect('localhost', 'root', 'root', 'test');

with con:
    #仍然是，第一步要獲取鏈接的cursor對象，用於執行查詢
    cur = con.cursor()
    #相似於其餘語言的query函數，execute是python中的執行查詢函數
    cur.execute("SELECT * FROM Writers")

    #使用fetchall函數，將結果集（多維元組）存入rows裏面
    rows = cur.fetchall()

    #依次遍歷結果集，發現每一個元素，就是表中的一條記錄，用一個元組來顯示
    for row in rows:
        print row

運行結果：

(1L, ‘Jack London’)
(2L, ‘Honore de Balzac’)
(3L, ‘Lion Feuchtwanger’)
(4L, ‘Emile Zola’)
(5L, ‘Truman Capote’)

上面的代碼，用來將全部的結果取出，不過打印的時候是每行一個元祖打印，如今咱們使用方法，取出其中的單個數據：

# -*- coding: UTF-8 -*-
# 來源：瘋狂的螞蟻的博客www.crazyant.net總結整理

import MySQLdb as mdb
import sys

#獲取mysql的連接對象
con = mdb.connect('localhost', 'root', 'root', 'test');

with con:
    #獲取執行查詢的對象
    cur = con.cursor()

    #執行那個查詢，這裏用的是select語句
    cur.execute("SELECT * FROM Writers")

    #使用cur.rowcount獲取結果集的條數
    numrows = int(cur.rowcount)

    #循環numrows次，每次取出一行數據
    for i in range(numrows):
        #每次取出一行，放到row中，這是一個元組(id,name)
        row = cur.fetchone()
        #直接輸出兩個元素
        print row[0], row[1]

運行結果：

1 Jack London
2 Honore de Balzac
3 Lion Feuchtwanger
4 Emile Zola
5 Truman Capote

• numrows = int(cur.rowcount)用於獲取結果集的數目
• row = cur.fetchone()每次取出一行數據，同時記錄集的指針執行下一行

實例四、使用字典cursor取得結果集（可使用表字段名字訪問值）

# -*- coding: UTF-8 -*-
# 來源：瘋狂的螞蟻的博客www.crazyant.net總結整理

import MySQLdb as mdb
import sys

#得到mysql查詢的連接對象
con = mdb.connect('localhost', 'root', 'root', 'test')

with con:
    #獲取鏈接上的字典cursor，注意獲取的方法，
    #每個cursor其實都是cursor的子類
    cur = con.cursor(mdb.cursors.DictCursor)

    #執行語句不變
    cur.execute("SELECT * FROM Writers")

    #獲取數據方法不變
    rows = cur.fetchall()

    #遍歷數據也不變（比上一個更直接一點）
    for row in rows:
        #這裏，可使用鍵值對的方法，由鍵名字來獲取數據
        print "%s %s" % (row["Id"], row["Name"])

實例五、獲取單個表的字段名和信息的方法

# -*- coding: UTF-8 -*-
# 來源：瘋狂的螞蟻的博客www.crazyant.net總結整理

import MySQLdb as mdb
import sys

#獲取數據庫的連接對象
con = mdb.connect('localhost', 'root', 'root', 'test')

with con:
    #獲取普通的查詢cursor
    cur = con.cursor()
    cur.execute("SELECT * FROM Writers")

    rows = cur.fetchall()

    #獲取鏈接對象的描述信息
    desc = cur.description
    print 'cur.description:',desc

    #打印表頭，就是字段名字
    print "%s %3s" % (desc[0][0], desc[1][0])

    for row in rows:
        #打印結果
        print "%2s %3s" % row

運行結果：

cur.description: ((‘Id’, 3, 1, 11, 11, 0, 0), (‘Name’, 253, 17, 25, 25, 0, 1))
Id Name
1 Jack London
2 Honore de Balzac
3 Lion Feuchtwanger
4 Emile Zola
5 Truman Capote

實例六、使用Prepared statements執行查詢（更安全方便）

# -*- coding: UTF-8 -*-
# 來源：瘋狂的螞蟻的博客www.crazyant.net總結整理
import MySQLdb as mdb
import sys

con = mdb.connect('localhost', 'root', 'root', 'test')

with con:    

    cur = con.cursor()
    #咱們看到，這裏能夠經過寫一個能夠組裝的sql語句來進行
    cur.execute("UPDATE Writers SET Name = %s WHERE Id = %s",
        ("Guy de Maupasant", "4"))
    #使用cur.rowcount獲取影響了多少行
    print "Number of rows updated: %d" % cur.rowcount

結果：

Number of rows updated: 1

實例七、把圖片用二進制存入MYSQL

有人喜歡把圖片存入MYSQL（這種作法貌似不多吧），我看大部分的程序，圖片都是存放在服務器上的文件，數據庫中存的只是圖片的地址而已，不過MYSQL是支持把圖片存入數據庫的，也相應的有一個專門的字段BLOB (Binary Large Object)，即較大的二進制對象字段，請看以下程序，注意測試圖片本身隨便找一個，地址要正確：

首先，在數據庫中建立一個表，用於存放圖片：

CREATE TABLE Images(Id INT PRIMARY KEY AUTO_INCREMENT, Data MEDIUMBLOB);

而後運行以下PYTHON代碼進行：

# -*- coding: UTF-8 -*-
# 來源：瘋狂的螞蟻的博客www.crazyant.net總結整理
import MySQLdb as mdb
import sys

try:
    #用讀文件模式打開圖片
    fin = open("../web.jpg")
    #將文本讀入img對象中
    img = fin.read()
    #關閉文件
    fin.close()

except IOError, e:
    #若是出錯，打印錯誤信息
    print "Error %d: %s" % (e.args[0],e.args[1])
    sys.exit(1)

try:
    #連接mysql，獲取對象
    conn = mdb.connect(host='localhost',user='root',passwd='root', db='test')
    #獲取執行cursor
    cursor = conn.cursor()
    #直接將數據做爲字符串，插入數據庫
    cursor.execute("INSERT INTO Images SET Data='%s'" % mdb.escape_string(img))

    #提交數據
    conn.commit()

    #提交以後，再關閉cursor和連接
    cursor.close()
    conn.close()

except mdb.Error, e:
    #若出現異常，打印信息
    print "Error %d: %s" % (e.args[0],e.args[1])
    sys.exit(1)

結果：

• escape_string函數將插入數據庫的字符串進行轉義，這會指一些SQL注入的攻擊

實例八、從數據庫中把圖片讀出來

# -*- coding: UTF-8 -*-
# 來源：瘋狂的螞蟻的博客www.crazyant.net總結整理
import MySQLdb as mdb
import sys

try:
    #鏈接mysql，獲取鏈接的對象
    conn = mdb.connect('localhost', 'root', 'root', 'test');

    cursor = conn.cursor()

    #執行查詢該圖片字段的SQL
    cursor.execute("SELECT Data FROM Images LIMIT 1")

    #使用二進制寫文件的方法，打開一個圖片文件，若不存在則自動建立
    fout = open('image.png','wb')
    #直接將數據如文件
    fout.write(cursor.fetchone()[0])
    #關閉寫入的文件
    fout.close()

    #釋放查詢數據的資源
    cursor.close()
    conn.close()

except IOError, e:
    #捕獲IO的異常 ，主要是文件寫入會發生錯誤
    print "Error %d: %s" % (e.args[0],e.args[1])
    sys.exit(1)

實例九、使用Transaction即事務（手動提交，自動回滾）

# -*- coding: UTF-8 -*-
# 來源：瘋狂的螞蟻的博客www.crazyant.net總結整理
import MySQLdb as mdb
import sys

try:
    #鏈接mysql，獲取鏈接的對象
    conn = mdb.connect('localhost', 'root', 'root', 'test');

    cursor = conn.cursor()
    #若是某個數據庫支持事務，會自動開啓
    #這裏用的是MYSQL，因此會自動開啓事務（如果MYISM引擎則不會）
    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"))   

    #事務的特性一、原子性的手動提交
    conn.commit()

    cursor.close()
    conn.close()

except mdb.Error, e:
    #若是出現了錯誤，那麼能夠回滾，就是上面的三條語句要麼執行，要麼都不執行
    conn.rollback()
    print "Error %d: %s" % (e.args[0],e.args[1])

結果：

一、由於不存在writer表（SQL第三條語句），因此出現錯誤：

Error 1146: Table ‘test.writer’ doesn’t exist

二、出現錯誤，出發異常處理，3條語句的前兩條會自動變成了沒有執行，結果不變

三、若是本代碼放到一個MyISAM引擎表，前兩句會執行，第三句不會；若是是INNDB引擎，則都不會執行。

全文完，本文翻譯自：http://zetcode.com/databases/mysqlpythontutorial/