MCP PostgreSQL 查询服务器

一个模型上下文协议（MCP）服务器实现，用于以只读模式查询PostgreSQL数据库，设计用于与Claude Desktop和其他MCP客户端一起工作。

概述

此项目实现了以下功能的模型上下文协议（MCP）服务器：

1. 提供安全、只读接口访问PostgreSQL数据库
2. 与Claude Desktop通过MCP协议集成
3. SQL查询验证，确保仅执行SELECT查询
4. 查询超时保护（10秒）

先决条件

• Node.js（v14或更高版本）
• npm（随Node.js提供）
• PostgreSQL数据库（通过命令行提供的连接详细信息）

安装

# 克隆仓库
git clone https://github.com/RathodDarshil/mcp-postgres-query-server.git
cd mcp-postgres-query-server

# 安装依赖项
npm install

# 构建项目
npm run build

与Claude Desktop连接

您可以配置Claude Desktop以自动启动并连接到MCP服务器：

1. 访问Claude Desktop的配置文件：

   • 打开Claude Desktop
   • 转到设置 > 开发者 > 编辑配置
   • 这将在默认文本编辑器中打开配置文件

2. 在claude_desktop_config.json的mcpServers部分添加postgres-query-server：

{
    "mcpServers": {
        "postgres-query": {
            "command": "node",
            "args": [
                "/path/to/your/mcp-postgres-query-server/dist/index.js",
                "postgresql://username:password@hostname:port/database"
            ]
        }
    }
}

3. 用实际项目目录的实际路径替换/path/to/your/
4. 用实际的PostgreSQL连接字符串替换数据库凭据
5. 保存文件并重新启动Claude Desktop。MCP服务器应该现在出现在设置中的MCP服务器选择下拉菜单中

配置示例

以下是带有postgres-query的配置文件完整示例：

{
    "mcpServers": {
        "postgres-query": {
            "command": "node",
            "args": [
                "/Users/darshilrathod/mcp-servers/mcp-postgres-query-server/dist/index.js",
                "postgresql://user:password@localhost:5432/mydatabase"
            ]
        }
    }
}

配置更新

要更新Claude Desktop配置：

1. 打开Claude Desktop
2. 转到设置 > 开发者 > 编辑配置
3. 在配置文件中进行更改
4. 保存文件
5. 重新启动Claude Desktop以使更改生效
6. 如果您已更新MCP服务器代码，请在重新启动之前使用npm run build进行重建

功能

• 只读数据库访问：仅允许SELECT查询，确保安全
• 查询验证：防止潜在有害的SQL操作
• 超时保护：运行时间超过10秒的查询将被自动终止
• MCP协议支持：完整的模型上下文协议实现
• JSON响应格式化：查询结果以结构化的JSON格式返回

API

工具

query-postgres

对配置好的PostgreSQL数据库执行只读SQL查询。

参数：

• query（字符串）：要执行的SQL SELECT查询

响应：

• JSON对象包含：
  • rows：结果集行
  • columns：列信息
  • rowCount：行数
  • type：查询类型

示例请求

{
  "procedure": "query-postgres",
  "params": {
    "query": "SELECT * FROM users LIMIT 10"
  }
}

示例响应

{
  "rows": [
    { "id": 1, "name": "Alice" },
    { "id": 2, "name": "Bob" }
  ],
  "columns": ["id", "name"],
  "rowCount": 2,
  "type": "SELECT"
}

开发

配置PostgreSQL连接

在config.js文件中，配置PostgreSQL连接详细信息：

module.exports = {
    host: 'localhost',
    port: 5432,
    user: 'yourdbuser',
    password: 'yourdbpassword',
    database: 'yourdatabasename'
};

运行查询

在index.js文件中，定义处理查询的逻辑：

const { Pool } = require('pg');
const pool = new Pool(require('./config'));

async function queryPostgres(query) {
    try {
        const result = await pool.query(query);
        return {
            rows: Array.from(result.rows),
            columns: result.columns,
            rowCount: result.rowCount,
            type: result.command
        };
    } catch (error) {
        throw new Error(`Query failed: ${error.message}`);
    }
}

module.exports = { queryPostgres };

安全注意事项

• 确保PostgreSQL凭据安全，避免明文存储
• 配置适当的防火墙规则以限制数据库访问
• 定期备份数据库以防数据丢失
• 启用SSL连接以加密与数据库的通信