[update][plugin][mongowriter] Replace deprecated MongoClient method

wgzhao · Dec 6, 2023 · 7e5dcc4 · 7e5dcc4
1 parent 5cfae66
commit 7e5dcc4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...godbwriter/src/main/java/com/wgzhao/addax/plugin/writer/mongodbwriter/util/MongoUtil.java b/...godbwriter/src/main/java/com/wgzhao/addax/plugin/writer/mongodbwriter/util/MongoUtil.java
@@ -22,12 +22,12 @@
 import com.wgzhao.addax.common.exception.AddaxException;
 import com.wgzhao.addax.plugin.writer.mongodbwriter.MongoDBWriterErrorCode;
 import com.mongodb.MongoClient;
+import com.mongodb.MongoClientOptions;
 import com.mongodb.MongoCredential;
 import com.mongodb.ServerAddress;
 
 import java.net.UnknownHostException;
 import java.util.ArrayList;
-import java.util.Collections;
 import java.util.List;
 
 public class MongoUtil
@@ -61,7 +61,7 @@ public static MongoClient initCredentialMongoClient(List<Object> addressList, St
         }
         try {
             MongoCredential credential = MongoCredential.createCredential(userName, database, password.toCharArray());
-            return new MongoClient(parseServerAddress(addressList), Collections.singletonList(credential));
+            return new MongoClient(parseServerAddress(addressList), credential, new MongoClientOptions.Builder().build());
         }
         catch (UnknownHostException e) {
             throw AddaxException.asAddaxException(MongoDBWriterErrorCode.ILLEGAL_ADDRESS, "不合法的地址");