python连接mysql数据库增删改查

import mysql.connector

# 连接MySQL数据库
def connect_db():
    try:
        connection = mysql.connector.connect(
            host='localhost',       # 数据库主机地址
            user='root',           # 数据库用户名
            password='password',   # 数据库密码
            database='testdb'      # 数据库名称
        )
        if connection.is_connected():
            print("成功连接到数据库")
            return connection
    except mysql.connector.Error as err:
        print(f"连接失败: {err}")
        return None

# 插入数据
def insert_data(connection, name, age):
    cursor = connection.cursor()
    sql = "INSERT INTO users (name, age) VALUES (%s, %s)"
    val = (name, age)
    cursor.execute(sql, val)
    connection.commit()
    print(f"插入数据成功，ID: {cursor.lastrowid}")

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

# 更新数据
def update_data(connection, user_id, new_name):
    cursor = connection.cursor()
    sql = "UPDATE users SET name = %s WHERE id = %s"
    val = (new_name, user_id)
    cursor.execute(sql, val)
    connection.commit()
    print(f"更新数据成功，受影响行数: {cursor.rowcount}")

# 删除数据
def delete_data(connection, user_id):
    cursor = connection.cursor()
    sql = "DELETE FROM users WHERE id = %s"
    val = (user_id,)
    cursor.execute(sql, val)
    connection.commit()
    print(f"删除数据成功，受影响行数: {cursor.rowcount}")

# 主函数
def main():
    connection = connect_db()
    if connection:
        # 插入数据示例
        insert_data(connection, 'Alice', 25)

        # 查询数据示例
        query_data(connection)

        # 更新数据示例
        update_data(connection, 1, 'Bob')

        # 删除数据示例
        delete_data(connection, 2)

        # 关闭数据库连接
        connection.close()

if __name__ == "__main__":
    main()

解释说明：

1. 连接数据库：

   • 使用 mysql.connector.connect() 方法连接 MySQL 数据库。
   • 需要提供主机地址、用户名、密码和数据库名称。

2. 插入数据：

   • 使用 INSERT INTO 语句插入新记录。
   • cursor.execute() 执行 SQL 语句，connection.commit() 提交更改。

3. 查询数据：

   • 使用 SELECT 语句查询表中的所有记录。
   • cursor.fetchall() 获取所有查询结果并打印。

4. 更新数据：

   • 使用 UPDATE 语句更新指定条件的记录。
   • cursor.rowcount 返回受影响的行数。

5. 删除数据：

   • 使用 DELETE 语句删除指定条件的记录。
   • cursor.rowcount 返回受影响的行数。

6. 主函数：

   • 包含了连接数据库、插入、查询、更新和删除操作，并在最后关闭数据库连接。