下面是一个使用Python进行数据库增删改查的示例,以MySQL数据库为例:
import mysql.connector
# 连接数据库
conn = mysql.connector.connect(
host="localhost",
user="root",
password="password",
database="mydatabase"
)
cursor = conn.cursor()
# 查询数据
def select_data():
cursor.execute("SELECT * FROM mytable")
result = cursor.fetchall()
for row in result:
print(row)
# 插入数据
def insert_data(name, age):
sql = "INSERT INTO mytable (name, age) VALUES (%s, %s)"
values = (name, age)
cursor.execute(sql, values)
conn.commit()
print("数据插入成功")
# 更新数据
def update_data(id, new_age):
sql = "UPDATE mytable SET age = %s WHERE id = %s"
values = (new_age, id)
cursor.execute(sql, values)
conn.commit()
print("数据更新成功")
# 删除数据
def delete_data(id):
sql = "DELETE FROM mytable WHERE id = %s"
values = (id,)
cursor.execute(sql, values)
conn.commit()
print("数据删除成功")
# 查询数据
select_data()
# 插入数据
insert_data("John", 25)
# 更新数据
update_data(1, 30)
# 删除数据
delete_data(2)
# 查询数据
select_data()
# 关闭数据库连接
cursor.close()
conn.close()
上述代码中,mysql.connector
用于连接MySQL数据库。首先使用connect()
方法连接到数据库,并创建cursor
对象用于执行SQL语句。
然后定义了四个函数来进行数据库操作,分别是select_data()
用于查询数据,insert_data()
用于插入数据,update_data()
用于更新数据,以及delete_data()
用于删除数据。每个函数都执行对应的SQL语句,并通过execute()
方法执行,最后通过commit()
方法提交更改。
在代码的最后,分别调用这些函数来执行对应的操作,最后关闭数据库连接。