Fastpostgresmcp

🚀 MCP 服務器 PostgreSQL 版本

MCP（Multi-Connection Proxy）服務器是一款代理服務，支持多種數據庫協議，還提供了豐富工具與資源，可用於管理數據庫連接。本文檔將詳細介紹如何使用 MCP 服務器與 PostgreSQL 數據庫進行交互。

🚀 快速開始

MCP 服務器可助力您高效地與 PostgreSQL 數據庫交互。以下將為您介紹安裝、配置、啟動服務的具體步驟。

📦 安裝指南

快速安裝

使用以下命令快速安裝 mcp-server-postgres：

npm install mcp-server-postgres --save

配置步驟

1. 創建配置文件：
   • 新建 config.json 文件。
   • 添加以下配置內容：

{
    "database": {
        "connections": {
            "main": {
                "type": "postgres",
                "host": "localhost",
                "port": 5432,
                "username": "db_user",
                "password": "db_password"
            }
        },
        "defaultConnection": "main"
    },
    "authentication": {
        "secretKey": "your_secret_key_here",
        "enableSSL": true
    }
}

- 將 `config.json` 添加到 `.env` 文件中：

echo "MCP_CONFIG=path/to/config.json" >> .gitignore

啟動服務

使用以下命令啟動服務：

node index.js --config config.json

✨ 主要特性

數據庫連接池管理

• 創建連接池：通過 DBConnectionFactory 類初始化 PostgreSQL 連接池。

const connectionFactory = new DBConnectionFactory({
    host: 'localhost',
    port: 5432,
    username: 'db_user',
    password: 'db_password'
});

• 獲取連接：

const connection = await connectionFactory.getConnection('main');

執行查詢

簡單查詢

const query = new QueryBuilder('users')
  .select(['id', 'username'])
  .where('active = true');

const result = await connection.query(query);

參數化查詢

const params = {
    "username": "john_doe",
    "status": "active"
};

const query = new QueryBuilder('users')
  .select(['id', 'email'])
  .where('username = :username AND status = :status', params);

const result = await connection.query(query);

處理事務

await connection.beginTransaction();
try {
    // 執行多個 SQL 操作
    await connection.execute("UPDATE orders SET status = 'processing'");
    await connection.execute("INSERT INTO order_items SELECT * FROM temp_order_items");
} catch (error) {
    await connection.rollback();
    throw error;
}

工具集

查詢工具 QueryTool

• 執行單條查詢：

const queryTool = new QueryTool(connection);
const result = await queryTool.query("SELECT * FROM users WHERE id = $1", [123]);

• 執行多條查詢：

const results = await queryTool.execute([
    "DELETE FROM sessions WHERE expires_at < NOW()",
    "UPDATE users SET last_login = NOW() WHERE username = 'admin'"
]);

事務工具 TransactionTool

• 包裹在事務中：

const transactionTool = new TransactionTool(connection);
await transactionTool.run(operations => {
    return Promise.all([
        connection.execute("INSERT INTO orders (user_id, order_date) VALUES ($1, NOW())", [userId]),
        connection.execute("UPDATE users SET last_order = NOW() WHERE id = $1", [userId])
    ]);
});

資源管理

模板化查詢

• 定義模板：

const queryTemplate = new QueryTemplate({
    "name": "getUsers",
    "text": "SELECT * FROM users WHERE active = true",
    "parameters": []
});

• 執行模板：

await queryTemplate.execute(connection);

🔧 技術細節

安全注意事項

防範 SQL 注入

• 使用參數化查詢，避免直接拼接 SQL 語句。
• 禁止使用 string_agg 或 array_agg 等聚合函數，以防注入風險。

數據庫權限

• 最小權限原則：為每個數據庫用戶分配最小的必要權限。
• 信息模式訪問：確保用於表和列列舉的信息模式用戶有適當的讀取權限。

傳輸層安全

• 生產環境強制使用 SSL/TLS 加密，建議設置 SSL 模式為 require 或更嚴格。

監控與日誌

性能監控

• 連接池狀態：監控活動連接數和空閒連接數。
• 查詢延遲：記錄每個查詢的執行時間，分析瓶頸。

日誌記錄

• 配置 winston 或其他日誌庫，輸出到文件或集中式日誌服務（如 ELK）。

升級指南

更新依賴

npm update mcp-server-postgres --save

遷移配置

• 檢查新版本的配置選項，更新 config.json 文件。
• 重新啟動服務，確保新配置生效。

📚 詳細文檔

更多資源

• 官方文檔：MCP 官網
• 示例代碼：GitHub 倉庫
• 社區支持：加入 Discord 社區 獲取幫助。

通過以上指南，您可以順利部署並使用 MCP 服務器與 PostgreSQL 數據庫進行高效交互。