如何在Python中操作MySQL？(Python操作MySQL数据库实用指南)

原创

ithorizon 6个月前 (10-21) 阅读数 18 #后端开发

Python操作MySQL数据库实用指南

一、引言

在当今的软件开发中，数据库操作是必不可少的一部分。Python作为一种流行的编程语言，提供了多种数据库操作的库。本文将详细介绍怎样在Python中操作MySQL数据库，包括连接数据库、执行SQL语句、查询数据、插入数据、更新数据和删除数据等操作。

二、环境准备

在进行Python操作MySQL之前，需要确保以下环境已经搭建好：

Python环境（建议使用Python 3.x版本）

MySQL数据库（建议使用MySQL 5.7及以上版本）

MySQLdb或pymysql库（用于Python与MySQL之间的交互）

三、连接MySQL数据库

首先，我们需要使用MySQLdb或pymysql库来连接MySQL数据库。以下是一个明了的示例：


import pymysql
# 连接数据库
connection = pymysql.connect(host='localhost',
                             user='root',
                             password='123456',
                             database='testdb',
                             charset='utf8mb4',
                             cursorclass=pymysql.cursors.DictCursor)

四、执行SQL语句

连接数据库后，我们可以通过创建游标对象来执行SQL语句。以下是一些基本的SQL操作示例：

4.1 查询数据

使用cursor.execute(sql)方法执行查询语句，并通过cursor.fetchall()获取查询导致：


# 创建游标对象
with connection.cursor() as cursor:
    # SQL查询语句
    sql = "SELECT * FROM students"
    cursor.execute(sql)
    result = cursor.fetchall()
    for row in result:
        print(row)

4.2 插入数据

插入数据时，使用cursor.execute(sql, data)方法，其中data是一个包含数据的元组或字典：


# 插入数据
with connection.cursor() as cursor:
    # SQL插入语句
    sql = "INSERT INTO students (name, age, class) VALUES (%s, %s, %s)"
    data = ('张三', 20, '计算机科学与技术1班')
    cursor.execute(sql, data)
    connection.commit()  # 提交事务

4.3 更新数据

更新数据时，使用与插入数据类似的方法：


# 更新数据
with connection.cursor() as cursor:
    # SQL更新语句
    sql = "UPDATE students SET age = %s WHERE name = %s"
    data = (21, '张三')
    cursor.execute(sql, data)
    connection.commit()  # 提交事务

4.4 删除数据

删除数据时，同样使用类似的方法：


# 删除数据
with connection.cursor() as cursor:
    # SQL删除语句
    sql = "DELETE FROM students WHERE name = %s"
    data = ('张三',)
    cursor.execute(sql, data)
    connection.commit()  # 提交事务

五、异常处理

在执行数据库操作时，也许会遇到各种异常。为了确保程序的健壮性，我们需要对也许出现的异常进行处理：


try:
    with connection.cursor() as cursor:
        # 执行SQL语句
        pass
    connection.commit()  # 提交事务
except pymysql.MySQLError as e:
    print("MySQL Error:", e)
    connection.rollback()  # 回滚事务
finally:
    connection.close()  # 关闭连接

六、批量操作

在实际应用中，我们时常需要批量插入或更新数据。以下是一个批量插入数据的示例：


# 批量插入数据
with connection.cursor() as cursor:
    # SQL插入语句
    sql = "INSERT INTO students (name, age, class) VALUES (%s, %s, %s)"
    data = [('张三', 20, '计算机科学与技术1班'),
            ('李四', 21, '计算机科学与技术2班'),
            ('王五', 22, '计算机科学与技术3班')]
    cursor.executemany(sql, data)
    connection.commit()  # 提交事务

七、事务管理

事务管理是数据库操作中非常重要的一部分。在Python中，我们可以通过以下行为来管理事务：


try:
    with connection.cursor() as cursor:
        # 执行多个SQL语句
        cursor.execute("UPDATE students SET age = %s WHERE name = %s", (21, '张三'))
        cursor.execute("UPDATE students SET age = %s WHERE name = %s", (22, '李四'))
    connection.commit()  # 提交事务
except pymysql.MySQLError as e:
    print("MySQL Error:", e)
    connection.rollback()  # 回滚事务
finally:
    connection.close()  # 关闭连接