一步一步教你如何用Python操作MySQL("Python操作MySQL全攻略：手把手教你从入门到精通")

原创

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

Python操作MySQL全攻略：手把手教你从入门到精通

一、前言

Python是一种广泛应用于各种场景的编程语言，其中包括数据库操作。MySQL是一种流行的关系型数据库管理系统，Python可以通过多种做法与之交互。本文将手把手教你怎样使用Python操作MySQL，从入门到精通。

二、环境准备

在开端之前，你需要确保已经安装了以下软件：

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

MySQL服务器

MySQL客户端（如MySQL Workbench）

Python数据库连接库：MySQL Connector或PyMySQL

三、连接MySQL数据库

首先，我们需要使用Python连接到MySQL数据库。这里我们以MySQL Connector为例。


import mysql.connector
# 创建数据库连接
conn = mysql.connector.connect(
    host='localhost',       # 数据库主机地址
    user='your_username',   # 数据库用户名
    passwd='your_password', # 数据库密码
    database='your_db'      # 数据库名
)
# 创建游标对象
cursor = conn.cursor()

四、执行SQL语句

连接胜利后，我们可以执行SQL语句来操作数据库。以下是一些常见的操作：

1. 创建表


# 创建表
create_table_query = """
CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(255) NOT NULL,
    age INT NOT NULL
)
"""
cursor.execute(create_table_query)
conn.commit()

2. 插入数据


# 插入数据
insert_query = "INSERT INTO users (name, age) VALUES (%s, %s)"
values = ('张三', 25)
cursor.execute(insert_query, values)
conn.commit()

3. 查询数据


# 查询数据
select_query = "SELECT * FROM users"
cursor.execute(select_query)
results = cursor.fetchall()
for row in results:
    print(row)

4. 更新数据


# 更新数据
update_query = "UPDATE users SET age = %s WHERE name = %s"
values = (30, '张三')
cursor.execute(update_query, values)
conn.commit()

5. 删除数据


# 删除数据
delete_query = "DELETE FROM users WHERE name = %s"
values = ('张三',)
cursor.execute(delete_query, values)
conn.commit()

五、异常处理

在操作数据库时，大概会遇到各种异常。为了确保程序的健壮性，我们需要捕获并处理这些异常。


try:
    # 执行数据库操作
    pass
except mysql.connector.Error as e:
    print(f"数据库差错: {e}")
except Exception as e:
    print(f"其他差错: {e}")
finally:
    # 关闭游标和连接
    if conn.is_connected():
        cursor.close()
        conn.close()

六、高级特性

除了基本的数据库操作外，Python还赞成一些高级特性，如事务处理、存储过程等。

1. 事务处理


try:
    # 开启事务
    conn.start_transaction()
    # 执行多个操作
    cursor.execute("UPDATE users SET age = %s WHERE name = %s", (30, '张三'))
    cursor.execute("DELETE FROM users WHERE name = %s", ('李四',))
    # 提交事务
    conn.commit()
except mysql.connector.Error as e:
    # 如果出现差错，回滚事务
    conn.rollback()
    print(f"数据库差错: {e}")
finally:
    # 关闭游标和连接
    if conn.is_connected():
        cursor.close()
        conn.close()

2. 存储过程


# 创建存储过程
create_procedure_query = """
CREATE PROCEDURE GetUsersAge(IN user_name VARCHAR(255), OUT user_age INT)
BEGIN
    SELECT age INTO user_age FROM users WHERE name = user_name;
END
"""
cursor.execute(create_procedure_query)
conn.commit()
# 调用存储过程
cursor.callproc('GetUsersAge', ('张三', 0))
result = cursor.fetchone()
print(f"张三的年龄是：{result[1]}")
conn.commit()