python中MySQLdb模塊用法實例

更新時間：2014年11月10日 12:54:16 投稿：shichen2014

這篇文章主要介紹了python中MySQLdb模塊用法,以實例形式詳細講述了MySQLdb模塊針對MySQL數據庫的各種常見操作方法,非常具有實用價值,需要的朋友可以參考下

本文實例講述了python中MySQLdb模塊用法。分享給大家供大家參考。具體用法分析如下：

MySQLdb其實有點像php或asp中連接數據庫的一個模式了，只是MySQLdb是針對mysql連接了接口，我們可以在python中連接MySQLdb來實現數據的各種操作。

python連接mysql的方案有oursql、PyMySQL、 myconnpy、MySQL Connector 等，不過本篇要說的確是另外一個類庫MySQLdb，MySQLdb 是用于Python鏈接Mysql數據庫的接口，它實現了 Python 數據庫 API 規(guī)范 V2.0，基于 MySQL C API 上建立的。可以從：https://pypi.python.org/pypi/MySQL-python 進行獲取和安裝，而且很多發(fā)行版的linux源里都有該模塊，可以直接通過源安裝。

一、數據庫連接

MySQLdb提供了connect方法用來和數據庫建立連接,接收數個參數,返回連接對象：

復制代碼代碼如下:

conn=MySQLdb.connect(host="localhost",user="root",passwd="jb51",db="test",charset="utf8")

比較常用的參數包括:
host:數據庫主機名.默認是用本地主機
user:數據庫登陸名.默認是當前用戶
passwd:數據庫登陸的秘密.默認為空
db:要使用的數據庫名.沒有默認值
port:MySQL服務使用的TCP端口.默認是3306
charset:數據庫編碼
更多關于參數的信息可以查這里 http://mysql-python.sourceforge.net/MySQLdb.html

然后,這個連接對象也提供了對事務操作的支持,標準的方法:
commit() 提交
rollback() 回滾

看一個簡單的查詢示例如下：

復制代碼代碼如下:

#!/usr/bin/python

# encoding: utf-8

import MySQLdb

# 打開數據庫連接

db = MySQLdb.connect("localhost","root","361way","test" )

# 使用cursor()方法獲取操作游標

cursor = db.cursor()

# 使用execute方法執(zhí)行SQL語句

cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法獲取一條數據庫。

data = cursor.fetchone()

print "Database version : %s " % data

# 關閉數據庫連接

db.close()

腳本執(zhí)行結果如下：
Database version : 5.5.40

二、cursor方法執(zhí)行與返回值

cursor方法提供兩類操作：1.執(zhí)行命令,2.接收返回值。
cursor用來執(zhí)行命令的方法

復制代碼代碼如下:

//用來執(zhí)行存儲過程,接收的參數為存儲過程名和參數列表,返回值為受影響的行數

callproc(self, procname, args)

//執(zhí)行單條sql語句,接收的參數為sql語句本身和使用的參數列表,返回值為受影響的行數

execute(self, query, args)

//執(zhí)行單挑sql語句,但是重復執(zhí)行參數列表里的參數,返回值為受影響的行數

executemany(self, query, args)

//移動到下一個結果集

nextset(self)

cursor用來接收返回值的方法

//接收全部的返回結果行.

fetchall(self)

//接收size條返回結果行.如果size的值大于返回的結果行的數量,則會返回cursor.arraysize條數據

fetchmany(self, size=None)

//返回一條結果行

fetchone(self)

//移動指針到某一行.如果mode='relative',則表示從當前所在行移動value條,如果mode='absolute',則表示從結果集的第一行移動value條

scroll(self, value, mode='relative')

//這是一個只讀屬性，并返回執(zhí)行execute()方法后影響的行數

rowcount

三、數據庫操作

1、創(chuàng)建database tables
如果數據庫連接存在我們可以使用execute()方法來為數據庫創(chuàng)建表，如下所示創(chuàng)建表EMPLOYEE：

復制代碼代碼如下:

#!/usr/bin/python

# encoding: utf-8

import MySQLdb

# 打開數據庫連接

db = MySQLdb.connect("localhost","root","361way","test" )

# 使用cursor()方法獲取操作游標

cursor = db.cursor()

# 如果數據表已經存在使用 execute() 方法刪除表。

cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 創(chuàng)建數據表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)

# 關閉數據庫連接

db.close()

2、數據庫插入操作

復制代碼代碼如下:

#!/usr/bin/python

# encoding: utf-8

import MySQLdb

# 打開數據庫連接

db = MySQLdb.connect("localhost","root","361way","test" )

# 使用cursor()方法獲取操作游標

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)

   # 提交到數據庫執(zhí)行

   db.commit()

except:

   # Rollback in case there is any error

   db.rollback()

# 關閉數據庫連接

db.close()

這里是一個單sql 執(zhí)行的示例，cursor.executemany的用法感興趣的讀者可以參看相關的aws主機資產管理系統(tǒng)示例。
上例也可以寫成通過占位符傳參的方式進行執(zhí)行，如下：

復制代碼代碼如下:

#!/usr/bin/python

# encoding: utf-8

import MySQLdb

# 打開數據庫連接

db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法獲取操作游標

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)

   # 提交到數據庫執(zhí)行

   db.commit()

except:

   # 發(fā)生錯誤時回滾

   db.rollback()

# 關閉數據庫連接

db.close()

也可以以變量的方式傳遞參數，如下：

復制代碼代碼如下:

..................................

user_id = "test"

password = "password123"

