Method convertCreateQuery

internal/engine/clickhouse/convert.go:770–819

(n *chast.CreateQuery)

}

func (c *cc) convertCreateQuery(n *chast.CreateQuery) ast.Node {
	// Handle CREATE DATABASE
	if n.CreateDatabase {
		return &ast.CreateSchemaStmt{
			Name:        &n.Database,
			IfNotExists: n.IfNotExists,
		}
	}

	// Handle CREATE TABLE
	if n.Table != "" {
		stmt := &ast.CreateTableStmt{
			Name: &ast.TableName{
				Name: identifier(n.Table),
			},
			IfNotExists: n.IfNotExists,
		}

		if n.Database != "" {
			stmt.Name.Schema = identifier(n.Database)
		}

		// Convert columns
		for _, col := range n.Columns {
			colDef := c.convertColumnDeclaration(col)
			stmt.Cols = append(stmt.Cols, colDef)
		}

		// Convert AS SELECT
		if n.AsSelect != nil {
			// This is a CREATE TABLE ... AS SELECT
			// The AsSelect field contains the SELECT statement
		}

		return stmt
	}

	// Handle CREATE VIEW
	if n.View != "" {
		return &ast.ViewStmt{
			View: &ast.RangeVar{
				Relname: &n.View,
			},
			Query:   c.convert(n.AsSelect),
			Replace: n.OrReplace,
		}
	}

	return &ast.TODO{}
}

func (c *cc) convertColumnDeclaration(n *chast.ColumnDeclaration) *ast.ColumnDef {
	colDef := &ast.ColumnDef{