SQL to Elasticsearch DSL Translator

项目简介

SQL to Elasticsearch DSL Translator 是一个基于 MCP (Model Conversion Platform) 框架构建的服务，可以将 MySQL SQL 查询语句转换为 Elasticsearch DSL (Domain Specific Language) 查询。

该工具支持常见的 SQL 操作，包括：

• SELECT 查询
• WHERE 条件过滤
• GROUP BY 聚合
• ORDER BY 排序
• LIMIT 限制结果数量
• 函数操作（COUNT, AVG, SUM等）
• UNION 和 MINUS 操作

这个转换器可以帮助熟悉 SQL 语法但不熟悉 Elasticsearch DSL 的开发者快速构建 Elasticsearch 查询。

整个项目全是基于 ai 的自主生成。 支持版本: Elasticsearch 7.17

部署指南

环境要求

• Python 3.13 或更高版本
• pip 或 poetry 用于依赖管理

安装步骤

1. 克隆项目代码：

   git clone <repository-url>
   cd SqlToDslTranslator-MCP
   

2. 安装依赖：

   # 使用 pip
   pip install -e .
   
   # 或使用 poetry
   poetry install
   

3. 运行服务：

   python -m SqlToDslTranslator_MCP
   

使用示例

基本查询转换

将简单的 SQL 查询转换为 Elasticsearch DSL：

from src.SqlToDslTranslator_MCP.server import SQLToESDSLConverter

# 创建转换器实例
converter = SQLToESDSLConverter()

sql = "SELECT id, name, age FROM users WHERE age > 18 ORDER BY age LIMIT 10"
dsl = converter.convert(sql)
print(dsl)

聚合查询

支持 GROUP BY 和聚合函数：

sql = "SELECT department, COUNT(*) as count FROM employees GROUP BY department"
dsl = converter.convert(sql)
print(dsl)

复杂条件查询

支持多种条件和函数：

sql = "SELECT name, ROUND(age/10)*10 as age_group, COUNT(*) FROM users WHERE status = 'active' GROUP BY ROUND(age/10)*10 HAVING COUNT(*) > 5"
dsl = converter.convert(sql)
print(dsl)

通过MCP工具使用

作为MCP工具使用时，可以直接调用convert函数：

from src.SqlToDslTranslator_MCP.server import convert

result = convert("SELECT COUNT(*) FROM logs WHERE level = 'ERROR'")
print(result)

命令行使用

也可以通过命令行工具进行转换：

echo "SELECT COUNT(*) FROM logs WHERE level = 'ERROR'" | python -m SqlToDslTranslator_MCP