diff --git a/dbpool.go b/dbpool.go
index 989ec38..3e30e4b 100644
--- a/dbpool.go
+++ b/dbpool.go
@@ -269,6 +269,8 @@ func (this *dbPool) Upsert(
 			if ds.Next() {
 				if len(updateKv) > 0 {
 					this.Update(dataSource, tblName, whereKv, updateKv, cb)
+				} else {
+					cb(nil, 0, 0)
 				}
 			} else {
 				this.Insert(dataSource, tblName, insertKv, cb)