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语句,以满足自己的需求。记得在进行数据库操作之前,先连接到数据库,并在操作完成后断开与数据库的连接。