python接口自動化（三十八）-python操做mysql數據庫（詳解）

時間  2019-11-18
標籤 python 接口 自動化 三十八 mysql 數據庫 詳解 欄目 Python 简体版
原文   原文鏈接

簡介

　　如今的招聘要求對QA人員的要求愈來愈高，測試的一些基礎知識就沒必要說了，來講測試知識之外的，會不會一門或者多門開發與語言，能不能讀懂代碼，會不會Linux，會不會搭建測試系統，會不會經常使用的數據庫，會不會SQL等等，所以咱們這篇文章來說解如何用java

python語言操做mysql數據庫。python

 本科階段曾學過使用java對MySQL數據庫進行操做，基本思路是先鏈接數據庫，而後執行SQL語句對數據庫進行操做，最後打印結果並斷開鏈接。使用Python操做數據庫的流程和以上過程基本一致，在對其進行介紹以前，先介紹一些基本的概念。mysql

基本概念

python操做數據庫的流程

以流程圖的方式展現python操做MySQL數據庫的流程：git

　　對上圖的解讀：首先檢查是否依次建立Connection對象（數據庫鏈接對象）用於打開數據庫鏈接，建立Cursor對象（遊標對象）用於執行查詢和獲取結果；而後執行SQL語句對數據庫進行增刪改查等操做並提交事務，此過程若是出現異常則使用回滾技術使數據庫恢github

復到執行SQL語句以前的狀態；最後，依次銷燬Cursor對象和Connection對象，以免多計算機內存過多的佔用和浪費。sql

　　下面依次對Connection對象、Cursor對象和事務等概念進行介紹。數據庫

Connection對象

Connection對象即爲數據庫鏈接對象，在python中可使用pymysql.connect()方法建立Connection對象，該方法的經常使用參數以下：編程

host：鏈接的數據庫服務器主機名，默認爲本地主機（localhost）；字符串類型（String） 。bootstrap

user：用戶名，默認爲當前用戶；字符串類型（String） 。服務器

passwd：密碼，無默認值；字符串類 （String）。

db：數據庫名稱，無默認值；字符串類型（String） 。

port：指定數據庫服務器的鏈接端口，默認爲3306；整型（int）。

charset：鏈接字符集；字符串類型（String）

Connection對象經常使用的方法以下：

cursor()：使用當前鏈接建立並返回遊標 。

commit()：提交當前事務 。

rollback()：回滾當前事務 。

close()：關閉當前鏈接

Cursor對象

Cursor對象即爲遊標對象，用於執行查詢和獲取結果，在python中可使用conn.cursor()建立，conn爲Connection對象。Cursor對象經常使用的方法和屬性以下：

execute()：執行數據庫查詢或命令，將結果從數據庫獲取到客戶端 fetchone()：獲取結果集的下一行 fetchmany()：獲取結果集的下幾行 fetchall()：獲取結果集中剩下的全部行 close()：關閉當前遊標對象 rowcount：最近一次的execute返回數據的行數或受影響的行數

事務

一、事務機制能夠確保數據一致性。

事務是數據庫理論中一個比較重要的概念，指訪問和更新數據庫的一個程序執行單元，具備ACID特性：

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

在開發時，咱們以如下三種方式使用事務：

正常結束事務：conn.commit() 異常結束事務：conn.rollback() 關閉自動commit：設置 conn.autocommit(False)

2 、使用python實現對MySQL數據庫的增刪改查等操做

在python中操做MySQL數據庫時，要使用的模塊是：

Python2中：mysqldb（pip2 install mysqldb） Python3中：pymysql（pip3 install pymysql）

本篇博客所使用的環境爲：

python 3.7 win 10 pycharm 2018.3.5 pymysql 0.9.2 mysql 5.6 

下面將以具體代碼的形式依次介紹python中如何實現對MySQL數據庫的增刪改查等操做。

python操做數據庫

Python 標準數據庫接口爲 Python DB-API，Python DB-API爲開發人員提供了數據庫應用編程接口。

Python 數據庫接口支持很是多的數據庫，你能夠選擇適合你項目的數據庫：

  • GadFly
  • mSQL
  • MySQL（小公司、小廠首選）
  • PostgreSQL
  • Microsoft SQL Server 2008（中型廠、中等公司首選）
  • Informix
  • Interbase
  • Oracle（大廠、大企業首選）
  • Sybase

你能夠訪問Python數據庫接口及API查看詳細的支持數據庫列表。

不一樣的數據庫你須要下載不一樣的DB API模塊，例如你須要訪問Oracle數據庫和Mysql數據，你須要下載Oracle和MySQL數據庫模塊。

