Python3出現"No module named 'MySQLdb'"問題-以及使用PyMySQL鏈接數據庫

 

Python3 與 Django 鏈接數據庫，出現了報錯：Error loading MySQLdb module: No module named 'MySQLdb'。緣由以下：
在 python2 中，使用 pip install mysql-python 進行安裝鏈接MySQL的庫，使用時 import MySQLdb 進行使用；
在 python3 中，改變了鏈接庫，改成了 pymysql 庫，使用pip install pymysql 進行安裝，直接導入便可使用；
可是在 Django 中， 鏈接數據庫時使用的是 MySQLdb 庫，這在與 python3 的合做中就會報如下錯誤了：

django.core.exceptions.ImproperlyConfigured: Error loading MySQLdb module: No module named 'MySQLdb'

解決方法：在 __init__.py 文件中添加如下代碼便可

import pymysql
pymysql.install_as_MySQLdb()

找了一下卻沒有找到 install_as_MySQLdb() 這個方法的源碼，不過顧名思義應該是讓 Django 把 pymysql 當成 MySQLdb 來使用吧.出現這個問題多是另一個很基本的緣由，就是沒有安裝相關庫，這個直接用 pip 安裝就能夠了.

==========================================================================================
什麼是PyMySQL
PyMySQL是Python3.x版本中用於鏈接MySQL服務器的一個庫，Python2.x中則使用mysqldb。

PyMySQL安裝
在使用PyMySQL以前，咱們須要確保PyMySQL已經安裝。
PyMySQL下載地址：https://github.com/PyMySQL/PyMySQL
若是還未安裝，咱們可使用如下命令安裝最新版的PyMySQL：

$ pip install PyMySQL

若是你的系統不支持pip命令，可使用如下方式安裝：
1）使用git命令下載安裝包安裝（也能夠手動下載）

$ git clone https://github.com/PyMySQL/PyMySQL
$ cd PyMySQL
$ python3 setup.py install

2）若是須要制定版本號，可使用curl命令來安裝

# X.X 爲PyMySQL 的版本號
$ curl -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz
$ cd PyMySQL*
$ python3 setup.py install

注意：請確保您有root權限來安裝上述模塊。

數據庫鏈接
鏈接數據庫前，請先確認如下事項：
-  已經建立數據庫TESTDB
-  在TESTDB數據庫中您已經建立了表EMPLOYEE
-  EMPLOYEE表字段爲FIRST_NAME,LAST_NAME,AGE,SEX和INCOME
-  鏈接數據庫TESTDB使用的用戶名爲「testuser」，密碼爲「test123」，能夠本身設定或者直接使用root用戶名及其密碼，Mysql數據庫用戶受權請使用Grant命令
-  在你的機子上已經安裝了PyMySQL模塊

實例說明
如下實例連接Mysql的TESTDB數據庫：

#!/usr/bin/python3
__author__ = 'mayi'
 
import pymysql
 
# 打開數據庫鏈接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用 cursor() 方法建立一個遊標對象 cursor
cursor = db.cursor()
 
# 使用 execute() 方法執行 SQL 查詢 
cursor.execute("SELECT VERSION()")
 
# 使用 fetchone() 方法獲取單條數據.
data = cursor.fetchone()
 
print ("Database version : %s " % data)
 
# 關閉數據庫鏈接
db.close()

建立數據庫表
若是數據庫鏈接存在咱們可使用execute()方法來爲數據庫建立表，以下所示建立表EMPLOYEE：

#!/usr/bin/python3
__author__ = 'mayi'
 
import pymysql
 
# 打開數據庫鏈接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用 cursor() 方法建立一個遊標對象 cursor
cursor = db.cursor()
 
# 使用 execute() 方法執行 SQL，若是表存在則刪除
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
 
# 使用預處理語句建立表
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()

數據庫插入操做
如下實例使用執行SQL Insert語句向表EMPLOYEE插入記錄：

#!/usr/bin/python3
__author__ = 'mayi'
 
import pymysql
 
# 打開數據庫鏈接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用cursor()方法獲取操做遊標 
cursor = db.cursor()
 
# SQL 插入語句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
 LAST_NAME, AGE, SEX, INCOME)
 VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
 # 執行sql語句
 cursor.execute(sql)
 # 提交到數據庫執行
 db.commit()
except:
 # 若是發生錯誤則回滾
 db.rollback()
 
# 關閉數據庫鏈接
db.close()

以上例子也能夠寫成以下形式：

#!/usr/bin/python3
__author__ = 'mayi'
 
import pymysql
 
# 打開數據庫鏈接
db = pymysql.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:
 # 執行sql語句
 cursor.execute(sql)
 # 執行sql語句
 db.commit()
except:
 # 發生錯誤時回滾
 db.rollback()
 
# 關閉數據庫鏈接
db.close()

