44 "context"
55 "encoding/json"
66 "fmt"
7+ "strings"
78)
89
910func GetSQL (ddl , question string ) (sql string , err error ) {
@@ -21,7 +22,8 @@ func GetSQL(ddl, question string) (sql string, err error) {
2122 if err != nil {
2223 return "" , fmt .Errorf ("生成SQL失败: %w" , err )
2324 }
24- return result .Content , nil
25+ sql = result .Content
26+ return trimSql (sql ), nil
2527}
2628
2729func ChoiceSQL (sqls , ddl , question string ) (sql string , err error ) {
@@ -39,7 +41,8 @@ func ChoiceSQL(sqls, ddl, question string) (sql string, err error) {
3941 if err != nil {
4042 return "" , fmt .Errorf ("选择SQL失败: %w" , err )
4143 }
42- return result .Content , nil
44+ sql = result .Content
45+ return trimSql (sql ), nil
4346}
4447
4548func PrettyRes (sql , question string , runResult []map [string ]interface {}) (res string , err error ) {
@@ -63,3 +66,12 @@ func PrettyRes(sql, question string, runResult []map[string]interface{}) (res st
6366 }
6467 return result .Content , nil
6568}
69+
70+ // 如果有sql tag 就删除
71+ func trimSql (sql string ) string {
72+ if strings .HasPrefix (sql , "```sql\n " ) {
73+ sql = strings .TrimLeft (sql , "```sql\n " )
74+ sql = strings .TrimRight (sql , "\n ```" )
75+ }
76+ return sql
77+ }
0 commit comments