目录

第三十三章：MySQL数据库

本章目标

完成本章学习后，你将能够：

基础操作

import pymysql
 
# 连接数据库
conn = pymysql.connect(
    host='localhost',
    user='user',
    password='password',
    database='mydb',
    charset='utf8mb4'
)
 
try:
    with conn.cursor() as cursor:
        # 创建表
        cursor.execute('''
            CREATE TABLE IF NOT EXISTS users (
                id INT AUTO_INCREMENT PRIMARY KEY,
                name VARCHAR(100),
                email VARCHAR(100)
            )
        ''')
 
        # 插入
        cursor.execute(
            "INSERT INTO users (name, email) VALUES (%s, %s)",
            ("Alice", "alice@example.com")
        )
        conn.commit()
 
        # 查询
        cursor.execute("SELECT * FROM users")
        results = cursor.fetchall()
        for row in results:
            print(row)
finally:
    conn.close()

连接池

from pymysqlpool import ConnectionPool
 
config = {
    'host': 'localhost',
    'user': 'user',
    'password': 'password',
    'database': 'mydb'
}
 
pool = ConnectionPool(size=10, name='mypool', **config)

本章练习

1. 实现MySQL CRUD操作 2. 使用连接池优化性能 3. 实现读写分离

下一章：第三十四章：ORM与SQLAlchemy