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 數據庫

連接

• URL 方法：

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

• 工作區方法：

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

• 直接參數方法：

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 數據庫

連接

• URL 方法：

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

• 工作區方法：

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

• 直接連接方法：

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); // 插入一個文檔

更新數據

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. 數據格式問題

   • 確保插入的數據與集合定義的模式一致。
   • 使用調試日誌檢查數據結構。

日誌記錄

• 在生產環境中啟用詳細的日誌記錄以跟蹤數據庫操作。
• 定期審查日誌文件以檢測潛在的安全威脅和性能問題。