org.springframework.data.mongodb.gridfs

Class ReactiveGridFsTemplate

java.lang.Object

org.springframework.data.mongodb.gridfs.ReactiveGridFsTemplate

All Implemented Interfaces:

ReactiveGridFsOperations

public class ReactiveGridFsTemplate
extends Object
implements ReactiveGridFsOperations

ReactiveGridFsOperations implementation to store content into MongoDB GridFS. Uses by default DefaultDataBufferFactory to create buffers.

Since:

2.2

Author:

Mark Paluch, Nick Stolwijk

Constructor Summary

Constructors

Constructor and Description
ReactiveGridFsTemplate(DataBufferFactory dataBufferFactory, ReactiveMongoDatabaseFactory dbFactory, MongoConverter converter, String bucket) Creates a new ReactiveGridFsTemplate using the given DataBufferFactory, ReactiveMongoDatabaseFactory and MongoConverter.
ReactiveGridFsTemplate(ReactiveMongoDatabaseFactory dbFactory, MongoConverter converter) Creates a new ReactiveGridFsTemplate using the given ReactiveMongoDatabaseFactory and MongoConverter.
ReactiveGridFsTemplate(ReactiveMongoDatabaseFactory dbFactory, MongoConverter converter, String bucket) Creates a new ReactiveGridFsTemplate using the given ReactiveMongoDatabaseFactory and MongoConverter.

Method Summary

Modifier and Type	Method and Description
protected com.mongodb.client.gridfs.model.GridFSUploadOptions	computeUploadOptionsFor(String contentType, org.bson.Document metadata) Compute the GridFSUploadOptions to be used from the given contentType and metadata Document.
reactor.core.publisher.Mono<Void>	delete(Query query) Deletes all files matching the given Query.
reactor.core.publisher.Flux<com.mongodb.client.gridfs.model.GridFSFile>	find(Query query) Returns a Flux emitting all files matching the given query.
reactor.core.publisher.Mono<com.mongodb.client.gridfs.model.GridFSFile>	findFirst(Query query) Returns a Mono emitting the frist GridFSFile matching the given query or Mono.empty() in case no file matches.
reactor.core.publisher.Mono<com.mongodb.client.gridfs.model.GridFSFile>	findOne(Query query) Returns a Mono emitting a single GridFSFile matching the given query or Mono.empty() in case no file matches.
protected com.mongodb.reactivestreams.client.gridfs.GridFSBucket	getGridFs()
protected org.bson.Document	getMappedQuery(org.bson.Document query)
reactor.core.publisher.Mono<ReactiveGridFsResource>	getResource(com.mongodb.client.gridfs.model.GridFSFile file) Returns a Mono emitting the ReactiveGridFsResource for a GridFSFile.
reactor.core.publisher.Mono<ReactiveGridFsResource>	getResource(String location) Returns a Mono emitting the ReactiveGridFsResource with the given file name.
reactor.core.publisher.Flux<ReactiveGridFsResource>	getResources(String locationPattern) Returns a Flux emitting all ReactiveGridFsResources matching the given file name pattern.
protected com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher	prepareQuery(Query query)
reactor.core.publisher.Mono<org.bson.types.ObjectId>	store(com.mongodb.reactivestreams.client.gridfs.AsyncInputStream content, String filename, String contentType, org.bson.Document metadata) Stores the given content into a file with the given name and content type using the given metadata.
reactor.core.publisher.Mono<org.bson.types.ObjectId>	store(com.mongodb.reactivestreams.client.gridfs.AsyncInputStream content, String filename, String contentType, Object metadata) Stores the given content into a file with the given name and content type using the given metadata.
reactor.core.publisher.Mono<org.bson.types.ObjectId>	store(org.reactivestreams.Publisher<DataBuffer> content, String filename, String contentType, org.bson.Document metadata) Stores the given content into a file with the given name and content type using the given metadata.
reactor.core.publisher.Mono<org.bson.types.ObjectId>	store(org.reactivestreams.Publisher<DataBuffer> content, String filename, String contentType, Object metadata) Stores the given content into a file with the given name and content type using the given metadata.
protected org.bson.Document	toDocument(Object value) Convert a given value into a Document.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.data.mongodb.gridfs.ReactiveGridFsOperations

