MCPでデータベースを繋ぐ：自然言語でPostgreSQL/MySQLを操作する実践ガイド

結論ファースト：最适合なAPIは何か？

本記事の結論を先に示します。HolySheep AI（今すぐ登録）が、自然言語データベースクエリ用途において最もコスト効率と柔軟性のバランスに優れています。

APIサービス比較表

サービス	レート	平均遅延	決済手段	対応モデル	適한チーム
HolySheep AI	¥1=$1（85%節約）	<50ms	WeChat Pay / Alipay / クレジットカード	GPT-4.1 / Claude Sonnet 4.5 / Gemini 2.5 Flash / DeepSeek V3.2	中小チーム、個人開発者、中国国内ユーザー
OpenAI公式	¥7.3=$1（基準）	80-150ms	クレジットカードのみ	GPT-4o / GPT-4.1	エンタープライズ企業
Anthropic公式	¥7.3=$1（基準）	100-200ms	クレジットカードのみ	Claude 3.5 Sonnet / Claude 3 Opus	コンプライアンス重視の企業
Google Vertex AI	¥6.5=$1	60-120ms	クレジットカード / 請求書	Gemini 1.5 / 2.0	GCPユーザー企業

HolySheep AIを選ぶ理由：

DeepSeek V3.2が¥1=$1（約$0.42/MTok出力）という破格の安さ
WeChat Pay / Alipay対応で中国在住開発者に最適
登録だけで無料クレジット付与
Ultra Language Models対応で高性能なSQL生成

MCP（Model Context Protocol）とは

MCPは、AIモデルが外部データソースやツールと安全に接続するためのプロトコルです。2024年に提唱され、CursorやClaude Desktopなどで採用が進んでいます。MCPを使うことで、データベースの認証情報をAIに直接渡さずに済み、セキュリティを保ちながら自然言語でのクエリ実行が可能になります。

前提条件と環境構築

# Node.js環境のセットアップ
node --version  # v18.0.0以上が必要

必要なパッケージをインストール
npm install @modelcontextprotocol/sdk pg mysql2 dotenv

プロジェクトフォルダを作成
mkdir mcp-db-query && cd mcp-db-query
npm init -y

PostgreSQLへの接続設定

まず、PostgreSQLデータベースとの接続をMCPで確立する方法を説明します。私の実践経験では、認証情報を環境変数で管理することがセキュリティ上重要です。

# .envファイル（絶対にGitにコミットしない）
DATABASE_URL=postgresql://username:password@localhost:5432/mydb
HOLYSHEEP_API_KEY=YOUR_HOLYSHEEP_API_KEY

MCPサーバー設定ファイル: mcp-server-postgres.js
import { Server } from '@modelcontextprotocol/sdk/server/index.js';
import { StdioServerTransport } from '@modelcontextprotocol/sdk/server/stdio.js';
import { CallToolRequestSchema, ListToolsRequestSchema } from '@modelcontextprotocol/sdk/types.js';
import pg from 'pg';

const { Pool } = pg;

// データベース接続プール
const pool = new Pool({
  connectionString: process.env.DATABASE_URL,
  max: 20,
  idleTimeoutMillis: 30000,
});

// MCPサーバーを作成
const server = new Server(
  { name: 'postgres-mcp-server', version: '1.0.0' },
  { capabilities: { tools: {} } }
);

// 利用可能なツールを定義
server.setRequestHandler(ListToolsRequestSchema, async () => {
  return {
    tools: [
      {
        name: 'execute_query',
        description: 'PostgreSQLクエリを実行して結果を返す',
        inputSchema: {
          type: 'object',
          properties: {
            sql: { type: 'string', description: '実行するSQLクエリ' },
            params: { type: 'array', description: 'パラメータ配列' }
          },
          required: ['sql']
        }
      },
      {
        name: 'describe_table',
        description: 'テーブル構造を取得する',
        inputSchema: {
          type: 'object',
          properties: {
            table_name: { type: 'string' }
          },
          required: ['table_name']
        }
      }
    ]
  };
});

