Method convertDeleteStmt

internal/engine/dolphin/convert.go:330–380

(n *pcast.DeleteStmt)

}

func (c *cc) convertDeleteStmt(n *pcast.DeleteStmt) *ast.DeleteStmt {
	stmt := &ast.DeleteStmt{
		WhereClause:   c.convert(n.Where),
		ReturningList: &ast.List{},
		WithClause:    c.convertWithClause(n.With),
	}

	if n.Limit != nil {
		stmt.LimitCount = c.convert(n.Limit.Count)
	}

	// Handle multi-table DELETE (DELETE t1, t2 FROM t1 JOIN t2 ...)
	if n.IsMultiTable && n.Tables != nil && len(n.Tables.Tables) > 0 {
		// Convert delete targets (e.g., jt.*, pt.*)
		targets := &ast.List{}
		for _, table := range n.Tables.Tables {
			// Each table in the delete list is a ColumnRef like "jt.*" or "pt.*"
			items := []ast.Node{}
			if table.Schema.String() != "" {
				items = append(items, NewIdentifier(table.Schema.String()))
			}
			items = append(items, NewIdentifier(table.Name.String()))
			items = append(items, &ast.A_Star{})
			targets.Items = append(targets.Items, &ast.ColumnRef{
				Fields: &ast.List{Items: items},
			})
		}
		stmt.Targets = targets

		// Convert FROM clause preserving JOINs
		if n.TableRefs != nil {
			fromList := c.convertTableRefsClause(n.TableRefs)
			if len(fromList.Items) == 1 {
				stmt.FromClause = fromList.Items[0]
			} else {
				stmt.FromClause = fromList
			}
		}
	} else {
		// Single-table DELETE
		rels := c.convertTableRefsClause(n.TableRefs)
		if len(rels.Items) != 1 {
			panic("expected one range var")
		}
		relations := &ast.List{}
		convertToRangeVarList(rels, relations)
		stmt.Relations = relations
	}

	return stmt
}

func (c *cc) convertDropTableStmt(n *pcast.DropTableStmt) ast.Node {
	drop := &ast.DropTableStmt{IfExists: n.IfExists}