python使用mysql数据库_使用Python环境

来源：佚名编辑：佚名

2024-07-08 19:30:59

Python 使用 MySQL 数据库需要安装 mysqlconnectorpython 包。在 Python 环境中，通过导入该包并创建连接对象，可以与 MySQL 数据库进行交互。使用游标对象执行 SQL 语句，实现数据的增删改查操作。

在Python环境下，使用MySQL数据库涉及到多个关键步骤，包括安装MySQL驱动、连接数据库、创建数据表、插入数据、查询数据、更新数据、删除数据、执行事务和关闭数据库连接，为了确保顺利地与MySQL数据库交互，需要对这些步骤有一个清晰的理解和正确的实践。

安装MySQL驱动

要在Python环境中使用MySQL数据库，首先需要安装相应的数据库驱动，对于MySQL，常用的驱动有pymysql和mysql.connector，这些驱动允许Python代码与MySQL数据库进行通信。

选择驱动

pymysql：一个纯Python写的MySQL客户端库，支持Python 2.x和3.x。

mysql.connector：是MySQL官方提供的驱动，同样支持Python 2.x和3.x。

安装这些驱动通常使用pip工具，例如安装pymysql可以使用如下命令：

pip install pymysql

或者安装mysql.connector：

pip install mysqlconnectorpython

连接MySQL数据库

连接数据库之前，需要准备以下参数：

主机名（hostname）：通常是’localhost’或数据库服务器的IP地址。

端口号（port）：MySQL默认端口是3306。

用户名（user）：用于登录数据库的用户名。

密码（password）：对应用户的密码。

数据库名（database）：要连接的数据库名称。

以下是使用pymysql连接MySQL数据库的示例代码：

import pymysql
配置连接参数
connection = pymysql.connect(
    host='localhost',
    user='your_username',
    password='your_password',
    db='your_database',
    charset='utf8mb4',
    cursorclass=pymysql.cursors.DictCursor
)
使用连接对象
try:
    with connection.cursor() as cursor:
        # 执行SQL语句
        sql = "SELECTid,name FROMyour_table"
        cursor.execute(sql)
        result = cursor.fetchall()
        for record in result:
            print(record)
finally:
    connection.close()

创建数据库和数据表

在与MySQL数据库的交互中，创建数据库和数据表是基本操作，这通常通过执行SQL语句完成：

with connection.cursor() as cursor:
    # 创建数据库
    sql_create_db = "CREATE DATABASE IF NOT EXISTS your_new_database;"
    cursor.execute(sql_create_db)
    
    # 使用新数据库
    sql_use_db = "USE your_new_database;"
    cursor.execute(sql_use_db)
    
    # 创建数据表
    sql_create_table = """
    CREATE TABLE IF NOT EXISTS your_table (
        id INT AUTO_INCREMENT PRIMARY KEY,
        name VARCHAR(255) NOT NULL,
        age INT
    );"""
    cursor.execute(sql_create_table)
    connection.commit()

插入、查询、更新和删除数据

一旦数据库和数据表被创建，就可以进行数据的插入、查询、更新和删除操作：

with connection.cursor() as cursor:
    # 插入数据
    sql_insert = "INSERT INTO your_table (name, age) VALUES ('John Doe', 30);"
    cursor.execute(sql_insert)
    connection.commit()
    
    # 查询数据
    sql_select = "SELECT * FROM your_table;"
    cursor.execute(sql_select)
    records = cursor.fetchall()
    for record in records:
        print(record)
    
    # 更新数据
    sql_update = "UPDATE your_table SET age = 31 WHERE name = 'John Doe';"
    cursor.execute(sql_update)
    connection.commit()
    
    # 删除数据
    sql_delete = "DELETE FROM your_table WHERE name = 'John Doe';"
    cursor.execute(sql_delete)
    connection.commit()

执行事务和关闭数据库连接

在对数据库进行修改操作时，事务管理非常重要，Python中的事务处理可以通过连接对象的commit()和rollback()方法实现：

try:
    with connection.cursor() as cursor:
        # 执行一系列SQL操作
        # ...
        connection.commit() # 提交事务
except Exception as e:
    connection.rollback() # 发生错误，回滚事务
finally:
    connection.close() # 关闭连接

不要忘记在完成所有数据库操作后关闭数据库连接，以释放资源，这通常通过调用连接对象的close()方法实现：