// ツール実行ハンドラー
server.setRequestHandler(CallToolRequestSchema, async (request) => {
  const { name, arguments: args } = request.params;

  try {
    if (name === 'execute_query') {
      const result = await pool.query(args.sql, args.params || []);
      return {
        content: [{
          type: 'text',
          text: JSON.stringify({ rows: result.rows, rowCount: result.rowCount })
        }]
      };
    }

    if (name === 'describe_table') {
      const result = await pool.query(`
        SELECT column_name, data_type, is_nullable 
        FROM information_schema.columns 
        WHERE table_name = $1
        ORDER BY ordinal_position
      `, [args.table_name]);
      return {
        content: [{
          type: 'text',
          text: JSON.stringify(result.rows)
        }]
      };
    }
  } catch (error) {
    return {
      content: [{ type: 'text', text: エラー: ${error.message} }],
      isError: true
    };
  }
});

// サーバー起動
const transport = new StdioServerTransport();
server.connect(transport);

自然言語SQL生成クライアント（HolySheep AI使用）

次に、HolySheep AIのAPIを使って自然言語クエリをSQLに変換し、実行するクライアントを作成します。DeepSeek V3.2モデルはSQL生成に優れており、コストも非常に安いのが利点です。

# natural-query-client.mjs
import OpenAI from 'openai';
import readline from 'readline';

// HolySheep AIクライアント設定
const client = new OpenAI({
  apiKey: process.env.HOLYSHEEP_API_KEY || 'YOUR_HOLYSHEEP_API_KEY',
  baseURL: 'https://api.holysheep.ai/v1'
});

// テーブルスキーマ定義（実際のスキーマに合わせて変更）
const schemaContext = `
テーブル名: users
- id (SERIAL, PRIMARY KEY)
- name (VARCHAR(100))
- email (VARCHAR(255), UNIQUE)
- created_at (TIMESTAMP)
- subscription_tier (VARCHAR(50))

テーブル名: orders
- id (SERIAL, PRIMARY KEY)
- user_id (INTEGER, FOREIGN KEY → users.id)
- amount (DECIMAL(10,2))
- status (VARCHAR(50))
- created_at (TIMESTAMP)
`;

// データベースへの直接接続（簡易版）
async function executeQuery(sql) {
  // 本番環境では、MCPサーバー経由で実行することを推奨
  console.log(実行SQL: ${sql});
  return { sql, message: 'MCPサーバーで実行してください' };
}

async function generateAndExecuteSQL(naturalLanguageQuery) {
  console.log(\n📝 質問: ${naturalLanguageQuery}\n);

  // DeepSeek V3.2でSQL生成
  const response = await client.chat.completions.create({
    model: 'deepseek-chat',  // DeepSeek V3.2相当
    messages: [
      {
        role: 'system',
        content: `あなたはPostgreSQLのSQL生成 Expert です。
以下のテーブルスキーマに基づいて、自然言語クエリをSQLに変換してください。

スキーマ:
${schemaContext}

重要なルール:
1. 結果のみをSQL文で返してください（説明は不要）
2. パラメータ値は$1, $2のように番号付きプレースホルダーを使用
3. 安全でないSQL（DROP, DELETE全件など）は実行禁止`
      },
      {
        role: 'user',
        content: naturalLanguageQuery
      }
    ],
    temperature: 0.1,
    max_tokens: 500
  });

  const generatedSQL = response.choices[0].message.content.trim();
  
  // SQLの検証と整形
  const cleanSQL = generatedSQL
    .replace(/```sql\n?/g, '')
    .replace(/```\n?/g, '')
    .trim();

  console.log(✨ 生成SQL: ${cleanSQL});
  
  // コスト確認
  const usage = response.usage;
  const inputCost = (usage.prompt_tokens / 1_000_000) * 0.07;  // DeepSeek入力
  const outputCost = (usage.completion_tokens / 1_000_000) * 0.42;  // DeepSeek出力
  console.log(💰 コスト: $${(inputCost + outputCost).toFixed(6)});

  // SQL実行
  return await executeQuery(cleanSQL);
}