數據庫查詢操做
Python查詢Mysql使用fetchone()方法獲取單條數據，使用fetchall()方法獲取多條數據。
-  fetchone()：該方法獲取下一個查詢結果集。結果集是一個對象
-  fetchall()：接收所有的返回結果行
-  rowcount：這是一個只讀屬性，並返回執行execute()方法後影響的行數

實例說明：
查詢EMPLOYEE表中salary（工資）字段大於1000的全部數據：

#!/usr/bin/python3
__author__ = 'mayi'
 
import pymysql
 
# 打開數據庫鏈接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用cursor()方法獲取操做遊標 
cursor = db.cursor()
 
# SQL 查詢語句
sql = "SELECT * FROM EMPLOYEE \
 WHERE INCOME > '%d'" % (1000)
try:
 # 執行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()

數據庫更新操做
更新操做用於更新數據表的數據，如下實例將TESTDB表中的SEX字段所有修改成'M'，AGE字段遞增1：

#!/usr/bin/python3
__author__ = 'mayi'
 
import pymysql
 
# 打開數據庫鏈接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用cursor()方法獲取操做遊標 
cursor = db.cursor()
 
# SQL 更新語句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1
 WHERE SEX = '%c'" % ('M')
try:
 # 執行SQL語句
 cursor.execute(sql)
 # 提交到數據庫執行
 db.commit()
except:
 # 發生錯誤時回滾
 db.rollback()
 
# 關閉數據庫鏈接
db.close()

刪除操做
刪除操做用於刪除數據表中的數據，如下實例演示了刪除數據表EMPLOYEE中AGE大於20的全部數據：

#!/usr/bin/python3
__author__ = 'mayi'
 
import pymysql
 
# 打開數據庫鏈接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用cursor()方法獲取操做遊標 
cursor = db.cursor()
 
# SQL 刪除語句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
 # 執行SQL語句
 cursor.execute(sql)
 # 提交修改
 db.commit()
except:
 # 發生錯誤時回滾
 db.rollback()
 
# 關閉鏈接
db.close()

執行事務
事務機制可
事務應該具備4個屬性：原子性、一致性、隔離性、持久性。這四個屬性一般稱爲ACID特性。
-  原子性（atomicity）。一個事務是一個不可分割的工做單位，事務中包括的諸操做要麼都作，要麼都不作。
-  一致性（consistency）。事務必須是使數據庫從一個一致性狀態變到另外一個一致性狀態。一致性與原子性是密切相關的。
-  隔離性（isolation）。一個事務的執行不能被其餘事務干擾。即一個事務內部的操做及使用的數據對併發的其餘事務是隔離的，併發執行的各個事務之間不能互相干擾。
-  持久性（durability）。持續性也稱永久性（permanence），指一個事務一旦提交，它對數據庫中數據的改變就應該是永久性的。接下來的其餘操做或故障不該該對其有任何影響。

實例說明：

# SQL刪除記錄語句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
 # 執行SQL語句
 cursor.execute(sql)
 # 向數據庫提交
 db.commit()
except:
 # 發生錯誤時回滾
 db.rollback()

對於支持事務的數據庫，在Python數據庫編程中，當遊標創建之時，就自動開始了一個隱形的數據庫事務。
commit()方法遊標的全部更新操做，rollback()方法回滾當前遊標的全部操做。每個方法都開始了一個新的事務。

錯誤處理

異常	描述
Warning	當有嚴重警告時觸發，例如插入數據是被截斷等等。必須是StandardError的子類。
Error	警告之外全部其餘錯誤類。必須是StandardError的子類。
InterfaceError	當有數據庫接口模塊自己的錯誤（而不是數據庫的錯誤）發生時觸發。必須是Error的子類。
DatabaseError	和數據庫有關的錯誤發生時觸發。必須是Error的子類。
DataError	當有數據處理時的錯誤發生時觸發，例如：除零錯誤，數據超範圍等等。必須是DatabaseError的子類。
OperationalError	指非用戶控制的，而是操做數據庫時發生的錯誤。例如：鏈接意外斷開、數據庫名未找到、事務處理失敗、內存分配錯誤等等操做數據庫是發生的錯誤。必須是DatabaseError的子類。
IntegrityError	完整性相關的錯誤，例如外鍵檢查失敗等。必須是DatabaseError子類。
InternamError	數據庫的內部錯誤，例如遊標（cursor）失效了、事務同步失敗等等。必須是DatabaseError子類。
ProgrammingError	程序錯誤，例如數據表（table）沒找到或已存在、SQL語句語法錯誤、參數數量錯誤等等。必須是DatabaseError的子類。
NotSupportedError	不支持錯誤，指使用了數據庫不支持的函數或API等。例如在鏈接對象上使用rollback()函數，然而數據庫並不支持事務或者事務已關閉。必須是DatabaseError的子類。