Function parsePgStatements

backend/plugin/parser/pg/pg.go:21–50

parsePgStatements is the ParseStatementsFunc for PostgreSQL. Returns []ParsedStatement with both text and AST populated.

(statement string)

// parsePgStatements is the ParseStatementsFunc for PostgreSQL.
// Returns []ParsedStatement with both text and AST populated.
func parsePgStatements(statement string) ([]base.ParsedStatement, error) {
	stmts, err := SplitSQL(statement)
	if err != nil {
		return nil, err
	}

	var result []base.ParsedStatement
	for _, stmt := range stmts {
		if stmt.Empty {
			continue
		}

		omniStmts, omniErr := ParsePg(stmt.Text)
		if omniErr != nil {
			return nil, convertOmniError(omniErr, statement, stmt)
		}

		for _, os := range omniStmts {
			result = append(result, base.ParsedStatement{
				Statement: stmt,
				AST: &OmniAST{
					Node:          os.AST,
					Text:          stmt.Text,
					StartPosition: stmt.Start,
				},
			})
		}
	}
	return result, nil
}

// convertOmniError converts an omni parser error to a base.SyntaxError with proper line:column position.
func convertOmniError(err error, _ string, stmt base.Statement) error {