Browse Source

Merge branch 'fix/mongo' into debug

Roc 2 months ago
parent
commit
0cad1611b5
1 changed files with 4 additions and 1 deletions
  1. 4 1
      utils/mgodb/mgo_config.go

+ 4 - 1
utils/mgodb/mgo_config.go

@@ -8,6 +8,7 @@ import (
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/event"
 	mgoptions "go.mongodb.org/mongo-driver/mongo/options"
+	"go.mongodb.org/mongo-driver/mongo/writeconcern"
 	"sync"
 )
 
@@ -78,7 +79,9 @@ func MgoNewClient(mgoConfig MgoConfig) *qmgo.Client {
 	}
 
 	// 创建options
-	ops := options.ClientOptions{ClientOptions: &mgoptions.ClientOptions{}}
+	ops := options.ClientOptions{ClientOptions: &mgoptions.ClientOptions{
+		WriteConcern: &writeconcern.WriteConcern{W: "majority"},
+	}}
 	ops.SetMonitor(cmdMonitor)
 
 	ctx := context.Background()