iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Bael 5369 new (#12073)

Browse Source 
* BAEL-5369: Checking Connection to MongoDB

* BAEL-5369:- Minor Fix Checking Connection to MongoDB
This commit is contained in:
Kapil Khandelwal 2022-04-19 05:05:55 +05:30 committed by GitHub
parent f4c4d890d6
commit 09d6595514
2 changed files with 8 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
persistence-modules/java-mongodb-2/src/main/java/com/baeldung/mongo/ConnectionCheck.java
View File

@ -7,7 +7,7 @@ import com.mongodb.ServerAddress;
public class ConnectionCheck {
public static void checkingConnection() {
public static MongoClient checkingConnection() {
MongoClientOptions.Builder builder = MongoClientOptions.builder();
@ -27,9 +27,10 @@ public class ConnectionCheck {
System.out.println(db.getStats());
} catch (Exception e) {
System.out.println("MongoDB Server is Down");
mongoClient.close();
}
return mongoClient;
}
public static void main(String[] args) {
@ -43,4 +44,3 @@ public class ConnectionCheck {
}
}

29
persistence-modules/java-mongodb-2/src/test/java/com/baeldung/mongo/ConnectionCheckLiveTest.java
View File

@ -3,45 +3,22 @@ package com.baeldung.mongo;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
import java.io.IOException;
import org.junit.BeforeClass;
import org.junit.Test;
import com.baeldung.ConnectionCheck;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.ServerAddress;
public class ConnectionCheckLiveTest {
private static MongoClient mongoClient;
private static MongoClientOptions.Builder builder;
private static ServerAddress ServerAddress;
@BeforeClass
public static void setup() throws IOException {
if (mongoClient == null) {
builder = MongoClientOptions.builder();
builder.connectionsPerHost(100);
builder.maxWaitTime(60000);
builder.connectTimeout(1500);
builder.socketTimeout(60000);
builder.socketKeepAlive(true);
ServerAddress = new ServerAddress("localhost", 27017);
mongoClient = new MongoClient(ServerAddress, builder.build());
}
}
ConnectionCheck ConnectionCheck = new ConnectionCheck();
@Test
public void givenMongoClient_whenConnectionCheck_thenCheckingForConnectionPoint() {
MongoClient mongoClient = ConnectionCheck.checkingConnection();
String connectionPoint = mongoClient.getConnectPoint();
assertNotNull(connectionPoint);
assertFalse(connectionPoint.isEmpty());
}
}