store, store, store, store, store, store

Constructor Detail

ReactiveGridFsTemplate

public ReactiveGridFsTemplate(ReactiveMongoDatabaseFactory dbFactory,
                              MongoConverter converter)

Creates a new ReactiveGridFsTemplate using the given ReactiveMongoDatabaseFactory and MongoConverter.

Parameters:

dbFactory - must not be null.

converter - must not be null.

ReactiveGridFsTemplate

public ReactiveGridFsTemplate(ReactiveMongoDatabaseFactory dbFactory,
                              MongoConverter converter,
                              @Nullable
                              String bucket)

Creates a new ReactiveGridFsTemplate using the given ReactiveMongoDatabaseFactory and MongoConverter.

Parameters:

dbFactory - must not be null.

converter - must not be null.

bucket -

ReactiveGridFsTemplate

public ReactiveGridFsTemplate(DataBufferFactory dataBufferFactory,
                              ReactiveMongoDatabaseFactory dbFactory,
                              MongoConverter converter,
                              @Nullable
                              String bucket)

Creates a new ReactiveGridFsTemplate using the given DataBufferFactory, ReactiveMongoDatabaseFactory and MongoConverter.

Parameters:

dataBufferFactory - must not be null.

dbFactory - must not be null.

converter - must not be null.

bucket -

Method Detail

store

public reactor.core.publisher.Mono<org.bson.types.ObjectId> store(com.mongodb.reactivestreams.client.gridfs.AsyncInputStream content,
                                                                  @Nullable
                                                                  String filename,
                                                                  @Nullable
                                                                  String contentType,
                                                                  @Nullable
                                                                  Object metadata)

Description copied from interface: ReactiveGridFsOperations

Stores the given content into a file with the given name and content type using the given metadata. The metadata object will be marshalled before writing.

Specified by:

store in interface ReactiveGridFsOperations

Parameters:

content - must not be null.

filename - must not be null or empty.

contentType - can be null.

metadata - can be null

Returns:

a Mono emitting the ObjectId of the GridFSFile just created.

store

public reactor.core.publisher.Mono<org.bson.types.ObjectId> store(org.reactivestreams.Publisher<DataBuffer> content,
                                                                  @Nullable
                                                                  String filename,
                                                                  @Nullable
                                                                  String contentType,
                                                                  @Nullable
                                                                  Object metadata)

Description copied from interface: ReactiveGridFsOperations

Stores the given content into a file with the given name and content type using the given metadata. The metadata object will be marshalled before writing.

Specified by:

store in interface ReactiveGridFsOperations

Parameters:

content - must not be null.

filename - must not be null or empty.

contentType - can be null.

metadata - can be null

Returns:

a Mono emitting the ObjectId of the GridFSFile just created.

store

public reactor.core.publisher.Mono<org.bson.types.ObjectId> store(com.mongodb.reactivestreams.client.gridfs.AsyncInputStream content,
                                                                  @Nullable
                                                                  String filename,
                                                                  @Nullable
                                                                  String contentType,
                                                                  @Nullable
                                                                  org.bson.Document metadata)

Description copied from interface: ReactiveGridFsOperations

Stores the given content into a file with the given name and content type using the given metadata.

Specified by:

store in interface ReactiveGridFsOperations

Parameters:

content - must not be null.

filename - must not be null or empty.

contentType - can be null.

metadata - can be null.

Returns:

a Mono emitting the ObjectId of the GridFSFile just created.

store

public reactor.core.publisher.Mono<org.bson.types.ObjectId> store(org.reactivestreams.Publisher<DataBuffer> content,
                                                                  @Nullable
                                                                  String filename,
                                                                  @Nullable
                                                                  String contentType,
                                                                  @Nullable
                                                                  org.bson.Document metadata)

Description copied from interface: ReactiveGridFsOperations

Stores the given content into a file with the given name and content type using the given metadata.

Specified by:

store in interface ReactiveGridFsOperations

Parameters:

content - must not be null.

filename - must not be null or empty.

