python3连接MySQL8.0的两种方式

Python3 是一种广泛使用的编程语言，它提供了多种方式来连接并操作MySQL数据库，尤其是在与MySQL 8.0版本配合时。本文将详细讲解两种主要的连接方式，以及如何执行基本的数据库操作，如查询、插入、更新和删除数据。 ### 连接方式一：使用`mysql.connector`模块 你需要确保已经安装了`mysql-connector-python`库，这可以通过下载MySQL官方提供的安装包（例如：`mysql-connector-python-8.0.17-py3.7-windows-x86-64bit.msi`）或使用`pip`命令进行安装： ```bash pip install mysql-connector-python ``` 安装完成后，你可以直接在Python代码中导入`mysql.connector`模块来建立连接： ```python import mysql.connector cnx = mysql.connector.connect( user='your_username', password='your_password', host='127.0.0.1', database='your_database' ) # 执行数据库操作... cnx.close() ``` ### 连接方式二：使用`connection`类 除了上述方式，你还可以通过`connection`类直接创建连接： ```python from mysql.connector import connection cnx = connection.MySQLConnection( user='your_username', password='your_password', host='127.0.0.1', database='your_database' ) # 执行数据库操作... cnx.close() ``` ### 错误处理 在执行数据库操作时，使用`try-except`块可以捕获并处理可能出现的错误。例如，检查用户名或密码错误，或者数据库不存在： ```python import mysql.connector from mysql.connector import errorcode try: cnx = mysql.connector.connect(user='scott', database='employ') except mysql.connector.Error as err: if err.errno == errorcode.ER_ACCESS_DENIED_ERROR: print("Something is wrong with your user name or password") elif err.errno == errorcode.ER_BAD_DB_ERROR: print("Database does not exist") else: print(err) else: cnx.close() ``` ### 数据查询 要从数据库中获取数据，你可以创建一个游标对象并执行SQL查询： ```python import mysql.connector myconn = mysql.connector.connect( host="localhost", user="lucy", passwd="123455", database="holiday" ) mycursor = myconn.cursor() my_cmd_sql = "SELECT * FROM birthday" mycursor.execute(my_cmd_sql) for row in mycursor: print(row) mycursor.close() myconn.close() ``` ### 插入、更新和删除数据 对于插入、更新和删除操作，你需要执行SQL命令并调用`commit()`方法来提交事务： ```python # 插入数据 insert_query = "INSERT INTO table_name (column1, column2) VALUES (%s, %s)" values = ('value1', 'value2') mycursor.execute(insert_query, values) myconn.commit() # 更新数据 update_query = "UPDATE table_name SET column1 = %s WHERE condition" new_value = 'new_value' mycursor.execute(update_query, (new_value,)) myconn.commit() # 删除数据 delete_query = "DELETE FROM table_name WHERE condition" mycursor.execute(delete_query) myconn.commit() ``` 记得在完成所有操作后关闭游标和连接，以释放资源并避免潜在的问题。 ### 总结 通过`mysql.connector`模块，Python3为连接MySQL 8.0提供了简单易用的接口。无论是通过模块导入还是直接使用`connection`类，都能方便地建立连接并执行各种数据库操作。同时，良好的错误处理机制能确保程序在遇到问题时能够优雅地退出。这些基础操作是Python数据库编程的核心，熟练掌握它们将有助于你更高效地管理数据库。