|
|
|
@ -3019,13 +3019,6 @@ public class ReactiveMongoTemplate implements ReactiveMongoOperations, Applicati |
|
|
|
public Publisher<Document> doInCollection(MongoCollection<Document> collection) |
|
|
|
public Publisher<Document> doInCollection(MongoCollection<Document> collection) |
|
|
|
throws MongoException, DataAccessException { |
|
|
|
throws MongoException, DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
if (LOGGER.isDebugEnabled()) { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
LOGGER.debug( |
|
|
|
|
|
|
|
String.format("findOne using query: %s fields: %s in db.collection: %s", serializeToJsonSafely(query), |
|
|
|
|
|
|
|
serializeToJsonSafely(fields.orElseGet(Document::new)), collection.getNamespace().getFullName())); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
FindPublisher<Document> publisher = preparer.initiateFind(collection, col -> col.find(query, Document.class)); |
|
|
|
FindPublisher<Document> publisher = preparer.initiateFind(collection, col -> col.find(query, Document.class)); |
|
|
|
|
|
|
|
|
|
|
|
if (fields.isPresent()) { |
|
|
|
if (fields.isPresent()) { |
|
|
|
|