// 対話型インターフェース
const rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout
});

console.log('🔍 自然言語SQL生成クライアント（HolySheep AI + DeepSeek V3.2）');
console.log('質問を入力してください（終了: exit）\n');

function askQuestion() {
  rl.question('> ', async (query) => {
    if (query.toLowerCase() === 'exit') {
      rl.close();
      return;
    }
    
    try {
      await generateAndExecuteSQL(query);
    } catch (error) {
      console.error(❌ エラー: ${error.message});
    }
    
    askQuestion();
  });
}

askQuestion();

MySQLへの対応方法

MySQLを使用する場合は、接続ライブラリとSQL生成プロンプトを少し変更するだけで対応できます。HolySheep AIのDeepSeek V3.2はMySQL方言にも対応しており、複雑なJOINやサブクエリも正確に生成できます。

# MySQL用MCPサーバー: mcp-server-mysql.js
import { Server } from '@modelcontextprotocol/sdk/server/index.js';
import { StdioServerTransport } from '@modelcontextprotocol/sdk/server/stdio.js';
import mysql from 'mysql2/promise';

// MySQL接続プール
const pool = mysql.createPool({
  host: process.env.MYSQL_HOST || 'localhost',
  user: process.env.MYSQL_USER,
  password: process.env.MYSQL_PASSWORD,
  database: process.env.MYSQL_DATABASE,
  waitForConnections: true,
  connectionLimit: 10,
  queueLimit: 0
});

const server = new Server(
  { name: 'mysql-mcp-server', version: '1.0.0' },
  { capabilities: { tools: {} } }
);

server.setRequestHandler(ListToolsRequestSchema, async () => ({
  tools: [
    {
      name: 'execute_mysql',
      description: 'MySQLクエリを実行',
      inputSchema: {
        type: 'object',
        properties: {
          sql: { type: 'string' },
          params: { type: 'array' }
        },
        required: ['sql']
      }
    },
    {
      name: 'get_mysql_schema',
      description: 'MySQLテーブル構造を取得',
      inputSchema: {
        type: 'object',
        properties: {
          table: { type: 'string' }
        }
      }
    }
  ]
}));

server.setRequestHandler(CallToolRequestSchema, async (request) => {
  const { name, arguments: args } = request.params;

  try {
    if (name === 'execute_mysql') {
      const [rows] = await pool.execute(args.sql, args.params || []);
      return {
        content: [{ type: 'text', text: JSON.stringify(rows) }]
      };
    }

    if (name === 'get_mysql_schema') {
      const [rows] = await pool.execute(
        'DESCRIBE ' + args.table
      );
      return {
        content: [{ type: 'text', text: JSON.stringify(rows) }]
      };
    }
  } catch (error) {
    return {
      content: [{ type: 'text', text: MySQL Error: ${error.message} }],
      isError: true
    };
  }
});

const transport = new StdioServerTransport();
server.connect(transport);

実践例：ECサイトの分析クエリ

以下の例では、実際のECサイト運用でよくある分析クエリを自然言語で実行しています。HolySheep AIのDeepSeek V3.2モデルは、複雑なビジネスロジックを含むSQLも正確に生成できることを確認しています。

# 実行例
$ node natural-query-client.mjs

🔍 自然言語SQL生成クライアント（HolySheep AI + DeepSeek V3.2）

> 今月の有料会員の中で、最も注文金額が高いユーザーは誰ですか？

📝 質問: 今月の有料会員の中で、最も注文金額が高いユーザーは誰ですか？

