SQLPrism
An MCP server that indexes SQL codebases into a queryable knowledge graph backed by DuckDB, enabling structural SQL queries instead of grep.
README
SQLPrism
An MCP server that indexes SQL codebases into a queryable knowledge graph backed by DuckDB. Instead of grepping through files, ask structural questions: what touches this table, where is this column transformed, what's the blast radius of this PR.
Built for SQL-heavy data projects — works with raw SQL, SQLMesh, and dbt.
Why Not Just Grep?
Grep finds strings. This tool understands SQL structure.
| Capability | Grep | SQLPrism |
|---|---|---|
| Find table references | Yes | Yes |
| CTE-to-CTE data flow | No — manual file reading | Yes — edges tracked in graph |
| Column lineage with transforms (CAST, COALESCE, SUM) | No | Yes — parsed from AST |
| Usage type (WHERE vs SELECT vs JOIN vs GROUP BY) | Fragile regex | Precise — parsed from AST |
| Multi-hop impact analysis | Manual tracing | Automatic graph traversal |
| PR blast radius | DIY with git diff | One call |
| Cross-CTE column tracing | Basically impossible | Built-in |
On a 200-model SQLMesh project, a column impact query returns 75 structured results in ~5,000 tokens. The grep equivalent would need 40-60 files opened, ~100,000+ tokens, and still wouldn't tell you whether a column appears in a WHERE filter or a SELECT.
Setup
1. Install
git clone https://github.com/darkcofy/sqlprism.git && cd sqlprism
uv sync
2. Configure
uv run sqlprism init # creates sqlprism.yml in the current directory
# edit sqlprism.yml to add your repos (see Configuration below)
uv run sqlprism reindex # index plain SQL repos
For dbt and SQLMesh projects, use reindex-dbt and reindex-sqlmesh respectively. See the CLI guide for full options.
Prerequisite: dbt and SQLMesh are not dependencies of sqlprism. The renderers shell out to
dbt compile/sqlmeshinside the target project's own virtualenv (viauv runby default). Install the renderer in that project — for exampleuv add dbt-core dbt-<adapter>oruv add sqlmesh— before runningreindex-dbt/reindex-sqlmesh. If the renderer is missing, sqlprism will raise a clear error pointing at the project directory.
3. Connect your MCP client
Claude Code:
claude mcp add sqlprism -- uv run --directory /path/to/sqlprism sqlprism serve
Claude Desktop / Cursor / Continue.dev (.mcp.json):
{
"mcpServers": {
"sqlprism": {
"command": "uv",
"args": ["run", "--directory", "/path/to/sqlprism", "sqlprism", "serve"]
}
}
}
Replace /path/to/sqlprism with the absolute path to your clone.
4. Reindex on Save
The graph stays fresh automatically when you set up on-save hooks. There are two modes depending on your editor.
Claude Code
Add a PostToolUse hook so the index updates whenever Claude writes or edits a file. Save this as .claude/settings.json in your project root:
{
"hooks": {
"PostToolUse": [
{
"matcher": "Write|Edit",
"hooks": [
{
"type": "command",
"command": "FILE=$(cat | jq -r '.tool_input.file_path // empty'); [ -n \"$FILE\" ] && [[ \"$FILE\" =~ \\.sql$ ]] && sqlprism reindex-file \"$FILE\" || true"
}
]
}
]
}
}
This extracts the file path from the hook's stdin JSON, checks it's a .sql file, and calls the CLI to reindex it. Run /hooks in Claude Code to verify the hook is active.
Other MCP clients (Cursor, Continue.dev)
The reindex_files MCP tool accepts absolute file paths and reindexes only the affected models. Plain SQL reindexes in ~50ms; dbt/SQLMesh models compile + reindex in ~2-5s. Calls are debounced per repo (500ms for SQL, 2s for rendered models) so rapid saves batch into a single operation.
Configure your client to call reindex_files with the saved file's path on save.
Editors without MCP (Vim, Neovim, Emacs, VS Code tasks)
The reindex-file CLI command works standalone — no running server needed:
sqlprism reindex-file /path/to/model.sql
Vim / Neovim:
autocmd BufWritePost *.sql silent !sqlprism reindex-file %:p
Emacs:
(add-hook 'after-save-hook
(lambda ()
(when (string-match-p "\\.sql\\'" buffer-file-name)
(start-process "sqlprism" nil "sqlprism" "reindex-file" buffer-file-name))))
VS Code (using the Run on Save extension, .vscode/settings.json):
{
"emeraldwalk.runonsave": {
"commands": [
{
"match": "\\.sql$",
"cmd": "sqlprism reindex-file ${file}"
}
]
}
}
Configuration
sqlprism init creates a default config at sqlprism.yml in the working directory. YAML is the default format; JSON is also supported (--format json). Existing sqlprism.json files are auto-discovered for backwards compatibility. Override the config path with --config PATH on any command.
db_path: ~/.sqlprism/graph.duckdb
sql_dialect: null
repos:
my-queries: /path/to/sql/repo
multi-dialect-repo:
path: /path/to/repo
dialect: starrocks
dialect_overrides:
athena/: athena
postgres/: postgres
sqlmesh_repos:
my-sqlmesh-project:
project_path: /path/to/sqlmesh/folder
env_file: /path/to/.env
dialect: athena
variables:
GRACE_PERIOD: 7
dbt_repos:
my-dbt-project:
project_path: /path/to/dbt/project
env_file: /path/to/.env
target: dev
dialect: starrocks
dbt_command: uv run dbt
| Field | Description |
|---|---|
db_path |
Path to the DuckDB database file. Defaults to ~/.sqlprism/graph.duckdb. |
sql_dialect |
Global default SQL dialect. null for auto-detect. |
repos |
Plain SQL repos. Value is a path string or an object with path, dialect, dialect_overrides. |
dialect |
Per-repo dialect override (e.g. "starrocks", "athena", "bigquery"). |
dialect_overrides |
Per-directory overrides using prefix matching or glob patterns. |
sqlmesh_repos |
SQLMesh projects. Renders models before parsing. |
dbt_repos |
dbt projects. Compiles models before parsing. |
SQL Dialect Support
Powered by sqlglot, the indexer supports 33 SQL dialects out of the box:
Athena, BigQuery, ClickHouse, Databricks, Doris, Dremio, Drill, Druid, DuckDB, Dune, Exasol, Fabric, Hive, Materialize, MySQL, Oracle, Postgres, Presto, PRQL, Redshift, RisingWave, SingleStore, Snowflake, Spark, Spark2, SQLite, StarRocks, Tableau, Teradata, Trino, TSQL.
Pass the dialect name as a lowercase string (e.g. "starrocks", "bigquery", "athena"). Dialect-specific quoting and identifier case normalization are handled automatically.
CLI Commands
Full reference: CLI guide
| Command | Description |
|---|---|
sqlprism init |
Create default config file. |
sqlprism reindex |
Incremental reindex of plain SQL repos. |
sqlprism reindex-file |
Fast on-save reindex of specific files. |
sqlprism reindex-dbt |
Compile and index a dbt project. |
sqlprism reindex-sqlmesh |
Render and index a SQLMesh project. |
sqlprism serve |
Start the MCP server (stdio or HTTP). |
sqlprism conventions init |
Generate sqlprism.conventions.yml from inferred conventions. |
sqlprism conventions refresh |
Re-run convention inference after reindex. |
sqlprism conventions diff |
Show what changed since last --init. |
sqlprism status |
Show index status. |
sqlprism query search |
Find entities by name pattern. |
sqlprism query references |
Find inbound/outbound dependencies. |
sqlprism query column-usage |
Find column usage across models. |
sqlprism query trace |
Multi-hop dependency tracing. |
sqlprism query lineage |
End-to-end column lineage chains. |
MCP Tools
Full reference: MCP tools guide
When running as an MCP server (sqlprism serve), the following tools are exposed:
| Tool | Description |
|---|---|
search |
Find entities by name pattern with pagination. |
find_references |
Inbound/outbound dependencies with snippets. |
find_column_usage |
Column usage — type, transforms, aliases. |
trace_dependencies |
Multi-hop upstream/downstream chains. |
trace_column_lineage |
End-to-end column lineage through CTEs. |
get_schema |
Table/view schema with columns, types, and dependencies. |
get_context |
One-call comprehensive context dump for a model. |
find_path |
Shortest path between two models (DuckPGQ). |
find_critical_models |
Rank models by PageRank importance (DuckPGQ). |
detect_cycles |
Find circular dependencies in the graph. |
find_subgraphs |
Identify disconnected clusters and orphaned models (DuckPGQ). |
find_bottlenecks |
High fan-out models with risk classification. |
check_impact |
Column-level impact analysis before making changes. |
pr_impact |
Structural diff + blast radius since a base commit. |
reindex |
Background incremental reindex of SQL repos. |
reindex_files |
Fast on-save reindex with per-repo debounce. |
reindex_dbt |
Background dbt compile + index. |
reindex_sqlmesh |
Background SQLMesh render + index. |
get_conventions |
Inferred project conventions — naming, references, columns. |
find_similar_models |
Find existing models similar to what you're building. |
suggest_placement |
Recommend where to place a new model based on references. |
search_by_tag |
Find models by semantic tag (business domain concept). |
list_tags |
List all semantic tags with model counts and confidence. |
index_status |
Index stats, cross-repo edges, and name collisions. |
Architecture
src/sqlprism/
types.py <- ParseResult, NodeResult, EdgeResult, ColumnUsageResult, parse_repo_config
languages/
__init__.py <- SQL_EXTENSIONS, is_sql_file()
sql.py <- sqlglot: tables, views, CTEs, column lineage, transforms
sqlmesh.py <- SQLMesh renderer (full project + selective render_models)
dbt.py <- dbt renderer (full project + selective render_models via --select)
utils.py <- Shared helpers (find_venv_dir, parse_dotenv, build_env, enrich_nodes)
core/
graph.py <- DuckDB storage layer (MVCC), queries, snippets, repo_type tracking
indexer.py <- Orchestrator: scan -> checksum -> parse -> store; file-level reindex with repo-type dispatch
mcp_tools.py <- FastMCP tool definitions (non-blocking reindex, per-repo debounce)
conventions.py <- Convention inference engine: layers, naming, references, tags, overrides
cli.py <- Click CLI: serve, reindex, reindex-file, reindex-sqlmesh, reindex-dbt, conventions, status, init
The SQL parser extracts:
- Nodes: tables, views, CTEs, queries (with schema metadata and dialect-aware case normalization)
- Edges: table references, CTE references, JOINs (with context like "FROM clause", "JOIN clause")
- Column usage: per-column tracking with usage type (select, where, join_on, group_by, order_by, having, partition_by, window_order), transforms (CAST, COALESCE, SUM, etc.), output aliases, and WHERE filter expressions
- Column lineage: end-to-end tracing through CTEs and subqueries back to source tables, with SELECT * expansion when schema catalog is available
Full architecture docs: Architecture overview | DuckDB schema
DuckPGQ Graph Analytics
SQLPrism optionally integrates with DuckPGQ for advanced graph analytics. When installed, these tools become available: find_path, find_critical_models, find_subgraphs, find_bottlenecks (clustering enrichment). DuckPGQ is installed automatically on first use — no manual setup needed.
Development
uv sync
uv run pytest # run tests (630+ tests)
uv run pytest --cov=sqlprism # run with coverage report
uv run pytest --cov=sqlprism --cov-report=html:coverage_html # HTML report
Code Coverage
License
Apache License 2.0 — see LICENSE.
推荐服务器
Baidu Map
百度地图核心API现已全面兼容MCP协议,是国内首家兼容MCP协议的地图服务商。
Playwright MCP Server
一个模型上下文协议服务器,它使大型语言模型能够通过结构化的可访问性快照与网页进行交互,而无需视觉模型或屏幕截图。
Magic Component Platform (MCP)
一个由人工智能驱动的工具,可以从自然语言描述生成现代化的用户界面组件,并与流行的集成开发环境(IDE)集成,从而简化用户界面开发流程。
Audiense Insights MCP Server
通过模型上下文协议启用与 Audiense Insights 账户的交互,从而促进营销洞察和受众数据的提取和分析,包括人口统计信息、行为和影响者互动。
VeyraX
一个单一的 MCP 工具,连接你所有喜爱的工具:Gmail、日历以及其他 40 多个工具。
graphlit-mcp-server
模型上下文协议 (MCP) 服务器实现了 MCP 客户端与 Graphlit 服务之间的集成。 除了网络爬取之外,还可以将任何内容(从 Slack 到 Gmail 再到播客订阅源)导入到 Graphlit 项目中,然后从 MCP 客户端检索相关内容。
Kagi MCP Server
一个 MCP 服务器,集成了 Kagi 搜索功能和 Claude AI,使 Claude 能够在回答需要最新信息的问题时执行实时网络搜索。
e2b-mcp-server
使用 MCP 通过 e2b 运行代码。
Neon MCP Server
用于与 Neon 管理 API 和数据库交互的 MCP 服务器
Exa MCP Server
模型上下文协议(MCP)服务器允许像 Claude 这样的 AI 助手使用 Exa AI 搜索 API 进行网络搜索。这种设置允许 AI 模型以安全和受控的方式获取实时的网络信息。