python连接mysql数据库、FastAPI、mysql-connector-python

为了使用Python连接到MySQL数据库，并且与FastAPI集成，你可以使用mysql-connector-python库。以下是一个简单的例子，展示了如何在FastAPI应用中设置数据库连接，并执行一个简单的查询。

首先，确保你已经安装了mysql-connector-python库。如果没有安装，可以使用以下命令安装：

pip install mysql-connector-python

然后，你可以使用以下代码在FastAPI应用中连接到MySQL数据库并执行查询：

from fastapi import FastAPI
import mysql.connector
from mysql.connector import Error
 
app = FastAPI()
 
@app.on_event("startup")
async def startup_event():
    try:
        # 连接到数据库
        global database_connection
        database_connection = mysql.connector.connect(
            host="your_host",
            user="your_username",
            password="your_password",
            database="your_database"
        )
        print("Connected to the database")
    except Error as e:
        print("Error while connecting to the database:", e)
 
@app.on_event("shutdown")
async def shutdown_event():
    # 关闭数据库连接
    global database_connection
    if database_connection.is_connected():
        database_connection.close()
        print("Database connection is closed")
 
@app.get("/items/")
async def read_items():
    query = "SELECT * FROM your_table"
    cursor = database_connection.cursor()
    cursor.execute(query)
    items = cursor.fetchall()
    return items
 

在这个例子中，startup_event 函数会在应用启动时被调用，建立到MySQL数据库的连接。shutdown_event 函数会在应用关闭时被调用，关闭数据库连接。read_items 路由使用全局数据库连接来执行一个查询并返回结果。

请确保替换 your_host, your_username, your_password, your_database, 和 your_table 为你的MySQL数据库的实际连接信息和表名。