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

在Python编程中，连接MySQL数据库并执行增删改查（CRUD）操作是常见的数据库交互需求。本篇文章将详细介绍如何使用Python的`mysql.connector`库实现这一目标。 要进行Python连接MySQL，你需要安装`mysql.connector`库。在命令行以管理员权限运行`pip install mysql.connector`命令即可完成安装。安装成功后，可以创建一个简单的Python脚本（如`test.py`），导入`mysql.connector`并尝试运行，以此检验库是否已安装正确。 接下来是连接MySQL数据库的步骤。创建一个名为`connectTest.py`的文件，导入`mysql.connector`库，并使用`connect()`函数设置数据库连接参数，包括主机地址（默认为本地`127.0.0.1`）、用户名、密码和要连接的数据库名。例如： ```python import mysql.connector connect = mysql.connector.connect( host="127.0.0.1", user="root", passwd="root", database="mysql" ) # 关闭连接 connect.close() ``` 运行`connectTest.py`，如果无异常，即表示连接成功。 执行SQL命令是数据库操作的核心。以下是一些基本操作的示例： 1. **创建表**：定义一个SQL创建表的语句，如创建一个名为`testtable`的表，包含`id`（主键）、`name`、`age`和`address`字段。然后使用游标`cursor()`执行`execute()`方法来执行SQL语句，并调用`commit()`提交事务： ```python import mysql.connector connect = mysql.connector.connect( host="127.0.0.1", user="root", passwd="root", database="test" ) sql = """ CREATE TABLE `test`.`testtable` ( `id` int NOT NULL, `name` varchar(255) NULL, `age` int NULL, `address` varchar(255) NULL, PRIMARY KEY (`id`) ); """ myCursor = connect.cursor() myCursor.execute(sql) connect.commit() connect.close() ``` 2. **插入数据**：编写SQL插入语句，使用占位符`%s`，并提供一个元组作为数据。通过游标执行SQL，确保使用`commit()`提交事务，以防止错误时数据丢失： ```python import mysql.connector connect = mysql.connector.connect( host="127.0.0.1", user="root", passwd="root", database="test" ) sql = "INSERT INTO `test`.`testtable`(`id`, `name`, `age`, `address`) VALUES (%s,%s,%s,%s)" var = (1, 'windSnowLi', 20, '中国') myCursor = connect.cursor() try: myCursor.execute(sql, var) connect.commit() except: connect.rollback() connect.close() ``` 3. **查询数据**：编写SQL查询语句，例如`SELECT * FROM testtable`，使用游标执行SQL，调用`fetchall()`获取所有结果并打印： ```python import mysql.connector connect = mysql.connector.connect( host="127.0.0.1", user="root", passwd="root", database="test" ) sql = "SELECT * FROM testtable" myCursor = connect.cursor() myCursor.execute(sql) results = myCursor.fetchall() print(results) connect.close() ``` 4. **更新数据**：编写SQL更新语句，例如更新某个记录的`name`字段，使用占位符和元组，然后执行和提交： ```python import mysql.connector connect = mysql.connector.connect( host="127.0.0.1", user="root", passwd="root", database="test" ) sql = "UPDATE `test`.`testtable` SET `name`=%s WHERE `id`=1" var = ('updatedName',) myCursor = connect.cursor() try: myCursor.execute(sql, var) connect.commit() except: connect.rollback() connect.close() ``` 5. **删除数据**：编写SQL删除语句，例如删除`id`为1的记录，执行并提交： ```python import mysql.connector connect = mysql.connector.connect( host="127.0.0.1", user="root", passwd="root", database="test" ) sql = "DELETE FROM `test`.`testtable` WHERE `id`=1" myCursor = connect.cursor() try: myCursor.execute(sql) connect.commit() except: connect.rollback() connect.close() ``` 以上就是使用Python的`mysql.connector`库连接MySQL数据库并进行增删改查的基本操作。这些示例代码可以帮助初学者快速理解和实践Python与MySQL的交互。在实际项目中，你可能需要根据具体需求进行调整，例如处理异常、使用预编译语句以提高安全性等。