🚀 MCP 万用数据库连接协议 sqlalchemy 服务器

MCP 万用数据库连接协议 sqlalchemy 服务器是一个基于 SQLAlchemy 的通用数据库连接服务器，支持多种数据库系统，能为开发者提供便捷、高效的数据库连接解决方案。

🚀 快速开始

安装

pip install mcp-sqlalchemy-server

配置

编辑配置文件 config.json：

{
  "port": 5001,
  "databases": {
    "mysql": {
      "driver": "mysql+pymysql",
      "host": "localhost",
      "database": "mydb",
      "user": "root",
      "password": "password"
    },
    "postgresql": {
      "driver": "postgresql+psycopg2",
      "host": "localhost",
      "database": "mydb",
      "user": "postgres",
      "password": "password"
    }
  }
}

启动

python -m mcp_sqlalchemy_server --config config.json

✨ 主要特性

支持的数据库系统

• MySQL
• PostgreSQL
• SQLite
• MSSQL
• Oracle

特性

• 支持多种连接协议
• 数据库自动重连
• 查询结果格式化（JSON, JSONL, Markdown 表格）
• 支持存储过程调用（仅限特定数据库）

📦 安装指南

安装

pip install mcp-sqlalchemy-server

配置

编辑配置文件 config.json：

{
  "port": 5001,
  "databases": {
    "mysql": {
      "driver": "mysql+pymysql",
      "host": "localhost",
      "database": "mydb",
      "user": "root",
      "password": "password"
    },
    "postgresql": {
      "driver": "postgresql+psycopg2",
      "host": "localhost",
      "database": "mydb",
      "user": "postgres",
      "password": "password"
    }
  }
}

启动

python -m mcp_sqlalchemy_server --config config.json

💻 使用示例

基础用法

const MCP = require('mcp-sqlalchemy-client');

// 连接到 MySQL 数据库
const mysqlConn = new MCP.Connection({
  database: 'mysql',
  user: 'root',
  password: 'password'
});

// 执行查询
mysqlConn.query('SELECT * FROM users').then(rows => {
  console.log(rows);
}).catch(err => {
  console.error(err);
});

// 连接到 PostgreSQL 数据库
const postgresConn = new MCP.Connection({
  database: 'postgresql',
  user: 'postgres',
  password: 'password'
});

// 执行查询
postgresConn.query('SELECT * FROM users').then(rows => {
  console.log(rows);
}).catch(err => {
  console.error(err);
});

高级用法

执行 SQL 查询

const query = 'SELECT * FROM users WHERE id = 1';
conn.query(query).then(rows => {
  console.log(rows);
}).catch(err => {
  console.error(err);
});

特殊功能（仅限 Virtuoso）

执行 SPASQL 查询

const query = 'EXEC Demo.demo.execute_spasql_query';
conn.spasql(query).then(rows => {
  console.log(rows);
}).catch(err => {
  console.error(err);
});

执行 SPARQL 查询

const query = 'SELECT * { <http://example.org> <p:age> ?age}';
conn.sparql(query).then(rows => {
  console.log(rows);
}).catch(err => {
  console.error(err);
});

调用 Virtuoso AI 助手

const prompt = '告诉我一些关于数据库优化的建议。';
conn.virtuosoSupportAI(prompt).then(response => {
  console.log(response);
}).catch(err => {
  console.error(err);
});

📚 详细文档

返回格式

• JSON：标准 JSON 数组，适合大多数情况。
• JSONL：每行一个 JSON 对象，适合大数据量输出。
• Markdown 表格：以 Markdown 格式返回表格数据，方便文档展示。

🔧 技术细节

故障排除

为了更方便地进行故障排除：

1. 安装 MCP 检查工具：

   npm install -g @modelcontextprotocol/inspector
   

2. 启动检查工具：

   npx @modelcontextprotocol/inspector uv --directory /path/to/mcp-sqlalchemy-server run mcp-sqlalchemy-server
   

访问提供的 URL 进行服务器交互故障排除。