正在显示
1 个修改的文件
包含
4 行增加
和
0 行删除
@@ -198,7 +198,11 @@ func GetIncrementSql(table string, column string, incre int, id int64) *utils.Sq | @@ -198,7 +198,11 @@ func GetIncrementSql(table string, column string, incre int, id int64) *utils.Sq | ||
198 | var sql *bytes.Buffer | 198 | var sql *bytes.Buffer |
199 | sql = bytes.NewBuffer(nil) | 199 | sql = bytes.NewBuffer(nil) |
200 | sql.WriteString(fmt.Sprintf("update %s set %s=%s+%d ", table, column, column, incre)) | 200 | sql.WriteString(fmt.Sprintf("update %s set %s=%s+%d ", table, column, column, incre)) |
201 | + if incre > 0 { | ||
201 | sql.WriteString(fmt.Sprintf(" where id=%d", id)) | 202 | sql.WriteString(fmt.Sprintf(" where id=%d", id)) |
203 | + } else { | ||
204 | + sql.WriteString(fmt.Sprintf(" where id=%d and %v>0", id, column)) | ||
205 | + } | ||
202 | return &utils.SqlData{ | 206 | return &utils.SqlData{ |
203 | Sql: sql.String(), | 207 | Sql: sql.String(), |
204 | } | 208 | } |
-
请 注册 或 登录 后发表评论