用python操作mysql实现增删改查
时间: 2023-07-11 09:37:02 浏览: 58
好的,下面是Python操作MySQL的增删改查示例代码:
首先需要安装MySQL相关库,使用pip命令安装pymysql库即可:
```
pip install pymysql
```
接下来是示例代码,假设我们要操作的数据库名为test,其中包含一张名为user的表,表中包含id、name、age三个字段:
```python
import pymysql
# 连接MySQL数据库
conn = pymysql.connect(
host='localhost',
port=3306,
user='root',
password='123456',
database='test'
)
# 插入数据
def insert():
try:
with conn.cursor() as cursor:
sql = "INSERT INTO user (name, age) VALUES (%s, %s)"
cursor.execute(sql, ('Tom', 20))
conn.commit()
print('插入成功')
except Exception as e:
print(f'插入失败,错误信息:{e}')
# 查询数据
def select():
with conn.cursor() as cursor:
sql = "SELECT * FROM user"
cursor.execute(sql)
results = cursor.fetchall()
for row in results:
id = row[0]
name = row[1]
age = row[2]
print(f'id={id}, name={name}, age={age}')
# 更新数据
def update():
try:
with conn.cursor() as cursor:
sql = "UPDATE user SET age=%s WHERE name=%s"
cursor.execute(sql, (25, 'Tom'))
conn.commit()
print('更新成功')
except Exception as e:
print(f'更新失败,错误信息:{e}')
# 删除数据
def delete():
try:
with conn.cursor() as cursor:
sql = "DELETE FROM user WHERE name=%s"
cursor.execute(sql, ('Tom',))
conn.commit()
print('删除成功')
except Exception as e:
print(f'删除失败,错误信息:{e}')
# 关闭数据库连接
conn.close()
```
以上代码中,insert函数实现了向user表中插入一条数据,select函数实现了查询user表中所有数据并输出,update函数实现了将名为Tom的记录的age字段更新为25,delete函数实现了删除名为Tom的记录。
需要注意的是,每次执行完操作后都需要调用commit方法提交事务。另外,使用完数据库连接后一定要记得关闭,否则会导致资源浪费和连接池溢出等问题。