Dify 集成 MySQL 实战：基于 MCP 协议的数据查询方案

设置 docker 的下载镜像代理，在 /etc/systemd/system/docker.service.d 目录新增文件 http-proxy.conf，内容如下：

[Service]
Environment="HTTP_PROXY=http://192.168.1.XXX:7897"
Environment="HTTPS_PROXY=http://192.168.1.XXX:7897"
Environment="NO_PROXY=localhost,127.0.0.1"

systemctl daemon-reload
systemctl restart docker
systemctl status docker

这样在下载镜像时就会很快。

在 Dify 项目目录下，通过 Docker Compose 来启动 Dify 服务。在终端中执行：

cp .env.example .env
docker compose up -d

验证安装是否成功：

docker compose ps

此命令会在后台启动 Dify 的所有相关服务，包括前端、后端以及必要的中间件服务。

基础配置：

启动完成后，通过浏览器访问 Dify 的前端界面，默认地址为 http://localhost:3000。首次访问时，需要进行一些基础配置，如设置管理员账号和密码等信息。

接着，配置 Dify 的服务器地址和端口。若采用默认配置，服务器地址即为 localhost，端口为 5000。若需修改，可在 Dify 项目目录下的 .env 文件中修改 API_SERVER_HOST 和 API_SERVER_PORT 等环境变量。

（三）安装与配置 MySQL

安装流程：略

准备表结构和数据：新建数据库 test。

CREATE DATABASE test CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;

1. 班级表

