python操作mysql

import mysql.connector

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

# 插入数据到表中
def insert_data(connection, name, age):
    try:
        cursor = connection.cursor()
        sql_query = "INSERT INTO users (name, age) VALUES (%s, %s)"
        data = (name, age)
        cursor.execute(sql_query, data)
        connection.commit()
        print("数据插入成功")
    except mysql.connector.Error as err:
        print(f"插入数据失败: {err}")

# 查询数据
def query_data(connection):
    try:
        cursor = connection.cursor()
        sql_query = "SELECT * FROM users"
        cursor.execute(sql_query)
        records = cursor.fetchall()
        for row in records:
            print(row)
    except mysql.connector.Error as err:
        print(f"查询数据失败: {err}")

# 关闭数据库连接
def close_connection(connection):
    if connection.is_connected():
        connection.close()
        print("数据库连接已关闭")

# 示例代码调用
if __name__ == "__main__":
    connection = connect_to_database()
    if connection:
        insert_data(connection, 'Alice', 30)
        query_data(connection)
        close_connection(connection)

解释说明：

1. 连接到MySQL数据库：connect_to_database 函数使用 mysql.connector.connect 方法连接到 MySQL 数据库，并返回连接对象。如果连接成功，会打印 "成功连接到数据库"。
2. 插入数据：insert_data 函数接受一个连接对象和要插入的数据（名字和年龄），然后执行 SQL 插入语句将数据插入到 users 表中。
3. 查询数据：query_data 函数执行 SQL 查询语句从 users 表中获取所有记录并打印出来。
4. 关闭数据库连接：close_connection 函数检查连接是否仍然有效，如果是，则关闭连接并打印 "数据库连接已关闭"。

注意事项：

• 需要安装 mysql-connector-python 库，可以通过 pip install mysql-connector-python 安装。
• 请根据实际情况修改 host, user, password, 和 database 参数。