文章目录

解锁Dify与MySQL的深度融合：MCP魔法开启数据新旅程
- 引言：技术融合的奇妙开篇
- 认识主角：Dify、MCP 与 MySQL
- - （一）Dify：大语言模型应用开发利器
  - （二）MCP：连接的桥梁
  - （三）MySQL：经典数据库
- 准备工作：搭建融合舞台
- - （一）环境搭建
  - （二）安装与配置 Dify
  - （三）安装与配置 MySQL
- 关键步骤：Dify 与 MySQL 的牵手过程
- - （一）安装必要插件
  - （二）配置 MCP SSE
  - （三）创建 Dify 工作流
  - （四）配置 Agent 策略
  - （五）搭建MCP SERVER
  - - 1.下载代码
    - 2.配置数据库
    - 3.配置依赖
    - 4.启动 mcp server
- 测试与优化：让融合更完美
- - （一）工作流测试
  - - 测试1.列出身高大于等于168cm所有学生
    - 测试2. 列出体重大于等于60kg的学生
    - 测试3. 哪个学生成绩最好
    - 测试4. 总成绩最好的是哪个班级
- 常见问题与解决方案：排忧解难
- - （一）连接失败
  - （二）工具调用错误
  - （三）SQL 执行错误

解锁Dify与MySQL的深度融合：MCP魔法开启数据新旅程

引言：技术融合的奇妙开篇

在当今数字化时代，数据管理与人工智能技术的融合日益紧密。Dify 作为一款强大的大语言模型应用开发平台，通过 MCP（模型上下文协议）与 MySQL 这一广泛使用的关系型数据库进行整合，为开发者们打开了一扇通往高效数据处理与智能应用开发的新大门。这种整合不仅能充分发挥 Dify 在自然语言处理和 AI 应用构建方面的优势，还能借助 MySQL 出色的数据存储和管理能力，实现更复杂、更智能的数据驱动型应用开发，极大地拓展了应用的功能边界和实用性。接下来，就让我们深入探索 Dify 通过 MCP 整合 MySQL 的详细过程与技术细节。

认识主角：Dify、MCP 与 MySQL

（一）Dify：大语言模型应用开发利器

Dify 是一款极具创新性的开源大语言模型（LLM）应用开发平台，它将后端即服务（Backend as Service, BaaS）与 LLMOps 理念巧妙融合，为开发者打造了一个便捷高效的 AI 应用开发环境。其低代码 / 无代码开发模式堪称一大亮点，通过直观的可视化界面，开发者只需简单的拖拽和配置操作，就能轻松定义 Prompt（提示词）、上下文以及插件等关键要素，无需在底层技术细节中耗费过多精力，这使得开发门槛大幅降低，即使是编程经验相对较少的人员也能参与到 AI 应用的开发中来。

Dify 还采用了模块化设计，各个模块功能明确、接口清晰，开发者可以根据具体的项目需求，灵活选择并组合使用这些模块，从而构建出高度个性化的 AI 应用。在功能组件方面，Dify 更是提供了丰富多样的选择，涵盖 AI 工作流、RAG 管道、Agent、模型管理等多个领域，全面支持从应用原型设计到实际生产部署的整个过程。同时，Dify 对多种主流大型语言模型提供了良好的支持，包括 OpenAI 的 GPT 系列、Claude3 等，开发者可以根据应用场景和性能要求，自由选择最契合的模型，进一步提升应用的智能水平和适应性。

（二）MCP：连接的桥梁

MCP，即模型上下文协议（Model Context Protocol），在 Dify 与 MySQL 的整合中扮演着至关重要的桥梁角色。作为一项新兴的开放协议，MCP 为大语言模型与外部应用之间搭建了一条双向通信通道，宛如 AI 世界里的 “USB-C” 接口，让模型能够便捷地发现、理解并安全调用各种外部工具或 API。

在 Dify 通过 MCP 整合 MySQL 的场景中，MCP 主要发挥了两方面关键作用。一方面，它提供了统一的协议支持，使得 Dify 中的大语言模型能够以标准化的方式与 MySQL 进行交互，避免了因不同数据库接口差异而带来的复杂适配工作。另一方面，MCP 还具备强大的工具调用能力，允许 Dify 根据用户的需求和指令，动态地调用 MySQL 相关的工具和功能，实现对数据库中数据的查询、更新、插入等操作，从而将大语言模型的智能处理能力与 MySQL 的数据存储和管理能力紧密结合起来，为开发者创造出更多的应用可能性。

（三）MySQL：经典数据库

MySQL 作为一款开源的关系型数据库管理系统，在数据存储和管理领域拥有着广泛的应用和卓越的声誉。它具备众多显著的优势，使其成为了众多企业和开发者的首选数据库之一。

