新闻中心

pymysql连接mysql

发布时间：2025-01-28 08:37:32 点击量：52

使用PyMySQL库来连接MySQL数据库是Python中常见的操作，特别是在开发和数据处理任务中。PyMySQL是一个纯Python编写的MySQL客户端库，兼容性较好且易于使用。下面我将详细介绍如何使用PyMySQL库连接到MySQL数据库，并执行基本的数据库操作。

安装PyMySQL

首先，确保你的Python环境中已经安装了PyMySQL库。可以使用以下命令通过pip进行安装：

pip install pymysql

连接MySQL数据库

PyMySQL库主要通过connect方法实现对MySQL数据库的连接。连接数据库时，我们需要提供以下信息：

host: MySQL服务器的主机地址，通常是localhost或IP地址。
user: 数据库用户名。
password: 数据库用户的密码。
database: 要连接的数据库的名称。
port (可选): MySQL服务的端口号，默认是3306。

下面是一个基本的示例代码，展示了如何连接到MySQL数据库：

import pymysql

# 建立数据库连接
connection = pymysql.connect(
    host='localhost',
    user='your_username',
    password='your_password',
    database='your_database_name',
    charset='utf8mb4',
    cursorclass=pymysql.cursors.DictCursor  # 可选的，返回字典而不是元组
)

try:
    # 创建游标对象
    with connection.cursor() as cursor:
        # 编写SQL查询
        sql = "SELECT * FROM your_table_name"

        # 执行SQL查询
        cursor.execute(sql)

        # 获取查询结果
        result = cursor.fetchall()
        for row in result:
            print(row)
finally:
    # 关闭数据库连接
    connection.close()

代码详解

导入库：首先，导入pymysql库。
建立连接：使用pymysql.connect()方法创建一个数据库连接对象，并指定主机、用户名、密码、数据库名称，以及可选的字符集和游标类型。
创建游标：使用connection.cursor()方法获取一个游标对象。游标用于执行SQL语句，并能从数据库中获取结果。
执行SQL语句：通过cursor.execute(sql)执行SQL查询语句。在这里，sql是一个普通的SQL查询字符串。
处理结果：使用cursor.fetchall()方法获取所有结果行，以列表形式返回数据。可以遍历这个结果集来处理数据。
关闭连接：确保在使用完数据库后关闭连接，以释放资源。通常使用try...finally结构来保证连接的关闭。

常见的SQL操作

除了基本的查询操作，使用PyMySQL可以进行插入、更新和删除等多种数据库操作。

插入数据

以下是插入数据的示例：

with connection.cursor() as cursor:
    sql = "INSERT INTO your_table_name (column1, column2) VALUES (%s, %s)"
    values = ("value1", "value2")
    cursor.execute(sql, values)
    connection.commit()  # 提交更改

注意执行插入操作后，需要使用connection.commit()将更改提交到数据库。

更新数据

更新数据的操作如下：

with connection.cursor() as cursor:
    sql = "UPDATE your_table_name SET column1 = %s WHERE column2 = %s"
    values = ("new_value", "filter_value")
    cursor.execute(sql, values)
    connection.commit()  # 提交更改

删除数据

删除数据的操作如下：

with connection.cursor() as cursor:
    sql = "DELETE FROM your_table_name WHERE column1 = %s"
    value = ("value_to_delete",)
    cursor.execute(sql, value)
    connection.commit()  # 提交更改

异常处理

在实际应用中，为了提高代码的健壮性，需要处理可能出现的异常。例如，可能会由于网络问题或数据库服务不可用导致连接失败。

可以通过捕获pymysql.MySQLError异常来处理这些错误：

try:
    connection = pymysql.connect(…)
    # database operations
except pymysql.MySQLError as e:
    print(f"Error connecting to MySQL Platform: {e}")
finally:
    if connection:
        connection.close()

使用上下文管理器

在Python中，使用上下文管理器更为优雅，即用with语句管理资源。PyMySQL支持上下文管理器，在连接和游标的使用中都可以应用，这样可以自动管理资源的开放和关闭：

import pymysql

with pymysql.connect(
    host='localhost',
    user='your_username',
    password='your_password',
    database='your_database_name',
    charset='utf8mb4'
) as connection:
    with connection.cursor() as cursor:
        sql = "SELECT * FROM your_table_name"
        cursor.execute(sql)
        result = cursor.fetchall()
        for row in result:
            print(row)