在第一季滾雪球學 python 中，我們已經接觸了 python 操作 sqlite，本篇博客為你介紹 python 與 mysql 和 nosql 之間的故事。

在正式學習之前，先確保你電腦上已經安裝了 mysql 。

mysql 的安裝博客：補充知識：2021 年 mysql 最新 windows 安裝教程，滾雪球學 python 第四季。

mysql 一些簡單命令

對于 mysql 的細致學習，咱們應該多帶帶開一個系列，這個 flag 先立下了，本文為了學習 python 操作 mysql 數據庫，只能先做一些基本鋪墊。

查看所有數據庫

show databases;

查看幫助

help

退出 mysql

exit

創建數據庫

create database cadb;

刪除數據庫

drop database cadb;

使用某個數據庫

use cadb;

查看庫表

show tables;

查看表結構

desc 表名;

除了上述內容外，你還要學習建表語句，刪表語句，表中插入數據語句，表刪除數據語句，表更新數據語句，這些稍后在 python 操作 mysql 中進行實現。

python 操作 mysql

操作數據庫一般被程序員成為 CRUD 操作（增刪改查），其中各個字符分別代表 C（Create） 新增，R（Read） 讀取，U（Update） 更新，D（Delete） 刪除。

在 python3 中推薦使用 pymysql 模塊操作數據庫，模塊使用命令 pip install PyMySQL 進行安裝。

在此之前，先通過 MySQL Command Line Client 創建一個表用來做測試。

新建庫，新建表，插入數據 命令依次如下

show databases;create database cadb;use cadb;-- 建表語句create table user(name varchar(10),uid int,primary key(uid));desc user;

接下來在表中插入 2 條數據。

insert into user(name,uid) values ("橡皮擦",1);insert into user(name,uid) values ("CSDN",2);

簡單的查詢 sql 如下所示：

select * from user;

下面就可以在 python 中編寫操作該庫表的相關代碼了，數據庫鏈接步驟如下：

1. 連接數據庫，生成連接對象；
2. 創建游標對象，用于訪問數據表；
3. 執行 sql 語句；
4. 關閉游標；
5. 關閉連接。

python 查詢數據
python 連接數據庫獲取數據

import pymysql# python 連接數據庫，返回數據庫連接對象conn = pymysql.connect(host="127.0.0.1", user="root", password="xiangpica", database="cadb", charset="utf8")print(conn)

輸出連接對象如下所示：

<pymysql.connections.Connection object at 0x00000000021E2F60>

其中 connect 方法相關的參數可以依據名稱進行判斷。

接下來就是創建游標，提取數據。

# 通過 cursor() 創建游標對象，并讓查詢結果以字典格式輸出cur = conn.cursor(cursor=pymysql.cursors.DictCursor)# 輸出 

下一步使用游標對象 cur 的 execute 方法執行 sql。

cur.execute("select * from user")

最后通過相關方法獲取查詢結果，本案例獲取所有用戶使用 fetchall 方法。

# 獲取查詢結果data = cur.fetchall()

輸入數據庫檢索的所有數據。

[{"name": "橡皮擦", "uid": 1}, {"name": "CSDN", "uid": 2}]

關閉游標，關閉連接

# 關閉游標cur.close()# 關閉數據庫連接conn.close()

接下來我們將其修改的復雜一些，檢索特定數據，例如 uid=1 的數據，并且用到上下文管理器 with 進行對象的關閉。

第一種寫法

import pymysql# python 連接數據庫，返回數據庫連接對象conn = pymysql.connect(host="127.0.0.1", user="root", password="xiangpica", database="cadb", charset="utf8")# print(conn)with conn.cursor(cursor=pymysql.cursors.DictCursor) as cur:    cur.execute("select * from user where uid = %s", 1)    # 獲取查詢結果    data = cur.fetchall()    print(data)# 關閉數據庫連接conn.close()

第二種寫法

import pymysql# python 連接數據庫，返回數據庫連接對象conn = pymysql.connect(host="127.0.0.1", user="root", password="xiangpica", database="cadb", charset="utf8")# print(conn)with conn.cursor(cursor=pymysql.cursors.DictCursor) as cur:    cur.execute("select * from user where uid = %(uid)s", {"uid": 1})    # 獲取查詢結果    data = cur.fetchall()    print(data)# 關閉數據庫連接conn.close()