MySQL 以其高度的可靠性和稳定性著称，经过长时间的发展和大规模应用的验证，它能够在各种复杂的环境下稳定运行，确保数据的安全存储和可靠访问，无论是面对小规模的个人项目，还是大规模的企业级应用，MySQL 都能从容应对。在性能方面，MySQL 表现出色，采用了高效的索引和查询优化技术，能够快速处理大规模数据和高并发的访问请求，迅速响应用户的查询和操作指令，为应用提供流畅的运行体验。此外，MySQL 还具备出色的可扩展性，支持水平和垂直扩展，能够根据业务的发展和数据量的增长，灵活地进行部署和配置调整，满足不断变化的业务需求。同时，MySQL 丰富的生态系统也为开发者提供了便利，大量的开源工具、第三方插件和扩展可供选择，进一步增强了其功能和应用场景。

准备工作：搭建融合舞台

（一）环境搭建

在开始整合 Dify 与 MySQL 之前，需要确保开发环境准备就绪。主要涉及 Python 环境以及相关插件的安装，建议使用 Python 3.8 及以上版本，以确保与后续安装的库和工具具有良好的兼容性。同时，为了实现 Dify 与 MySQL 之间基于 MCP 的通信和数据交互，还需要安装一些关键的插件和依赖库。例如，用于支持 MCP 协议的相关插件，以及能够实现 Dify 与 MySQL 进行连接和数据操作的数据库驱动插件等，具体版本可根据官方文档和实际测试来确定，以保障系统的稳定性和功能的完整性。

（二）安装与配置 Dify

安装步骤：

首先，通过官方 GitHub 仓库获取 Dify 的源代码。打开终端，执行以下命令进行克隆：

git clone https://github.com/langgenius/dify.git --branch 1.1.0

安装过程需要依赖 Docker 和 Docker Compose，若尚未安装，需先完成这两个工具的安装。在 rocky 9.5 系统上，安装 Docker 的命令如下：

# 先开 外网代理export http_proxy="http://192.168.1.xxx:7897"export https_proxy="http://192.168.1.xxx:7897"export no_proxy="localhost,127.0.0.1"#更新dnf源
dnf update
# 搜索docker 镜像
dnf search docker #添加 docker安装包仓库dnf -y install dnf-plugins-corednf config-manager --add-repo https://download.docker.com/linux/rhel/docker-ce.repo#安装docker  compose
sudo dnf install docker-ce docker-ce-cli containerd.io docker-buildx-plugin docker-compose-plugin
#docker 设置为开机自启动
sudo systemctl enable --now docker

设置 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 .envdocker compose up -d# 验证安装是否成功
(base) [root@localhost docker]# pwd
/root/dify/docker
(base) [root@localhost docker]# docker compose ps
NAME                     IMAGE                                       COMMAND                   SERVICE         CREATED        STATUS                  PORTS
docker-api-1             langgenius/dify-api:1.2.0                   "/bin/bash /entrypoi…"   api             25 hours ago   Up 25 hours             5001/tcp
docker-db-1              postgres:15-alpine                          "docker-entrypoint.s…"   db              25 hours ago   Up 25 hours (healthy)   5432/tcp
docker-nginx-1           nginx:latest                                "sh -c 'cp /docker-e…"   nginx           25 hours ago   Up 25 hours             0.0.0.0:80->80/tcp, :::80->80/tcp, 0.0.0.0:443->443/tcp, :::443->443/tcp
docker-plugin_daemon-1   langgenius/dify-plugin-daemon:0.0.7-local   "/bin/bash -c /app/e…"   plugin_daemon   25 hours ago   Up 25 hours             0.0.0.0:5003->5003/tcp, :::5003->5003/tcp
docker-redis-1           redis:6-alpine                              "docker-entrypoint.s…"   redis           25 hours ago   Up 25 hours (healthy)   6379/tcp
docker-sandbox-1         langgenius/dify-sandbox:0.2.11              "/main"                   sandbox         25 hours ago   Up 25 hours (healthy)   
docker-ssrf_proxy-1      ubuntu/squid:latest                         "sh -c 'cp /docker-e…"   ssrf_proxy      25 hours ago   Up 25 hours             3128/tcp
docker-weaviate-1        semitechnologies/weaviate:1.19.0            "/bin/weaviate --hos…"   weaviate        25 hours ago   Up 25 hours             
docker-web-1             langgenius/dify-web:1.2.0                   "/bin/sh ./entrypoin…"   web             25 hours ago   Up 25 hours             3000/tcp
docker-worker-1          langgenius/dify-api:1.2.0                   "/bin/bash /entrypoi…"   worker          25 hours ago   Up 25 hours             5001/tcp
(base) [root@localhost docker]#

