FastAPI 中如何使用 SQLAlchemy Core？

推荐答案

在 FastAPI 中使用 SQLAlchemy Core 可以通过以下步骤实现：

1. 安装依赖： 首先，确保安装了 fastapi 和 sqlalchemy 包。

   pip install fastapi sqlalchemy

2. 创建数据库连接： 使用 SQLAlchemy 创建一个数据库连接。

   from sqlalchemy import create_engine, MetaData
   
   DATABASE_URL = "sqlite:///./test.db"
   engine = create_engine(DATABASE_URL)
   metadata = MetaData()

3. 定义表结构： 使用 SQLAlchemy Core 定义表结构。

   // www.javascriptcn.com code example
   from sqlalchemy import Table, Column, Integer, String
   
   users = Table(
       "users",
       metadata,
       Column("id", Integer, primary_key=True),
       Column("name", String),
       Column("email", String),
   )

4. 创建表： 在数据库中创建表。

   metadata.create_all(engine)

5. 在 FastAPI 中使用 SQLAlchemy Core： 在 FastAPI 的路由中使用 SQLAlchemy Core 进行数据库操作。

   // www.javascriptcn.com code example
   from fastapi import FastAPI, Depends
   from sqlalchemy.orm import Session
   from sqlalchemy import select
   
   app = FastAPI()
   
   def get_db():
       db = Session(engine)
       try:
           yield db
       finally:
           db.close()
   
   @app.get("/users/")
   def read_users(db: Session = Depends(get_db)):
       query = select(users)
       result = db.execute(query)
       return result.fetchall()

本题详细解读

SQLAlchemy Core 简介

SQLAlchemy Core 是 SQLAlchemy 的一个组件，它提供了 SQL 表达式语言（SQL Expression Language），允许开发者以编程方式构建 SQL 查询。与 ORM 不同，SQLAlchemy Core 更接近底层的 SQL 操作，适合需要更精细控制数据库操作的场景。

在 FastAPI 中使用 SQLAlchemy Core 的步骤

1. 安装依赖： 使用 pip 安装 fastapi 和 sqlalchemy 包，确保项目中有这些依赖。

2. 创建数据库连接： 使用 create_engine 函数创建一个数据库连接引擎。DATABASE_URL 是数据库的连接字符串，可以是 SQLite、PostgreSQL、MySQL 等。

3. 定义表结构： 使用 Table 类定义表结构，Column 类定义表中的列。metadata 对象用于管理表结构。

4. 创建表： 使用 metadata.create_all(engine) 在数据库中创建表。这一步通常在应用启动时执行。

5. 在 FastAPI 中使用 SQLAlchemy Core： 在 FastAPI 的路由中，通过 Session 对象执行 SQL 查询。get_db 函数用于获取数据库会话，Depends 用于依赖注入。

代码示例解析

• get_db 函数： 该函数用于获取数据库会话，并在请求处理完成后关闭会话。通过 yield 实现依赖注入。

• read_users 路由： 该路由使用 select 语句查询 users 表中的所有数据，并返回查询结果。

通过以上步骤，你可以在 FastAPI 中成功使用 SQLAlchemy Core 进行数据库操作。