MCP Mongodb Mysql Server

🚀 MCP-MySQL-MongoDB Server

This project offers a powerful toolset for managing both MySQL and MongoDB databases simultaneously, ensuring the security and efficiency of data operations.

🚀 Quick Start

The following steps will guide you through the installation and setup process of the MCP-MySQL-MongoDB Server.

📦 Installation

Install Dependencies

Run the following command to install the required dependencies:

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

Initialize the Project

Create a package.json file and add the following content:

{
  "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"
  }
}

Create the Server File

Create a server.ts file and add the following content:

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

const app = express();
app.listen(3000, () => {
  console.log('Server is running and listening on port 3000');
});

// Initialize database connections
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 };
}

// Route examples
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 });
  }
});

💻 Usage Examples

MySQL Database

Connection

1. URL Method

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

2. Workspace Method

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

3. Direct Parameter Method

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

Query

// Basic query
await mysqlServer.query('SELECT * FROM users');

// Query with prepared statements
const preparedStatement = new MySQLPreparedStatement(
  'INSERT INTO users (name, age) VALUES (?, ?)',
  [user.name, user.age]
);
await mysqlServer.execute(preparedStatement);

Close the Connection

await mysqlServer.close();

MongoDB Database

Connection

1. URL Method

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

2. Workspace Method

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

3. Direct Connection Method

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

Query

const collection = db.collection('users');
await collection.find().toArray(); // Get all documents

const query = { age: 25 };
await collection.findOne(query); // Find a single document based on conditions

Insert Data

const user = { name: 'John', age: 30 };
await collection.insertOne(user); // Insert a single document

Update Data

const query = { name: 'John' };
const update = { $set: { age: 31 } };
await collection.updateOne(query, update); // Update a single document

Delete Data

const query = { name: 'John' };
await collection.deleteOne(query); // Delete a single document that meets the conditions

Close the Connection

await client.close();

✨ Features

MySQL Server

• Prepared Statement Support: Prevents SQL injection attacks.
• Transaction Support: Ensures the atomicity, consistency, isolation, and durability of database operations.
• ResultSet Iteration: Efficiently handles large - scale data queries.

MongoDB Database

• Asynchronous Driver: Non - blocking operations to improve performance.
• Workspace Support: Automatically loads and saves data in the development environment.
• Connection Pool Management: Optimizes resource utilization.

⚠️ Important Note

MySQL Security

• Prepared Statements: Always use prepared statements to prevent SQL injection attacks.
• Least - Privilege Users: Create users with the minimum required permissions for database connections.
• Encrypted Communication: Enable SSL certificates in the production environment.

MongoDB Security

• Authentication: Always enable authentication.
• Network Encryption: Use SSL/TLS to encrypt communication.
• Access Control: Restrict access to sensitive collections and fields.

❗ Error Handling

Common Issues

1. Connection Timeout

• Check if the database service is running.
• Ensure that the firewall allows the relevant ports.

2. Permission Error

• Verify that the user credentials are correct.
• Check if the user has sufficient permissions.

3. Data Format Issue

• Ensure that the inserted data matches the schema defined in the collection.
• Use debug logs to check the data structure.

Logging

• Enable detailed logging in the production environment to track database operations.
• Regularly review log files to detect potential security threats and performance issues.