### 使用 FastAPI 和 SQL 构建完整的商城数据库系统 构建一个完整的商城数据库系统涉及多个方面，包括设计数据库模式、定义模型、实现 CRUD 操作以及集成到 FastAPI 中。以下是详细的说明： #### 数据库设计 为了支持商城的功能需求，可以考虑以下几个主要表结构： 1. **Users**: 存储用户的注册信息。 2. **Products**: 存储商品的信息。 3. **Orders**: 记录订单详情。 4. **OrderItems**: 关联 Orders 表和 Products 表。 这些表可以通过外键关联起来，形成一个关系型数据库体系。 ```sql CREATE TABLE Users ( id SERIAL PRIMARY KEY, username VARCHAR(50) NOT NULL UNIQUE, email VARCHAR(100) NOT NULL UNIQUE, password_hash VARCHAR(255) NOT NULL ); CREATE TABLE Products ( id SERIAL PRIMARY KEY, name VARCHAR(100) NOT NULL, description TEXT, price DECIMAL(10, 2) NOT NULL, stock INTEGER DEFAULT 0 ); CREATE TABLE Orders ( id SERIAL PRIMARY KEY, user_id INTEGER REFERENCES Users(id), order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); CREATE TABLE OrderItems ( id SERIAL PRIMARY KEY, order_id INTEGER REFERENCES Orders(id), product_id INTEGER REFERENCES Products(id), quantity INTEGER NOT NULL, total_price DECIMAL(10, 2) NOT NULL ); ``` #### 定义模型 使用 `SQLModel` 来定义数据模型，这使得我们可以轻松地将对象映射到数据库中的表格[^1]。 ```python from sqlmodel import Field, Relationship, SQLModel class User(SQLModel, table=True): id: int = Field(default=None, primary_key=True) username: str = Field(max_length=50, unique=True) email: str = Field(max_length=100, unique=True) password_hash: str class Product(SQLModel, table=True): id: int = Field(default=None, primary_key=True) name: str = Field(max_length=100) description: str | None = None price: float stock: int = Field(default=0) class Order(SQLModel, table=True): id: int = Field(default=None, primary_key=True) user_id: int = Field(foreign_key="user.id") order_date: datetime.datetime = Field(default_factory=datetime.datetime.now) items: list["OrderItem"] = Relationship(back_populates="order") class OrderItem(SQLModel, table=True): id: int = Field(default=None, primary_key=True) order_id: int = Field(foreign_key="order.id") product_id: int = Field(foreign_key="product.id") quantity: int total_price: float order: Order = Relationship(back_populates="items") ``` #### 配置数据库连接 通过配置异步或同步的数据库会话来管理与 PostgreSQL 的交互[^1]。 ```python from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession from sqlalchemy.orm import sessionmaker DATABASE_URL = "postgresql+asyncpg://user:password@localhost/dbname" engine = create_async_engine(DATABASE_URL, echo=True, future=True) async_session = sessionmaker(engine, class_=AsyncSession, expire_on_commit=False) ``` #### 创建 API 路由 利用 FastAPI 提供的强大路由机制，为商城系统的各个模块创建相应的端点。 ```python from fastapi import Depends, FastAPI, HTTPException from sqlalchemy.future import select from sqlalchemy.exc import IntegrityError app = FastAPI() @app.post("/users/", response_model=User) async def create_user(user: UserCreate, db: AsyncSession = Depends(get_db)): try: stmt = insert(User).values(**user.dict()) result = await db.execute(stmt) await db.commit() return {**user.dict(), "id": result.inserted_primary_key[0]} except IntegrityError as e: raise HTTPException(status_code=400, detail=f"User already exists.") ``` 以上是一个简单的例子展示如何用 FastAPI 和 SQL 构建商城数据库系统的一部分功能。实际应用中还需要加入更多的错误处理逻辑、安全性措施以及其他业务逻辑。