Python 往 MySQL 数据库中写入数据和更新插入数据

1. 引言

MySQL 是一个流行的关系型数据库管理系统，广泛应用于各类应用程序中。在开发过程中，使用 Python 连接 MySQL 数据库进行数据的写入和更新是常见的需求之一。本文将介绍如何使用 Python 进行数据的写入和更新插入。

2. 安装 MySQL Connector

首先，在使用 Python 连接 MySQL 之前，需要安装相应的模块。推荐使用 MySQL Connector 来连接和操作 MySQL 数据库。可以使用以下命令安装 MySQL Connector：

pip install mysql-connector-python

3. 连接 MySQL 数据库

在使用 Python 连接 MySQL 数据库之前，需要先创建一个数据库，并确保已经设置好数据库的连接信息，包括数据库名称、主机名、用户名和密码。在连接之前，可以通过以下代码来测试是否能够与数据库成功建立连接：

import mysql.connector

try:
    conn = mysql.connector.connect(
        host="localhost",
        user="root",
        password="password",
        database="test"
    )
    print("Connected successfully!")
except mysql.connector.Error as e:
    print("Error connecting to MySQL database:", e)
finally:
    conn.close()

在上述代码中，使用 mysql.connector.connect() 方法来连接 MySQL 数据库，传入相应的连接信息。

4. 插入数据

插入数据是向数据库中添加新记录的过程。使用 Python 可以方便地通过 SQL 语句实现数据的插入。以下是一个示例代码，演示如何向 MySQL 数据库中插入一条新的记录：

import mysql.connector

try:
    conn = mysql.connector.connect(
        host="localhost",
        user="root",
        password="password",
        database="test"
    )

    cursor = conn.cursor()
    sql = "INSERT INTO users (name, age) VALUES (%s, %s)"
    data = ("John Doe", 25)
    cursor.execute(sql, data)
    conn.commit()

    print("Data inserted successfully!")

except mysql.connector.Error as e:
    conn.rollback()
    print("Error inserting data into MySQL database:", e)

finally:
    conn.close()

在上述代码中，首先使用 conn.cursor() 方法创建一个游标对象，然后使用 SQL 语句定义插入操作，将要插入的数据通过 execute() 方法传入。使用 conn.commit() 来提交事务，将数据写入到数据库中。

5. 更新插入数据

如果在插入数据时，数据已经存在于数据库中，可以选择更新数据而不是插入新记录。使用 Python 也可以方便地通过 SQL 语句实现数据的更新插入。以下是一个示例代码，演示如何向 MySQL 数据库中更新插入数据：

import mysql.connector

try:
    conn = mysql.connector.connect(
        host="localhost",
        user="root",
        password="password",
        database="test"
    )

    cursor = conn.cursor()
    sql = "INSERT INTO users (name, age) VALUES (%s, %s) ON DUPLICATE KEY UPDATE age = VALUES(age)"
    data = ("John Doe", 26)
    cursor.execute(sql, data)
    conn.commit()

    print("Data updated or inserted successfully!")

except mysql.connector.Error as e:
    conn.rollback()
    print("Error updating or inserting data into MySQL database:", e)

finally:
    conn.close()