plpgsql-parser

import { parse } from '@pgsql/parser'; import { deparse } from '@pgsql/deparser'; import type { SelectStmt } from '@pgsql/types'; async function processSqlQuery(sql: string) { try { console.log(`Parsing SQL: ${sql}`); // Parse the SQL query into an Abstract Syntax Tree (AST) const ast = await parse(sql); console.log('Parsed AST (partial):', JSON.stringify(ast.stmts[0]?.stmt, null, 2)); // Example: Accessing a specific type of statement and its properties if (ast.stmts[0]?.stmt.SelectStmt) { const selectStmt = ast.stmts[0].stmt.SelectStmt as SelectStmt; console.log('Target list items:', selectStmt.targetList?.map(t => JSON.stringify(t.ResTarget?.val))); } // Convert the AST back to SQL (deparse) const deparsedSql = await deparse(ast); console.log(`Deparsed SQL: ${deparsedSql}`); } catch (error: any) { console.error('Error processing SQL:', error.message); if (error.sqlDetails) { console.error('SQL Details:', error.sqlDetails); } } } // Example SQL queries processSqlQuery('SELECT id, name FROM users WHERE status = $1 ORDER BY created_at DESC;'); processSqlQuery('CREATE FUNCTION add(a INT, b INT) RETURNS INT LANGUAGE plpgsql AS $$ BEGIN RETURN a + b; END; $$;'); // Intentionally malformed SQL to demonstrate error handling // processSqlQuery('SELECT * FROM users WHERE;');