Python连接MySQL数据库：详细教程与示例代码

见贤思齐

文章目录1.安装必要的库2.建立与MySQL的连接3.执行SQL查询4.插入数据5.更新数据6.删除数据7.错误处理8.小结在数据驱动的开发中，连接数据库是一个至关重要的技能。Python作为一门强大的编程语言，提供了多种方式连接并操作MySQL数据库。本文将详细介绍如何在Python中连接MySQL数据库，包括所需库的安装、基本连接方法、执行查询、处理结果集以及错误处理。1.安装必要的库在Python中，常用的MySQL连接库是mysql-connector-python和PyMySQL。以下示例将使用mysql-connector-python，它是MySQL官方提供的连接器。使用pip安装mysql-connector-pythonpipinstallmysql-connector-python1使用pip安装mysql-connector-python库，这个库提供了与MySQL数据库通信的功能。2.建立与MySQL的连接安装完库后，就可以在Python中建立与MySQL的连接了。以下是一个基本的连接示例：importmysql.connector#建立连接conn=mysql.connector.connect(host='localhost',user='yourusername',password='yourpassword',database='yourdatabase')print("连接成功")conn.close()123456789101112importmysql.connector：导入mysql.connector模块。mysql.connector.connect()：建立与MySQL数据库的连接，参数包括主机名、用户名、密码和数据库名。conn.close()：关闭数据库连接。3.执行SQL查询建立连接后，就可以执行SQL查询。以下是一个查询示例：importmysql.connectorconn=mysql.connector.connect(host='localhost',user='yourusername',password='yourpassword',database='yourdatabase')cursor=conn.cursor()#执行查询cursor.execute("SELECT*FROMyourtable")#获取查询结果results=cursor.fetchall()forrowinresults:print(row)cursor.close()conn.close()12345678910111213141516171819202122cursor=conn.cursor()：创建一个游标对象，用于执行SQL查询。cursor.execute("SELECT*FROMyourtable")：执行SQL查询。results=cursor.fetchall()：获取所有查询结果。forrowinresults：遍历结果集并打印每一行。cursor.close()：关闭游标。conn.close()：关闭数据库连接。4.插入数据除了查询数据，还可以使用Python插入数据。以下是一个插入数据的示例：importmysql.connectorconn=mysql.connector.connect(host='localhost',user='yourusername',password='yourpassword',database='yourdatabase')cursor=conn.cursor()#插入数据sql="INSERTINTOyourtable(column1,column2)VALUES(%s,%s)"val=("value1","value2")cursor.execute(sql,val)conn.commit()print(cursor.rowcount,"记录插入成功")cursor.close()conn.close()12345678910111213141516171819202122sql="INSERTINTOyourtable(column1,column2)VALUES(%s,%s)"：定义插入SQL语句。val=("value1","value2")：定义插入的数据。cursor.execute(sql,val)：执行插入操作。conn.commit()：提交事务。cursor.rowcount：获取插入的记录数。5.更新数据更新数据与插入数据类似，只需更改SQL语句。以下是一个更新数据的示例：importmysql.connectorconn=mysql.connector.connect(host='localhost',user='yourusername',password='yourpassword',database='yourdatabase')cursor=conn.cursor()#更新数据sql="UPDATEyourtableSETcolumn1=%sWHEREcolumn2=%s"val=("newvalue","value2")cursor.execute(sql,val)conn.commit()print(cursor.rowcount,"记录更新成功")cursor.close()conn.close()12345678910111213141516171819202122sql="UPDATEyourtableSETcolumn1=%sWHEREcolumn2=%s"：定义更新SQL语句。val=("newvalue","value2")：定义更新的数据。cursor.execute(sql,val)：执行更新操作。conn.commit()：提交事务。cursor.rowcount：获取更新的记录数。6.删除数据删除数据也与插入和更新类似。以下是一个删除数据的示例：importmysql.connectorconn=mysql.connector.connect(host='localhost',user='yourusername',password='yourpassword',database='yourdatabase')cursor=conn.cursor()#删除数据sql="DELETEFROMyourtableWHEREcolumn2=%s"val=("value2",)cursor.execute(sql,val)conn.commit()print(cursor.rowcount,"记录删除成功")cursor.close()conn.close()12345678910111213141516171819202122sql="DELETEFROMyourtableWHEREcolumn2=%s"：定义删除SQL语句。val=("value2",)：定义删除的数据条件。cursor.execute(sql,val)：执行删除操作。conn.commit()：提交事务。cursor.rowcount：获取删除的记录数。7.错误处理在数据库操作过程中，可能会遇到各种错误，如连接失败、SQL语法错误等。可以使用try-except语句进行错误处理。importmysql.connectorfrommysql.connectorimportErrortry:conn=mysql.connector.connect(host='localhost',user='yourusername',password='yourpassword',database='yourdatabase')ifconn.is_connected():print("连接成功")exceptErrorase:print("错误:",e)finally:ifconn.is_connected():conn.close()print("连接已关闭")123456789101112131415161718192021try块：尝试建立数据库连接。exceptErrorase：捕获并打印错误信息。finally块：确保连接关闭。8.小结本文详细介绍了如何在Python中连接并操作MySQL数据库，包括库的安装、基本连接、执行查询、插入数据、更新数据、删除数据以及错误处理。掌握这些技能将大大提高数据驱动开发的效率和可靠性。数据库操作是Python编程中的重要部分，熟练掌握这些知识将为开发工作带来巨大帮助。推荐我的相关专栏：python错误记录python笔记数据结构