Package io.clonecloudstore.common.database.mongo

Class MongoStreamHelper<F,E extends F>

java.lang.Object

io.clonecloudstore.common.database.mongo.MongoStreamHelper<F,E>

Type Parameters:

F - the DAO interface type

E - the real DAO type

All Implemented Interfaces:

StreamHelperInterface<E>

public class MongoStreamHelper<F,E extends F>
extends Object
implements StreamHelperInterface<E>

Mongo implementation of the StreamHelper

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_LIST

Constructor Summary

Constructors

Constructor	Description
MongoStreamHelper()	Constructor

Method Summary

Modifier and Type	Method	Description
ClosingIterator<E>	findIterator(ExtendedPanacheMongoRepositoryBase<F,E> repositoryBase, org.bson.Document document)
ClosingIterator<E>	findIterator(RepositoryBaseInterface<E> repositoryBase, DbQuery query)
Stream<E>	findStream(RepositoryBaseInterface<E> repositoryBase, DbQuery query)

Methods inherited from class java.lang.Object

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

Field Details

MAX_LIST

public static final int MAX_LIST

See Also:

• Constant Field Values

Constructor Details

MongoStreamHelper

public MongoStreamHelper()

Constructor

Method Details

findStream

public Stream<E> findStream(RepositoryBaseInterface<E> repositoryBase,
 DbQuery query)
                     throws CcsDbException

Specified by:

findStream in interface StreamHelperInterface<F>

Parameters:

repositoryBase - the repository to use

query - the query

Returns:

the stream of elements

Throws:

CcsDbException

findIterator

public ClosingIterator<E> findIterator(ExtendedPanacheMongoRepositoryBase<F,E> repositoryBase,
 org.bson.Document document)
                                throws CcsDbException

Throws:

CcsDbException

findIterator

public ClosingIterator<E> findIterator(RepositoryBaseInterface<E> repositoryBase,
 DbQuery query)
                                throws CcsDbException

Specified by:

findIterator in interface StreamHelperInterface<F>

Parameters:

repositoryBase - the repository to use

query - the query

Returns:

the iterator of elements

Throws:

CcsDbException