MCP（Model Context Protocol）は、Anthropic社が2024年11月に発表し、オープンソース化したプロトコルです。このプロトコルは、大規模言語モデルと外部ツールやデータソースとのインタラクションを実現することを目的としています。MCPを利用することで、ユーザーは大規模言語モデルの出力を手動でコピー＆ペーストして実行する必要がなく、大規模言語モデルが直接ツールに指示を送り、対応するアクション(Action)を実行させることが可能になります。
OceanBase MCP Serverは、MCPプロトコルを通じて大規模言語モデルとOceanBaseデータベースとの連携機能を提供し、SQL文の実行を可能にします。GitHub上でオープンソースとして公開されており、適切なクライアントを使用すれば迅速にプロジェクトのプロトタイプを構築できます。
Augment Codeは、開発者向けのAIプラットフォームです。コードを理解し、問題をデバッグし、コードベースを把握しているため、より迅速にリリースできるよう支援します。チャット、次のステップの編集、コード補完機能を活用して、より多くの作業を効率的に進めることができます。
本記事では、Augment Codeを使用して、OceanBase MCP Serverを通じて迅速にバックエンドアプリケーションを構築する方法を紹介します。
前提条件
OceanBaseデータベースのデプロイが完了し、MySQLモードのユーザーテナントが作成されていること。ユーザーテナントの作成方法の詳細については、テナントの作成を参照してください。
Python 3.11 以降および対応するpipをインストールしていること。使用しているマシンのPythonバージョンが低い場合は、Minicondaを使用して新しいPython 3.11以降の環境を作成できます。具体的な手順については、Minicondaのインストールガイドを参照してください。
使用しているOSに応じて、Gitをインストールします。OSに応じてダウンロードしてインストールします。
Windows：https://git-scm.com/downloads/win。
macOS：https://git-scm.com/download/mac。
Linux：https://git-scm.com/downloads/linux。
Pythonパッケージマネージャーuvをインストールします。
macOS/Linuxでは、スタンドアロンスクリプトを使用してインストールできます。
curl -LsSf https://astral.sh/uv/install.sh | shWindowsプラットフォームでは、以下のスクリプトを使用します。
irm https://astral.sh/uv/install.ps1 | iexまたは、プラットフォームに依存しないpipインストール方法を使用します。
pip install uv
インストールが完了したら、
uv --versionコマンドを使用してインストールが正常に完了したかどうかを確認します。pip install uv uv --versionAugment Codeのインストール：
VS Codeを開きます(まだインストールしていない場合は、公式ドキュメントに従ってインストールしてください)。
サイドバーの拡張機能アイコンをクリックします。
「Augment Code」を検索してインストールをクリックします。
Augment Codeアカウントに登録してログインします。
ステップ１：データベース接続情報を取得する
OceanBaseデータベースのデプロイ担当者または管理者から、該当するデータベース接続文字列を取得します。例：
obclient -h$host -P$port -u$user_name -p$password -D$database_name
パラメータの説明：
$host：OceanBaseデータベースへの接続IPアドレス。OceanBaseデータベースプロキシ(OceanBase Database Proxy、ODP)接続方式ではODPアドレスを使用し、直接接続方式ではOBServerノードのIPアドレスを使用します。$port：OceanBaseデータベースへの接続ポート。ODP接続方式のデフォルトポートは2883で、ODPデプロイ時にカスタマイズ可能です。直接接続方式のデフォルトポートは2881で、OceanBaseデータベースのデプロイ時にカスタマイズ可能です。$database_name：アクセス対象のデータベース名。注意
テナントに接続するユーザーは、そのデータベースに対する
CREATE、INSERT、DROP、およびSELECT権限を持っている必要があります。ユーザー権限の詳細については、MySQLモードの権限分類を参照してください。$user_name：テナントの接続アカウント。ODP接続の一般的な形式：ユーザー名@テナント名#クラスタ名またはクラスタ名:テナント名:ユーザー名。直接接続方式の形式：ユーザー名@テナント名。$password：アカウントのパスワード。
その他の接続文字列の詳細については、OBClientを使用したOceanBaseテナントへの接続を参照してください。
ステップ2：OceanBase MCP Serverを設定する
OceanBase MCP Serverリポジトリのクローン
次のコマンドを実行して、ソースコードをローカルにダウンロードします：
git clone https://github.com/oceanbase/awesome-oceanbase-mcp.git
ソースコードディレクトリに移動します：
cd awesome-oceanbase-mcp
依存関係のインストール
oceanbase_mcp_server ディレクトリで以下のコマンドを実行して仮想環境を作成し、依存関係をインストールします：
uv venv
source .venv/bin/activate
uv pip install .
MCP Serverの追加と設定
Augment CodeでOceanBase MCP Serverを設定します。
[Import from json] をクリックし、mcp設定ファイルを入力します。
設定ファイルに情報を入力し、確認をクリックします。
/path/to/your/oceanbase_mcp_serverはoceanbase_mcp_serverフォルダの絶対パスに置き換える必要があります。OB_HOST、OB_PORT、OB_USER、OB_PASSWORD、OB_DATABASEはご自身のデータベースの対応する情報に置き換えてください：{ "mcpServers": { "oceanbase": { "command": "uv", "args": [ "--directory", "/path/to/your/oceanbase_mcp_server/src/oceanbase_mcp_server", "run", "oceanbase_mcp_server" ], "env": { "OB_HOST": "***", "OB_PORT": "***", "OB_USER": "***", "OB_PASSWORD": "***", "OB_DATABASE": "***" } } } }データベースへの接続が可能かどうかを検証します。
「customerテーブルを作成し、主キーはID、name、age、telephone、locationフィールドを含む」というプロンプトが表示されたら、それに従って操作します：
Augment Codeは現在のtestデータベース内のテーブル数を表示します。これは、OceanBaseデータベースへの正常な接続を示しています。
ステップ3：FastAPIを使用してRESTful APIスタイルのプロジェクトを迅速に作成する
FastAPIは、Python用のWebフレームワークであり、RESTful APIを迅速に構築できます。
テーブルを作成します。
プロンプト「customerテーブルを作成し、主キーはID、name、age、telephone、locationフィールドを含む」と入力します：
テストデータを挿入します。
プロンプト「10件のテストデータを挿入」と入力します：
FastAPIプロジェクトを作成します。
プロンプト「FastAPIプロジェクトを作成し、customerテーブルに基づくRESTful APIを生成する」と入力します。複数のファイルが自動生成され、コードが自動修復され、FastAPIプロジェクトが起動します：
テーブル内のデータを確認します。
コマンドラインで
curl http://127.0.0.1:8000/customersを実行するか、他のリクエストツールを使用して、テーブル内のデータを確認します：curl http://127.0.0.1:8000/customers [{"name":"Zhang San","age":28,"telephone":"13812345678","location":"Chaoyang District, Beijing","id":1},{"name":"Li Si","age":35,"telephone":"13987654321","location":"Pudong New Area, Shanghai","id":2},{"name":"Wang Wu","age":42,"telephone":"15612345678","location":"Tianhe District, Guangzhou","id":3},{"name":"Zhao Liu","age":29,"telephone":"18712345678","location":"Nanshan District, Shenzhen","id":4},{"name":"Qian Qi","age":33,"telephone":"13512345678","location":"Xihu District, Hangzhou","id":5},{"name":"Sun Ba","age":26,"telephone":"15987654321","location":"Jinjiang District, Chengdu","id":6},{"name":"Zhou Jiu","age":38,"telephone":"18612345678","location":"Jianghan District, Wuhan","id":7},{"name":"Wu Shi","age":31,"telephone":"13712345678","location":"Gulou District, Nanjing","id":8},{"name":"Zheng Shiyi","age":45,"telephone":"15812345678","location":"Yanta District, Xi'an","id":9},{"name":"Wang Shier","age":27,"telephone":"18512345678","location":"Yuzhong District, Chongqing","id":10},{"name":"Test User","age":25,"telephone":"13900000000","location":"Test Address","id":11}]作成、削除、変更、検索のコードがすべて生成されました。
from sqlalchemy.orm import Session from database import Customer from schemas import CustomerCreate, CustomerUpdate from typing import List, Optional def get_customer(db: Session, customer_id: int) -> Optional[Customer]: """IDに基づいて単一の顧客を取得する""" return db.query(Customer).filter(Customer.id == customer_id).first() def get_customers(db: Session, skip: int = 0, limit: int = 100) -> List[Customer]: """顧客リストを取得する""" return db.query(Customer).offset(skip).limit(limit).all() def create_customer(db: Session, customer: CustomerCreate) -> Customer: """新しい顧客を作成する""" db_customer = Customer(**customer.dict()) db.add(db_customer) db.commit() db.refresh(db_customer) return db_customer def update_customer(db: Session, customer_id: int, customer: CustomerUpdate) -> Optional[Customer]: """顧客情報を更新する""" db_customer = db.query(Customer).filter(Customer.id == customer_id).first() if db_customer: update_data = customer.dict(exclude_unset=True) for field, value in update_data.items(): setattr(db_customer, field, value) db.commit() db.refresh(db_customer) return db_customer def delete_customer(db: Session, customer_id: int) -> bool: """顧客を削除する""" db_customer = db.query(Customer).filter(Customer.id == customer_id).first() if db_customer: db.delete(db_customer) db.commit() return True return False def search_customers_by_name(db: Session, name: str) -> List[Customer]: """氏名に基づいて顧客を検索する""" return db.query(Customer).filter(Customer.name.contains(name)).all() def get_customers_by_location(db: Session, location: str) -> List[Customer]: """住所に基づいて顧客を取得する""" return db.query(Customer).filter(Customer.location.contains(location)).all()