Python连接Mysql进行增删改查的示例代码

1. 导入模块和连接数据库

首先我们需要导入`pymysql`模块来连接MySQL数据库。确保你已经在你的系统中安装了`pymysql`模块,并在代码中导入它。

import pymysql

接着,我们需要连接到MySQL数据库。你需要指定数据库的连接参数,如主机名、用户名、密码和数据库名称。以下是连接数据库的示例代码:

# 连接数据库

connection = pymysql.connect(

host='localhost', # 主机名

user='root', # 用户名

password='password', # 密码

db='mydatabase' # 数据库名称

)

2. 插入数据

插入数据到MySQL数据库需要使用`INSERT`语句。以下是插入数据的示例代码:

# 创建一个游标对象

cursor = connection.cursor()

# 插入数据

sql = "INSERT INTO `person` (`name`, `age`) VALUES (%s, %s)"

values = ('John', 25)

cursor.execute(sql, values)

# 提交事务

connection.commit()

在上面的示例代码中,我们首先创建了一个游标对象。然后,我们定义了一个SQL语句,并指定了要插入的数据。最后,我们执行了SQL语句,并提交了事务。

3. 查询数据

查询数据使用`SELECT`语句。以下是查询数据的示例代码:

# 创建一个游标对象

cursor = connection.cursor()

# 查询数据

sql = "SELECT * FROM `person`"

cursor.execute(sql)

# 获取查询结果

results = cursor.fetchall()

# 打印结果

for row in results:

print(row)

在上面的示例代码中,我们首先创建了一个游标对象。然后,我们定义了一个SQL语句,并执行了它。最后,我们使用`fetchall()`方法来获取查询结果,并将结果打印出来。

4. 更新数据

更新数据使用`UPDATE`语句。以下是更新数据的示例代码:

# 创建一个游标对象

cursor = connection.cursor()

# 更新数据

sql = "UPDATE `person` SET `age` = %s WHERE `name` = %s"

values = (30, 'John')

cursor.execute(sql, values)

# 提交事务

connection.commit()

在上面的示例代码中,我们首先创建了一个游标对象。然后,我们定义了一个SQL语句,并指定要更新的数据。最后,我们执行了SQL语句,并提交了事务。

5. 删除数据

删除数据使用`DELETE`语句。以下是删除数据的示例代码:

# 创建一个游标对象

cursor = connection.cursor()

# 删除数据

sql = "DELETE FROM `person` WHERE `name` = %s"

value = ('John',)

cursor.execute(sql, value)

# 提交事务

connection.commit()

在上面的示例代码中,我们首先创建了一个游标对象。然后,我们定义了一个SQL语句,并指定要删除的数据。最后,我们执行了SQL语句,并提交了事务。

6. 断开数据库连接

当你完成了对MySQL数据库的操作之后,你需要断开与数据库的连接。以下是断开数据库连接的示例代码:

# 关闭游标对象和数据库连接

cursor.close()

connection.close()

在上面的示例代码中,我们首先关闭了游标对象,然后关闭了数据库连接。

以上是Python连接MySQL数据库进行增删改查的示例代码。你可以根据自己的实际情况,修改代码中的数据库连接参数和SQL语句,以满足自己的需求。记得在进行数据库操作之前,先连接到数据库,并在操作完成后断开与数据库的连接。

后端开发标签