contentType - can be null.

metadata - can be null.

Returns:

a Mono emitting the ObjectId of the GridFSFile just created.

find

public reactor.core.publisher.Flux<com.mongodb.client.gridfs.model.GridFSFile> find(Query query)

Description copied from interface: ReactiveGridFsOperations

Returns a Flux emitting all files matching the given query.
Note: Currently Sort criteria defined at the Query will not be regarded as MongoDB does not support ordering for GridFS file access.

Specified by:

find in interface ReactiveGridFsOperations

Parameters:

query - must not be null.

Returns:

Flux.empty() if no mach found.

See Also:

MongoDB Jira: JAVA-431

findOne

public reactor.core.publisher.Mono<com.mongodb.client.gridfs.model.GridFSFile> findOne(Query query)

Description copied from interface: ReactiveGridFsOperations

Returns a Mono emitting a single GridFSFile matching the given query or Mono.empty() in case no file matches.
NOTE If more than one file matches the given query the resulting Mono emits an error. If you want to obtain the first found file use ReactiveGridFsOperations.findFirst(Query).

Specified by:

findOne in interface ReactiveGridFsOperations

Parameters:

query - must not be null.

Returns:

Mono.empty() if not match found.

findFirst

public reactor.core.publisher.Mono<com.mongodb.client.gridfs.model.GridFSFile> findFirst(Query query)

Description copied from interface: ReactiveGridFsOperations

Returns a Mono emitting the frist GridFSFile matching the given query or Mono.empty() in case no file matches.

Specified by:

findFirst in interface ReactiveGridFsOperations

Parameters:

query - must not be null.

Returns:

Mono.empty() if not match found.

delete

public reactor.core.publisher.Mono<Void> delete(Query query)

Description copied from interface: ReactiveGridFsOperations

Deletes all files matching the given Query.

Specified by:

delete in interface ReactiveGridFsOperations

Parameters:

query - must not be null.

Returns:

a Mono signalling operation completion.

getResource

public reactor.core.publisher.Mono<ReactiveGridFsResource> getResource(String location)

Description copied from interface: ReactiveGridFsOperations

Returns a Mono emitting the ReactiveGridFsResource with the given file name.

Specified by:

getResource in interface ReactiveGridFsOperations

Parameters:

location - must not be null.

Returns:

Mono.empty() if no match found.

getResource

public reactor.core.publisher.Mono<ReactiveGridFsResource> getResource(com.mongodb.client.gridfs.model.GridFSFile file)

Description copied from interface: ReactiveGridFsOperations

Returns a Mono emitting the ReactiveGridFsResource for a GridFSFile.

Specified by:

getResource in interface ReactiveGridFsOperations

Parameters:

file - must not be null.

Returns:

Mono.empty() if no match found.

getResources

public reactor.core.publisher.Flux<ReactiveGridFsResource> getResources(String locationPattern)

Description copied from interface: ReactiveGridFsOperations

Returns a Flux emitting all ReactiveGridFsResources matching the given file name pattern.

Specified by:

getResources in interface ReactiveGridFsOperations

Parameters:

locationPattern - must not be null.

Returns:

Flux.empty() if no match found.

prepareQuery

protected com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher prepareQuery(Query query)

getGridFs

protected com.mongodb.reactivestreams.client.gridfs.GridFSBucket getGridFs()

getMappedQuery

protected org.bson.Document getMappedQuery(org.bson.Document query)

Parameters:

query - pass the given query though a QueryMapper to apply type conversion.

Returns:

never null.

computeUploadOptionsFor

protected com.mongodb.client.gridfs.model.GridFSUploadOptions computeUploadOptionsFor(@Nullable
                                                                                      String contentType,
                                                                                      @Nullable
                                                                                      org.bson.Document metadata)

Compute the GridFSUploadOptions to be used from the given contentType and metadata Document.

Parameters:

contentType - can be null.

metadata - can be null

Returns:

never null.

toDocument

protected org.bson.Document toDocument(@Nullable
                                       Object value)

Convert a given value into a Document.

Parameters:

value - can be null.

Returns:

an empty Document if the source value is null.