Python与数据库交互：入门指南

import mysql.connector

# 连接数据库
def connect_to_database():
    try:
        conn = mysql.connector.connect(
            host="your_host",
            user="your_user",
            password="your_password",
            database="your_database"
        )
        print("成功连接到数据库")
        return conn
    except mysql.connector.Error as err:
        print("数据库连接失败：", err)

# 查询数据
def query_data(conn, query):
    try:
        cursor = conn.cursor()
        cursor.execute(query)
        results = cursor.fetchall()
        for row in results:
            print(row)
    except mysql.connector.Error as err:
        print("查询数据失败：", err)

# 插入数据
def insert_data(conn, query, values):
    try:
        cursor = conn.cursor()
        cursor.execute(query, values)
        conn.commit()
        print("数据插入成功")
    except mysql.connector.Error as err:
        print("插入数据失败：", err)

# 更新数据
def update_data(conn, query):
    try:
        cursor = conn.cursor()
        cursor.execute(query)
        conn.commit()
        print("数据更新成功")
    except mysql.connector.Error as err:
        print("更新数据失败：", err)

# 删除数据
def delete_data(conn, query):
    try:
        cursor = conn.cursor()
        cursor.execute(query)
        conn.commit()
        print("数据删除成功")
    except mysql.connector.Error as err:
        print("删除数据失败：", err)

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

# 测试连接和查询
conn = connect_to_database()
query = "SELECT * FROM your_table"
query_data(conn, query)
close_connection(conn)