Examples of org.hibernate.Query.scroll()

org.hibernate.Query.scroll()
Return the query results as ScrollableResults. The scrollability of the returned results depends upon JDBC driver support for scrollable ResultSets.
@see ScrollableResults @return the result iterator @throws HibernateException

    protected ScrollableResults queryResults(int offset, FullTextSession session) {
        Query query =
                session.createQuery("from " + getEntityType().getName());
        query.setFirstResult(offset);
        query.setMaxResults(MAX_QUERY_ROWS);
        return query.scroll(ScrollMode.FORWARD_ONLY);
    }


}

View Full Code Here

                                        + "join fetch tft.textFlow.document "
                                        + "join fetch tft.textFlow.document.locale "
                                        + "join fetch tft.textFlow.document.projectIteration "
                                        + "join fetch tft.textFlow.document.projectIteration.project");
        query.setFetchSize(Integer.MIN_VALUE);
        return query.scroll(ScrollMode.FORWARD_ONLY);
    }
}

View Full Code Here

     */
    @Override
    public <RT> CloseableIterator<RT> iterate(Expression<RT> projection) {
        Query query = createQuery(projection);
        reset();
        ScrollableResults results = query.scroll(ScrollMode.FORWARD_ONLY);
        return new ScrollableResultsIterator<RT>(results);
    }


    @Override
    public List<Tuple> list(Expression<?>... args) {

View Full Code Here

     * @return
     */
    public ScrollableResults scroll(ScrollMode mode, Expression<?> expr) {
        Query query = createQuery(expr);
        reset();
        return query.scroll(mode);
    }


    /**
     * Return the query results as <tt>ScrollableResults</tt>. The
     * scrollability of the returned results depends upon JDBC driver

View Full Code Here

     * @return
     */
    public ScrollableResults scroll(ScrollMode mode, Expression<?>... args) {
        Query query = createQuery(args);
        reset();
        return query.scroll(mode);
    }


    /**
     * Enable caching of this query result set.
     * @param cacheable Should the query results be cacheable?

View Full Code Here


    @Override
    public <RT> CloseableIterator<RT> iterate(Expression<RT> projection) {
        Query query = createQuery(projection);
        reset();
        ScrollableResults results = query.scroll(ScrollMode.FORWARD_ONLY);
        return new ScrollableResultsIterator<RT>(results);
    }


    @Override
    public <RT> SearchResults<RT> listResults(Expression<RT> projection) {

View Full Code Here

    public SyntaxChecker checkScroll() {
      Session s = openSession();
      s.beginTransaction();
      Query query = s.createQuery( hql );
      preparer.prepare( query );
      query.scroll();
      s.getTransaction().commit();
      s.close();
      return this;
    }

View Full Code Here

    s.save( new Foo() );
    s.save( new Foo() );
    s.save( new Bar() );
    Query query = s.createQuery("select f, f.integer from Foo f");
    assertTrue( query.getReturnTypes().length==2 );
    ScrollableResults iter = query.scroll();
    assertTrue( iter.next() );
    assertTrue( iter.scroll(1) );
    FooProxy f2 = (FooProxy) iter.get()[0];
    assertTrue( f2!=null );
    assertTrue( iter.scroll(-1) );

View Full Code Here


    s = openSession();
    txn = s.beginTransaction();
    query = s.createQuery("select f, f.integer from Foo f");
    assertTrue( query.getReturnTypes().length==2 );
    iter = query.scroll();
    assertTrue( iter.next() );
    assertTrue( iter.scroll(1) );
    f2 = (FooProxy) iter.get()[0];
    assertTrue( f2!=null );
    assertTrue( f2.getString()!=null  && f2.getComponent().getImportantDates().length > 0 );

View Full Code Here

//      " select count(subject) as sub, subject from "
//          + AuditEvent.class.getName() + " GROUP BY subject) AS grp");


      Query q = s.createQuery("select count(ae.subject), ae.subject FROM "+ AE_CLASS + " AS ae "+
          "GROUP BY ae.subject ORDER BY count(ae.subject) desc");
      ScrollableResults sr = q.scroll();
      List<Object[]> l = new ArrayList<Object[]>();
      int i = 0;
      while(sr.next()) {
        System.out.println(i++);
        Object[] oa = sr.get();

View Full Code Here

0 1 2 3 4

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.