con.execute('insert into Login values("%s", "%s")' % \

             (user_id, password))

..................................

3、數據庫查詢操作
以查詢EMPLOYEE表中salary（工資）字段大于1000的所有數據為例：

復制代碼代碼如下:

#!/usr/bin/python

# encoding: utf-8

import MySQLdb

# 打開數據庫連接

db = MySQLdb.connect("localhost","root","361way","test" )

# 使用cursor()方法獲取操作游標

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]

      # 打印結果

      print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \

             (fname, lname, age, sex, income )

except:

   print "Error: unable to fecth data"

# 關閉數據庫連接

db.close()

以上腳本執(zhí)行結果如下：
fname=Mac, lname=Mohan, age=20, sex=M, income=2000

4、數據庫更新操作
更新操作用于更新數據表的的數據，以下實例將 test表中的 SEX 字段全部修改為 'M'，AGE 字段遞增1：

復制代碼代碼如下:

# encoding: utf-8

#!/usr/bin/python

import MySQLdb

# 打開數據庫連接

db = MySQLdb.connect("localhost","root","361way","test" )

# 使用cursor()方法獲取操作游標

cursor = db.cursor()

# SQL 更新語句

sql = "UPDATE EMPLOYEE SET AGE = AGE + 1

                          WHERE SEX = '%c'" % ('M')

try:

   # 執(zhí)行SQL語句

   cursor.execute(sql)

   # 提交到數據庫執(zhí)行

   db.commit()

except:

   # 發(fā)生錯誤時回滾

   db.rollback()

# 關閉數據庫連接

db.close()

5、執(zhí)行事務

事務機制可以確保數據一致性。
事務應該具有4個屬性：原子性、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。
① 原子性（atomicity）。一個事務是一個不可分割的工作單位，事務中包括的諸操作要么都做，要么都不做。
② 一致性（consistency）。事務必須是使數據庫從一個一致性狀態(tài)變到另一個一致性狀態(tài)。一致性與原子性是密切相關的。
③ 隔離性（isolation）。一個事務的執(zhí)行不能被其他事務干擾。即一個事務內部的操作及使用的數據對并發(fā)的其他事務是隔離的，并發(fā)執(zhí)行的各個事務之間不能互相干擾。
④ 持久性（durability）。持續(xù)性也稱永久性（permanence），指一個事務一旦提交，它對數據庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。

Python DB API 2.0 的事務提供了兩個方法 commit 或 rollback。實例：

復制代碼代碼如下:

# SQL刪除記錄語句

sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)

try:

   # 執(zhí)行SQL語句

   cursor.execute(sql)

   # 向數據庫提交

   db.commit()

except:

   # 發(fā)生錯誤時回滾

   db.rollback()

對于支持事務的數據庫，在Python數據庫編程中，當游標建立之時，就自動開始了一個隱形的數據庫事務。commit()方法游標的所有更新操作，rollback（）方法回滾當前游標的所有操作。每一個方法都開始了一個新的事務。

希望本文所述對大家的Python程序設計有所幫助。

您可能感興趣的文章:

Python+FuzzyWuzzy實現模糊匹配的示例詳解
在日常開發(fā)工作中，經常會遇到這樣的一個問題：要對數據中的某個字段進行匹配，但這個字段有可能會有微小的差異。本文將分享一個簡單易用的模糊字符串匹配工具包：FuzzyWuzzy，讓你輕松解決煩惱的匹配問題
2022-04-04
Python+PyQt5實現滅霸響指功能
這篇文章主要介紹了Python+PyQt5實現滅霸響指功能，本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
2020-05-05
Python實現的爬取網易動態(tài)評論操作示例
這篇文章主要介紹了Python實現的爬取網易動態(tài)評論操作,結合實例形式分析了Python針對網易評論正則爬取及json格式數據轉換、提取等相關操作技巧,需要的朋友可以參考下
2018-06-06
Python中if語句的使用方法詳解
if語句用來表示某種可能的情況，并如何處理該情況。if語句可以用來表示一種可能性、兩種可能性或者多種可能性，這篇文章主要介紹了Python中if語句的使用方法,需要的朋友可以參考下
2023-03-03
Python庫AutoTS一行代碼得到最強時序基線
AutoTS它是一個用于自動時間序列分析的 Python 庫。AutoTS 允許我們用一行代碼訓練多個時間序列模型，以便我們可以選擇最適合的模型，今天介紹一種非常霸道的工具，融合了自動化機器學習技術開發(fā)的AutoTS
2022-03-03
Python爬蟲之Scrapy環(huán)境搭建案例教程
這篇文章主要介紹了Python爬蟲之Scrapy環(huán)境搭建案例教程,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內容,需要的朋友可以參考下
2021-07-07
Flask項目的部署的實現步驟
本文主要介紹了Flask項目的部署的實現步驟，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2022-04-04
python有幾個版本
在本篇內容里小編給大家分享的是關于python版本的相關知識點內容，需要的朋友們可以學習下。
2020-06-06
Python 類方法和實例方法(@classmethod)，靜態(tài)方法(@staticmethod)原理與用法分析
這篇文章主要介紹了Python 類方法和實例方法(@classmethod)，靜態(tài)方法(@staticmethod),結合實例形式分析了Python 類方法和實例方法及靜態(tài)方法相關原理、用法及相關操作注意事項,需要的朋友可以參考下
2019-09-09
python實現坦克大戰(zhàn)游戲附詳細注釋
這篇文章主要為大家詳細介紹了python實現坦克大戰(zhàn)游戲，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2019-05-05