Fastpostgresmcp

🚀 MCP サーバ PostgreSQL バージョン

MCP（Multi-Connection Proxy）サーバは、複数のデータベースプロトコルをサポートする代理サービスです。データベース接続を管理するための豊富なツールとリソースを提供します。このドキュメントでは、MCP サーバを使用して PostgreSQL データベースとやり取りする方法を詳しく説明します。

🚀 クイックスタート

MCP サーバを使用して PostgreSQL データベースとやり取りするには、まずサーバをインストールし、設定を行い、起動する必要があります。以下のセクションでは、これらの手順を詳しく説明します。

📦 インストール

クイックインストール

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 またはそれ以上に設定することをお勧めします。

📚 ドキュメント

アップグレードガイド

依存関係の更新

npm update mcp-server-postgres --save

設定の移行

• 新しいバージョンの設定オプションを確認し、config.json ファイルを更新します。
• サービスを再起動し、新しい設定が適用されることを確認します。

その他のリソース

• 公式ドキュメント：MCP 公式サイト
• サンプルコード：GitHub リポジトリ
• コミュニティサポート：Discord コミュニティ に参加してヘルプを得ることができます。

以上のガイドを参考に、MCP サーバを使用して PostgreSQL データベースと効率的にやり取りすることができます。