DB-API 是一個規範. 它定義了一系列必須的對象和數據庫存取方式, 以便爲各類各樣的底層數據庫系統和多種多樣的數據庫接口程序提供一致的訪問接口 。

Python的DB-API，爲大多數的數據庫實現了接口，使用它鏈接各數據庫後，就能夠用相同的方式操做各數據庫。

Python DB-API使用流程：

  • 引入 API 模塊。
  • 獲取與數據庫的鏈接。
  • 執行SQL語句和存儲過程。
  • 關閉數據庫鏈接。

什麼是MySQLdb?

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

PyMySQL 遵循 Python 數據庫 API v2.0 規範，幷包含了 pure-Python MySQL 客戶端庫。

如何安裝MySQLdb?

在使用 PyMySQL 以前，咱們須要確保 PyMySQL 已安裝。

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

若是還未安裝，咱們可使用如下命令安裝最新版的 PyMySQL：

1 pip install PyMySQL

 

若是你的系統不支持 pip 命令，可使用如下方式安裝：

一、使用 git 命令下載安裝包安裝(你也能夠手動下載)：

1 git clone https://github.com/PyMySQL/PyMySQL
2 cd PyMySQL/
3 python3 setup.py install

二、若是須要制定版本號，可使用 curl 命令來安裝：

1 # X.X 爲 PyMySQL 的版本號
2 url -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz
3 cd PyMySQL*
4 python3 setup.py install
5 # 如今你能夠刪除 PyMySQL* 目錄

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

安裝的過程當中可能會出現"ImportError: No module named setuptools"的錯誤提示，意思是你沒有安裝setuptools，你能夠訪問https://pypi.python.org/pypi/setuptools 找到各個系統的安裝方法。

Linux 系統安裝實例：

1 $ wget https://bootstrap.pypa.io/ez_setup.py
2 $ python3 ez_setup.py

數據庫鏈接

鏈接數據庫前，請先確認如下事項：

  • 您已經建立了數據庫 TESTDB（測試數據庫）
  • 在TESTDB數據庫中您已經建立了表 EMPLOYEE（測試用的測試表）
  • EMPLOYEE表字段爲 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
  • 鏈接數據庫TESTDB（測試數據庫）使用的用戶名爲 "testuser" ，密碼爲 "test123",你能夠能夠本身設定或者直接使用root用戶名及其密碼，Mysql數據庫用戶受權請使用Grant命令。
  • 在你的機子上已經安裝了 Python MySQLdb 模塊。
  • 若是你對sql語句不熟悉，能夠本身先簡單的學習一下

一、查看有沒有建立數據庫TESTDB（測試數據庫），打開MySQL的client界面輸入密碼 後，輸入命令：

1 show databases;

二、看到沒有那個數據庫，那咱們就開始建立一個TESTDB數據庫，輸入命令：

1 create database TESTDB;

三、再次輸入第一步的命令查看，看到已經成功建立

 

四、查看TESTDB數據庫裏，有沒有EMPLOYEE（測試用的測試表），輸入命令：

1 use testdb;
2 show tables;

五、查看到在TESTDB數據庫中沒有EMPLOYEE表，那麼沒有咱們就建立一張EMPLOYEE表便可。

建立一個實例

運行結果：（從結果中咱們能夠看見成功建立了一個Connection和Cursor對象。）

下面將以具體代碼的形式依次介紹python中如何實現對MySQL數據庫的增刪改查等操做。

實例：

一、鏈接數據庫

運行結果：

參考代碼：

 1 # coding=utf-8
 2 # 1.先設置編碼，utf-8可支持中英文，如上，通常放在第一行
 3 
 4 # 2.註釋：包括記錄建立時間，建立人，項目名稱。
 5 '''
 6 Created on 2019-5-22
 7 @author: 北京-宏哥
 8 Project:學習和使用python操做MySQL數據庫
 9 '''
10 # 3.導入模塊
11 import pymysql
12 
13 import pymysql
14 
15 # 打開數據庫鏈接
16 conn = pymysql.connect('localhost', 'root', 'root', 'testdb')
17 
18 # 使用cursor()方法建立一個遊標對象
19 cursor = conn.cursor()
20 
21 # 使用execute()方法執行SQL查詢
22 cursor.execute('SELECT VERSION()')
23 
24 # 使用fetchone()方法獲取單條數據
25 data = cursor.fetchone()
26 
27 # 打印
28 print('database version: %s' % data)
29 
30 # 關閉數據庫鏈接
31 conn.close()

二、建立數據庫表

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

