1
This commit is contained in:
parent
94bdf86097
commit
5c45b36138
@ -269,6 +269,8 @@ func (this *dbPool) Upsert(
|
|||||||
if ds.Next() {
|
if ds.Next() {
|
||||||
if len(updateKv) > 0 {
|
if len(updateKv) > 0 {
|
||||||
this.Update(dataSource, tblName, whereKv, updateKv, cb)
|
this.Update(dataSource, tblName, whereKv, updateKv, cb)
|
||||||
|
} else {
|
||||||
|
cb(nil, 0, 0)
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
this.Insert(dataSource, tblName, insertKv, cb)
|
this.Insert(dataSource, tblName, insertKv, cb)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user