下面是一个使用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()
方法提交更改。
在代码的最后,分别调用这些函数来执行对应的操作,最后关闭数据库连接。