mirror of
https://gitee.com/dromara/mayfly-go
synced 2025-11-02 23:40:24 +08:00
This commit is contained in:
@@ -193,6 +193,7 @@ func doUpdate(update *sqlparser.Update, execSqlReq *DbSqlExecReq, dbSqlExec *ent
|
|||||||
// 可能使用别名,故空格切割
|
// 可能使用别名,故空格切割
|
||||||
tableName := strings.Split(tableStr, " ")[0]
|
tableName := strings.Split(tableStr, " ")[0]
|
||||||
where := sqlparser.String(update.Where)
|
where := sqlparser.String(update.Where)
|
||||||
|
biz.IsTrue(len(where) > 0, "SQL[%s]未执行. 请完善 where 条件后再执行", execSqlReq.Sql)
|
||||||
|
|
||||||
updateExprs := update.Exprs
|
updateExprs := update.Exprs
|
||||||
updateColumns := make([]string, 0)
|
updateColumns := make([]string, 0)
|
||||||
@@ -227,6 +228,7 @@ func doDelete(delete *sqlparser.Delete, execSqlReq *DbSqlExecReq, dbSqlExec *ent
|
|||||||
// 可能使用别名,故空格切割
|
// 可能使用别名,故空格切割
|
||||||
table := strings.Split(tableStr, " ")[0]
|
table := strings.Split(tableStr, " ")[0]
|
||||||
where := sqlparser.String(delete.Where)
|
where := sqlparser.String(delete.Where)
|
||||||
|
biz.IsTrue(len(where) > 0, "SQL[%s]未执行. 请完善 where 条件后再执行", execSqlReq.Sql)
|
||||||
|
|
||||||
// 查询删除数据
|
// 查询删除数据
|
||||||
selectSql := fmt.Sprintf("SELECT * FROM %s %s LIMIT 200", tableStr, where)
|
selectSql := fmt.Sprintf("SELECT * FROM %s %s LIMIT 200", tableStr, where)
|
||||||
|
|||||||
Reference in New Issue
Block a user