Skip to content

Commit a8fe6cf

Browse files
Slairmy丁少龙
andauthored
修复执行 bulkWrite 导致 panic (#50)
* Update server.go * 修复bulkWrite异常 * 回退格式化的代码 Co-authored-by: 丁少龙 <dingshaolong@aipai.com>
1 parent 099c9d2 commit a8fe6cf

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

pkg/mongo_client/mongo_client.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,11 @@ func (m *MongoProxy) getHandler(i interface{}, f coreExecutor) gotask.Handler {
4343
func (m *MongoProxy) exec(i interface{}, payload []byte, result *[]byte, f coreExecutor) error {
4444
var r interface{}
4545
defer func() {
46-
*result = r.([]byte)
46+
if r == nil {
47+
*result = nil
48+
} else {
49+
*result = r.([]byte)
50+
}
4751
}()
4852
return m.getHandler(i, f)(payload, &r)
4953
}

0 commit comments

Comments
 (0)