Add CREATE MATERIALIZED VIEW support with distribution and options

- Add parseCreateMaterializedViewStatement for MATERIALIZED VIEW parsing
- Add ViewOption interface with ViewStatementOption, ViewDistributionOption, and ViewForAppendOption types
- Parse DISTRIBUTION = HASH(columns) and FOR_APPEND options
- Use $ref for duplicate identifiers in DistributionColumns
- Enable MaterializedViewTests130/140/150/160 and Baselines* variants

Author: claude

ast/create_view_statement.go

@@ -13,7 +13,35 @@ type CreateViewStatement struct {
 func (c *CreateViewStatement) node()      {}
 func (c *CreateViewStatement) statement() {}
 
-// ViewOption represents a view option like SCHEMABINDING.
-type ViewOption struct {
+// ViewOption is an interface for different view option types.
+type ViewOption interface {
+	viewOption()
+}
+
+// ViewStatementOption represents a simple view option like SCHEMABINDING.
+type ViewStatementOption struct {
+	OptionKind string `json:"OptionKind,omitempty"`
+}
+
+func (v *ViewStatementOption) viewOption() {}
+
+// ViewDistributionOption represents a DISTRIBUTION option for materialized views.
+type ViewDistributionOption struct {
+	OptionKind string                        `json:"OptionKind,omitempty"`
+	Value      *ViewHashDistributionPolicy `json:"Value,omitempty"`
+}
+
+func (v *ViewDistributionOption) viewOption() {}
+
+// ViewHashDistributionPolicy represents the hash distribution policy for materialized views.
+type ViewHashDistributionPolicy struct {
+	DistributionColumn  *Identifier   `json:"DistributionColumn,omitempty"`
+	DistributionColumns []*Identifier `json:"DistributionColumns,omitempty"`
+}
+
+// ViewForAppendOption represents the FOR_APPEND option for materialized views.
+type ViewForAppendOption struct {
 	OptionKind string `json:"OptionKind,omitempty"`
 }
+
+func (v *ViewForAppendOption) viewOption() {}

parser/marshal.go

@@ -2817,6 +2817,13 @@ func createViewStatementToJSON(s *ast.CreateViewStatement) jsonNode {
 		}
 		node["Columns"] = cols
 	}
+	if len(s.ViewOptions) > 0 {
+		opts := make([]jsonNode, len(s.ViewOptions))
+		for i, opt := range s.ViewOptions {
+			opts[i] = viewOptionToJSON(opt)
+		}
+		node["ViewOptions"] = opts
+	}
 	if s.SelectStatement != nil {
 		node["SelectStatement"] = selectStatementToJSON(s.SelectStatement)
 	}
@@ -2825,6 +2832,50 @@ func createViewStatementToJSON(s *ast.CreateViewStatement) jsonNode {
 	return node
 }
 
+func viewOptionToJSON(opt ast.ViewOption) jsonNode {
+	switch o := opt.(type) {
+	case *ast.ViewStatementOption:
+		return jsonNode{
+			"$type":      "ViewOption",
+			"OptionKind": o.OptionKind,
+		}
+	case *ast.ViewDistributionOption:
+		node := jsonNode{
+			"$type":      "ViewDistributionOption",
+			"OptionKind": o.OptionKind,
+		}
+		if o.Value != nil {
+			valueNode := jsonNode{
+				"$type": "ViewHashDistributionPolicy",
+			}
+			if o.Value.DistributionColumn != nil {
+				valueNode["DistributionColumn"] = identifierToJSON(o.Value.DistributionColumn)
+			}
+			if len(o.Value.DistributionColumns) > 0 {
+				cols := make([]jsonNode, len(o.Value.DistributionColumns))
+				for i, c := range o.Value.DistributionColumns {
+					// First column is same as DistributionColumn, use $ref
+					if i == 0 && o.Value.DistributionColumn != nil {
+						cols[i] = jsonNode{"$ref": "Identifier"}
+					} else {
+						cols[i] = identifierToJSON(c)
+					}
+				}
+				valueNode["DistributionColumns"] = cols
+			}
+			node["Value"] = valueNode
+		}
+		return node
+	case *ast.ViewForAppendOption:
+		return jsonNode{
+			"$type":      "ViewForAppendOption",
+			"OptionKind": o.OptionKind,
+		}
+	default:
+		return jsonNode{"$type": "UnknownViewOption"}
+	}
+}
+
 func createSchemaStatementToJSON(s *ast.CreateSchemaStatement) jsonNode {
 	node := jsonNode{
 		"$type": "CreateSchemaStatement",

parser/parse_statements.go

@@ -1789,6 +1789,8 @@ func (p *Parser) parseCreateStatement() (ast.Statement, error) {
 			return p.parseCreateSequenceStatement()
 		case "SPATIAL":
 			return p.parseCreateSpatialIndexStatement()
+		case "MATERIALIZED":
+			return p.parseCreateMaterializedViewStatement()
 		case "SERVER":
 			// Check if it's SERVER ROLE or SERVER AUDIT
 			p.nextToken() // consume SERVER
@@ -2899,7 +2901,7 @@ func (p *Parser) parseCreateViewStatement() (*ast.CreateViewStatement, error) {
 		p.nextToken()
 		// Parse view options
 		for p.curTok.Type == TokenIdent {
-			opt := ast.ViewOption{OptionKind: p.curTok.Literal}
+			opt := &ast.ViewStatementOption{OptionKind: p.curTok.Literal}
 			stmt.ViewOptions = append(stmt.ViewOptions, opt)
 			p.nextToken()
 			if p.curTok.Type == TokenComma {
@@ -2927,6 +2929,104 @@ func (p *Parser) parseCreateViewStatement() (*ast.CreateViewStatement, error) {
 	return stmt, nil
 }
 
+func (p *Parser) parseCreateMaterializedViewStatement() (*ast.CreateViewStatement, error) {
+	// Consume MATERIALIZED
+	p.nextToken()
+
+	// Expect VIEW
+	if p.curTok.Type != TokenView {
+		return nil, fmt.Errorf("expected VIEW after MATERIALIZED, got %s", p.curTok.Literal)
+	}
+	p.nextToken()
+
+	stmt := &ast.CreateViewStatement{
+		IsMaterialized: true,
+	}
+
+	// Parse view name
+	son, err := p.parseSchemaObjectName()
+	if err != nil {
+		return nil, err
+	}
+	stmt.SchemaObjectName = son
+
+	// Parse WITH options for materialized view
+	if p.curTok.Type == TokenWith || strings.ToUpper(p.curTok.Literal) == "WITH" {
+		p.nextToken() // consume WITH
+		if p.curTok.Type == TokenLParen {
+			p.nextToken()
+			for p.curTok.Type != TokenRParen && p.curTok.Type != TokenEOF {
+				optionName := strings.ToUpper(p.curTok.Literal)
+				p.nextToken()
+
+				if optionName == "DISTRIBUTION" {
+					// Parse DISTRIBUTION = HASH(col1, col2, ...)
+					if p.curTok.Type == TokenEquals {
+						p.nextToken()
+					}
+					if strings.ToUpper(p.curTok.Literal) == "HASH" {
+						p.nextToken()
+						if p.curTok.Type == TokenLParen {
+							p.nextToken()
+							distOpt := &ast.ViewDistributionOption{
+								OptionKind: "Distribution",
+								Value:      &ast.ViewHashDistributionPolicy{},
+							}
+							// Parse column list
+							for p.curTok.Type != TokenRParen && p.curTok.Type != TokenEOF {
+								col := p.parseIdentifier()
+								if distOpt.Value.DistributionColumn == nil {
+									distOpt.Value.DistributionColumn = col
+								}
+								distOpt.Value.DistributionColumns = append(distOpt.Value.DistributionColumns, col)
+								if p.curTok.Type == TokenComma {
+									p.nextToken()
+								} else {
+									break
+								}
+							}
+							if p.curTok.Type == TokenRParen {
+								p.nextToken()
+							}
+							stmt.ViewOptions = append(stmt.ViewOptions, distOpt)
+						}
+					}
+				} else if optionName == "FOR_APPEND" {
+					stmt.ViewOptions = append(stmt.ViewOptions, &ast.ViewForAppendOption{
+						OptionKind: "ForAppend",
+					})
+				}
+
+				if p.curTok.Type == TokenComma {
+					p.nextToken()
+				} else if p.curTok.Type != TokenRParen {
+					break
+				}
+			}
+			if p.curTok.Type == TokenRParen {
+				p.nextToken()
+			}
+		}
+	}
+
+	// Expect AS
+	if p.curTok.Type != TokenAs {
+		p.skipToEndOfStatement()
+		return stmt, nil
+	}
+	p.nextToken()
+
+	// Parse SELECT statement
+	selStmt, err := p.parseSelectStatement()
+	if err != nil {
+		p.skipToEndOfStatement()
+		return stmt, nil
+	}
+	stmt.SelectStatement = selStmt
+
+	return stmt, nil
+}
+
 func (p *Parser) parseCreateSchemaStatement() (*ast.CreateSchemaStatement, error) {
 	// Consume SCHEMA
 	p.nextToken()

parser/testdata/Baselines140_MaterializedViewTests140/metadata.json

@@ -1 +1 @@
-{"todo": true}
+{}

parser/testdata/Baselines150_MaterializedViewTests150/metadata.json

@@ -1 +1 @@
-{"todo": true}
+{}

parser/testdata/Baselines160_MaterializedViewTests160/metadata.json

@@ -1 +1 @@
-{"todo": true}
+{}

parser/testdata/MaterializedViewTests140/metadata.json

@@ -1 +1 @@
-{"todo": true}
+{}

parser/testdata/MaterializedViewTests150/metadata.json

@@ -1 +1 @@
-{"todo": true}
+{}

parser/testdata/MaterializedViewTests160/metadata.json

@@ -1 +1 @@
-{"todo": true}
+{}