運行代碼後查看有沒有表建立，輸入命令：

1 use TESTDB；
2 show tables;

運行結果：

參考代碼：

 1 # coding=utf-8
 2 # 1.先設置編碼，utf-8可支持中英文，如上，通常放在第一行
 3 
 4 # 2.註釋：包括記錄建立時間，建立人，項目名稱。
 5 '''
 6 Created on 2019-5-22
 7 @author: 北京-宏哥
 8 Project:學習和使用python操做MySQL數據庫
 9 '''
10 # 3.導入模塊
11 import pymysql
12 
13 import pymysql
14 
15 # 打開數據庫鏈接
16 conn = pymysql.connect('localhost', 'root', 'root', 'testdb')
17 
18 # 使用cursor()方法建立一個遊標對象cursor
19 cursor = conn.cursor()  # 遊標對象用於執行查詢和獲取結果
20 
21 # 使用execute()方法執行SQL，若是表存在則將其刪除
22 cursor.execute('DROP TABLE IF EXISTS EMPLOYEE')
23 
24 # 使用預處理語句建立表
25 sql = """CREATE TABLE `employee` (
26   `first_name` varchar(255) DEFAULT NULL COMMENT '姓',
27   `last_name` varchar(255) DEFAULT NULL COMMENT '名',
28   `age` int(11) DEFAULT NULL COMMENT '年齡',
29   `sex` varchar(255) DEFAULT NULL COMMENT '性別',
30   `income` varchar(255) DEFAULT NULL COMMENT '收入'
31 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
32 """
33 
34 # 執行SQL語句
35 cursor.execute(sql)
36 
37 # 關閉數據庫鏈接
38 conn.close()

三、數據庫插入操做

如下實例使用執行 SQL INSERT 語句向表 EMPLOYEE 插入記錄：

一、首先查詢有沒有記錄輸入查詢語句：

1 select * from employee;

二、代碼實現

運行結果：

再次查看有沒有記錄，輸入第一步的sql語句：（能夠看到插入一條記錄）

參考代碼：

# coding=utf-8
# 1.先設置編碼，utf-8可支持中英文，如上，通常放在第一行

# 2.註釋：包括記錄建立時間，建立人，項目名稱。
'''
Created on 2019-5-22
@author: 北京-宏哥
Project:學習和使用python操做MySQL數據庫
'''
# 3.導入模塊
import pymysql

import pymysql

# 打開數據庫鏈接
conn = pymysql.connect('localhost', 'root', 'root', 'testdb')

# 使用cursor()方法獲取操做遊標
cursor = conn.cursor()

# SQL語句：向數據表中插入數據
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""

# 異常處理
try:
    # 執行SQL語句
    cursor.execute(sql)
    # 提交事務到數據庫執行
    conn.commit()  # 事務是訪問和更新數據庫的一個程序執行單元
except:
    # 若是發生錯誤則執行回滾操做
    conn.rollback()

# 關閉數據庫鏈接
conn.close()

另外一種寫法：

# coding=utf-8
# 1.先設置編碼，utf-8可支持中英文，如上，通常放在第一行

# 2.註釋：包括記錄建立時間，建立人，項目名稱。
'''
Created on 2019-5-22
@author: 北京-宏哥
Project:學習和使用python操做MySQL數據庫
'''
# 3.導入模塊
import pymysql

import pymysql

# 打開數據庫鏈接
conn = pymysql.connect('localhost', 'root', 'root', 'testdb')

# 使用cursor()方法獲取操做遊標
cursor = conn.cursor()

# SQL語句：向數據表中插入數據
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES ('%s', '%s',  %s,  '%s',  %s)" % \
       ('Mac', 'Mohan', 20, 'M', 2000)
# 異常處理
try:
    # 執行SQL語句
    cursor.execute(sql)
    # 提交事務到數據庫執行
    conn.commit()  # 事務是訪問和更新數據庫的一個程序執行單元
except:
    # 若是發生錯誤則執行回滾操做
    conn.rollback()

# 關閉數據庫鏈接
conn.close()

實例：

如下代碼使用變量向SQL語句中傳遞參數:

1 ..................................
2 user_id = "root"
3 password = "root"
4 
5 con.execute('insert into Login values( %s,  %s)' % \
6              (user_id, password))
7 ..................................

三、數據庫查詢操做

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

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

實例：

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

運行結果：

參考代碼：

 1 # coding=utf-8
 2 # 1.先設置編碼，utf-8可支持中英文，如上，通常放在第一行
 3 
 4 # 2.註釋：包括記錄建立時間，建立人，項目名稱。
 5 '''
 6 Created on 2019-5-22
 7 @author: 北京-宏哥
 8 Project:學習和使用python操做MySQL數據庫
 9 '''
