Python數據庫編程(MySQL)

Python DB API作用

背景：沒有Python DB API之前，接口程序混亂！

---

當應用程序想切換不同的的數據庫時，由於程序接口的混亂所帶來的代價是非常大的。為此，Python 官方規范訪問數據庫的接口，防止在使用不同數據庫時造成的問題。這個官方規范的接口叫做 Python DB API 。該接口的說明文檔在這

有了這接口帶來的好處不言而喻，大大方便數據庫的訪問，開發只需要學習了API，就可以以少量的修改為代價進行不同數據庫的切換。

---

Python DB API包含的內容

API中主要的模塊如下：

各模塊的作用可以用一張圖表示如下：

Python DB API訪問數據庫流程

pymysql 和 MySQLdb

pymysql 是在 Python3.x 和 2.x 版本中用於連接 MySQL 服務器的一個庫，Python2中則使用mysqldb。

pymysql 遵循 Python 數據庫 API v2.0 規范，並包含了 pure-Python MySQL 客戶端庫。下面便以 pymysql 為例，對於其他數據庫同樣的有着 pysql、pymongo 等等。

---

pymysql 安裝

在使用 pymysql 之前，我們需要確保 pymysql 已安裝。

pymysql 下載地址：https://github.com/PyMySQL/PyMySQL。

如果還未安裝，我們可以使用以下命令安裝最新版的 pymysql：

$ pip install PyMySQL

MySQLdb 安裝

從 sourceforge 網站下載

安裝很簡單就不說了

pymysql測試

In [1]: import pymysql

connection對象

生成對象的方法：pymysql.connect，方法參數如下：

---

connection 對象支持的方法：

測試如下：

# -*- coding: utf-8 -*- import pymysql db_connection = pymysql.connect( host='127.0.0.1', user='xxxx', password='xxxx', database='python2test', charset='utf8' ) cursors = db_connection.cursor() if __name__ == '__main__': print(db_connection) print(cursors)

運行結果：

<pymysql.connections.Connection object at 0x0000000004EFD358> <pymysql.cursors.Cursor object at 0x00000000050F4518>

cursor對象

游標對象：用於執行查詢和獲取結果

cursor對象支持的方法：

其中execute方法：執行SQL將結果從數據庫獲取到客戶端的過程如下：

fetch*（）方法的過程如下：

執行簡單查詢數據庫的版本

# -*- coding: utf-8 -*- import pymysql db_connection = pymysql.connect( host='127.0.0.1', user='xxxx', password='xxxx', database='python2test', charset='utf8' ) # 使用 cursor() 方法創建一個游標對象 cursor cursors = db_connection.cursor() # 使用 execute() 方法執行 SQL 查詢 cursors.execute("SELECT VERSION()") # 使用 fetchone() 方法獲取單條數據. data = cursors.fetchone() print ("Database version : %s " % data) # 關閉數據庫連接 db_connection.close()

運行結果：

Database version : 5.5.53 

創建數據庫表

# -*- coding: utf-8 -*- import pymysql # 打開數據庫連接 db = pymysql.connect( host='127.0.0.1', user='XXXX', password='XXXX', database='python2test', charset='utf8' ) # 使用 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()

運行結果：

創建之前查詢數據庫中存在的表如下：

mysql> USE PYTHON2TEST; Database changed mysql> SHOW TABLES; Empty set (0.00 sec)

創建之后查詢數據庫中存在的表如下：

mysql> SHOW TABLES;
+-----------------------+ | Tables_in_python2test | +-----------------------+ | employee | +-----------------------+ 1 row in set (0.00 sec)

數據庫插入操作

# encoding:utf-8 import pymysql # 打開數據庫連接 db = pymysql.connect( host='127.0.0.1', user='xxxx', password='xxxx', database='python2test', charset='utf8' ) # 使用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() print("插入成功！") except: # 如果發生錯誤則回滾 db.rollback() print("插入失敗！") # 關閉數據庫連接 db.close()

