From dfbd6ea73be507a50189a1cdc92d80802b974626 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=80=E5=A2=A8=E6=9F=93=E5=B0=BD=E9=9D=92=E8=A1=A3?= =?UTF-8?q?=E9=A2=9C?= <378809360@qq.com> Date: Wed, 15 Aug 2018 18:17:29 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=20gdb=5Fmodel.go?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- g/database/gdb/gdb_model.go | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/g/database/gdb/gdb_model.go b/g/database/gdb/gdb_model.go index b89172419..0539d99a8 100644 --- a/g/database/gdb/gdb_model.go +++ b/g/database/gdb/gdb_model.go @@ -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++ } }