Method Transform

transpiler/transform/operators.go:22–79

(tree *pg_query.ParseResult, result *Result)

}

func (t *OperatorTransform) Transform(tree *pg_query.ParseResult, result *Result) (bool, error) {
	changed := false

	for _, stmt := range tree.Stmts {
		if stmt.Stmt == nil {
			continue
		}

		if selectStmt := stmt.Stmt.GetSelectStmt(); selectStmt != nil {
			if t.transformSelectStmt(selectStmt) {
				changed = true
			}
		} else if insertStmt := stmt.Stmt.GetInsertStmt(); insertStmt != nil {
			if t.transformInsertStmt(insertStmt) {
				changed = true
			}
		} else if updateStmt := stmt.Stmt.GetUpdateStmt(); updateStmt != nil {
			if t.transformUpdateStmt(updateStmt) {
				changed = true
			}
		} else if deleteStmt := stmt.Stmt.GetDeleteStmt(); deleteStmt != nil {
			if t.transformDeleteStmt(deleteStmt) {
				changed = true
			}
		} else if ctasStmt := stmt.Stmt.GetCreateTableAsStmt(); ctasStmt != nil {
			// CREATE TABLE AS SELECT (and CREATE OR REPLACE TABLE AS, which the
			// transpiler routes here after stripping OR REPLACE; also CREATE
			// MATERIALIZED VIEW AS / SELECT INTO). Without descending into the
			// AS-SELECT body, a chained JSON arrow there is left as a raw
			// operator and hits DuckDB's ->> precedence bug once the parens are
			// normalized away by the pg_query round-trip — e.g. a SQLMesh
			// `CREATE OR REPLACE TABLE ... AS ... CASE WHEN x AND (j -> 'a') ->>
			// 'b' LIKE ... ` materialization fails with a spurious numeric cast.
			// Query is usually a SelectStmt; for `CREATE TABLE t AS EXECUTE plan`
			// it's an ExecuteStmt (no arrows to rewrite), so the nil-check below
			// intentionally skips it.
			if ctasStmt.Query != nil {
				if ctasSelect := ctasStmt.Query.GetSelectStmt(); ctasSelect != nil {
					if t.transformSelectStmt(ctasSelect) {
						changed = true
					}
				}
			}
		} else if viewStmt := stmt.Stmt.GetViewStmt(); viewStmt != nil {
			// CREATE [OR REPLACE] VIEW ... AS SELECT ... — the view body carries
			// the same arrow-precedence risk as a CTAS body.
			if viewStmt.Query != nil {
				if viewSelect := viewStmt.Query.GetSelectStmt(); viewSelect != nil {
					if t.transformSelectStmt(viewSelect) {
						changed = true
					}
				}
			}
		}
	}

	return changed, nil
}