Package io.clonecloudstore.common.database.postgre

Class PostgreStreamHelper<F,E extends F>

java.lang.Object

io.clonecloudstore.common.database.postgre.PostgreStreamHelper<F,E>

Type Parameters:

F - the DAO interface type

E - the real DAO type

All Implemented Interfaces:

StreamHelperInterface<E>

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

Postgre implementation of the StreamHelper

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_LIST

Constructor Summary

Constructors

Constructor	Description
PostgreStreamHelper()	Constructor

Method Summary

Modifier and Type	Method	Description
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

Constructor Details

PostgreStreamHelper

public PostgreStreamHelper()

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(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