Dify — Chatflow - 数据库智能查询

发布时间:2026/6/28 3:13:32
Dify — Chatflow - 数据库智能查询 完整工作流如图因为没有直接执行SQL的节点所以中间会多增加好多节点去处理数据创建数据库在mysql中的 dify_chatflow 数据库下创建表及插入数据(来源马士兵教育)-- 使用dify_chatflow数据库 use dify_chatflow; -- 客户表 CREATE TABLE dify_chatflow.customers ( customer_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 客户ID, name VARCHAR(100) NOT NULL COMMENT 客户姓名, email VARCHAR(100) COMMENT 客户邮箱, phone VARCHAR(20) COMMENT 客户电话, address VARCHAR(255) COMMENT 客户地址 ) COMMENT客户表; INSERT INTO dify_chatflow.customers (name, email, phone, address) VALUES (张三, zhangsanexample.com, 13800138000, 北京市朝阳区), (李四, lisiexample.com, 13800138001, 上海市浦东新区), (王五, wangwuexample.com, 13800138002, 广州市天河区), (赵六, zhaoliuexample.com, 13800138003, 深圳市南山区), (孙七, sunqiexample.com, 13800138004, 杭州市西湖区), (周八, zhoubaexample.com, 13800138005, 成都市武侯区), (吴九, wujiuexample.com, 13800138006, 武汉市江汉区), (郑十, zhengshiexample.com, 13800138007, 南京市鼓楼区), (钱十一, qianshiyiexample.com, 13800138008, 长沙市岳麓区), (刘十二, liushierexample.com, 13800138009, 重庆市渝中区); -- 产品表 CREATE TABLE dify_chatflow.products ( product_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 产品ID, name VARCHAR(100) NOT NULL COMMENT 产品名称, description TEXT COMMENT 产品描述, price DECIMAL(10, 2) NOT NULL COMMENT 产品价格, stock_quantity INT NOT NULL COMMENT 库存数量 ) COMMENT产品表; INSERT INTO dify_chatflow.products (name, description, price, stock_quantity) VALUES (产品A, 这是产品A的描述。, 100.00, 50), (产品B, 这是产品B的描述。, 200.00, 30), (产品C, 这是产品C的描述。, 150.00, 20), (产品D, 这是产品D的描述。, 300.00, 10), (产品E, 这是产品E的描述。, 250.00, 15), (产品F, 这是产品F的描述。, 120.00, 40), (产品G, 这是产品G的描述。, 80.00, 60), (产品H, 这是产品H的描述。, 90.00, 70), (产品I, 这是产品I的描述。, 110.00, 55), (产品J, 这是产品J的描述。, 130.00, 35); -- 订单表 CREATE TABLE dify_chatflow.orders ( order_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 订单ID, customer_id INT NOT NULL COMMENT 客户ID, order_date DATE NOT NULL COMMENT 订单日期, total_amount DECIMAL(10, 2) NOT NULL COMMENT 总金额, FOREIGN KEY (customer_id) REFERENCES customers(customer_id) ) COMMENT订单表; INSERT INTO dify_chatflow.orders (customer_id, order_date, total_amount) VALUES (1, 2025-03-01, 300.00), (2, 2025-03-02, 450.00), (3, 2025-03-03, 200.00), (4, 2025-03-04, 150.00), (5, 2025-03-05, 500.00), (6, 2025-03-06, 350.00), (7, 2025-03-07, 400.00), (8, 2025-03-08, 250.00), (9, 2025-03-09, 600.00), (10, 2025-03-10, 700.00); -- 订单明细表 CREATE TABLE dify_chatflow.order_details ( order_detail_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 订单明细ID, order_id INT NOT NULL COMMENT 订单ID, product_id INT NOT NULL COMMENT 产品ID, quantity INT NOT NULL COMMENT 数量, unit_price DECIMAL(10, 2) NOT NULL COMMENT 单价, FOREIGN KEY (order_id) REFERENCES orders(order_id), FOREIGN KEY (product_id) REFERENCES products(product_id) ) COMMENT订单明细表; INSERT INTO dify_chatflow.order_details (order_id, product_id, quantity, unit_price) VALUES (1, 1, 2, 100.00), (1, 2, 1, 200.00), (2, 3, 3, 150.00), (2, 4, 1, 300.00), (3, 5, 2, 250.00), (3, 6, 1, 120.00), (4, 7, 5, 80.00), (4, 8, 2, 90.00), (5, 9, 4, 110.00), (5, 10, 3, 130.00); -- 供应商表 CREATE TABLE dify_chatflow.suppliers ( supplier_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 供应商ID, name VARCHAR(100) NOT NULL COMMENT 供应商名称, contact_name VARCHAR(100) COMMENT 联系人姓名, phone VARCHAR(50) COMMENT 联系电话, address VARCHAR(255) COMMENT 联系地址 ) COMMENT供应商表; INSERT INTO dify_chatflow.suppliers (name, contact_name, phone, address) VALUES (京东供应链, 赵经理, 13800138001, 北京市大兴区产业园1号楼), (阿里巴巴供货, 孙先生, 13800138002, 杭州市西湖区科技园B座), (苏宁供货商, 李主管, 13800138003, 南京市玄武区软件谷), (唯品会供货中心, 陈小姐, 13800138004, 广州市天河区商务中心), (拼多多合作商, 王助理, 13800138005, 上海市浦东新区电商产业园); -- 产品供应商关系表 CREATE TABLE dify_chatflow.product_suppliers ( id INT AUTO_INCREMENT PRIMARY KEY COMMENT 主键, product_id INT NOT NULL COMMENT 产品ID, supplier_id INT NOT NULL COMMENT 供应商ID, FOREIGN KEY (product_id) REFERENCES products(product_id), FOREIGN KEY (supplier_id) REFERENCES suppliers(supplier_id) ) COMMENT产品供应商关系表; INSERT INTO dify_chatflow.product_suppliers (product_id, supplier_id) VALUES (1, 1), (2, 1), (3, 2), (4, 2), (5, 3), (6, 3), (7, 4), (8, 4), (9, 5), (10, 5); -- 客户反馈表 CREATE TABLE dify_chatflow.customer_feedback ( feedback_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 反馈ID, customer_id INT NOT NULL COMMENT 客户ID, product_id INT NOT NULL COMMENT 产品ID, rating INT NOT NULL COMMENT 评分1-5, comment TEXT COMMENT 反馈内容, feedback_date DATE COMMENT 反馈日期, FOREIGN KEY (customer_id) REFERENCES customers(customer_id), FOREIGN KEY (product_id) REFERENCES products(product_id) ) COMMENT客户反馈表; INSERT INTO dify_chatflow.customer_feedback (customer_id, product_id, rating, comment, feedback_date) VALUES (1, 1, 5, 产品很好, 2025-03-05), (2, 2, 4, 性价比高, 2025-03-06), (3, 3, 3, 一般般, 2025-03-07), (4, 4, 5, 非常满意, 2025-03-08), (5, 5, 2, 不太好用, 2025-03-09), (6, 6, 4, 还不错, 2025-03-10), (7, 7, 5, 值得购买, 2025-03-11), (8, 8, 3, 中规中矩, 2025-03-12), (9, 9, 4, 挺好, 2025-03-13), (10, 10, 5, 超级棒, 2025-03-14);表结果作为知识库构建-- 客户表 CREATE TABLE customers ( customer_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 客户ID, name VARCHAR(100) NOT NULL COMMENT 客户姓名, email VARCHAR(100) COMMENT 客户邮箱, phone VARCHAR(20) COMMENT 客户电话, address VARCHAR(255) COMMENT 客户地址 ) COMMENT客户表; -- 产品表 CREATE TABLE products ( product_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 产品ID, name VARCHAR(100) NOT NULL COMMENT 产品名称, description TEXT COMMENT 产品描述, price DECIMAL(10, 2) NOT NULL COMMENT 产品价格, stock_quantity INT NOT NULL COMMENT 库存数量 ) COMMENT产品表; -- 订单表 CREATE TABLE orders ( order_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 订单ID, customer_id INT NOT NULL COMMENT 客户ID, order_date DATE NOT NULL COMMENT 订单日期, total_amount DECIMAL(10, 2) NOT NULL COMMENT 总金额, FOREIGN KEY (customer_id) REFERENCES customers(customer_id) ) COMMENT订单表; -- 订单明细表 CREATE TABLE order_details ( order_detail_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 订单明细ID, order_id INT NOT NULL COMMENT 订单ID, product_id INT NOT NULL COMMENT 产品ID, quantity INT NOT NULL COMMENT 数量, unit_price DECIMAL(10, 2) NOT NULL COMMENT 单价, FOREIGN KEY (order_id) REFERENCES orders(order_id), FOREIGN KEY (product_id) REFERENCES products(product_id) ) COMMENT订单明细表; -- 供应商表 CREATE TABLE suppliers ( supplier_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 供应商ID, name VARCHAR(100) NOT NULL COMMENT 供应商名称, contact_name VARCHAR(100) COMMENT 联系人姓名, phone VARCHAR(50) COMMENT 联系电话, address VARCHAR(255) COMMENT 联系地址 ) COMMENT供应商表; -- 产品供应商关系表 CREATE TABLE product_suppliers ( id INT AUTO_INCREMENT PRIMARY KEY COMMENT 主键, product_id INT NOT NULL COMMENT 产品ID, supplier_id INT NOT NULL COMMENT 供应商ID, FOREIGN KEY (product_id) REFERENCES products(product_id), FOREIGN KEY (supplier_id) REFERENCES suppliers(supplier_id) ) COMMENT产品供应商关系表; -- 客户反馈表 CREATE TABLE customer_feedback ( feedback_id INT AUTO_INCREMENT PRIMARY KEY COMMENT 反馈ID, customer_id INT NOT NULL COMMENT 客户ID, product_id INT NOT NULL COMMENT 产品ID, rating INT NOT NULL COMMENT 评分1-5, comment TEXT COMMENT 反馈内容, feedback_date DATE COMMENT 反馈日期, FOREIGN KEY (customer_id) REFERENCES customers(customer_id), FOREIGN KEY (product_id) REFERENCES products(product_id) ) COMMENT客户反馈表;创建知识库创建Chatflow生成查询SQLSYSTEM内容如下复制到提示词中要将 {{上下文}} 进行处理你是一位SQL专家擅长根据用户的自然语言结合知识库{{上下文}} 中的内容查询生成SQL语句。 1.请根据用户的自然语言描述生成对应的SQL查询语句直接返回可执行的SQL即可返回的内容应当可以直接在数据库中执行查询不需要额外的信息、解释或说明。 2.SQL只能是select相关sql所有查询的表及字段只能来自于知识库严谨随意添加不存在于知识库中的表或者字段 3.如果根据用户的自然语言无法生成select相关sql请直接返回 select 无法生成SQL from dual 4.用户的描述只能转换为基于知识库中表的查询不能查询mysql相关系统表