### 创建与 MySQL 数据库交互的 API 为了创建一个能够与 MySQL 数据库交互的 Python API，可以使用 `FastAPI` 和 `mysql-connector-python` 库来完成这一目标。以下是完整的解决方案： #### 安装依赖项 在开始之前，请确保安装了所需的库： ```bash pip install fastapi uvicorn mysql-connector-python ``` --- #### 配置数据库连接函数 定义一个用于建立数据库连接并返回游标的函数。此部分代码已在引用中提供[^1]。 ```python import mysql.connector def get_conn(): """ 获取数据库连接 """ config = { 'user': 'root', 'password': '1qaz!QAZ', # 替换为实际密码 'host': '127.0.0.1', 'database': 'pb_cms_base' } conn = mysql.connector.connect(**config) cursor = conn.cursor(dictionary=True) # 返回字典形式的结果集 return (conn, cursor) ``` --- #### 初始化 FastAPI 实例 初始化一个 `FastAPI` 对象作为 Web 框架的核心组件。 ```python from fastapi import FastAPI app = FastAPI() ``` --- #### 编写路由以查询数据 通过定义 `/query/` 路由，允许客户端请求特定的数据表内容。以下是一个简单的例子，展示如何从指定表中读取所有记录。 ```python @app.get("/query/") async def query_table(table_name: str): try: conn, cursor = get_conn() # 建立数据库连接 query_sql = f"SELECT * FROM `{table_name}`" cursor.execute(query_sql) # 执行 SQL 查询语句 result = cursor.fetchall() # 获取全部结果 conn.close() # 关闭连接 return {"data": result} except Exception as e: return {"error": str(e)} ``` 上述代码实现了动态查询功能，其中 `table_name` 是路径参数，表示要查询的目标表格名称。如果发生错误，则会捕获异常并将错误消息返回给调用方。 --- #### 测试接口 启动服务后可以通过访问 URL 来测试该接口的功能。例如，在浏览器地址栏输入如下链接即可查看名为 `users` 的表中的所有条目： ``` http://127.0.0.1:8000/query/?table_name=users ``` 运行服务器的方法如下所示： ```bash uvicorn your_script_name:app --reload ``` > **注意**: 将 `your_script_name` 替换成保存脚本的实际文件名（不带 `.py` 后缀）。 --- #### ORM 方式替代原生SQL 对于更复杂的场景或者希望减少手动拼接字符串带来的风险时，推荐采用 SQLAlchemy 或者 PyMySQL 结合 ORM 工具的方式来进行开发[^2]。这种方式不仅提高了安全性还增强了可维护性。 示例代码片段展示了如何利用 SqlAlchemy 自动生成模型类以及执行基本 CRUD 操作的过程。 ```python from sqlalchemy.ext.declarative import declarative_base Base = declarative_base() class User(Base): __tablename__ = 'users' id = Column(Integer, primary_key=True) name = Column(String) # 更多字段省略... ``` 最后记得关闭所有的资源释放工作以免造成内存泄漏等问题[^3]。 --- 相关问题