MCPDatabasesSSE

🗄️ DataBaseSse プロジェクト（SSE バージョン）

このプロジェクトは、https://github.com/alvnavraii/mcpDataBases で公開されている「stido」リリースのSSE バージョンです。PostgreSQL データベースと SQLite データベース間のデータ管理と移行に向けた改善と調整が含まれており、Server-Sent Events（SSE）を通じて機能を提供します。

📁 主な構成

• main.py：🖥️ PostgreSQL データベースのテーブルに対するクエリ、挿入、更新、削除、変更を行うツールを備えた MCP サーバーです。SSE にも対応しています。
• connection.py：🔗 PostgreSQL データベースへの接続を管理します。
• pg_to_sqlite.py：🔄 PostgreSQL から SQLite へすべてのテーブルとデータを移行するスクリプトです。
• ecommerce.db：🗃️ 移行によって生成される SQLite データベースです（任意）。

⚙️ 機能

• CRUD 操作：➕ PostgreSQL データベースのテーブルでレコードを作成、🔎 読み取り、✏️ 更新、❌ 削除します。
• テーブル管理：🏗️ テーブルの作成、🛠️ 変更、🗑️ 削除を簡単に行えます。
• データ移行：🔄 PostgreSQL と SQLite 間で構造とデータを自動転送します。
• 高度なクエリ：🧮 分析やメンテナンスのためのカスタム SQL クエリを実行します。
• SSE 対応：📡 操作や通知に対して、Server-Sent Events を使用してリアルタイムに応答します。

🚀 使用例

1. MCP サーバー（main.py）

• SSE を使用してデータベース管理ツールを公開する MCP サーバーを実行します：

  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';