====== 第三十三章:MySQL数据库 ======
===== 本章目标 =====
完成本章学习后,你将能够:
* 使用pymysql连接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. 实现读写分离
下一章:[[python_course:chapter34|第三十四章:ORM与SQLAlchemy]]