✨ 生成SQL: 
SELECT u.name, u.email, SUM(o.amount) as total_amount
FROM users u
JOIN orders o ON u.id = o.user_id
WHERE u.subscription_tier != 'free'
  AND o.created_at >= DATE_TRUNC('month', CURRENT_DATE)
  AND o.status = 'completed'
GROUP BY u.id, u.name, u.email
ORDER BY total_amount DESC
LIMIT 1

💰 コスト: $0.000142

> 過去7日間で注文がなかったアクティブユーザー教えてください

📝 質問: 過去7日間で注文がなかったアクティブユーザー教えてください

✨ 生成SQL:
SELECT u.id, u.name, u.email, MAX(o.created_at) as last_order_date
FROM users u
LEFT JOIN orders o ON u.id = o.user_id
WHERE u.created_at >= CURRENT_DATE - INTERVAL '30 days'
GROUP BY u.id, u.name, u.email
HAVING MAX(o.created_at) < CURRENT_DATE - INTERVAL '7 days'
   OR MAX(o.created_at) IS NULL
ORDER BY last_order_date ASC NULLS FIRST

💰 コスト: $0.000189

2026年最新モデル価格比較（出力コスト）

モデル	公式価格($/MTok出力)	HolySheep AI($/MTok出力)	節約率	SQL生成適性
GPT-4.1	$8.00	$8.00（¥1=$1）	¥7.3→¥1（86%安）	★★★★☆
Claude Sonnet 4.5	$15.00	$15.00（¥1=$1）	¥7.3→¥1（86%安）	★★★★★
Gemini 2.5 Flash	$2.50	$2.50（¥1=$1）	¥7.3→¥1（86%安）	★★★☆☆
DeepSeek V3.2	$0.42	$0.42（¥1=$1）	¥7.3→¥1（86%安）	★★★★☆

コスト最適化のポイント：SQL生成タスクにはDeepSeek V3.2（$0.42/MTok）が最もコストパフォーマンスに優れています。一方、複雑なテーブルJOINやウィンドウ関数を含む高度なクエリには、Claude Sonnet 4.5（$15/MTok）が精度で勝ります。

よくあるエラーと対処法

エラー1：AuthenticationError - APIキーが無効

# 症状
Error: Incorrect API key provided: YOUR_HOLYSHEEP_API_KEY

原因
.envファイルが読み込まれていない、またはキーが正しくない

解決方法
1. .envファイルの存在確認
ls -la .env

2. 正しいフォーマットで再設定
echo 'HOLYSHEEP_API_KEY=sk-your-actual-key-here' > .env

3. コード内で直接読み込みを確認
import 'dotenv/config';
console.log('API Key loaded:', !!process.env.HOLYSHEEP_API_KEY);

4. それでも解決しない場合、Holysheepダッシュボードで新しいキーを生成
https://www.holysheep.ai/dashboard/api-keys

エラー2：Connection Refused - データベース接続失敗

# 症状
Error: connect ECONNREFUSED 127.0.0.1:5432

原因
PostgreSQLが起動していない、または接続情報が間違っている

解決方法
1. PostgreSQLの状態確認
sudo systemctl status postgresql

2. 起動していない場合
sudo systemctl start postgresql
sudo systemctl enable postgresql

3. 接続情報の確認（pg_hba.conf）
IPv4ローカル接続を許可する設定になっているか確認

4. 接続テスト
psql -h localhost -U username -d database_name

5. 環境変数の確認
cat .env | grep DATABASE
DATABASE_URL=postgresql://user:pass@host:5432/dbname
               ↑プロトコル      ↑ホスト名    ↑ポート

エラー3：SQLインジェクション脆弱性

# 症状（セキュリティスキャンで検出）
Potential SQL Injection vulnerability in execute_query

原因
ユーザー入力を直接SQLクエリに挿入している

危険な例（絶対に避ける）
const sql = SELECT * FROM users WHERE name = '${userInput}';  // ❌危険

