Function testDialectQueries

pkg/sql/parser/integration_test.go:236–296

testDialectQueries is a helper function to test queries from a specific dialect file

(t *testing.T, filePath string, dialectName string)

// testDialectQueries is a helper function to test queries from a specific dialect file
func testDialectQueries(t *testing.T, filePath string, dialectName string) {
	// Read SQL file
	content, err := os.ReadFile(filePath)
	if err != nil {
		t.Skipf("File not found: %s (may not be implemented yet)", filePath)
		return
	}

	queries := extractQueries(string(content))
	if len(queries) == 0 {
		t.Skipf("No queries found in %s", filePath)
		return
	}

	successCount := 0
	failureCount := 0

	for i, query := range queries {
		queryNum := i + 1
		t.Run(strings.TrimSpace(query)[:min(50, len(strings.TrimSpace(query)))], func(t *testing.T) {
			// Tokenize
			tkz := tokenizer.GetTokenizer()
			defer tokenizer.PutTokenizer(tkz)

			tokens, tokErr := tkz.Tokenize([]byte(query))
			if tokErr != nil {
				failureCount++
				t.Logf("Query #%d tokenization failed: %v", queryNum, tokErr)
				t.Logf("Query: %s", truncateQuery(query))
				return
			}

			// Convert tokens

			// Parse
			p := NewParser()
			_, parseErr := p.ParseFromModelTokens(tokens)

			if parseErr != nil {
				failureCount++
				t.Logf("Query #%d parsing failed: %v", queryNum, parseErr)
				t.Logf("Query: %s", truncateQuery(query))
			} else {
				successCount++
				t.Logf("Query #%d: ✅ Success", queryNum)
			}
		})
	}

	// Report dialect-specific results
	total := successCount + failureCount
	successRate := 0.0
	if total > 0 {
		successRate = (float64(successCount) / float64(total)) * 100.0
	}

	t.Logf("\n%s Dialect Results:", dialectName)
	t.Logf("  Total:   %d queries", total)