Function handleAnalyzeSQL

pkg/mcp/tools.go:338–391

handleAnalyzeSQL is the MCP tool handler for "analyze_sql". It fans out all six analysis tools concurrently and merges the results.

(ctx context.Context, req mcpmcp.CallToolRequest)

// handleAnalyzeSQL is the MCP tool handler for "analyze_sql".
// It fans out all six analysis tools concurrently and merges the results.
func handleAnalyzeSQL(ctx context.Context, req mcpmcp.CallToolRequest) (*mcpmcp.CallToolResult, error) {
	sql := req.GetString("sql", "")
	if sql == "" {
		return nil, fmt.Errorf("parameter 'sql' is required and must not be empty")
	}

	type namedResult struct {
		name string
		data map[string]any
		err  error
	}

	tasks := []struct {
		name string
		fn   func() (map[string]any, error)
	}{
		{"validate", func() (map[string]any, error) { return validateSQLInternal(sql, "") }},
		{"parse", func() (map[string]any, error) { return parseSQLInternal(sql) }},
		{"metadata", func() (map[string]any, error) { return extractMetadataInternal(sql) }},
		{"security", func() (map[string]any, error) { return securityScanInternal(sql) }},
		{"lint", func() (map[string]any, error) { return lintSQLInternal(sql) }},
		{"format", func() (map[string]any, error) { return formatSQLInternal(sql, 2, false, false) }},
	}

	results := make(chan namedResult, len(tasks))
	var wg sync.WaitGroup
	for _, t := range tasks {
		wg.Add(1)
		go func(t struct {
			name string
			fn   func() (map[string]any, error)
		}) {
			defer wg.Done()
			data, err := t.fn()
			results <- namedResult{name: t.name, data: data, err: err}
		}(t)
	}
	wg.Wait()
	close(results)

	combined := make(map[string]any, len(tasks)+1)
	errs := make(map[string]string)
	for r := range results {
		if r.err != nil {
			errs[r.name] = r.err.Error()
		} else {
			combined[r.name] = r.data
		}
	}
	if len(errs) > 0 {
		combined["errors"] = errs
	}
	return toolResult(combined)
}