Author: tchemit Date: 2013-12-18 23:54:50 +0100 (Wed, 18 Dec 2013) New Revision: 2940 Url: http://nuiton.org/projects/topia/repository/revisions/2940 Log: add findAllLazy(int batchsize) + open some api on AbstractTopiaDao Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java 2013-12-18 22:52:14 UTC (rev 2939) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java 2013-12-18 22:54:50 UTC (rev 2940) @@ -149,7 +149,7 @@ return newFromClause(null); } - protected String newFromClause(String alias) { + public String newFromClause(String alias) { String hql = "from " + getTopiaEntityEnum().getImplementationFQN(); if (StringUtils.isNotBlank(alias)) { hql += " " + alias; @@ -354,7 +354,7 @@ return result; } - protected TopiaQueryBuilderRunQueryStep<E> forHql(String hql, Map<String, Object> hqlParameters) { + public TopiaQueryBuilderRunQueryStep<E> forHql(String hql, Map<String, Object> hqlParameters) { TopiaQueryBuilderRunQueryStep<E> result = new TopiaQueryBuilderRunQueryStep<E>(this, hql, hqlParameters); return result; } @@ -504,7 +504,7 @@ return result; } - protected <K> List<K> find(String hql, Map<String, Object> hqlParameters, TopiaPagerBean pager) { + public <K> List<K> find(String hql, Map<String, Object> hqlParameters, TopiaPagerBean pager) { Preconditions.checkNotNull(hql); Preconditions.checkNotNull(hqlParameters); Preconditions.checkNotNull(pager); @@ -533,6 +533,12 @@ protected <K> Iterable<K> findAllLazy(String hql, Map<String, Object> hqlParameters) { + Iterable<K> result= findAllLazy(hql, hqlParameters, batchSize); + return result; + } + + protected <K> Iterable<K> findAllLazy(String hql, Map<String, Object> hqlParameters, int batchSize) { + Preconditions.checkNotNull(hql); Preconditions.checkNotNull(hqlParameters); @@ -870,6 +876,11 @@ } @Override + public Iterable<E> findAllLazy(int batchSize) { + return getNextStep().findAllLazy(batchSize); + } + + @Override public long count() { return getNextStep().count(); } @@ -979,6 +990,11 @@ } @Override + public Iterable<E> findAllLazy(int batchSize) { + return topiaDAO.findAllLazy(hql, hqlParameters, batchSize); + } + + @Override public List<E> find(int startIndex, int endIndex) { return topiaDAO.find(hql, hqlParameters, startIndex, endIndex); } Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java 2013-12-18 22:52:14 UTC (rev 2939) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java 2013-12-18 22:54:50 UTC (rev 2940) @@ -119,6 +119,8 @@ Iterable<E> findAllLazy(); + Iterable<E> findAllLazy(int batchSize); + List<E> find(int startIndex, int endIndex); List<E> find(TopiaPagerBean pager);