Method convertInsertQuery

internal/engine/clickhouse/convert.go:725–768

(n *chast.InsertQuery)

}

func (c *cc) convertInsertQuery(n *chast.InsertQuery) *ast.InsertStmt {
	stmt := &ast.InsertStmt{
		Relation: &ast.RangeVar{
			Relname: &n.Table,
		},
	}

	if n.Database != "" {
		stmt.Relation.Schemaname = &n.Database
	}

	// Convert column list
	if len(n.Columns) > 0 {
		stmt.Cols = &ast.List{}
		for _, col := range n.Columns {
			name := col.Name()
			stmt.Cols.Items = append(stmt.Cols.Items, &ast.ResTarget{
				Name: &name,
			})
		}
	}

	// Convert SELECT subquery if present
	if n.Select != nil {
		stmt.SelectStmt = c.convert(n.Select)
	}

	// Convert VALUES clause
	if len(n.Values) > 0 {
		selectStmt := &ast.SelectStmt{
			ValuesLists: &ast.List{},
		}
		for _, row := range n.Values {
			rowList := &ast.List{}
			for _, val := range row {
				rowList.Items = append(rowList.Items, c.convertExpr(val))
			}
			selectStmt.ValuesLists.Items = append(selectStmt.ValuesLists.Items, rowList)
		}
		stmt.SelectStmt = selectStmt
	}

	return stmt
}

func (c *cc) convertCreateQuery(n *chast.CreateQuery) ast.Node {
	// Handle CREATE DATABASE