安全な解决方法（パラメータ化クエリ）
const sql = 'SELECT * FROM users WHERE name = $1';
const params = [userInput];
await pool.query(sql, params);  // ✅安全

MCPサーバー側でもパラメータ検証を追加
server.setRequestHandler(CallToolRequestSchema, async (request) => {
  const dangerousKeywords = ['DROP', 'TRUNCATE', '--', '/*', '*/'];
  const sqlUpper = args.sql.toUpperCase();
  
  for (const keyword of dangerousKeywords) {
    if (sqlUpper.includes(keyword)) {
      return {
        content: [{ type: 'text', text: 'この操作は許可されていません' }],
        isError: true
      };
    }
  }
  
  // 正常処理続行...
});

エラー4：Rate LimitExceeded - API呼び出し制限

# 症状
Error: 429 Rate limit exceeded for DeepSeek model

原因
短時間に过多なAPIリクエストを送信している

解決方法
1. リトライロジックを追加（指数バックオフ）
async function callWithRetry(fn, maxRetries = 3) {
  for (let i = 0; i < maxRetries; i++) {
    try {
      return await fn();
    } catch (error) {
      if (error.status === 429 && i < maxRetries - 1) {
        const waitTime = Math.pow(2, i) * 1000;  // 1s, 2s, 4s
        console.log(Rate limit. Waiting ${waitTime}ms...);
        await new Promise(r => setTimeout(r, waitTime));
      } else {
        throw error;
      }
    }
  }
}

// 2. キャッシュ機能の実装
const queryCache = new Map();
const CACHE_TTL = 5 * 60 * 1000;  // 5分

function getCachedQuery(key) {
  const cached = queryCache.get(key);
  if (cached && Date.now() - cached.timestamp < CACHE_TTL) {
    return cached.result;
関連リソース
📚 AI API 記事一覧
💰 料金を見る
📖 開発者ドキュメント
🚀 無料登録
関連記事
Gemini 2.5 Pro API 接入教程：2M Token コンテキストウィンドウ实战ガイド
無料 AI API 2026 完全ガイド：主要サービスの無料枠一覧と比較
LanceDB 組込みベクトルデータベース：エッジデバイス RAG 実装 完全ガイド

結論ファースト：最适合なAPIは何か？

APIサービス比較表

MCP（Model Context Protocol）とは

前提条件と環境構築

必要なパッケージをインストール

プロジェクトフォルダを作成

PostgreSQLへの接続設定

MCPサーバー設定ファイル: mcp-server-postgres.js

自然言語SQL生成クライアント（HolySheep AI使用）

MySQLへの対応方法

実践例：ECサイトの分析クエリ

2026年最新モデル価格比較（出力コスト）

よくあるエラーと対処法

エラー1：AuthenticationError - APIキーが無効

原因

解決方法

1. .envファイルの存在確認

2. 正しいフォーマットで再設定

3. コード内で直接読み込みを確認

4. それでも解決しない場合、Holysheepダッシュボードで新しいキーを生成

https://www.holysheep.ai/dashboard/api-keys

エラー2：Connection Refused - データベース接続失敗

原因

解決方法

1. PostgreSQLの状態確認

2. 起動していない場合

3. 接続情報の確認（pg_hba.conf）

IPv4ローカル接続を許可する設定になっているか確認

4. 接続テスト

5. 環境変数の確認

DATABASE_URL=postgresql://user:pass@host:5432/dbname

↑プロトコル ↑ホスト名 ↑ポート

エラー3：SQLインジェクション脆弱性

原因

危険な例（絶対に避ける）

安全な解决方法（パラメータ化クエリ）

MCPサーバー側でもパラメータ検証を追加

エラー4：Rate LimitExceeded - API呼び出し制限

原因

解決方法

1. リトライロジックを追加（指数バックオフ）

関連リソース

関連記事

🔥 HolySheep AIを使ってみる

`https://www.holysheep.ai/dashboard/api-keys`

`↑プロトコル ↑ホスト名 ↑ポート`