🚀 数据库SSE项目（SSE版本）
本项目是原始“stido”发布在 https://github.com/alvnavraii/mcpDataBases 上项目的 SSE 版本。它对管理 PostgreSQL 和 SQLite 数据库之间数据迁移的功能进行了改进与适配，并通过服务器发送事件（SSE）将这些功能公开，为数据库操作带来了更高效、实时的体验。
✨ 主要特性
- CRUD 操作：支持在 PostgreSQL 数据库表中进行创建、查询、更新和删除记录的操作，满足基本的数据管理需求。
- 表管理：可方便地创建、修改和删除表，灵活应对不同的数据结构变化。
- 数据迁移：能够自动在 PostgreSQL 和 SQLite 之间转移结构和数据，实现数据库间的无缝切换。
- 高级查询：支持执行自定义 SQL 查询，适用于数据分析和数据库维护等场景。
- SSE 支持：利用服务器发送事件实现实时操作响应和通知，提升操作的及时性和交互性。
📦 安装指南
文档未提及安装步骤，暂不提供相关内容。
📁 主要结构
- main.py：作为 MCP 服务器，提供了查询、插入、更新、删除和修改 PostgreSQL 数据库表的工具，并且现在支持 SSE 功能。
- connection.py：负责管理与 PostgreSQL 数据库的连接，确保数据交互的稳定。
- pg_to_sqlite.py：该脚本用于将所有表和数据从 PostgreSQL 迁移到 SQLite，实现数据库间的数据转移。
- ecommerce.db：由迁移生成的 SQLite 数据库，为可选文件。
💻 使用示例
基础用法
1. 启动 MCP 服务器
运行 MCP 服务器以通过 SSE 公开数据库管理工具：
python3 main.py
2. 数据迁移
运行迁移脚本以将所有表和数据从 PostgreSQL 迁移到 SQLite：
python3 pg_to_sqlite.py
高级用法
1. MCP 服务器工具使用
- 🔎
query_db(query)：执行 SELECT 查询并通过 SSE 返回结果。 - ➕
insert_db(query)：执行 INSERT 语句，并通过 SSE 通知操作结果。 - ✏️
update_db(query)：执行 UPDATE 语句，并通过 SSE 通知操作结果。 - ❌
delete_db(query)：执行 DELETE 语句，并通过 SSE 通知操作结果。 - 🏗️
create_table(query)：执行 CREATE TABLE 语句，并通过 SSE 通知操作结果。 - 🛠️
alter_table(query)：执行 ALTER TABLE 语句，并通过 SSE 通知操作结果。 - 🗑️
drop_table(query)：执行 DROP TABLE 语句，并通过 SSE 通知操作结果。
2. CRUD 操作示例
- 创建记录：
INSERT INTO users (email, password) VALUES ('user@domain.com', 'secret');
- 查询记录：
SELECT * FROM products WHERE is_active = TRUE;
- 更新记录：
UPDATE categories SET name = 'New Technologies' WHERE id = 1;
- 删除记录：
DELETE FROM carts WHERE created_at < '2024-01-01';
🔧 技术细节
文档未提供详细的技术实现细节，暂不展示相关内容。
📄 许可证
文档未提及许可证信息，暂不提供相关内容。