此命令会在后台启动 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) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '班级ID，示例：202301',`className` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '班级名称，示例：2023级计算机1班',`grade` int NOT NULL COMMENT '年级，示例：2023',`headTeacherId` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '班主任ID，外键(teachers.id)，示例：T003',`classroom` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '教室位置，示例：1号楼302',`studentCount` int NOT NULL COMMENT '学生人数，示例：35',`remark` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '备注信息，示例：市级优秀班集体',PRIMARY KEY (`id`),KEY `headTeacherId` (`headTeacherId`),CONSTRAINT `headTeacherId` FOREIGN KEY (`headTeacherId`) REFERENCES `teachers` (`id`) ON DELETE CASCADE ON UPDATE CASCADE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='班级表';

2.课程表

CREATE TABLE `courses` (`id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '课程ID，示例：C001',`courseName` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '课程名称，示例：高等数学',`credit` int NOT NULL COMMENT '学分，示例：4',`teacherId` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '授课教师ID，外键(teachers.id)，示例：T001',`semester` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '学期，格式"YYYY-N"，示例：2023-1',`type` enum('必修','选修') CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '选修' COMMENT '课程类型，"必修"或"选修"，示例：选修',`prerequisite` varchar(255) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '先修课程ID，可选，外键(courses.id)，示例：C003',PRIMARY KEY (`id`),KEY `teacherId` (`teacherId`),CONSTRAINT `teacherId` FOREIGN KEY (`teacherId`) REFERENCES `teachers` (`id`) ON DELETE CASCADE ON UPDATE CASCADE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='课程表';

3.成绩表

CREATE TABLE `scores` (`id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '成绩记录ID，示例：S20230101C001',`studentId` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '学生ID，外键(students.id)，示例：S20230101',`courseId` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '课程ID，外键(courses.id)，示例：C001',`score` int NOT NULL COMMENT '综合成绩，0-100，示例：85',`examDate` date NOT NULL COMMENT '考试日期，示例：2024-5-20',`usualScore` int DEFAULT '0' COMMENT '平时成绩，0-100，示例：90',`finalScore` int DEFAULT '0' COMMENT '期末成绩，0-100，示例：80',PRIMARY KEY (`id`),KEY `studentId` (`studentId`),KEY `courseId` (`courseId`),CONSTRAINT `courseId` FOREIGN KEY (`courseId`) REFERENCES `courses` (`id`) ON DELETE CASCADE ON UPDATE CASCADE,CONSTRAINT `studentId` FOREIGN KEY (`studentId`) REFERENCES `students` (`id`) ON DELETE CASCADE ON UPDATE CASCADE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='成绩表';

4.学生表

CREATE TABLE `students` (`id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '学号，示例：S20230101',`name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '学生姓名，示例：王强',`gender` enum('男','女') CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '男' COMMENT '性别，"男"或"女"，示例：男',`birthDate` datetime NOT NULL COMMENT '出生日期，示例：2005-01-15',`classId` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '班级ID，外键(classes.id)，示例：202301',`phone` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '联系电话，示例：13812345678',`email` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '电子邮箱，示例：20230101@school.edu.cn',`emergencyContact` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '紧急联系人电话，示例：13876543210',`address` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '家庭住址，示例：北京市海淀区中关村大街1栋101室',`height` int NOT NULL COMMENT '身高(cm)，示例：175',`weight` int NOT NULL COMMENT '体重(kg)，示例：65',`healthStatus` enum('良好‌','一般‌','较差') CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '良好‌' COMMENT '健康状况，示例：良好',PRIMARY KEY (`id`),KEY `classId` (`classId`),CONSTRAINT `classId` FOREIGN KEY (`classId`) REFERENCES `classes` (`id`) ON DELETE CASCADE ON UPDATE CASCADE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='学生表';

5.教师表

CREATE TABLE `teachers` (`id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '教师ID，示例：T001',`name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '教师姓名，示例：张建国',`gender` enum('男','女') CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '男' COMMENT '性别，"男"或"女"，示例：男',`subject` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '教授科目，示例：数学',`title` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '职称，示例：教授',`phone` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '联系电话，示例：13812345678',`office` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '办公室位置，示例：博学楼301',`wechat` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '微信，示例：lily_teacher',`isHeadTeacher` enum('true','false') CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT 'false' COMMENT '是否为班主任，示例：true',PRIMARY KEY (`id`,`office`) USING BTREE,KEY `id` (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='教师表';

录入数据

插入 teachers 表数据

INSERT INTO `teachers` (`id`, `name`, `gender`, `subject`, `title`, `phone`, `office`, `wechat`, `isHeadTeacher`) VALUES
('T001', '张建国', '男', '数学', '教授', '13812345678', '博学楼301', 'lily_teacher', 'true'),
('T002', '李明', '男', '英语', '副教授', '13812345679', '博学楼302', 'tom_teacher', 'false'),
('T003', '王芳', '女', '物理', '讲师', '13812345680', '博学楼303', 'lucy_teacher', 'true'),
('T004', '赵强', '男', '化学', '副教授', '13812345681', '博学楼304', 'jack_teacher', 'false'),
('T005', '陈静', '女', '计算机', '教授', '13812345682', '博学楼305', 'rose_teacher', 'true'),
('T006', '刘伟', '男', '语文', '讲师', '13812345683', '博学楼306', 'mike_teacher', 'false'),
('T007', '黄丽', '女', '历史', '副教授', '13812345684', '博学楼307', 'jane_teacher', 'true'),
('T008', '周明', '男', '地理', '讲师', '13812345685', '博学楼308', 'ben_teacher', 'false'),
('T009', '吴芳', '女', '生物', '教授', '13812345686', '博学楼309', 'susan_teacher', 'true'),
('T010', '郑强', '男', '政治', '副教授', '13812345687', '博学楼310', 'david_teacher', 'false');

插入 classes 表数据

INSERT INTO `classes` (`id`, `className`, `grade`, `headTeacherId`, `classroom`, `studentCount`, `remark`) VALUES
('202301', '2023级计算机1班', 2023, 'T005', '1号楼302', 35, '市级优秀班集体'),
('202302', '2023级数学1班', 2023, 'T001', '1号楼303', 32, '校级优秀班集体'),
('202303', '2023级英语1班', 2023, 'T002', '1号楼304', 30, NULL),
('202304', '2023级物理1班', 2023, 'T003', '1号楼305', 34, '校级先进班集体'),
('202305', '2023级化学1班', 2023, 'T004', '1号楼306', 31, NULL),
('202201', '2022级计算机1班', 2022, 'T005', '1号楼402', 36, '市级优秀班集体'),
('202202', '2022级数学1班', 2022, 'T001', '1号楼403', 33, NULL),
('202203', '2022级英语1班', 2022, 'T002', '1号楼404', 32, '校级优秀班集体'),
('202204', '2022级物理1班', 2022, 'T003', '1号楼405', 30, NULL),
('202205', '2022级化学1班', 2022, 'T004', '1号楼406', 35, '市级先进班集体');

插入 students 表数据

INSERT INTO `students` (`id`, `name`, `gender`, `birthDate`, `classId`, `phone`, `email`, `emergencyContact`, `address`, `height`, `weight`, `healthStatus`) VALUES
('S20230101', '王强', '男', '2005-01-15 00:00:00', '202301', '13812345678', '20230101@school.edu.cn', '13876543210', '北京市海淀区中关村大街1栋101室', 175, 65, '良好'),
('S20230102', '李华', '女', '2005-02-20 00:00:00', '202301', '13812345679', '20230102@school.edu.cn', '13876543211', '上海市浦东新区张江高科技园区2栋201室', 165, 55, '良好'),
('S20230201', '张明', '男', '2005-03-10 00:00:00', '202302', '13812345680', '20230201@school.edu.cn', '13876543212', '广州市天河区珠江新城3栋301室', 180, 70, '良好'),
('S20230202', '刘芳', '女', '2005-04-05 00:00:00', '202302', '13812345681', '20230202@school.edu.cn', '13876543213', '深圳市南山区科技园4栋401室', 168, 58, '良好'),
('S20230301', '陈伟', '男', '2005-05-15 00:00:00', '202303', '13812345682', '20230301@school.edu.cn', '13876543214', '南京市玄武区珠江路5栋501室', 178, 68, '良好'),
('S20230302', '赵丽', '女', '2005-06-20 00:00:00', '202303', '13812345683', '20230302@school.edu.cn', '13876543215', '杭州市西湖区文三路6栋601室', 162, 52, '良好'),
('S20230401', '黄强', '男', '2005-07-10 00:00:00', '202304', '13812345684', '20230401@school.edu.cn', '13876543216', '成都市高新区天府软件园7栋701室', 176, 66, '良好'),
('S20230402', '周静', '女', '2005-08-05 00:00:00', '202304', '13812345685', '20230402@school.edu.cn', '13876543217', '武汉市洪山区光谷广场8栋801室', 167, 57, '良好'),
('S20230501', '吴伟', '男', '2005-09-15 00:00:00', '202305', '13812345686', '20230501@school.edu.cn', '13876543218', '西安市雁塔区科技路9栋901室', 177, 67, '良好'),
('S20230502', '郑芳', '女', '2005-10-20 00:00:00', '202305', '13812345687', '20230502@school.edu.cn', '13876543219', '长沙市岳麓区麓谷大道10栋1001室', 163, 53, '良好');

插入 courses 表数据

INSERT INTO `courses` (`id`, `courseName`, `credit`, `teacherId`, `semester`, `type`, `prerequisite`) VALUES
('C001', '高等数学', 4, 'T001', '2023-1', '必修', NULL),
('C002', '大学英语', 3, 'T002', '2023-1', '必修', NULL),
('C003', '大学物理', 4, 'T003', '2023-1', '必修', NULL),
('C004', '大学化学', 3, 'T004', '2023-1', '必修', NULL),
('C005', '计算机基础', 3, 'T005', '2023-1', '必修', NULL),
('C006', '数据结构', 4, 'T005', '2023-2', '选修', 'C005'),
('C007', '线性代数', 3, 'T001', '2023-2', '选修', 'C001'),
('C008', '概率论与数理统计', 4, 'T001', '2023-2', '选修', 'C001'),
('C009', '英语口语', 2, 'T002', '2023-2', '选修', 'C002'),
('C010', '物理实验', 2, 'T003', '2023-2', '选修', 'C003');

插入 scores 表数据

INSERT INTO `scores` (`id`, `studentId`, `courseId`, `score`, `examDate`, `usualScore`, `finalScore`) VALUES
('S20230101C001', 'S20230101', 'C001', 85, '2024-05-20', 90, 80),
('S20230101C002', 'S20230101', 'C002', 90, '2024-05-20', 85, 95),
('S20230101C005', 'S20230101', 'C005', 95, '2024-05-20', 92, 98),
('S20230201C001', 'S20230201', 'C001', 88, '2024-05-20', 87, 90),
('S20230201C003', 'S20230201', 'C003', 82, '2024-05-20', 80, 85),
('S20230301C002', 'S20230301', 'C002', 87, '2024-05-20', 85, 90),
('S20230301C004', 'S20230301', 'C004', 80, '2024-05-20', 78, 82),
('S20230401C003', 'S20230401', 'C003', 86, '2024-05-20', 84, 88),
('S20230401C005', 'S20230401', 'C005', 92, '2024-05-20', 90, 94),
('S20230501C004', 'S20230501', 'C004', 84, '2024-05-20', 82, 86);

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

（一）安装必要插件

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

Agent 策略集合（支持 MCP SSE 发现和调用工具）
github地址：https://github.com/junjiem/dify-plugin-agent-mcp_sse

通过 HTTP with SSE 传输使用 MCP 协议来发现和调用工具。
github地址：https://github.com/junjiem/dify-plugin-tools-mcp_sse
在这里插入图片描述

（二）配置 MCP SSE

插件安装完成后，需要对 MCP SSE 进行配置，以建立与 MySQL 服务的连接。具体操作如下：
在 Dify 的插件管理界面中，点击已安装的 MCP SSE 插件。
在这里插入图片描述
点击上图中的已授权，出现如下图，配置上mcp mysq server的sse 地址：

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

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

在这里插入图片描述

填写完成后，点击保存。这样，Dify 就能够通过 MCP SSE 插件与指定的 MySQL 服务地址进行通信，为后续的数据交互做好准备。

（三）创建 Dify 工作流

接下来，需要在 Dify 中创建一个工作流，用于实现与 MySQL 的交互逻辑。创建过程如下：

进入 Dify 的工作流创建页面，选择创建工作流类型为 “Chatflow”，并为工作流命名，例如 “Dify_MySQL_Integration” 。
在这里插入图片描述

在工作流设计画布中，默认会有一个 LLM 节点，但在我们的场景中，需要删除该节点，因为我们主要通过 Agent 来调用 MySQL 相关工具。
在这里插入图片描述

从节点库中拖拽一个 “Agent” 节点到画布上。这个 Agent 节点将作为与 MySQL 交互的核心组件，负责根据用户的指令调用相应的 MCP 工具，实现对 MySQL 数据库的操作。此时，一个基本的工作流框架就搭建好了，后续还需要对 Agent 进行详细配置。

（四）配置 Agent 策略

1.选择 ReAct (Support MCP Tools) 策略：点击添加的 Agent 节点，在右侧的配置面板中，将 AGENT 策略选择为 “ReAct (Support MCP Tools)” 。选择该策略的原因在于它对 MCP 工具的支持较为稳定和有效。例如，在实际测试中，若选择 FunctionCalling 策略，可能会遇到调用 MCP 时提示找不到 call_tool 方法的问题，而 ReAct 策略能够避免此类问题，确保 Agent 能够顺利调用 MCP 工具与 MySQL 进行交互。
在这里插入图片描述

2.配置工具列表：在 Agent 配置面板的 “工具列表” 部分，点击右侧的添加按钮，选择 “通过 SSE 发现和调用 MCP 工具” 。然后添加与 MySQL 相关的工具列表，假设之前在 MCP SSE 中配置的 MySQL 服务地址对应的名称为 “mysql_mcp_server”，则在 MCP 服务器配置中添加：

在这里插入图片描述
注：要选择对应模型：
我原来选择我本地部署的deepseek:14B ，非常慢，导致达不到预想的结果，后面改成用阿里百炼云的API 模型，效果杆杆的。
通过这样的配置，Agent 就能够识别并调用与该 MySQL 服务相关的工具，实现对数据库的查询、更新等操作。

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

使用中文回复。当用户提问中涉及学生、教师、成绩、班级、课程等实体时，需要使用 MySQL MCP 进行数据查询和操作，表结构说明如下：# 学生管理系统数据库表结构说明## 1. 教师表 (teachers)| 字段名 | 类型 | 描述 | 约束 | 示例 |
|--------|------|------|------|------|
| id | varchar | 教师ID | 主键 | "T001" |
| name | varchar | 教师姓名 | 必填 | "张建国" |
| gender | enum | 性别 | "男"或"女" | "男" |
| subject | varchar | 教授科目 | 必填 | "数学" |
| title | varchar | 职称 | 必填 | "教授" |
| phone | varchar | 联系电话 | 必填 | "13812345678" |
| office | varchar | 办公室位置 | 必填 | "博学楼301" |
| wechat | varchar | 微信(可选) | 可选 | "lily_teacher" |
| isHeadTeacher | enum | 是否为班主任，"true"或"false" | 可选 | true |## 2. 班级表 (classes)| 字段名 | 类型 | 描述 | 约束 | 示例 |
|--------|------|------|------|------|
| id | varchar | 班级ID | 主键 | "202301" |
| className | varchar | 班级名称 | 必填 | "2023级计算机1班" |
| grade | int | 年级 | 必填 | 2023 |
| headTeacherId | varchar | 班主任ID | 外键(teachers.id) | "T003" |
| classroom | varchar | 教室位置 | 必填 | "1号楼302" |
| studentCount | int | 学生人数 | 必填 | 35 |
| remark | varchar | 备注信息 | 可选 | "市级优秀班集体" |## 3. 课程表 (courses)| 字段名 | 类型 | 描述 | 约束 | 示例 |
|--------|------|------|------|------|
| id | varchar | 课程ID | 主键 | "C001" |
| courseName | varchar | 课程名称 | 必填 | "高等数学" |
| credit | int | 学分 | 必填 | 4 |
| teacherId | varchar | 授课教师ID | 外键(teachers.id) | "T001" |
| semester | varchar | 学期 | 格式"YYYY-N" | "2023-1" |
| type | enum | 课程类型 | "必修"或"选修" | "必修" |
| prerequisite | varchar | 先修课程ID | 可选,外键(courses.id) | "C003" |## 4. 学生表 (students)| 字段名 | 类型 | 描述 | 约束 | 示例 |
|--------|------|------|------|------|
| id | varchar | 学号 | 主键 | "S20230101" |
| name | varchar | 学生姓名 | 必填 | "王强" |
| gender | enum | 性别 | "男"或"女" | "男" |
| birthDate | date | 出生日期 | 必填 | date("2005-01-15") |
| enrollmentDate | date | 入学日期 | 必填 | date("2023-8-1") |
| classId | varchar | 班级ID | 外键(classes.id) | "202301" |
| phone | varchar | 联系电话 | 必填 | "13812345678" |
| email | varchar | 电子邮箱 | 必填 | "20230101@school.edu.cn" |
| emergencyContact | varchar | 紧急联系人电话 | 必填 | "13876543210" |
| address | varchar | 家庭住址 | 必填 | "北京市海淀区中关村大街1栋101室" |
| height | int | 身高(cm) | 必填 | 175 |
| weight | int | 体重(kg) | 必填 | 65 |
| healthStatus | enum | 健康状况 | 必填，"良好"或"一般‌"或"较差" | "良好" |## 5. 成绩表 (scores)| 字段名 | 类型 | 描述 | 约束 | 示例 |
|--------|------|------|------|------|
| id | varchar | 成绩记录ID | 主键 | "S20230101C001" |
| studentId | varchar | 学生ID | 外键(students.id) | "S20230101" |
| courseId | varchar | 课程ID | 外键(courses.id) | "C001" |
| score | int | 综合成绩 | 0-100 | 85 |
| examDate | date | 考试日期 | 必填 | date("2024-5-20") |
| usualScore | int | 平时成绩 | 0-100 | 90 |
| finalScore | int | 期末成绩 | 0-100 | 80 |### 补考成绩记录说明
补考记录在_id后添加"_M"后缀，如"S20230101C001_M"## 表关系说明1. **一对多关系**:- 一个班级(classes)对应多个学生(students)- 一个教师(teachers)可以教授多门课程(courses)- 一个学生(students)有多条成绩记录(scores)2. **外键约束**:- students.classId → classes.id- courses.teacherId → teachers.id- scores.studentId → students.id- scores.courseId → courses.id- classes.headTeacherId → teachers.id

这里的 “query” 变量将作为用户输入的查询内容，传递给 Agent，Agent 根据这个变量的值调用相应的 MySQL 工具进行查询操作。同时，还需要设置最大迭代次数，该参数用于控制工具调用的深度和复杂性，防止出现无限循环或过度调用工具的情况，避免资源浪费和系统性能问题，默认值通常为 3，可根据实际需求进行调整。最后，在 “连接直接回复” 部分选择变量 “Agent.text”，这样 Agent 执行任务后的结果将通过该变量直接回复给用户。完成上述配置后，点击发布预览，一个能够通过 MCP 与 MySQL 进行整合的 Dify 工作流就配置完成了。

（五）搭建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 工作流进行测试，以验证其是否能够正确地与 MySQL 进行整合并实现预期的功能。

测试方式：进入 Dify 的工作流测试界面，在输入框中输入实际的查询问题，例如 “哪个老师学生最多” 。这个问题看似简单，却涉及到对数据库中教师与学生关系数据的查询和分析。Dify 工作流接收到这个问题后，会触发之前配置好的 Agent 节点。

工作原理：Agent 节点根据配置的指令和策略，识别出这是一个需要查询 MySQL 数据库的任务，然后通过 MCP 协议调用相应的 MySQL 工具。该工具将问题转化为 SQL 查询语句，并发送到 MySQL 数据库进行执行。假设数据库中存储教师和学生信息的表分别为teachers和students，且students表中有一个字段teacher_id用于关联teachers表，那么生成的 SQL 查询语句可能类似于：

SELECT teachers.teacher_name, COUNT(students.student_id) AS student_countFROM teachersJOIN students ON teachers.teacher_id = students.teacher_idGROUP BY teachers.teacher_nameORDER BY student_count DESCLIMIT 1;

结果查看：MySQL 数据库执行查询后，将结果返回给 Dify 工作流中的 Agent 节点，Agent 节点再将结果按照之前配置的格式和变量，通过 “连接直接回复” 中的Agent.text变量返回给用户。用户在 Dify 的工作流测试界面中就能看到查询结果，例如 “教师 [具体教师姓名] 的学生最多，共有 [X] 名学生” 。通过这样的测试过程，可以直观地验证 Dify 与 MySQL 的整合是否成功，以及工作流的配置是否正确。如果测试过程中出现问题，如查询结果为空、报错等，就需要仔细检查工作流的配置、SQL 语句的正确性以及数据库的连接和权限设置等方面，逐步排查并解决问题。

测试1.列出身高大于等于168cm所有学生

原数据如下：
在这里插入图片描述
大模型回答的结果：

在这里插入图片描述
符合预期。

测试2. 列出体重大于等于60kg的学生

在这里插入图片描述

符合预期。

测试3. 哪个学生成绩最好

在这里插入图片描述

符合预期。

测试4. 总成绩最好的是哪个班级

在这里插入图片描述
符合预期。

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

在 Dify 通过 MCP 整合 MySQL 的过程中，可能会遇到一些常见问题，下面为大家一一列举并提供相应的解决方案。

（一）连接失败

错误描述：在配置 MCP SSE 连接 MySQL 服务地址后，Dify 无法成功连接到 MySQL，可能提示 “连接超时” 或 “无法找到服务器” 等错误信息。

可能原因：

网络问题：MySQL 服务器与 Dify 所在的服务器之间网络不通，可能是由于防火墙阻止了连接，或者网络配置错误。例如，MySQL 服务器的防火墙未开放 Dify 连接所需的端口（默认为 3306），导致 Dify 无法建立连接。

地址或端口错误：在配置 MCP SSE 的 MySQL 服务地址和端口时，填写错误。如将 IP 地址写错，或者端口号与 MySQL 实际监听的端口不一致。

MySQL 服务未正常运行：MySQL 服务器端的服务可能未启动，或者在运行过程中出现异常停止，导致无法响应 Dify 的连接请求。

解决方案：

检查网络和防火墙：在 MySQL 服务器上，检查防火墙设置，确保 Dify 所在服务器的 IP 地址能够访问 MySQL 的端口。在 Linux 系统中，若使用的是 ufw 防火墙，可通过sudo ufw allow 3306命令开放 3306 端口（假设 MySQL 使用默认端口）。对于 CentOS 系统，使用firewall - cmd --zone = public --add - port = 3306/tcp --permanent命令添加端口规则，并执行sudo firewall - cmd --reload使规则生效。同时，可使用ping命令测试两台服务器之间的网络连通性，使用telnet命令测试端口是否可访问，如telnet mysql_server_ip 3306 。

确认地址和端口：仔细检查 MCP SSE 配置中填写的 MySQL 服务地址和端口，确保与 MySQL 服务器的实际配置一致。可登录 MySQL 服务器，查看 MySQL 配置文件（通常是my.cnf或my.ini），确认bind - address和port参数的设置。

检查 MySQL 服务状态：在 MySQL 服务器上，使用sudo systemctl status mysql命令检查 MySQL 服务是否正在运行。若服务未运行，可使用sudo systemctl start mysql命令启动服务。如果服务启动失败，查看 MySQL 的错误日志（通常位于/var/log/mysql/error.log），根据日志信息排查具体原因，如数据库文件损坏、配置错误等。

（二）工具调用错误

错误描述：在 Dify 工作流中，配置好 Agent 策略和工具列表后，调用 MySQL 相关工具时，提示 “找不到工具” 或 “工具调用失败” 等错误。

可能原因：

插件安装或配置问题：Agent 策略 (支持 MCP 工具) 和 MCP SSE 插件可能未正确安装，或者在插件配置过程中出现错误。例如，MCP SSE 插件的 sse 地址配置错误，导致无法正确发现和调用 MySQL 工具。

策略选择不当：在 Agent 配置中，选择的 AGENT 策略与 MCP 工具不兼容。如前文提到的，若选择 FunctionCalling 策略，可能会遇到调用 MCP 时提示找不到 call_tool 方法的问题。

工具列表配置错误：在 Agent 的工具列表中，MCP 服务器地址配置错误，或者未正确添加与 MySQL 相关的工具。

解决方案：

检查插件安装和配置：在 Dify 的插件管理界面，确认 Agent 策略 (支持 MCP 工具) 和 MCP SSE 插件已成功安装。对于 MCP SSE 插件，点击插件进入配置页面，检查添加的 sse 地址是否正确。若有多个 MCP 应用，确保每个应用的地址和配置都准确无误。可参考前文安装插件时的步骤和配置示例，重新核对配置信息。

选择正确的策略：将 Agent 的 AGENT 策略选择为 “ReAct (Support MCP Tools)”，该策略对 MCP 工具的支持较为稳定。避免使用可能存在兼容性问题的策略，如 FunctionCalling 策略。

核对工具列表配置：在 Agent 的工具列表配置中，仔细检查 MCP 服务器地址的配置，确保与 MCP SSE 插件中配置的地址一致。同时，确认已正确添加与 MySQL 相关的工具，可参考前文工作流配置中工具列表的添加步骤和示例，重新添加或修改工具列表。

（三）SQL 执行错误

错误描述：在 Dify 工作流测试时，输入查询问题后，返回的结果提示 SQL 执行错误，如 “语法错误”“表不存在” 等。

可能原因：

提示词或指令问题：在 Agent 配置的指令（提示词）中，对用户输入的解析和转换为 SQL 语句的逻辑存在问题，导致生成的 SQL 语句语法错误。例如，指令中对变量的引用错误，或者对查询条件的描述不清晰，使得生成的 SQL 语句无法正确执行。

数据库结构变化：MySQL 数据库中的表结构发生了变化，如字段名称修改、表被删除等，但 Dify 工作流中的配置和查询逻辑未及时更新，导致查询时提示 “表不存在” 或 “未知列” 等错误。

解决方案：

优化提示词和指令：仔细检查 Agent 配置中的指令，确保其能够准确地将用户输入转换为正确的 SQL 语句。可参考一些 SQL 生成的示例和规则，对指令进行优化和调试。例如，在指令中明确变量的使用方式和查询条件的表达，如 “使用中文回复。查询学生表中成绩大于变量 score 的学生信息，变量 score 由用户输入” 。同时，在工作流测试时，逐步分析用户输入和生成的 SQL 语句之间的转换过程，找出问题所在并进行修正。

同步数据库结构信息：定期检查 MySQL 数据库的结构变化，当数据库结构发生改变时，及时更新 Dify 工作流中的相关配置和查询逻辑。可以建立数据库结构变更的通知机制，确保开发人员能够及时了解数据库的变化情况。在 Dify 工作流中，根据新的数据库结构，修改查询语句中的表名、字段名等信息，以保证查询的正确性。例如，若 “students” 表被重命名为 “student_information”，则需要在 Dify 工作流的查询语句中相应地修改表名。通过对这些常见问题的分析和解决，可以帮助开发者在 Dify 通过 MCP 整合 MySQL 的过程中更加顺利地进行开发和调试，确保系统的稳定运行。