Mcpdatabasessse

🚀 数据库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';

🔧 技术细节

文档未提供详细的技术实现细节，暂不展示相关内容。

📄 许可证

文档未提及许可证信息，暂不提供相关内容。