兩種寫法，在 execute 方法參數存在差異，可直接對比學習。

python 更新數據表數據
接下來演示的是使用 python 去更新表數據，例如將 uid = 2 的 name 列更新為 Code。

import pymysql# python 連接數據庫，返回數據庫連接對象conn = pymysql.connect(host="127.0.0.1", user="root", password="xiangpica", database="cadb", charset="utf8")# print(conn)with conn.cursor(cursor=pymysql.cursors.DictCursor) as cur:    try:        cur.execute("update user set name =%s where uid = %s", ["Code", 2])        conn.commit()  # 提交事務    except Exception as e:        print("數據更新異常", e)        conn.rollback()  # 數據回滾# 關閉數據庫連接conn.close()

上述代碼核心為在執行 SQL 操作之后，需要使用事務處理，即 conn.commit 提交事務，確保當前修改生效，如果出現異常，還需要使用 conn.rollback 對提交事務進行回滾。

cursor. execute 可以返回受影響行數，可以直接通過該值判斷是否修改成功。

本次代碼還使用了 try-except 語句，對于 PyMySQL 模塊內置的異常類，清單如下：

• StandardError
  • Warning
  • Error
    • InterfaceError
    • DatabaseError
      • DataError
      • OperationalError
      • IntegrityError
      • ProgrammingError
      • NotSupportedError

python 新增數據表數據
接下來演示增加數據，本次插入數據都采用硬編碼，如果想創建一個自動遞增的表字段，需要繼續研究 sql 相關寫法。

import pymysql# python 連接數據庫，返回數據庫連接對象conn = pymysql.connect(host="127.0.0.1", user="root", password="xiangpica", database="cadb", charset="utf8")# print(conn)with conn.cursor(cursor=pymysql.cursors.DictCursor) as cur:    try:        affected = cur.execute("insert into user(name,uid) values (%s,%s)", ["Good", 3])        conn.commit()  # 提交事務        print("受影響行數", affected)    except Exception as e:        print("數據插入異常", e)        conn.rollback()  # 數據回滾# 關閉數據庫連接conn.close()

python 刪除表格數據
核心代碼如下所示：

affected = cur.execute("delete from user where uid = %s", [3])conn.commit()  # 提交事務print("受影響行數", affected)

寫到這里，你可以自行完成一個 python 簡單的數據庫操作封裝。

python 操作 nosql 之 dbm

mysql 數據關系型數據庫，與之對應的就是非關系型數據庫，例如 python 內置的 dbm（database manager ）

第一個要學習的方法是 dbm.open，方法原型如下所示：

def open(file, flag="r", mode=0o666):

flag 參數：

• r : 只讀；
• w : 只寫；
• n : 總是創建一個數據庫，打開方式為讀寫；
• c : 存在不創建，不存在則創建。

關閉數據庫使用 dbm.close()，使用 with 語句之后，不需要手動釋放資源。

with dbm.open(xxx) as db:	pass

dbm 存儲的形式類似 python 字典，以鍵值對形式存在。

import dbmwith dbm.open("example.db", "n") as db:    db["name"] = "橡皮擦" # 存儲值    db["age"] = "18" # values must be bytes or strings

讀取值使用 db[key] 即可，如果沒有 key 值，提示 KeyError 錯誤。

import dbmwith dbm.open("example.db", "r") as db:    ca = db["name"]    age = db["age"]    print(ca)

dbm 數據庫保存的數據是字符串類型或者字節序列類型，讀取到的值是字節序列類型，需要使用解碼函數 decode 轉換成字符串。

寫在后面

以上內容就是本文的全部內容，希望對學習路上的你有所幫助~

今天是持續寫作的第 230 / 365 天。
期待 關注，點贊、評論、收藏。

更多精彩

• 滾雪球學 Python（完結）
• 滾雪球學 Python 第二輪（完結）
• 滾雪球學 Python 第三輪
• 滾雪球學 Python 番外篇（完結）