| 43 | } |
| 44 | |
| 45 | export async function executeQuery( |
| 46 | connection: mysql.Connection, |
| 47 | query: string, |
| 48 | values?: unknown[] |
| 49 | ) { |
| 50 | const [rows, fields] = await connection.execute(query, values) |
| 51 | |
| 52 | if (Array.isArray(rows)) { |
| 53 | return { |
| 54 | rows: rows as unknown[], |
| 55 | rowCount: rows.length, |
| 56 | fields, |
| 57 | } |
| 58 | } |
| 59 | |
| 60 | return { |
| 61 | rows: [], |
| 62 | rowCount: (rows as mysql.ResultSetHeader).affectedRows || 0, |
| 63 | fields, |
| 64 | } |
| 65 | } |
| 66 | |
| 67 | export function validateQuery(query: string): { isValid: boolean; error?: string } { |
| 68 | const trimmedQuery = query.trim().toLowerCase() |