75 lines
3.7 KiB
Go
75 lines
3.7 KiB
Go
package ai
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
)
|
|
|
|
// schemaContextCap 注入给模型的库表结构上下文长度上限。
|
|
const schemaContextCap = 4000
|
|
|
|
// BuildMessages 按 action 选 system 模板装配对话;req.Schema 非空时注入库表列上下文。
|
|
func BuildMessages(req ChatReq) []Message {
|
|
driver := req.Driver
|
|
if driver == "" {
|
|
driver = "mysql"
|
|
}
|
|
sys := "你是资深数据库工程师助手,服务于数据库客户端 OpsxDB。回答使用中文。SQL 放在 ```sql 代码块中。\n规则：\n- 禁止输出思考过程、推理草稿、内心独白或逐步分析；只给用户最终答案。\n- 禁止编造上下文中未出现的列名或表结构；多轮跟进、用户换表时同样适用——上下文未列出该表的列，就不得在 SQL 里写 created_at/updated_at/order_time 等任何未出现的列名。\n- 缺表/缺时间列/意图不清/换表后列未知时：用一两句中文澄清（可问具体时间字段），或只给出探测列的 SQL（如 DESCRIBE / information_schema.COLUMNS）；不要为了「可执行」硬造业务 SQL。\n- 「最近 N 天数据变化」默认指业务行时间过滤；不得默认用 information_schema.TABLES.UPDATE_TIME 充当终答（除非用户明确要表元数据更新时间）。\n- 「最新数据」类请求：仅当上下文已给出可用排序列（时间列或主键）时才写 ORDER BY … LIMIT；否则先澄清列名。"
|
|
var task string
|
|
switch strings.ToLower(req.Action) {
|
|
case "generate":
|
|
task = fmt.Sprintf("根据用户描述生成一条 %s 方言的 SQL。结构足够且列名均已出现在上下文时：极简说明（≤2 行）+ 一条可执行 SQL；结构不足、换表后列未知或缺时间列时：只输出一两句澄清或 DESCRIBE/查列 SQL，禁止默认 created_at，不要输出思考过程。", driver)
|
|
case "ask":
|
|
task = "回答用户关于当前数据库、数据或 SQL 的问题；只有用户明确要求编写 SQL 且上下文已含所需列名时才给出业务 SQL（极简说明≤2 行 + SQL 块）。列未知时一句澄清或只给 DESCRIBE/查列 SQL，禁止猜测 created_at 等。你没有调用数据库工具，不要声称已经查询或修改数据。禁止输出思考过程。"
|
|
case "explain":
|
|
task = "逐部分解释用户给出的 SQL:访问路径、索引使用、潜在代价。"
|
|
case "optimize":
|
|
task = "审查用户给出的 SQL 并给出优化版本:索引建议、重写建议、说明理由。"
|
|
case "fix":
|
|
task = "根据报错信息修复用户给出的 SQL,指出错误原因并给出修正后的完整 SQL。"
|
|
case "dialect":
|
|
task = fmt.Sprintf("把用户给出的 SQL 转换为 %s 方言,保持语义一致。", driver)
|
|
case "sample":
|
|
task = "为当前库生成一条有代表性的示例查询 SQL。"
|
|
default:
|
|
task = "回答用户关于数据库 / SQL 的问题。"
|
|
}
|
|
var sb strings.Builder
|
|
sb.WriteString(sys)
|
|
sb.WriteString("\n")
|
|
sb.WriteString(task)
|
|
if req.Database != "" {
|
|
sb.WriteString(fmt.Sprintf("\n当前数据库: %s(%s)", req.Database, driver))
|
|
}
|
|
if s := strings.TrimSpace(req.Schema); s != "" {
|
|
if len(s) > schemaContextCap {
|
|
s = s[:schemaContextCap]
|
|
}
|
|
sb.WriteString("\n当前数据库结构:\n")
|
|
sb.WriteString(s)
|
|
}
|
|
|
|
var user strings.Builder
|
|
if p := strings.TrimSpace(req.Prompt); p != "" {
|
|
user.WriteString(p)
|
|
}
|
|
if s := strings.TrimSpace(req.SQL); s != "" {
|
|
if user.Len() > 0 {
|
|
user.WriteString("\n\n")
|
|
}
|
|
user.WriteString("SQL:\n")
|
|
user.WriteString(s)
|
|
}
|
|
if e := strings.TrimSpace(req.Error); e != "" {
|
|
user.WriteString("\n\n报错:\n")
|
|
user.WriteString(e)
|
|
}
|
|
if user.Len() == 0 {
|
|
user.WriteString("你好")
|
|
}
|
|
return []Message{
|
|
{Role: "system", Content: sb.String()},
|
|
{Role: "user", Content: user.String()},
|
|
}
|
|
}
|