CREATE TABLE `classes` (
  `id` varchar(255) NOT NULL COMMENT '班级 ID',
  `className` varchar(255) NOT NULL COMMENT '班级名称',
  `grade` int NOT NULL COMMENT '年级',
  `headTeacherId` varchar(255) NOT NULL COMMENT '班主任 ID',
  `classroom` varchar(255) NOT NULL COMMENT '教室位置',
  `studentCount` int NOT NULL COMMENT '学生人数',
  `remark` varchar(255) DEFAULT NULL COMMENT '备注信息',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='班级表';

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 '选修' COMMENT '课程类型',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='课程表';

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 COMMENT='成绩表';

4. 学生表

CREATE TABLE `students` (
  `id` varchar(255) NOT NULL COMMENT '学号',
  `name` varchar(255) NOT NULL COMMENT '学生姓名',
  `gender` enum('男','女') NOT NULL DEFAULT '男' COMMENT '性别',
  `birthDate` datetime NOT NULL COMMENT '出生日期',
  `classId` varchar(255) NOT NULL COMMENT '班级 ID',
  `phone` varchar(255) NOT NULL COMMENT '联系电话',
  `email` varchar(255) NOT NULL COMMENT '电子邮箱',
  `height` int NOT NULL COMMENT '身高 (cm)',
  `weight` int NOT NULL COMMENT '体重 (kg)',
  `healthStatus` enum('良好','一般','较差') NOT NULL DEFAULT '良好' COMMENT '健康状况',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='学生表';

5. 教师表

CREATE TABLE `teachers` (
  `id` varchar(255) NOT NULL COMMENT '教师 ID',
  `name` varchar(255) NOT NULL COMMENT '教师姓名',
  `gender` enum('男','女') NOT NULL DEFAULT '男' COMMENT '性别',
  `subject` varchar(255) NOT NULL COMMENT '教授科目',
  `title` varchar(255) NOT NULL COMMENT '职称',
  `phone` varchar(255) NOT NULL COMMENT '联系电话',
  `office` varchar(255) NOT NULL COMMENT '办公室位置',
  `wechat` varchar(255) DEFAULT NULL COMMENT '微信',
  `isHeadTeacher` enum('true','false') DEFAULT 'false' COMMENT '是否为班主任',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='教师表';

录入数据示例：

INSERT INTO `teachers` VALUES ('T001','张建国','男','数学','教授','13812345678','博学楼 301','lily_teacher','true');
-- 其他数据依此类推

关键步骤：Dify 与 MySQL 的牵手过程

（一）安装必要插件

在 Dify 平台中，要实现通过 MCP 整合 MySQL，首先需要安装两个关键插件：Agent 策略（支持 MCP 工具）和 MCP SSE。

• Agent 策略集合（支持 MCP SSE 发现和调用工具）：https://github.com/junjiem/dify-plugin-agent-mcp_sse
• MCP SSE（通过 HTTP with SSE 传输使用 MCP 协议来发现和调用工具）：https://github.com/junjiem/dify-plugin-tools-mcp_sse

（二）配置 MCP SSE

插件安装完成后，需要对 MCP SSE 进行配置，以建立与 MySQL 服务的连接。具体操作如下：

在 Dify 的插件管理界面中，点击已安装的 MCP SSE 插件，点击已授权，配置上 mcp mysql server 的 sse 地址：

{
  "mysql_mcp_server_pro": {
    "url": "http://192.168.1.XXX:9000/sse"
  }
}

注：不要留空格，不然会报错。

填写完成后，点击保存。这样，Dify 就能够通过 MCP SSE 插件与指定的 MySQL 服务地址进行通信。

（三）创建 Dify 工作流

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

在工作流设计画布中，删除默认的 LLM 节点，因为我们主要通过 Agent 来调用 MySQL 相关工具。

从节点库中拖拽一个'Agent'节点到画布上。这个 Agent 节点将作为与 MySQL 交互的核心组件，负责根据用户的指令调用相应的 MCP 工具。

（四）配置 Agent 策略

1. 选择 ReAct (Support MCP Tools) 策略：点击添加的 Agent 节点，在右侧的配置面板中，将 AGENT 策略选择为'ReAct (Support MCP Tools)'。该策略对 MCP 工具的支持较为稳定。

2. 配置工具列表：在 Agent 配置面板的'工具列表'部分，点击右侧的添加按钮，选择'通过 SSE 发现和调用 MCP 工具'。然后添加与 MySQL 相关的工具列表。

建议选用性能较好的云 API 模型，避免本地部署模型导致响应过慢。

3. 配置指令：指令部分也就是提示词，它是引导 Agent 正确执行任务的关键。例如，可以设置如下指令：

使用中文回复。当用户提问中涉及学生、教师、成绩、班级、课程等实体时，需要使用 MySQL MCP 进行数据查询和操作，表结构说明如下：
...（此处省略详细表结构说明，参考原文档）...

这里的'query'变量将作为用户输入的查询内容，传递给 Agent。同时，还需要设置最大迭代次数，默认值通常为 3。最后，在'连接直接回复'部分选择变量'Agent.text'。

（五）搭建 MCP SERVER

1. 下载代码

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

2. 配置数据库

vi .env
cd mysql_mcp_server_pro/src/config

3. 配置依赖

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

4. 启动 mcp server

uv run server.py

测试与优化：让融合更完美

（一）工作流测试

完成上述配置后，就可以对创建的 Dify 工作流进行测试。

测试方式：进入 Dify 的工作流测试界面，在输入框中输入实际的查询问题，例如'哪个老师学生最多'。

工作原理：Agent 节点根据配置的指令和策略，识别出这是一个需要查询 MySQL 数据库的任务，然后通过 MCP 协议调用相应的 MySQL 工具。该工具将问题转化为 SQL 查询语句，并发送到 MySQL 数据库进行执行。

结果查看：MySQL 数据库执行查询后，将结果返回给 Dify 工作流中的 Agent 节点，Agent 节点再通过'连接直接回复'中的变量返回给用户。

测试用例

1. 列出身高大于等于 168cm 所有学生：符合预期。
2. 列出体重大于等于 60kg 的学生：符合预期。
3. 哪个学生成绩最好：符合预期。
4. 总成绩最好的是哪个班级：符合预期。

常见问题与解决方案：排忧解难

（一）连接失败

错误描述：Dify 无法成功连接到 MySQL，可能提示'连接超时'或'无法找到服务器'。

可能原因：网络不通、防火墙阻止、地址或端口错误、MySQL 服务未正常运行。

解决方案：检查网络和防火墙，确认地址和端口，检查 MySQL 服务状态。

（二）工具调用错误

错误描述：调用 MySQL 相关工具时，提示'找不到工具'或'工具调用失败'。

可能原因：插件安装或配置问题、策略选择不当、工具列表配置错误。

解决方案：检查插件安装和配置，选择正确的策略（ReAct），核对工具列表配置。

（三）SQL 执行错误

错误描述：返回的结果提示 SQL 执行错误，如'语法错误''表不存在'。

可能原因：提示词或指令问题、数据库结构变化。

解决方案：优化提示词和指令，同步数据库结构信息。