Python中pymysql模块详解：安装、连接、执行SQL语句等常见操作

梅老板

文章目录前言一、pymysql模块介绍二、使用步骤1.安装pymysql模块2.连接数据库及常用操作3.执行SQL语句插入数据更新数据删除数据查询数据4.错误处理总结前言  在Python中，我们经常需要连接和操作数据库。pymysql是一个流行的Python模块，专门用于与MySQL数据库进行交互。本文将介绍pymysql模块的基本使用方法，以及它在实际开发中的一些应用场景。一、pymysql模块介绍  pymysql是一个用于Python编程的第三方模块，用于连接和操作MySQL数据库。它提供了一个简单而强大的接口，使开发者能够轻松地在Python程序中执行各种数据库操作，如查询、插入、更新和删除数据等。  pymysql模块由Python实现，它遵循PythonDatabaseAPI规范（PEP249），这使得它与其他数据库API兼容，并使得在不同的数据库之间切换变得更加容易。  pymysql在Python开发者社区非常受欢迎，因为它易于使用、功能强大并且具有良好的性能。它提供了许多高级特性，如事务管理、连接池、数据类型转换等，使得开发数据库驱动的应用程序变得更加便捷和高效。  总之，pymysql模块是一个重要的工具，可帮助Python开发者轻松地与MySQL数据库进行交互和操作。二、使用步骤1.安装pymysql模块在使用pymysql模块之前，首先需要将其安装到Python环境中。可以通过在命令行中运行以下命令来安装pymysql模块：pipinstallpymysql1如遇【‘pip’不是内部或外部命令，也不是可运行的程序或批处理文件。】可查看本人另一篇文章来解决!【三步解决】‘pip‘不是内部或外部命令，也不是可运行的程序或批处理文件。2.连接数据库及常用操作代码如下（示例）：#导入pymysql模块importpymysql#建立数据库连接conn=pymysql.connect(host='localhost', #主机名（或IP地址）port=3306, #端口号，默认为3306user='root', #用户名password='password', #密码charset='utf8mb4' #设置字符编码)#获取mysql服务信息（测试连接，会输出MySQL版本号）print(conn.get_server_info())#创建游标对象cursor=conn.cursor()#选择数据库conn.select_db("mytable")#执行查询操作cursor.execute('SELECT*FROMmytable')#获取查询结果，返回元组result:tuple=cursor.fetchall()#关闭游标和连接cursor.close()conn.close()123456789101112131415161718192021222324252627282930  在这个示例中，我们使用pymysql中的connect()函数建立与MySQL数据库的连接，需要提供数据库的主机地址、端口号、用户名、密码。此外我们还可以设置字符编码以确保正确处理数据中的特殊字符。3.执行SQL语句  一旦建立了与数据库的连接，我们就可以执行各种SQL操作，例如插入、更新、删除和查询等。以下是一些常见的SQL操作示例：插入数据sql="INSERTINTOmytable(name,age)VALUES('John',25)"cursor.execute(sql)conn.commit()123更新数据sql="UPDATEmytableSETage=26WHEREname='John'"cursor.execute(sql)conn.commit()123删除数据sql="DELETEFROMmytableWHEREname='John'"cursor.execute(sql)conn.commit()123查询数据sql="SELECT*FROMmytable"cursor.execute(sql)#只要不涉及数据的更改，可以不需要调用commit()方法提交更改result=cursor.fetchall()forrowinresult:print(row)123456  使用cursor.execute()方法来执行SQL语句，当更改表中数据时，必须调用conn.commit()方法来提交更改，否则数据库表中的数据不会发生改变。操作完成后，可以使用cursor.fetchall()方法获取查询结果，该方法返回一个元组。如果觉得commit()方法有点麻烦的话，可以在创建连接时设置autocommit=True，实现自动提交更改，这样就不需要每次执行完SQL操作后，都调用commit()方法啦。示例代码如下：#获取mysql连接对象conn=pymysql.Connect(host="localhost",#主机名（或IP地址）port=3306,#端口号，mysql默认3306user='root',#用户名password='password',#密码autocommit=True#自动提交更改)123456784.错误处理  在操作数据库时，可能会遇到各种错误。Python和pymysql都给我们提供了一些方法来帮助处理错误，例如使用try-except块来捕获异常，以及使用conn.rollback()方法来回滚事务。try:#执行一些操作...conn.commit()exceptExceptionase:print(f"发生错误：{e}")conn.rollback()finally:cursor.close()conn.close()12345678910  在这个示例中，try代码块中的操作可能会抛出异常。我们可以在except代码块中捕获异常，并通过打印错误消息来进行错误处理。另外，无论是否发生异常，都应该使用finally代码块来关闭游标和连接。总结  本文介绍了Python中pymysql模块的基本使用方法。通过使用pymysql模块，我们可以轻松地连接、操作和管理MySQL数据库。无论是简单的查询还是复杂的事务处理，pymysql都为我们提供了强大而灵活的功能。  希望本文能够帮助你快速入门并掌握pymysql模块的使用！如果你想深入了解更多关于pymysql的内容，建议参考官方文档或其他相关资源。pymysql官方文档：https://pymysql.readthedocs.io/Python官方文档：https://docs.python.org/3/library/index.html