本项目聚焦于在 FastMCP 应用里,展示具备异步支持的 SQLite 数据库的具体使用方式,为开发者提供便捷高效的数据管理解决方案。
pip install -r requirements.txt
python server.py
query_db 工具从数据库中检索数据。aiosqlite 实现异步 SQLite 数据库操作,提升数据处理效率。server.py:主要的 FastMCP 服务器实现,带有数据库上下文管理。database.py:具有异步支持的 SQLite 数据库实现。demo.db:SQLite 数据库文件(首次运行时自动创建)。演示数据库包含一个 users 表,结构如下:
CREATE TABLE users (
id INTEGER PRIMARY KEY AUTOINCREMENT,
name TEXT NOT NULL,
email TEXT UNIQUE NOT NULL
)
首次运行时会自动插入以下示例数据:
Database 类提供以下方法:
connect():创建新的数据库连接并初始化模式。query():执行样本查询以检索所有用户。disconnect():关闭数据库连接。要修改数据库模式或添加新表:
database.py 中的 _init_db() 方法。Database 类添加新的方法以实现自定义查询。server.py 中的 query_db 工具以使用新方法。数据库实现包括: