修复执行 bulkWrite 导致 panic (#50)

* Update server.go * 修复bulkWrite异常 * 回退格式化的代码 Co-authored-by: 丁少龙 <[email protected]>
hyperf · Feb 21, 2022 · a8fe6cf · a8fe6cf
1 parent 099c9d2
commit a8fe6cf
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/mongo_client/mongo_client.go b/pkg/mongo_client/mongo_client.go
@@ -43,7 +43,11 @@ func (m *MongoProxy) getHandler(i interface{}, f coreExecutor) gotask.Handler {
 func (m *MongoProxy) exec(i interface{}, payload []byte, result *[]byte, f coreExecutor) error {
 	var r interface{}
 	defer func() {
-		*result = r.([]byte)
+		if r == nil {
+			*result = nil
+		} else {
+			*result = r.([]byte)
+		}
 	}()
 	return m.getHandler(i, f)(payload, &r)
 }