写pymysql基础知识实例教程
时间: 2023-07-08 17:41:51 浏览: 100
Python中操作MySQL入门实例
好的,下面是一个简单的Pymysql实例教程:
1. 安装Pymysql
在终端(或者命令行)中输入以下命令来安装Pymysql:
```
pip install pymysql
```
2. 连接数据库
在Python脚本中,使用以下代码来连接数据库:
```python
import pymysql
# 连接数据库
conn = pymysql.connect(
host='localhost', # 数据库地址
port=3306, # 数据库端口
user='root', # 数据库用户名
password='123456', # 数据库密码
db='test', # 数据库名称
charset='utf8mb4' # 数据库编码
)
# 创建游标
cursor = conn.cursor()
```
其中,`host`、`port`、`user`、`password`、`db`、`charset`分别对应数据库的地址、端口、用户名、密码、数据库名称和编码方式。`pymysql.connect()` 函数返回一个连接对象,用于后续的数据库操作。
3. 执行SQL语句
可以使用游标对象 `cursor` 来执行SQL语句,例如:
```python
# 插入数据
sql = "INSERT INTO students(name, age, gender) VALUES(%s, %s, %s)"
cursor.execute(sql, ('张三', 18, '男'))
# 查询数据
sql = "SELECT * FROM students WHERE age > %s"
cursor.execute(sql, (20,))
result = cursor.fetchall()
for row in result:
print(row)
```
其中,`execute()` 方法接收两个参数:SQL语句和参数。在插入数据时,可以使用 `%s` 占位符来表示参数,然后在 `execute()` 方法的第二个参数中传入实际的参数。在查询数据时,可以使用 `%s` 占位符来表示条件参数,然后在 `execute()` 方法的第二个参数中传入实际的参数,最后使用 `fetchall()` 方法获取所有查询结果。
4. 提交和回滚
在执行INSERT、UPDATE、DELETE等修改数据库的操作时,需要调用 `conn.commit()` 方法来提交事务。如果出现错误,可以调用 `conn.rollback()` 方法来回滚事务,例如:
```python
try:
# 执行SQL语句
...
# 提交事务
conn.commit()
except Exception as e:
# 回滚事务
conn.rollback()
print(e)
finally:
# 关闭游标和连接
cursor.close()
conn.close()
```
在执行SQL语句时,可以使用try-except语句来捕获异常,如果出现异常,则调用 `conn.rollback()` 方法来回滚事务,最后关闭游标和连接。
这就是一个简单的Pymysql实例教程,希望对你有所帮助。
阅读全文