🚀 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. 数据格式问题

   • 确保插入的数据与集合定义的模式一致。
   • 使用调试日志检查数据结构。

日志记录

• 在生产环境中启用详细的日志记录以跟踪数据库操作。
• 定期审查日志文件以检测潜在的安全威胁和性能问题。