clickhouse-mcp-agent 0.2.1a1

AI agent for ClickHouse database analysis via MCP

ClickHouse MCP Agent

A PydanticAI agent that integrates with ClickHouse databases using the Model Context Protocol (MCP).

Features

• MCP-based ClickHouse integration with secure database access
• Structured output with natural language analysis and SQL transparency
• Flexible connection management for different ClickHouse instances
• Built-in configurations for common scenarios

Usage

Basic Query

from agent import query_clickhouse

result = await query_clickhouse(
    query="What are the top 5 GitHub repositories by stars?",
    connection="playground",
    model="gemini-2.0-flash",
    api_key="your-google-api-key"
)
print(f"Analysis: {result.analysis}")

Custom Connection

from agent import ClickHouseConfig

config = ClickHouseConfig(
    name="production",
    host="clickhouse.company.com",
    port="8443",
    user="analyst",
    password="secret"
)

result = await query_clickhouse(
    query="SHOW TABLES", 
    connection=config,
    model="gemini-2.0-flash",
    api_key="your-google-api-key"
)

Current Usage (Library Import)

# When installed as a library: pip install clickhouse-mcp-agent
from agent import query_clickhouse, ClickHouseConfig

# Basic usage
result = await query_clickhouse(
    query="SHOW DATABASES", 
    connection="playground",
    model="gemini-2.0-flash",
    api_key="your-google-api-key"
)

# RBAC with dynamic user credentials
user_config = ClickHouseConfig(
    name="user_session",
    host="clickhouse.company.com",
    user="analyst_jane",
    password="jane_specific_password"
)
result = await query_clickhouse(
    query="SELECT * FROM user_logs", 
    connection=user_config,
    model="gemini-2.0-flash",
    api_key="your-google-api-key"
)

# Completely dynamic 
result = await query_clickhouse(
    query="SHOW TABLES",
    connection=ClickHouseConfig(
        name="runtime",
        host="dynamic.clickhouse.com",
        user="runtime_user",
        password="runtime_pass"
    ),
    model="gemini-2.0-flash",
    api_key="your-google-api-key-here" 
)

Environment Variables

The project automatically loads from .env file:

result = await query_clickhouse(
    query="SELECT 1", 
    connection="env",
    model="gemini-2.0-flash",
    api_key="your-google-api-key"
)

Built-in Connections

• playground: ClickHouse SQL playground (public demo data)
• local: Local instance (localhost:9000)
• env: From environment variables

CLI

./run.sh                         # Automated run script
# OR manually:
source .venv/bin/activate
clickhouse-mcp-demo             # CLI command from pyproject.toml
python -m agent.main            # Direct module execution

Output

Returns ClickHouseOutput with:

• analysis: Natural language results with SQL queries mentioned in the response
• sql_used: Optional SQL query that was executed (when available)
• confidence: Confidence level of the analysis (1-10 scale)

Requirements

• Python 3.10+
• AI API key (Google/Gemini) - can be set via environment variable, .env file, or passed directly to the function

All other dependencies (UV, MCP servers, etc.) are handled automatically by pyproject.toml.

Roadmap

✅ Completed Features

• MCP Integration: PydanticAI + ClickHouse MCP server integration
• Query Execution: SQL query execution via MCP tools
• Schema Inspection: Database, table, and column exploration
• Connection Management: Multiple connection configurations (playground, local, env)
• RBAC Support: Pass different user credentials dynamically via ClickHouseConfig
• Dynamic Connections: Runtime connection configuration without environment dependencies
• Direct API Key Passing: Pass AI API keys directly to functions (model_api_key parameter)
• Structured Output: ClickHouseOutput with analysis, SQL, and confidence
• CLI Interface: Command-line tool via clickhouse-mcp-demo
• Type Safety: Full mypy compliance with proper type annotations
• Code Quality: Black formatting, isort import organization, flake8 linting

🚧 Planned Features (Discussed)

Enhanced Conversation Support

• Message History: Add message_history parameter to query_clickhouse() for conversation continuity
• Conversational Agent: ConversationalClickHouseAgent class for persistent memory across queries

Model Support

• Model Agnostic Support: Support for different AI models beyond Gemini

---

Contributing

Have ideas for new features? Found something missing?

1. Check existing issues/discussions
2. Open a feature request with use case details
3. Consider contributing via pull request

Current Focus: Message history integration and model agnostic support.