Postgresql MCP Server Wt6

🚀 PostgreSQL MCP サーバー

このサーバーは、PostgreSQL データベースとのインターフェースを提供するモデルコンテキストプロトコル (MCP) サーバーです。標準 API を通じてクエリの実行、データベース操作の実行、トランザクションの管理が可能です。

✨ 主な機能

• パラメータ付きの SQL クエリを実行し、SQL インジェクションを防止します。
• 挿入、更新、削除操作を実行します。
• トランザクション内で複数のステートメントを実行します。
• データベースのスキーマ情報を取得します。
• パラメータを安全に処理し、SQL インジェクションを防止します。

📦 インストール

1. リポジトリをクローンします：

git clone https://github.com/yourusername/postgres-mcp.git
cd postgres-mcp

2. 依存関係をダウンロードします：

go mod download

3. データベース接続を設定します：

cp .env.example .env

.env ファイルを編集し、PostgreSQL データベースの資格情報を入力します。 4. サーバーをビルドします：

go build -o postgres-mcp

5. サーバーを起動します：

./postgres-mcp

💻 使用例

基本的な使用法

このサーバーは以下の MCP ツールを公開しています。

execute_tool

単一の SQL ステートメントを実行します。 リクエスト：

{
  "statement": "INSERT INTO users(name, email) VALUES($1, $2)",
  "arguments": ["Jane Doe", "jane@example.com"]
}

レスポンス：

{
  "rows affected": 1
}

query_tool

SELECT クエリを実行し、結果を返します。 リクエスト：

{
  "statement": "SELECT * FROM users WHERE id = $1",
  "arguments": [1]
}

レスポンス：

{
  "rows": [
    {
      "id": 1,
      "name": "John Doe",
      "email": "john@example.com"
    }
  ],
  "columns": ["id", "name", "email"],
  "rowCount": 1
}

transaction_tool

トランザクション内で複数のステートメントを実行します。 リクエスト：

{
  "statements": [
    "INSERT INTO users(name, email) VALUES($1, $2)",
    "INSERT INTO user_roles(user_id, role) VALUES($1, $2)"
  ],
  "arguments": [
    ["Alice", "alice@example.com"],
    [1, "admin"]
  ]
}

レスポンス：

{
  "results": [
    {
      "statement": 0,
      "rowsAffected": 1
    },
    {
      "statement": 1,
      "rowsAffected": 1
    }
  ]
}

schema_tool

テーブルのスキーマ情報を取得します。 リクエスト：

{
  "table_name": "users"
}

レスポンス：

{
  "table": "users",
  "columns": [
    {
      "name": "id",
      "type": "integer",
      "nullable": false,
      "default": "nextval('users_id_seq'::regclass)"
    },
    {
      "name": "name",
      "type": "text",
      "nullable": true
    }
  ]
}

高度な使用法

以下は Go を使用して query_tool を呼び出す例です。

package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io/ioutil"
	"net/http"
)

type QueryRequest struct {
	Statement string   `json:"statement"`
	Arguments []string `json:"arguments"`
}

func main() {
	query := &QueryRequest{
		Statement: "SELECT * FROM users WHERE id = $1",
		Arguments: []string{strconv.Itoa(1)},
	}

	jsonReq, err := json.Marshal(query)
	if err != nil {
		panic(err)
	}

	resp, err := http.Post("http://localhost:8080/query", "application/json", bytes.NewBuffer(jsonReq))
	if err != nil {
		panic(err)
	}

	defer resp.Body.Close()
	body, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		panic(err)
	}

	var result map[string]interface{}
	json.Unmarshal(body, &result)
	fmt.Printf("%#v\n", result)
}

⚠️ 重要提示

• パラメータ化クエリを使用して SQL インジェクションを防止してください。
• データベースユーザーの権限を制限してください。
• 本番環境では SSL/TLS 暗号化を有効にしてください。
• クエリ内で機密情報を公開しないでください。
• 定期的にデータベースのアクティビティを監査および監視してください。

📄 ライセンス

このプロジェクトは MIT ライセンスの下で提供されています。