### Python 中不使用 ORM 模型时 Router 调用 Service 层的实现方式 在 Python 的 Web 开发中，尤其是在不依赖于 ORM（对象关系映射）工具的情况下，`router` 层和 `service` 层之间的通信可以通过清晰的功能划分来实现。下面详细介绍如何设计这一过程。 --- #### **Router 层调用 Service 层** 在 FastAPI 或 Flask 等框架中，`router` 层主要用于定义 API 接口以及处理 HTTP 请求与响应。当接收到请求后，`router` 层会将解析后的数据传递给 `service` 层进行进一步处理[^1]。 以下是一个基于 FastAPI 的示例： ```python from fastapi import FastAPI, HTTPException from pydantic import BaseModel app = FastAPI() class UserLogin(BaseModel): username: str password: str @app.post("/login/") async def handle_login(user_data: UserLogin): try: # 调用 service 层逻辑 result = await authenticate_user(user_data.username, user_data.password) return {"message": "Authentication successful", "data": result} except ValueError as e: raise HTTPException(status_code=400, detail=str(e)) ``` 在这个例子中，`handle_login` 函数作为 `router` 层的一部分，接收用户输入的数据，并将其传递到名为 `authenticate_user` 的服务函数中进行验证[^1]。 --- #### **Service 层返回逻辑判断后的数据** `service` 层的核心职责是封装业务逻辑并提供独立于框架的具体功能实现。如果未使用 ORM，则需要直接操作数据库或外部服务。以下是 `service` 层的一个可能实现： ```python import psycopg2.pool # 使用 PostgreSQL 数据库连接池 # 初始化数据库连接池 pool = psycopg2.pool.ThreadedConnectionPool( minconn=5, maxconn=10, database="example_db", user="postgres", password="password", host="localhost", port="5432" ) def fetch_connection(): """从连接池获取一个可用的数据库连接""" return pool.getconn() def release_connection(conn): """释放数据库连接回到连接池""" pool.putconn(conn) async def authenticate_user(username: str, password: str): """ 验证用户身份的服务逻辑 :param username: 用户名 :param password: 密码 :return: 成功时返回用户信息；失败时抛出异常 """ if not username or not password: raise ValueError("Username and password must be provided") conn = None try: conn = fetch_connection() cursor = conn.cursor() query = "SELECT id, name FROM users WHERE username=%s AND password=%s LIMIT 1;" cursor.execute(query, (username, password)) # 参数化查询以防止 SQL 注入 row = cursor.fetchone() if not row: raise ValueError("Invalid credentials") return {"id": row[0], "name": row[1]} finally: if conn: release_connection(conn) # 确保无论成功与否都释放连接 ``` 这段代码展示了如何通过原始 SQL 查询而非 ORM 来访问数据库。其中还引入了数据库连接池机制以优化性能[^2]。 --- #### **完整的交互流程** 为了更清楚地理解整个工作流，我们可以总结如下步骤： 1. 客户端向 `/login/` 发起 POST 请求，附带用户名和密码。 2. `router` 层捕获该请求，解析 JSON 数据为 Pydantic 模型实例 (`UserLogin`)。 3. `router` 层调用 `service` 层中的 `authenticate_user` 方法，传入解析后的参数。 4. 在 `service` 层内部： - 获取数据库连接； - 构造安全的 SQL 查询语句； - 执行查询并根据结果决定是否认证成功； - 返回用户信息或将错误反馈至 `router` 层。 5. 如果一切正常，`router` 层将以 JSON 格式返回成功的消息及其附加数据；否则触发相应的 HTTP 错误响应。 --- ### 总结 尽管现代开发倾向于采用 ORM 工具简化数据库操作，但在某些特定场景下（比如追求极致性能），直接编写 SQL 是完全可行的选择。此时只需确保各层之间界限分明——即让 `router` 层专注于请求路由管理，而把复杂的业务逻辑交予专门化的 `service` 层去完成即可[^4]。 ---