10 # 3.導入模塊
11 import pymysql
12 
13 import pymysql
14 
15 # 打開數據庫鏈接
16 conn = pymysql.connect('localhost', 'root', 'root', 'testdb')
17 
18 # 使用cursor()方法獲取操做遊標
19 cursor = conn.cursor()
20 
21 # SQL語句：查詢
22 sql = "SELECT * FROM employee WHERE income > 1000 "
23 
24 # 異常處理
25 try:
26     # 執行SQL語句
27     cursor.execute(sql)
28     # 獲取全部的記錄列表
29     results = cursor.fetchall()
30     # 遍歷列表
31     for row in results:
32         # 打印列表元素
33         print(row)
34         # 姓
35         first_name = row[0]
36         # 名
37         last_name = row[1]
38         # 年齡
39         age = row[2]
40         # 性別
41         sex = row[3]
42         # 收入
43         income = row[4]
44         # 打印列表元素
45         print(first_name, last_name, age, sex, income)
46 except:
47     print('Uable to fetch data!')
48 
49 # 關閉數據庫鏈接
50 conn.close()

四、數據庫更新操做

更新操做用於更新數據表的的數據，如下實例將 EMPLOYEE 表中的 SEX 字段爲 'M' 的 AGE 字段遞增 5：

一、之前age是20，

二、代碼實現：

三、運行結果：

四、查詢age變動到25了沒有

五、參考代碼：

# coding=utf-8
# 1.先設置編碼，utf-8可支持中英文，如上，通常放在第一行

# 2.註釋：包括記錄建立時間，建立人，項目名稱。
'''
Created on 2019-5-22
@author: 北京-宏哥
Project:學習和使用python操做MySQL數據庫
'''
# 3.導入模塊
import pymysql

import pymysql

# 打開數據庫鏈接
conn = pymysql.connect('localhost', 'root', 'root', 'testdb')

# 使用cursor()方法獲取操做遊標
cursor = conn.cursor()

# SQL語句，執行更新操做
sql = 'UPDATE employee SET age = age + 5 WHERE sex = "M"'

# 異常處理
try:
    # 執行SQL語句
    cursor.execute(sql)
    # 提交到數據庫執行
    conn.commit()
except:
    # 發生錯誤時回滾
    conn.rollback()

# 關閉數據庫鏈接
conn.close()

五、刪除操做

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

一、大於20的只有一條，刪除了就沒有記錄了，輸入

1  select * from employee;

二、代碼實現

 

三、運行結果

四、查看數據庫表，重複第一步

 

五、參考代碼

 1 # coding=utf-8
 2 # 1.先設置編碼，utf-8可支持中英文，如上，通常放在第一行
 3 
 4 # 2.註釋：包括記錄建立時間，建立人，項目名稱。
 5 '''
 6 Created on 2019-5-22
 7 @author: 北京-宏哥
 8 Project:學習和使用python操做MySQL數據庫
 9 '''
10 # 3.導入模塊
11 import pymysql
12 
13 import pymysql
14 
15 # 打開數據庫鏈接
16 conn = pymysql.connect('localhost', 'root', 'root', 'testdb')
17 
18 # 使用cursor()方法獲取操做遊標
19 cursor = conn.cursor()
20 
21 # SQL語句，執行刪除操做
22 sql = 'DELETE FROM employee WHERE age >20'
23 
24 # 異常處理
25 try:
26     # 執行SQL語句
27     cursor.execute(sql)
28     # 提交到數據庫執行
29     conn.commit()
30 except:
31     # 發生錯誤時回滾
32     conn.rollback()
33 
34 # 關閉數據庫鏈接
35 conn.close()

執行事務

事務機制能夠確保數據一致性。

事務應該具備4個屬性：原子性、一致性、隔離性、持久性。這四個屬性一般稱爲ACID特性。

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

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

實例：

 1 # SQL刪除記錄語句
 2 sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
 3 try:
 4    # 執行SQL語句
 5    cursor.execute(sql)
 6    # 向數據庫提交
 7    db.commit()
 8 except:
 9    # 發生錯誤時回滾
10    db.rollback()

對於支持事務的數據庫， 在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的子類。

小結

 　　哈哈，終於搞完了、整完了，累死寶寶了，已到半夜，明天有時間分享！！！

　　小夥伴python操做MySQL數據庫就是這麼簡單！！！最重要的本身要會、要有紮實的SQL基礎。

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程