mirror of
https://gitee.com/johng/gf
synced 2026-06-07 10:22:11 +08:00
更新 gdb_model.go
This commit is contained in:
@ -420,32 +420,26 @@ func (md *Model) getFormattedSql() string {
|
||||
|
||||
// 组块结果集
|
||||
// @author ymrjqyy
|
||||
// @author 2018-08-13
|
||||
// @author 2018-08-15
|
||||
func (md *Model) Chunk(limit int, callback func(result Result, err error) bool) {
|
||||
var page = 1
|
||||
for {
|
||||
md.ForPage(page, limit)
|
||||
|
||||
sqls := md.getFormattedSql()
|
||||
data, err := md.getAll(sqls, md.whereArgs...)
|
||||
|
||||
if err != nil {
|
||||
callback(nil, err)
|
||||
break
|
||||
}
|
||||
|
||||
if len(data) == 0 {
|
||||
break
|
||||
}
|
||||
|
||||
if callback(data, err) == false {
|
||||
break
|
||||
}
|
||||
|
||||
if len(data) < limit {
|
||||
break
|
||||
}
|
||||
|
||||
page++
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user