Python 3:使用pymysql连接与操作MySQL数据库详解

需积分: 1 1 下载量 97 浏览量 更新于2024-08-03 收藏 12KB MD 举报
在Python 3中,Python程序接入MySQL数据库是常见的任务,通常通过使用`mysqlclient`或更推荐的`pymysql`库来实现数据操作。这两个库的主要区别在于`mysqlclient`可能兼容性稍差,而`pymysql`作为纯Python库,安装更为方便,适合初学者和生产环境。 要开始使用`pymysql`,首先确保在Python环境中安装它。对于MySQL 8及以上版本,可能需要额外安装`cryptography`库以支持密码认证。以下是通过`pymysql`操作MySQL数据库的五个关键步骤: 1. 创建连接:使用`pymysql.connect()`函数建立与MySQL服务器的连接,需要提供数据库地址(通常是主机名或IP)、用户名、密码以及数据库名称。 ```python import pymysql conn = pymysql.connect(host='localhost', user='your_username', password='your_password', database='hrs') ``` 2. 获取游标:连接成功后,创建一个游标对象,用于执行SQL语句。 ```python cursor = conn.cursor() ``` 3. 执行SQL语句:使用`cursor.execute()`方法发送SQL指令,如创建表、插入数据等。例如,创建表的代码片段已在描述中给出: ```sql CREATE TABLE tb_dept ( dno INT NOT NULL COMMENT '编号', dname VARCHAR(10) NOT NULL COMMENT '名称', dloc VARCHAR(20) NOT NULL COMMENT '所在地', PRIMARY KEY (dno) ); ``` 4. 处理插入、更新和删除操作:针对`insert`、`update`或`delete`操作,使用`cursor.execute()`方法,然后调用`conn.commit()`来提交事务,确保数据持久化到数据库。 ```python cursor.execute("INSERT INTO tb_emp ...") conn.commit() ``` 5. 关闭连接:完成所有操作后,记得关闭游标和连接以释放资源。 ```python cursor.close() conn.close() ``` 在实际项目中,可能还会涉及异常处理和错误处理,以及使用参数化查询来防止SQL注入。此外,为了提高代码可读性和维护性,可以使用ORM(对象关系映射)工具如SQLAlchemy,它提供了更高级别的接口来操作数据库。 Python程序接入MySQL数据库涉及到连接建立、数据操作和事务管理等多个环节,熟练掌握这些基本步骤对于开发人员来说是至关重要的。通过`pymysql`,开发者能够有效地将Python的数据处理逻辑与MySQL数据库集成,实现高效的数据存储和检索。