MCP Mongodb Mysql Server

🚀 MCP-MySQL-MongoDB サーバー

このプロジェクトは、MySQL と MongoDB データベースを同時に管理するための強力なツールセットを提供します。前処理文、トランザクションサポート、非同期ドライバーなどの機能により、データ操作の安全性と効率性を確保します。

🚀 クイックスタート

このサーバーを使用するには、まず必要な依存関係をインストールし、プロジェクトを初期化し、サーバーファイルを作成する必要があります。以下の手順に従ってセットアップを行ってください。

📦 インストール

依存関係のインストール

必要な依存関係をインストールするには、以下のコマンドを実行します。

npm install mcp-mysql-server mongodb typescript @types/node @types/express express

プロジェクトの初期化

package.json ファイルを作成し、以下の内容を追加します。

{
  "name": "mcp-mysql-mongodb-server",
  "version": "1.0.0",
  "main": "server.ts",
  "scripts": {
    "start": "ts-node server.ts"
  },
  "dependencies": {
    "express": "^4.18.2",
    "mcp-mysql-server": "^1.0.0",
    "mongodb": "^5.0.0",
    "@types/node": "^16.0.0",
    "@types/express": "^4.17.1"
  },
  "devDependencies": {
    "ts-node": "^9.0.0",
    "typescript": "^5.0.0"
  }
}

サーバーファイルの作成

server.ts ファイルを作成し、以下の内容を追加します。

import express from 'express';
import { MySQLServer } from 'mcp-mysql-server';
import { MongoClient } from 'mongodb';

const app = express();
app.listen(3000, () => {
  console.log('サーバーが起動し、ポート 3000 でリッスンしています');
});

// データベース接続の初期化
const mysqlServer = new MySQLServer({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'test'
});

async function connectMongoDB() {
  const client = await MongoClient.connect('mongodb://localhost:27017', { useNewUrlParser: true, useUnifiedTopology: true });
  const db = client.db('test');
  return { client, db };
}

// ルートの例
app.get('/api/mysql', async (req, res) => {
  try {
    const result = await mysqlServer.query('SELECT * FROM users LIMIT 10');
    res.json(result);
  } catch (error) {
    res.status(500).json({ error: error.message });
  }
});

app.get('/api/mongodb', async (req, res) => {
  try {
    const { db } = await connectMongoDB();
    const collection = db.collection('users');
    const result = await collection.find().toArray();
    res.json(result);
  } catch (error) {
    res.status(500).json({ error: error.message });
  }
});

💻 使用例

MySQL データベース

接続

1. URL 方法：

   const mysqlServer = new MySQLServer({
     connectionUrl: 'mysql://user:password@host/database'
   });
   

2. ワークスペース方法：

   const mysqlServer = new MySQLServer({
     workspace: '/path/to/workspace',
     database: 'database-name'
   });
   

3. 直接パラメーター方法：

   const mysqlServer = new MySQLServer({
     host: 'localhost',
     user: 'root',
     password: 'password',
     database: 'test'
   });
   

クエリ

// 基本的なクエリ
await mysqlServer.query('SELECT * FROM users');

// プリペアドステートメントを使用したクエリ
const preparedStatement = new MySQLPreparedStatement(
  'INSERT INTO users (name, age) VALUES (?, ?)',
  [user.name, user.age]
);
await mysqlServer.execute(preparedStatement);

接続の閉じる

await mysqlServer.close();

MongoDB データベース

接続

1. URL 方法：

   const client = await MongoClient.connect('mongodb://localhost:27017/test', { useNewUrlParser: true, useUnifiedTopology: true });
   

2. ワークスペース方法：

   const { client, db } = await connectMongoDB();
   

3. 直接接続方法：

   const client = new MongoClient('mongodb://localhost:27017', { useNewUrlParser: true, useUnifiedTopology: true });
   const db = client.db('test');
   

クエリ

const collection = db.collection('users');
await collection.find().toArray(); // すべてのドキュメントを取得

const query = { age: 25 };
await collection.findOne(query); // 条件に一致する単一のドキュメントを検索

データの挿入

const user = { name: 'John', age: 30 };
await collection.insertOne(user); // 1つのドキュメントを挿入

データの更新

const query = { name: 'John' };
const update = { $set: { age: 31 } };
await collection.updateOne(query, update); // 単一のドキュメントを更新

データの削除

const query = { name: 'John' };
await collection.deleteOne(query); // 条件に一致する単一のドキュメントを削除

接続の閉じる

await client.close();

✨ 主な機能

MySQL サーバー

• プリペアドステートメントのサポート：SQL インジェクション攻撃を防止します。
• トランザクションのサポート：データベース操作の原子性、一貫性、分離性、永続性を保証します。
• 結果セットの反復処理：大量のデータクエリを効率的に処理します。

MongoDB データベース

• 非同期ドライバー：非ブロッキング操作によりパフォーマンスを向上させます。
• ワークスペースのサポート：開発環境でデータを自動的に読み込み、保存します。
• 接続プールの管理：リソースの利用を最適化します。

⚠️ 重要提示

MySQL のセキュリティ

• プリペアドステートメント：常にプリペアドステートメントを使用して、SQL インジェクション攻撃を防止します。
• 最小限の権限を持つユーザー：データベース接続には、最小限の権限を持つユーザーを作成します。
• 暗号化通信：本番環境では SSL 証明書を有効にします。

MongoDB のセキュリティ

• 認証：常に認証を有効にします。
• ネットワーク暗号化：SSL/TLS を使用して通信を暗号化します。
• アクセス制御：機密性の高いコレクションやフィールドへのアクセスを制限します。

🔧 エラー処理

一般的な問題

1. 接続タイムアウト

   • データベースサービスが実行中かどうかを確認します。
   • ファイアウォールが関連するポートを許可していることを確認します。

2. 権限エラー

   • ユーザーの資格情報が正しいことを確認します。
   • ユーザーが十分な権限を持っていることを確認します。

3. データ形式の問題

   • 挿入するデータがコレクション定義のスキーマと一致することを確認します。
   • デバッグログを使用してデータ構造を確認します。

ログ記録

• 本番環境では、データベース操作を追跡するために詳細なログ記録を有効にします。
• 潜在的なセキュリティ脅威やパフォーマンス問題を検出するために、定期的にログファイルをレビューします。