query_table
Retrieve data from a specified table in a MariaDB database with a customizable row limit, enabling efficient data exploration and analysis for AI assistants.
Instructions
특정 테이블에서 데이터를 조회합니다 (제한된 행 반환).
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| database | Yes | 데이터베이스의 이름입니다. | |
| limit | No | 반환할 최대 행 수 (기본값 100). | |
| table | Yes | 테이블의 이름입니다. |
Implementation Reference
- src/index.ts:157-169 (handler)The execution handler for the 'query_table' tool. It validates inputs, connects to the specified database, executes a SELECT * query with LIMIT on the table, and returns the results as a JSON string.
case "query_table": { const dbName = args.database as string; // 데이터베이스 이름 추출 const tableName = args.table as string; // 테이블 이름 추출 // 반환할 행 수 제한 (기본값 100) const limit = typeof args.limit === 'number' && args.limit > 0 ? args.limit : 100; if (!dbName) throw new McpError(ErrorCode.InvalidParams, "필수 파라미터 누락: database"); if (!tableName) throw new McpError(ErrorCode.InvalidParams, "필수 파라미터 누락: table"); connection = await createDbConnection(dbName); // 지정된 DB로 연결 // 데이터 조회 쿼리 (안전을 위해 백틱 사용 및 LIMIT 적용) const query = `SELECT * FROM \`${tableName}\` LIMIT ?;`; const [rows] = await connection.query(query, [limit]); // 쿼리 실행 (limit 값 바인딩) return { content: [{ type: "text", text: JSON.stringify(rows, null, 2) }] }; } - src/index.ts:103-116 (registration)Registration of the 'query_table' tool in the listTools response, including its name, description, and input schema.
{ name: "query_table", description: "특정 테이블에서 데이터를 조회합니다 (제한된 행 반환).", inputSchema: { type: "object", properties: { database: { type: "string", description: "데이터베이스의 이름입니다." }, table: { type: "string", description: "테이블의 이름입니다." }, limit: { type: "number", description: "반환할 최대 행 수 (기본값 100).", default: 100 }, // 향후 개선: where_clause, columns, order_by 등 추가 }, required: ["database", "table"] } } - src/index.ts:106-115 (schema)Input schema definition for the 'query_table' tool, specifying required database and table parameters, optional limit, with descriptions.
inputSchema: { type: "object", properties: { database: { type: "string", description: "데이터베이스의 이름입니다." }, table: { type: "string", description: "테이블의 이름입니다." }, limit: { type: "number", description: "반환할 최대 행 수 (기본값 100).", default: 100 }, // 향후 개선: where_clause, columns, order_by 등 추가 }, required: ["database", "table"] } - src/index.ts:37-49 (helper)Helper function to create a MySQL/MariaDB connection, used by the query_table handler to connect to the specified database.
async function createDbConnection(dbName?: string) { try { const connection = await mysql.createConnection({ ...dbConfig, database: dbName || dbConfig.database, // 특정 DB가 제공되면 사용, 아니면 기본값 사용 }); return connection; } catch (error: any) { console.error("데이터베이스 연결 오류:", error.message); // MCP 클라이언트에게 더 구체적인 오류 제공 throw new McpError(ErrorCode.InternalError, `데이터베이스 연결 실패: ${error.message}`); } }