Python操作MySQL的從入門到實(shí)戰(zhàn)指南

更新時(shí)間：2026年03月27日 08:59:50 作者：·云揚(yáng)·

本文介紹了使用Python操作MySQL的全過程,包括環(huán)境準(zhǔn)備、Python基礎(chǔ)回顧、實(shí)戰(zhàn)操作等,環(huán)境準(zhǔn)備中提到安裝Python和VSCode,并推薦安裝插件,Python基礎(chǔ)回顧部分簡要介紹了注釋、數(shù)據(jù)類型、條件判斷、循環(huán)和函數(shù)等內(nèi)容,需要的朋友可以參考下

1 基礎(chǔ)環(huán)境準(zhǔn)備

想要順利進(jìn)行后續(xù)操作，先把基礎(chǔ)環(huán)境搭好，這一步很簡單，跟著官網(wǎng)指引來就行～

1.1 Windows 安裝 Python3

官方下載地址：https://www.python.org/downloads/
安裝注意：勾選「Add Python to PATH」，這樣后續(xù)在命令行就能直接調(diào)用 Python 啦

1.2 安裝 VS Code

官方下載地址：https://code.visualstudio.com/
推薦插件：Python（微軟官方插件）、Code Runner（一鍵運(yùn)行代碼）

1.3 創(chuàng)建 Python 文件

打開 VS Code → 新建文件 → 保存為 mysql_operation.py（后綴必須是 .py），準(zhǔn)備開始寫代碼～

2 Python 基礎(chǔ)快速回顧

如果是剛學(xué) Python 的同學(xué)，先掌握這些基礎(chǔ)就夠了，后續(xù)操作都會用到～

2.1 注釋（代碼說明很重要）

# 單行注釋：用 # 開頭，注釋一行內(nèi)容
# 下面是多行注釋，用三個(gè)單引號或雙引號包裹
'''
多行注釋第一行
多行注釋第二行
'''
"""
雙引號版多行注釋
適合注釋較長的說明
"""

2.2 常用數(shù)據(jù)類型

# 整數(shù)類型：用于存儲年齡、編號等整數(shù)
age = 25
# 浮點(diǎn)數(shù)類型：用于存儲小數(shù)
pi = 3.14
print(type(pi))  # 輸出 <class 'float'>，查看數(shù)據(jù)類型

# 字符串類型：用于存儲姓名、文本等
name = "maria"
print(type(name))  # 輸出  <class 'str'>

# 輸出方式示例
print("你好，Python！")  # 直接輸出字符串
print(name)  # 輸出變量
print("名字是：", name)  # 字符串和變量組合輸出

2.3 條件判斷（根據(jù)條件執(zhí)行不同邏輯）

score = 91

score = 91
if score >= 90:
    print("優(yōu)秀")  # 滿足條件時(shí)執(zhí)行
elif score >= 80:
    print("良好")
elif score >= 60:
    print("及格")
else:
    print("不及格")  # 所有條件都不滿足時(shí)執(zhí)行

2.4 循環(huán)（重復(fù)執(zhí)行代碼）

# for 循環(huán)：遍歷字符串、列表等
name = "maria"
for char in name:
    print(char)  # 依次輸出 m、a、r、i、a

# while 循環(huán)：根據(jù)條件重復(fù)執(zhí)行
name = "maria"
index = 0
while index<len(name):  # len(name) 是字符串長度（5）
    char = name[index]
    print(char)
    index += 1  # 索引自增，避免死循環(huán)

2.5 函數(shù)（封裝可復(fù)用的代碼）

# 定義函數(shù)：求兩個(gè)數(shù)的最大值
def max_value(a, b):
    if a > b:
        return a  # 返回較大值
    else:
        return b

# 調(diào)用函數(shù)
result = max_value(2, 3)
print(result)  # 輸出 3

3 Python 操作 MySQL 實(shí)戰(zhàn)

這部分是核心！教大家用 Python 對 MySQL 執(zhí)行增刪查改（CRUD）操作～

第一步：創(chuàng)建 MySQL 測試環(huán)境

先在 MySQL 中創(chuàng)建測試表和專用用戶，避免使用 root 用戶直接操作（安全規(guī)范）。

-- 創(chuàng)建測試表 test_table
CREATE TABLE test_table (
  id INT AUTO_INCREMENT PRIMARY KEY,  # 自增主鍵
  name VARCHAR(255),  # 姓名
  age INT  # 年齡
);

