package catalog

import (
	"github.com/sqlc-dev/sqlc/internal/sql/ast"
	"github.com/sqlc-dev/sqlc/internal/sql/sqlerr"
)

func (c *Catalog) createView(stmt *ast.ViewStmt, colGen columnGenerator) error {
	cols, err := colGen.OutputColumns(stmt.Query)
	if err != nil {
		return err
	}

	catName := ""
	if stmt.View.Catalogname != nil {
		catName = *stmt.View.Catalogname
	}
	schemaName := ""
	if stmt.View.Schemaname != nil {
		schemaName = *stmt.View.Schemaname
	}

	tbl := Table{
		Rel: &ast.TableName{
			Catalog: catName,
			Schema:  schemaName,
			Name:    *stmt.View.Relname,
		},
		Columns: cols,
	}

	ns := tbl.Rel.Schema
	if ns == "" {
		ns = c.DefaultSchema
	}
	schema, err := c.getSchema(ns)
	if err != nil {
		return err
	}
	_, existingIdx, err := schema.getTable(tbl.Rel)
	if err == nil && !stmt.Replace {
		return sqlerr.RelationExists(tbl.Rel.Name)
	}

	if stmt.Replace && err == nil {
		schema.Tables[existingIdx] = &tbl
	} else {
		schema.Tables = append(schema.Tables, &tbl)
	}

	return nil
}