OceanBase MCP ServerとTraeの連携

obclient -h$host -P$port -u$user_name -p$password -D$database_name

```shell
git clone https://github.com/oceanbase/mcp-oceanbase.git
```

```shell
cd mcp-oceanbase
```

```shell
uv venv
source .venv/bin/activate
uv pip install .
```

```json
{
"mcpServers": {
"oceanbase": {
"command": "uv",
"args": [
"--directory",
// oceanbase_mcp_serverフォルダの絶対パスに置き換える必要があります
"/path/to/your/mcp-oceanbase/src/oceanbase_mcp_server",
"run",
"oceanbase_mcp_server"
],
"env": {
// OceanBaseデータベースの接続情報に置き換える必要があります
"OB_HOST": "***",
"OB_PORT": "***",
"OB_USER": "***",
"OB_PASSWORD": "***",
"OB_DATABASE": "***"
}
}
}
}
```

<!-- ![2-10](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/cloud/integrations/AI/trae-10.png) -->

<!-- ![2-11](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/cloud/integrations/AI/trae-11.png) -->

<!-- ![2-12](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/cloud/integrations/AI/trae-12.png) -->

<!-- ![2-13](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/cloud/integrations/AI/trae-13.png) -->

```shell
uv venv
source .venv/bin/activate
uv pip install -r requirements.txt
```

uvicorn main:app --reload

curl http://127.0.0.1:8000/customers

```json
[{"ID":1,"name":"張三","age":25,"telephone":"13800138000","location":"北京"},{"ID":2,"name":"李四","age":30,"telephone":"13900139000","location":"上海"},{"ID":3,"name":"王五","age":35,"telephone":"13700137000","location":"廣州"},{"ID":4,"name":"趙六","age":22,"telephone":"13600136000","location":"深圳"},{"ID":5,"name":"孫七","age":40,"telephone":"13500135000","location":"成都"},{"ID":6,"name":"周八","age":28,"telephone":"13400134000","location":"杭州"},{"ID":7,"name":"吳九","age":33,"telephone":"13300133000","location":"南京"},{"ID":8,"name":"鄭十","age":27,"telephone":"13200132000","location":"武漢"},{"ID":9,"name":"陳十一","age":31,"telephone":"13100131000","location":"西安"},{"ID":10,"name":"林十二","age":24,"telephone":"13000130000","location":"重慶"}]
```

from fastapi import FastAPI
from pydantic import BaseModel
import mysql.connector

app = FastAPI()

# データベース接続設定
config = {
    'user': '*******',
    'password': '******',
    'host': 'xx.xxx.xxx.xx',
    'database': 'test',
    'port':xxxx,
    'raise_on_warnings': True
}

class Customer(BaseModel):
    id: int
    name: str
    age: int
    telephone: str
    location: str

@app.get('/customers')
async def get_customers():
    cnx = mysql.connector.connect(**config)
    cursor = cnx.cursor(dictionary=True)
    query = 'SELECT * FROM customer'
    cursor.execute(query)
    results = cursor.fetchall()
    cursor.close()
    cnx.close()
    return results

@app.get('/customers/{customer_id}')
async def get_customer(customer_id: int):
    cnx = mysql.connector.connect(**config)
    cursor = cnx.cursor(dictionary=True)
    query = 'SELECT * FROM customer WHERE ID = %s'
    cursor.execute(query, (customer_id,))
    result = cursor.fetchone()
    cursor.close()
    cnx.close()
    return result

@app.post('/customers')
async def create_customer(customer: Customer):
    cnx = mysql.connector.connect(**config)
    cursor = cnx.cursor()
    query = 'INSERT INTO customer (ID, name, age, telephone, location) VALUES (%s, %s, %s, %s, %s)'
    data = (customer.id, customer.name, customer.age, customer.telephone, customer.location)
    cursor.execute(query, data)
    cnx.commit()
    cursor.close()
    cnx.close()
    return {'message': 'Customer created successfully'}

@app.put('/customers/{customer_id}')
async def update_customer(customer_id: int, customer: Customer):
    cnx = mysql.connector.connect(**config)
    cursor = cnx.cursor()
    query = 'UPDATE customer SET name = %s, age = %s, telephone = %s, location = %s WHERE ID = %s'
    data = (customer.name, customer.age, customer.telephone, customer.location, customer_id)
    cursor.execute(query, data)
    cnx.commit()
    cursor.close()
    cnx.close()
    return {'message': 'Customer updated successfully'}

@app.delete('/customers/{customer_id}')
async def delete_customer(customer_id: int):
    cnx = mysql.connector.connect(**config)
    cursor = cnx.cursor()
    query = 'DELETE FROM customer WHERE ID = %s'
    cursor.execute(query, (customer_id,))
    cnx.commit()
    cursor.close()
    cnx.close()
    return {'message': 'Customer deleted successfully'}