-- 創(chuàng)建 Python 專用操作用戶
CREATE USER 'python_rw'@'%' IDENTIFIED BY 'Idyq8_a1';
-- 授予增刪查改等權(quán)限（根據(jù)實(shí)際需求調(diào)整）
GRANT create,alter,insert,delete,select,update ON *.* TO 'python_rw'@'%';

第二步：安裝 MySQL 連接模塊

Python 本身不支持直接連接 MySQL，需要安裝第三方模塊：

pip install pymysql==1.1.0

（如果提示 pip 不是內(nèi)部命令，檢查 Python 是否添加到環(huán)境變量）

第三步：Python 增刪查改完整代碼

把以下代碼復(fù)制到 mysql_operation.py 中，修改數(shù)據(jù)庫連接信息即可使用～

# 導(dǎo)入 pymysql 庫
import pymysql
from pymysql.err import OperationalError, ProgrammingError

# 1. 建立數(shù)據(jù)庫連接（替換為你的數(shù)據(jù)庫信息）
# 增加連接參數(shù)，提升穩(wěn)定性
config = {
    'host': '192.168.184.151',  # 數(shù)據(jù)庫地址
    'user': 'python_rw',  # 用戶名
    'password': 'Idyq8_a1',  # 密碼
    'database': 'maria',  # 數(shù)據(jù)庫名
    'charset': 'utf8mb4',  # 字符集（避免中文亂碼）
    'connect_timeout': 10,  # 連接超時(shí)時(shí)間（防止卡死）
    'cursorclass': pymysql.cursors.DictCursor  # 可選：返回字典格式結(jié)果，更易讀
}

# 初始化連接和游標(biāo)為None，避免空對象調(diào)用
cnx = None
cursor = None

try:
    # 先測試連接是否能成功建立
    cnx = pymysql.connect(**config)
    print("? 數(shù)據(jù)庫連接成功")

    # 2. 創(chuàng)建游標(biāo)對象
    cursor = cnx.cursor()

    # 3. 插入數(shù)據(jù)（INSERT）
    sql_insert = "INSERT INTO test_table (name, age) VALUES (%s, %s)"
    values_insert = ("John", 25)
    cursor.execute(sql_insert, values_insert)
    cnx.commit()
    print(f"?? 數(shù)據(jù)插入成功，新增記錄 ID：{cursor.lastrowid}")

    # 4. 查詢數(shù)據(jù)（SELECT）
    sql_select = "SELECT * FROM test_table"
    cursor.execute(sql_select)
    rows = cursor.fetchall()
    print("\n?? 查詢結(jié)果：")
    # 適配 DictCursor，用鍵取值（更直觀）
    for row in rows:
        print(f"ID: {row['id']}, 姓名: {row['name']}, 年齡: {row['age']}")

    # 5. 更新數(shù)據(jù)（UPDATE）
    sql_update = "UPDATE test_table SET age = %s WHERE name = %s"
    values_update = (30, "John")
    cursor.execute(sql_update, values_update)
    cnx.commit()
    print(f"\n?? 數(shù)據(jù)更新成功，影響行數(shù)：{cursor.rowcount}")

    # 6. 刪除數(shù)據(jù)（DELETE）
    sql_delete = "DELETE FROM test_table WHERE name = %s"
    values_delete = ("John",)  # 單個(gè)參數(shù)保留逗號
    cursor.execute(sql_delete, values_delete)
    cnx.commit()
    print(f"???  數(shù)據(jù)刪除成功，影響行數(shù)：{cursor.rowcount}")

except OperationalError as e:
    # 專門捕獲連接相關(guān)錯誤（地址/密碼/數(shù)據(jù)庫不存在）
    print(f"? 數(shù)據(jù)庫連接失?。簕str(e)}")
    print("請檢查：1.數(shù)據(jù)庫地址是否正確 2.用戶名/密碼是否正確 3.數(shù)據(jù)庫是否存在")
except ProgrammingError as e:
    # 專門捕獲SQL語法/表不存在錯誤
    print(f"? SQL執(zhí)行失?。簕str(e)}")
    print("請檢查：1.test_table表是否存在 2.字段名（name/age）是否正確")
except Exception as e:
    # 其他未知錯誤
    if cnx:  # 只有連接成功才回滾
        cnx.rollback()
    print(f"? 操作失敗：{str(e)}")
finally:
    # 7. 安全關(guān)閉游標(biāo)和連接（判斷對象是否存在，避免空指針）
    if cursor:
        cursor.close()
    if cnx:
        cnx.close()
    print("\n?? 數(shù)據(jù)庫連接已關(guān)閉")