🗄️ 数据库SSE项目（SSE版本）

此项目是原始“stido”发布在 https://github.com/alvnavraii/mcpDataBases 上的 SSE 版本。它包括了管理 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 ('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';