MCP ServerとRelational Databaseの接続

connectionジェネレーターは、TypeScript MCP ServerをRelational Databaseプロジェクトに接続し、createServerとそのトランスポートエントリーポイント内でPrismaクライアントを利用可能にします。

前提条件

このジェネレーターを使用する前に、以下を用意してください：

1. ts#mcp-serverプロジェクト
2. ts#rdbプロジェクト

使用方法

ジェネレーターの実行

VSCode

1. インストール Nx Console VSCode Plugin まだインストールしていない場合
2. VSCodeでNxコンソールを開く
3. クリック Generate (UI) "Common Nx Commands"セクションで
4. 検索 @aws/nx-plugin - connection
5. 必須パラメータを入力
6. クリック Generate

CLI

pnpm

pnpm nx g @aws/nx-plugin:connection

yarn

yarn nx g @aws/nx-plugin:connection

npm

npx nx g @aws/nx-plugin:connection

bun

bunx nx g @aws/nx-plugin:connection

変更されるファイルを確認するためにドライランを実行することもできます

pnpm

pnpm nx g @aws/nx-plugin:connection --dry-run

yarn

yarn nx g @aws/nx-plugin:connection --dry-run

npm

npx nx g @aws/nx-plugin:connection --dry-run

bun

bunx nx g @aws/nx-plugin:connection --dry-run

MCPサーバープロジェクトをソースとして、リレーショナルデータベースプロジェクトをターゲットとして選択します。プロジェクトに複数のMCPサーバーコンポーネントが含まれている場合は、sourceComponentを指定して明確にします。

オプション

パラメータ	型	デフォルト	説明
sourceProject 必須	string	-	ソース プロジェクト
targetProject 必須	string	-	接続先のターゲット プロジェクト
sourceComponent	string	-	接続元のソース コンポーネント (コンポーネント名、ソース プロジェクト ルートからの相対パス、またはジェネレーター ID)。プロジェクトをソースとして明示的に選択するには '.' を使用します。
targetComponent	string	-	接続先のターゲット コンポーネント (コンポーネント名、ターゲット プロジェクト ルートからの相対パス、またはジェネレーター ID)。プロジェクトをターゲットとして明示的に選択するには '.' を使用します。

ジェネレーターの出力

ジェネレーターは、MCPサーバーのソースディレクトリ内の3つのファイルを変更します：

• Directorypackages/my-service/src/my-mcp

  • server.ts createServerが{ db }パラメータを受け取るように更新
  • http.ts const server = createServer({ db })の上でPrismaクライアントを作成
  • stdio.ts await createServer({ db }).connect(transport)の前にPrismaクライアントを作成

さらに、<mcp-server-name>-serve-localターゲットが、データベースのserve-localターゲットに依存するように更新されます。

仕組み

サーバー定義

createServerはPrismaクライアントをパラメータとして受け取るため、同期的に保たれ、クライアントをツールやリソースに渡すことができます：

packages/my-service/src/my-mcp/server.ts

import { getPrisma as getMyDb } from ':my-scope/my-db';

export const createServer = ({
  myDb,
}: {
  myDb: Awaited<ReturnType<typeof getMyDb>>;
}) => {
  const server = new McpServer({ name: 'my-service', version: '1.0.0' });
  // register tools/resources that use myDb
  return server;
};

HTTPトランスポート

Prismaクライアントは、createServer呼び出しの上で、リクエストハンドラー内で作成されます：

packages/my-service/src/my-mcp/http.ts

import { getPrisma as getMyDb } from ':my-scope/my-db';

app.post('/mcp', async (req, res) => {
  try {
    const myDb = await getMyDb();
    const server = createServer({ myDb });
    // ...
  }
});

Stdioトランスポート

同じパターンがstdioトランスポートエントリーポイントにも適用されます：

packages/my-service/src/my-mcp/stdio.ts

import { getPrisma as getMyDb } from ':my-scope/my-db';

export const startMcpServer = async () => {
  const transport = new StdioServerTransport();
  const myDb = await getMyDb();
  await createServer({ myDb }).connect(transport);
};

複数のデータベース

異なるターゲットで再度ジェネレーターを実行すると、最初のデータベースと並んで2番目のデータベースが追加されます。両方が一緒にcreateServerに渡されます：

packages/my-service/src/my-mcp/http.ts

const postgresDb = await getPostgresDb();
const mySqlDb = await getMySqlDb();
const server = createServer({ postgresDb, mysqlDb });

インフラストラクチャ

生成されたMCPサーバーコンストラクトはIGrantableとIConnectableを実装しているため、コンストラクト上で直接データベースへのネットワークアクセスとIAMアクセスを許可できます。

CDK

packages/infra/src/stacks/application-stack.ts

import { MyDatabase } from ':my-scope/common-constructs';

const db = new MyDatabase(this, 'Db', { vpc, ... });
const myMcpServer = new MyMcpServer(this, 'MyMcpServer', { vpc, ... });

db.allowDefaultPortFrom(myMcpServer);
db.grantConnect(myMcpServer);

allowDefaultPortFromはセキュリティグループルールを開き、MCPサーバーランタイムがデータベースポートに到達できるようにします。grantConnectは、サーバーの実行ロールにIAM rds-db:connect権限を付与します。

Terraform

データベースモジュールの出力をMCPサーバーモジュールに渡すことで、データベースに到達し、そのランタイム設定を読み取ることができます：

packages/infra/src/main.tf

module "my_database" {
  source              = "../../common/terraform/src/app/dbs/my-database"
  vpc_id              = module.vpc.vpc_id
  database_subnet_ids = module.vpc.private_isolated_subnet_ids
}

module "my_mcp_server" {
  source = "../../common/terraform/src/app/mcp-servers/my-mcp-server"

  appconfig_application_id     = module.my_database.appconfig_application_id
  database_cluster_resource_id = module.my_database.cluster_resource_id
  database_runtime_user        = module.my_database.database_runtime_user
  database_security_group_id   = module.my_database.security_group_id
  database_port                = module.my_database.cluster_port
}

MCPサーバーの実行ロールがrds-db:connect権限を持ち、そのセキュリティグループがデータベースポート上でデータベースセキュリティグループに到達できることを確認してください。

ローカル開発

pnpm

pnpm nx <mcp-server-name>-serve-local <project-name>

yarn

yarn nx <mcp-server-name>-serve-local <project-name>

npm

npx nx <mcp-server-name>-serve-local <project-name>

bun

bunx nx <mcp-server-name>-serve-local <project-name>

これにより、MCPサーバーと接続されているすべてのデータベースが起動します。SERVE_LOCAL=true環境変数により、各PrismaクライアントはAuroraの代わりにローカルのDockerデータベースに接続します。