Dify 与 MySQL 集成实战：基于 MCP 协议的数据交互方案

2. 课程表

CREATE TABLE courses (
    id VARCHAR(255) NOT NULL COMMENT '课程 ID',
    courseName VARCHAR(255) NOT NULL COMMENT '课程名称',
    credit INT NOT NULL COMMENT '学分',
    teacherId VARCHAR(255) NOT NULL COMMENT '授课教师 ID',
    semester VARCHAR(255) DEFAULT NULL COMMENT '学期',
    type ENUM('必修','选修') NOT NULL DEFAULT '选修',
    prerequisite VARCHAR(255) DEFAULT NULL,
    PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

3. 成绩表

CREATE TABLE scores (
    id VARCHAR(255) NOT NULL COMMENT '成绩记录 ID',
    studentId VARCHAR(255) NOT NULL COMMENT '学生 ID',
    courseId VARCHAR(255) NOT NULL COMMENT '课程 ID',
    score INT NOT NULL COMMENT '综合成绩',
    examDate DATE NOT NULL COMMENT '考试日期',
    usualScore INT DEFAULT 0 COMMENT '平时成绩',
    finalScore INT DEFAULT 0 COMMENT '期末成绩',
    PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

4. 学生表

CREATE TABLE students (
    id VARCHAR(255) NOT NULL COMMENT '学号',
    name VARCHAR(255) NOT NULL COMMENT '姓名',
    gender ENUM('男','女') NOT NULL DEFAULT '男',
    birthDate DATETIME NOT NULL COMMENT '出生日期',
    classId VARCHAR(255) NOT NULL COMMENT '班级 ID',
    phone VARCHAR(255) NOT NULL COMMENT '联系电话',
    height INT NOT NULL COMMENT '身高 (cm)',
    weight INT NOT NULL COMMENT '体重 (kg)',
    healthStatus ENUM('良好','一般','较差') NOT NULL DEFAULT '良好',
    PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

5. 教师表

CREATE TABLE teachers (
    id VARCHAR(255) NOT NULL COMMENT '教师 ID',
    name VARCHAR(255) NOT NULL COMMENT '姓名',
    gender ENUM('男','女') NOT NULL DEFAULT '男',
    subject VARCHAR(255) NOT NULL COMMENT '教授科目',
    title VARCHAR(255) NOT NULL COMMENT '职称',
    phone VARCHAR(255) NOT NULL COMMENT '联系电话',
    office VARCHAR(255) NOT NULL COMMENT '办公室位置',
    isHeadTeacher ENUM('true','false') DEFAULT 'false',
    PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

录入测试数据后，确保各表关联正常。

集成实施

安装必要插件

在 Dify 平台中，需安装两个关键插件以支持 MCP 工具发现与调用：

1. Agent 策略（支持 MCP 工具）：用于管理 Agent 行为。
2. MCP SSE：通过 HTTP with SSE 传输 MCP 协议。

配置 MCP SSE

在 Dify 插件管理界面，找到已安装的 MCP SSE 插件并点击授权。配置 MCP Server 的 SSE 地址，格式如下（注意不要留空格）：

{
  "mysql_mcp_server_pro": {
    "url": "http://<your_ip>:9000/sse"
  }
}

保存后，Dify 即可与指定的 MySQL 服务通信。

创建工作流

进入 Dify 工作流创建页面，选择类型为'Chatflow'，命名为 Dify_MySQL_Integration。

1. 删除默认的 LLM 节点，因为我们主要通过 Agent 调用工具。
2. 从节点库拖入一个'Agent'节点，这将作为核心交互组件。

配置 Agent 策略

1. 选择策略：将 Agent 策略设为 ReAct (Support MCP Tools)。相比 FunctionCalling，该策略对 MCP 工具的支持更稳定，能避免找不到 call_tool 方法的问题。
2. 添加工具：在工具列表中选择'通过 SSE 发现和调用 MCP 工具'，添加之前配置的 MySQL 服务名称（如 mysql_mcp_server）。
3. 设置指令：提示词是引导 Agent 的关键。建议包含表结构说明和查询规则。例如：

   使用中文回复。当用户提问涉及学生、教师、成绩时，使用 MySQL MCP 进行查询。表结构如下：
   # 学生管理系统数据库表结构说明
   ## 1. 教师表 (teachers)... [此处省略详细表结构，实际使用时请填入完整 schema]
   

   设置最大迭代次数为 3，防止无限循环。连接直接回复变量选 Agent.text。

搭建 MCP Server

我们需要运行一个独立的 MCP Server 来暴露 MySQL 接口。

1. 下载代码

git clone https://github.com/wenb1n-dev/mysql_mcp_server_pro.git
cd mysql_mcp_server_pro

2. 配置数据库 编辑 .env 文件，填入 MySQL 连接信息：

vi .env

3. 安装依赖

pip install mcp mysql-connector-python uvicorn python-dotenv starlette

4. 启动服务

uv run server.py

确保端口（默认 9000）未被占用且防火墙允许访问。

测试验证

完成配置后，进入工作流测试界面输入问题验证效果。

场景 1：列出身高大于等于 168cm 的所有学生 输入："列出身高大于等于 168cm 所有学生" 预期结果：Agent 生成 SQL 查询 students 表并返回符合条件的名单。

场景 2：列出体重大于等于 60kg 的学生 输入："列出体重大于等于 60kg 的学生" 预期结果：正确过滤体重字段。

场景 3：哪个学生成绩最好 输入："哪个学生成绩最好" 预期结果：关联 scores 表，按分数排序取第一条。

场景 4：总成绩最好的是哪个班级 输入："总成绩最好的是哪个班级" 预期结果：多表 JOIN 聚合计算，返回班级名称。

常见问题排查

连接失败

现象：提示'连接超时'或'无法找到服务器'。 排查：

1. 检查网络连通性，使用 ping 和 telnet <ip> 3306 测试端口。
2. 确认防火墙是否开放了 MySQL 端口（默认 3306）及 MCP Server 端口（9000）。
3. 检查 .env 中的 IP 和端口是否与实际情况一致。

工具调用错误

现象：提示'找不到工具'或'工具调用失败'。 排查：

1. 确认 Agent 策略是否为 ReAct (Support MCP Tools)。
2. 检查 MCP SSE 插件配置中的 URL 是否正确，且没有多余空格。
3. 验证 MCP Server 是否正在运行，日志是否有报错。

SQL 执行错误

现象：提示'语法错误'或'表不存在'。 排查：

1. 检查 Agent 指令中的表结构描述是否与数据库实际结构一致。
2. 确认数据库权限，确保连接账号有查询权限。
3. 查看 Dify 生成的中间 SQL 语句，分析逻辑是否符合规范。

通过以上步骤，你可以顺利实现 Dify 与 MySQL 的深度集成，利用自然语言轻松操作数据库。