Method convertUpdateQuery

internal/engine/clickhouse/convert.go:858–889

(n *chast.UpdateQuery)

}

func (c *cc) convertUpdateQuery(n *chast.UpdateQuery) *ast.UpdateStmt {
	rv := &ast.RangeVar{
		Relname: &n.Table,
	}
	if n.Database != "" {
		rv.Schemaname = &n.Database
	}
	stmt := &ast.UpdateStmt{
		Relations: &ast.List{
			Items: []ast.Node{rv},
		},
	}

	// Convert assignments
	if len(n.Assignments) > 0 {
		stmt.TargetList = &ast.List{}
		for _, assign := range n.Assignments {
			name := identifier(assign.Column)
			stmt.TargetList.Items = append(stmt.TargetList.Items, &ast.ResTarget{
				Name: &name,
				Val:  c.convertExpr(assign.Value),
			})
		}
	}

	// Convert WHERE clause
	if n.Where != nil {
		stmt.WhereClause = c.convertExpr(n.Where)
	}

	return stmt
}

func (c *cc) convertDeleteQuery(n *chast.DeleteQuery) *ast.DeleteStmt {
	rv := &ast.RangeVar{