org.turro.jpa.stream.DaoStream< T > Class Template Reference

Public Member Functions
	DaoStream (Dao dao, String query)
	DaoStream (Dao dao, WhereClause wc)
	DaoStream (Dao dao, SqlClause sc)
	DaoStream (Dao dao, AbstractJpaQuery< T > query)
Stream< T >	stream ()
Stream< T >	stream (int batchSize)

Static Public Member Functions
static AtomicCounter	getCounter ()

Detailed Description

Author

Lluis Turró Cutiller lluis.nosp@m.@tur.nosp@m.ro.or.nosp@m.g

Definition at line 34 of file DaoStream.java.

Constructor & Destructor Documentation

DaoStream() [1/4]

org.turro.jpa.stream.DaoStream< T >.DaoStream	(	Dao	dao,
		String	query
	)

Definition at line 43 of file DaoStream.java.

                                          {
    this(dao, new WhereClause());
    wc.addClause(query);
  }

Here is the call graph for this function:

DaoStream() [2/4]

org.turro.jpa.stream.DaoStream< T >.DaoStream	(	Dao	dao,
		WhereClause	wc
	)

Definition at line 48 of file DaoStream.java.

                                            {
    this.dao = dao;
    this.wc = wc;
    this.sc = null;
    this.query = null;
  }

DaoStream() [3/4]

org.turro.jpa.stream.DaoStream< T >.DaoStream	(	Dao	dao,
		SqlClause	sc
	)

Definition at line 55 of file DaoStream.java.

                                          {
    this.dao = dao;
    this.wc = null;
    this.sc = sc;
    this.query = null;
  }

DaoStream() [4/4]

org.turro.jpa.stream.DaoStream< T >.DaoStream	(	Dao	dao,
		AbstractJpaQuery< T >	query
	)

Definition at line 62 of file DaoStream.java.

                                                       {
    this.dao = dao;
    this.wc = null;
    this.sc = null;
    this.query = query;
  }

Member Function Documentation

getCounter()

static AtomicCounter org.turro.jpa.stream.DaoStream< T >.getCounter ( )

static

Definition at line 136 of file DaoStream.java.

                                           {
    return openStreams;
  }

stream() [1/2]

Stream<T> org.turro.jpa.stream.DaoStream< T >.stream

(

)

Definition at line 75 of file DaoStream.java.

                            {
    return stream(100);
  }

Here is the caller graph for this function:

stream() [2/2]

Stream<T> org.turro.jpa.stream.DaoStream< T >.stream

(

int

batchSize

)

Definition at line 79 of file DaoStream.java.

                                         {
    manager = new DaoManager(dao);
    Query q = null;
    if(query != null) {
      q = (Query) manager.createQuery(query.query());
    } else if(wc != null) {
      q = (Query) manager.createQuery(wc.getClause());
      wc.setNamedParameters(q);
    } else if(sc != null) {
      q = (Query) manager.createQuery(sc.clause());
      manager.setNamedParameters(q, sc.getNamedValues());
    }
    if(q != null) {
      //q.setReadOnly(true);
      //q.setLockMode(LockModeType.NONE);
      //q.setFetchSize(batchSize);
      openStreams.increment();
      return (Stream<T>) q.<T>stream().onClose(() -> {
        manager.close();
        openStreams.decrement();
      });
    }
    return null;
//    results = q.scroll(ScrollMode.FORWARD_ONLY);
//    return Stream
//            .generate(() -> next(batchSize))
//            .takeWhile(Predicate.not(List::isEmpty))
//            .flatMap(List::stream)
//            .onClose(() -> {
//              results.close();
//              manager.close();
//              openStreams.decrement();
//            });
  }

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• DaoStream.java