execute
Execute INSERT, UPDATE, DELETE or other modifying SQL queries in MySQL databases and return affected rows count for data manipulation operations.
Instructions
Execute an INSERT, UPDATE, DELETE or other modifying query. Returns affected rows count.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| sql | Yes | SQL query to execute | |
| params | No | Query parameters for prepared statement |
Implementation Reference
- src/index.ts:182-205 (handler)The main handler logic for the 'execute' tool. It retrieves the database pool, checks SQL permissions, executes the modifying SQL query (INSERT/UPDATE/DELETE), and returns structured output with affected rows, insert ID, and changed rows.
async ({ sql, params }) => { const p = await getPool(); // Check if the operation is allowed checkSqlPermission(sql); const [result] = await p.execute<ResultSetHeader>(sql, params || []); const output = { affectedRows: result.affectedRows, insertId: result.insertId, changedRows: result.changedRows, }; return { content: [ { type: "text" as const, text: JSON.stringify(output, null, 2), }, ], structuredContent: output, }; } - src/index.ts:178-181 (schema)Zod schema defining the input parameters for the 'execute' tool: sql (required string) and optional params array.
{ sql: z.string().describe("SQL query to execute"), params: z.array(z.unknown()).optional().describe("Query parameters for prepared statement"), }, - src/index.ts:175-206 (registration)Registration of the 'execute' tool using server.tool(), including name, description, input schema, and handler function.
server.tool( "execute", "Execute an INSERT, UPDATE, DELETE or other modifying query. Returns affected rows count.", { sql: z.string().describe("SQL query to execute"), params: z.array(z.unknown()).optional().describe("Query parameters for prepared statement"), }, async ({ sql, params }) => { const p = await getPool(); // Check if the operation is allowed checkSqlPermission(sql); const [result] = await p.execute<ResultSetHeader>(sql, params || []); const output = { affectedRows: result.affectedRows, insertId: result.insertId, changedRows: result.changedRows, }; return { content: [ { type: "text" as const, text: JSON.stringify(output, null, 2), }, ], structuredContent: output, }; } );