check total

e831f857 · linj · a6a5509e · e831f857
Commit e831f857 authored Jan 10, 2020 by linj
Show whitespace changes
Inline Side-by-side

Showing with 4 additions and 0 deletions

localdb_v1.go plugin/dapp/trade/executor/localdb_v1.go +4 -0

No files found.
--- a/plugin/dapp/trade/executor/localdb_v1.go
+++ b/plugin/dapp/trade/executor/localdb_v1.go
@@ -32,6 +32,10 @@ const (
 // TradeUpdateLocalDBV2 trade 本地数据库升级
 // from 1 to 2
 func TradeUpdateLocalDBV2(localDB dbm.DB, total int) error {
+	// 外部不指定， 强制分批执行
+	if total <= 0 {
+		total = 10000
+	}
 	toVersion := 2
 	kvdb := dbm.NewKVDB(localDB)
 	version, err := getVersion(kvdb)