MCPDatabasesSSE

🗄️ DataBaseSse 项目（SSE 版本）

此项目是原始“stido”版本的 SSE 版本，原始版本可在 https://github.com/alvnavraii/mcpDataBases 获取。此项目经过改进和适配，可用于管理 PostgreSQL 和 SQLite 数据库之间的数据，并通过服务器发送事件（SSE）提供相关功能。

📁 主要结构

• main.py：🖥️ MCP 服务，提供用于查询、插入、更新、删除 PostgreSQL 数据库中的数据以及修改表的工具，现已支持 SSE。
• connection.py：🔗 管理与 PostgreSQL 数据库的连接。
• pg_to_sqlite.py：🔄 将 PostgreSQL 中的所有表和数据迁移到 SQLite 的脚本。
• ecommerce.db：🗃️ 迁移生成的 SQLite 数据库（可选）。

⚙️ 功能

• CRUD 操作：➕ 在 PostgreSQL 数据库表中创建、🔎 读取、✏️ 更新和 ❌ 删除记录。
• 表管理：🏗️ 轻松创建、🛠️ 修改和 🗑️ 删除表。
• 数据迁移：🔄 在 PostgreSQL 和 SQLite 之间自动传输结构和数据。
• 高级查询：🧮 执行自定义 SQL 查询以进行分析或维护。
• SSE 支持：📡 使用服务器发送事件为操作和通知提供实时响应。

🚀 使用示例

1. MCP 服务（main.py）

• 运行 MCP 服务，通过 SSE 提供数据库管理工具：

  python3 main.py
  

• 可用工具：
  • 🔎 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. 数据库之间的数据迁移

• 运行迁移脚本，将 PostgreSQL 中的所有表和数据复制到 SQLite：

  python3 pg_to_sqlite.py
  

• 你可以修改脚本，以便双向迁移数据，或在不同的架构之间迁移数据。

3. CRUD 操作示例

• 创建记录： 📝

  INSERT INTO users (email, password) VALUES ('[email protected]', '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';
  

---