運行結果：

運行之前的查詢的結果：

mysql> SELECT * FROM EMPLOYEE; Empty set (0.00 sec)

運行之后的查詢的結果：

mysql> SELECT * FROM EMPLOYEE;
+------------+-----------+------+------+--------+ | FIRST_NAME | LAST_NAME | AGE | SEX | INCOME | +------------+-----------+------+------+--------+ | Mac | Mohan | 20 | M | 2000 | +------------+-----------+------+------+--------+ 1 row in set (0.00 sec)

數據庫查詢操作

Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。

• fetchone(): 該方法獲取下一個查詢結果集。結果集是一個對象
• fetchall(): 接收全部的返回結果行.
• rowcount: 這是一個只讀屬性，並返回執行execute()方法后影響的行數。

# encoding:utf-8 import pymysql # 打開數據庫連接 db = pymysql.connect( host='127.0.0.1', user='root', password='root', database='python2test', charset='utf8' ) # 使用cursor()方法獲取操作游標 cursor = db.cursor() # SQL 查詢語句 sql = "SELECT * FROM EMPLOYEE \  WHERE INCOME > '%d'" % (1000) try: # 執行SQL語句 cursor.execute(sql) # 獲取所有記錄列表 results = cursor.fetchall() print("FIRST_NAME\tLAST_NAME\tAGE\tSEX\tINCOME |") for row in results: fname = row[0] lname = row[1] age = row[2] sex = row[3] income = row[4] # 打印結果 print("%s\t\t\t%s\t\t\t%d\t%s\t%d" % (fname, lname, age, sex, income)) except: print("Error: unable to fetch data") # 關閉數據庫連接 db.close()

運行結果：

FIRST_NAME LAST_NAME AGE SEX INCOME | TIC TOC 20 M 2000 ONE INF 20 M 10000 [Finished in 0.2s]

數據庫更新操作

# encoding:utf-8 import pymysql # 打開數據庫連接 db = pymysql.connect( host='127.0.0.1', user='root', password='root', database='python2test', charset='utf8' ) # 使用cursor()方法獲取操作游標 cursor = db.cursor() # SQL 更新語句 sql = "UPDATE EMPLOYEE SET INCOME = INCOME * 1.2 WHERE SEX = '%c'" % ('M') try: # 執行SQL語句 cursor.execute(sql) # 提交到數據庫執行 db.commit() except: # 發生錯誤時回滾 db.rollback() # 關閉數據庫連接 db.close()

運行結果：

mysql> SELECT * FROM EMPLOYEE; +------------+-----------+------+------+--------+ | FIRST_NAME | LAST_NAME | AGE | SEX | INCOME | +------------+-----------+------+------+--------+ | TIC | TOC | 20 | M | 2400 | | ONE | INF | 20 | M | 12000 | +------------+-----------+------+------+--------+ 2 rows in set (0.00 sec)

刪除操作

# encoding:utf-8 import pymysql # 打開數據庫連接 db = pymysql.connect( host='127.0.0.1', user='root', password='root', database='python2test', charset='utf8' ) # 使用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），指一個事務一旦提交，它對數據庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。

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

# SQL 刪除語句 sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20) try: # 執行SQL語句，只是在緩沖區中得到更改 cursor.execute(sql) # 提交修改到數據庫之中 db.commit() except: # 發生錯誤時回滾 db.rollback() # 關閉連接 db.close()

對於支持事務的數據庫， 在Python數據庫編程中，當游標建立之時，就自動開始了一個隱形的數據庫事務。

commit()方法游標的所有更新操作，rollback（）方法回滾當前游標的所有操作。每一個方法都開始了一個新的事務。

錯誤處理

DB API中定義了一些數據庫操作的錯誤及異常，下表列出了這些錯誤和異常:

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

原博：https://www.cnblogs.com/oneTOinf/p/8306390.html