一、Pymysql简介
Pymysql是Python中用于连接MySQL数据库的一个库，它提供了丰富的API，使得Python开发者可以轻松地与MySQL数据库进行交互。本文将详细介绍Pymysql的安装、配置和使用方法，帮助读者快速上手。
二、Pymysql安装
- 使用pip安装Pymysql
在命令行中输入以下命令进行安装：
bash pip install pymysql
- 使用源码安装
如果需要从源码安装，请先克隆Pymysql的GitHub仓库：
bash git clone https://github.com/PyMySQL/PyMySQL.git
然后进入仓库目录，执行以下命令：
bash python setup.py install
三、Pymysql配置
- 导入Pymysql
在Python代码中，首先需要导入Pymysql模块：
python import pymysql
- 连接MySQL数据库
使用Pymysql.connect()方法连接MySQL数据库，需要提供以下参数：
- host：数据库服务器地址
- port：数据库服务器端口号
- user：数据库用户名
- password：数据库密码
- database：数据库名
python conn = pymysql.connect(host='localhost', port=3306, user='root', password='123456', database='testdb')
四、Pymysql查询
- 创建游标对象
使用conn.cursor()方法创建一个游标对象，用于执行SQL语句：
python cursor = conn.cursor()
- 执行查询
使用cursor.execute()方法执行查询语句，并获取查询结果：
python cursor.execute("SELECT * FROM users") rows = cursor.fetchall() for row in rows: print(row)
- 关闭游标
查询完成后，需要关闭游标对象：
python cursor.close()
五、Pymysql操作
- 插入数据
使用cursor.execute()方法执行插入语句：
python cursor.execute("INSERT INTO users (username, password) VALUES ('test', '123456')") conn.commit()
- 更新数据
使用cursor.execute()方法执行更新语句：
python cursor.execute("UPDATE users SET password='newpassword' WHERE username='test'") conn.commit()
- 删除数据
使用cursor.execute()方法执行删除语句：
python cursor.execute("DELETE FROM users WHERE username='test'") conn.commit()
六、Pymysql关闭连接
查询和操作完成后，需要关闭数据库连接：
python conn.close()
七、Pymysql常见问题解答
Q：Pymysql如何处理异常？
A：Pymysql使用try-except语句处理异常，例如：
python try: conn = pymysql.connect(host='localhost', port=3306, user='root', password='123456', database='testdb') cursor = conn.cursor() cursor.execute("SELECT * FROM users") rows = cursor.fetchall() for row in rows: print(row) except pymysql.MySQLError as e: print("MySQL Error:", e) finally: cursor.close() conn.close()
Q：Pymysql如何支持连接池？
A：Pymysql支持连接池，可以通过pymysql.pooling模块使用。例如：
python from pymysql import pooling
dbconfig = { 'host': 'localhost', 'port': 3306, 'user': 'root', 'password': '123456', 'database': 'testdb' }
pool_name = 'mypool' pool_size = 5 pool = pooling.ConnectionPool(pool_name=pool_name, pool_size=pool_size, dbconfig)
conn = pool.get_connection() cursor = conn.cursor() cursor.execute("SELECT * FROM users") rows = cursor.fetchall() for row in rows: print(row) cursor.close() conn.close()
Q：Pymysql如何支持事务？
A：Pymysql支持事务，可以通过conn.begin()方法开启事务，使用conn.commit()提交事务，使用conn.rollback()回滚事务。例如：
python conn.begin() cursor.execute("UPDATE users SET password='newpassword' WHERE username='test'") cursor.execute("INSERT INTO users (username, password) VALUES ('newuser', 'newpassword')") conn.commit()