DB Agent MCP Server

import mysql from "mysql2/promise";

export function createMySQLAdapter() {
  const pool = mysql.createPool({
    host: process.env.DB_HOST,
    port: Number(process.env.DB_PORT || 3306),
    user: process.env.DB_USER,
    password: process.env.DB_PASS,
    database: process.env.DB_NAME,
    connectionLimit: 5,
  });

  return {
    async query(sql: string) {
      const [rows] = await pool.query(sql);
      return rows as any[];
    }
  };
}