DBZ-8202 extended support for mongoDb
This commit is contained in:
parent
bfb6938db8
commit
4451d3df45
@ -16,6 +16,7 @@
|
|||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
|
import com.mongodb.MongoException;
|
||||||
import com.mongodb.client.ChangeStreamIterable;
|
import com.mongodb.client.ChangeStreamIterable;
|
||||||
import com.mongodb.client.MongoClient;
|
import com.mongodb.client.MongoClient;
|
||||||
import com.mongodb.client.MongoCollection;
|
import com.mongodb.client.MongoCollection;
|
||||||
@ -235,7 +236,14 @@ public static ChangeStreamIterable<BsonDocument> openChangeStream(MongoClient cl
|
|||||||
|
|
||||||
public static BsonTimestamp hello(MongoClient client, String dbName) {
|
public static BsonTimestamp hello(MongoClient client, String dbName) {
|
||||||
var database = client.getDatabase(dbName);
|
var database = client.getDatabase(dbName);
|
||||||
var result = database.runCommand(new Document("hello", 1), BsonDocument.class);
|
BsonDocument result;
|
||||||
|
try {
|
||||||
|
result = database.runCommand(new Document("hello", 1), BsonDocument.class);
|
||||||
|
}
|
||||||
|
catch (MongoException e) {
|
||||||
|
LOGGER.error(e.getMessage(), e);
|
||||||
|
result = database.runCommand(new Document("isMaster", 1), BsonDocument.class);
|
||||||
|
}
|
||||||
return result.getTimestamp("operationTime");
|
return result.getTimestamp("operationTime");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user