Spring JdbcTemplate 查询分页

1.大家都有的page类

[java] view plaincopy

  1. public class CurrentPage<E> {  

  2.     private int pageNumber;  

  3.     private int pagesAvailable;  

  4.     private List<E> pageItems = new ArrayList<E>();  

  5.     public void setPageNumber(int pageNumber) {  

  6.         this.pageNumber = pageNumber;  

  7.     }  

  8.     public void setPagesAvailable(int pagesAvailable) {  

  9.         this.pagesAvailable = pagesAvailable;  

  10.     }  

  11.     public void setPageItems(List<E> pageItems) {  

  12.         this.pageItems = pageItems;  

  13.     }  

  14.     public int getPageNumber() {  

  15.         return pageNumber;  

  16.     }  

  17.     public int getPagesAvailable() {  

  18.         return pagesAvailable;  

  19.     }  

  20.     public List<E> getPageItems() {  

  21.         return pageItems;  

  22.     }  

  23. }  

 

2.分页的助手类

[java] view plaincopy

  1. import java.sql.ResultSet;  

  2. import java.sql.SQLException;  

  3. import java.util.List;  

  4. import org.springframework.dao.DataAccessException;  

  5. import org.springframework.jdbc.core.JdbcTemplate;  

  6. import org.springframework.jdbc.core.ResultSetExtractor;  

  7. import org.springframework.jdbc.core.simple.ParameterizedRowMapper;  

  8. public class PaginationHelper<E> {  

  9.     public CurrentPage<E> fetchPage(final JdbcTemplate jt,  

  10.             final String sqlCountRows, final String sqlFetchRows,  

  11.             final Object args[], final int pageNo, final int pageSize,  

  12.             final ParameterizedRowMapper<E> rowMapper) {  

  13.         // determine how many rows are available  

  14.         final int rowCount = jt.queryForInt(sqlCountRows, args);  

  15.         // calculate the number of pages  

  16.         int pageCount = rowCount / pageSize;  

  17.         if (rowCount > pageSize * pageCount) {  

  18.             pageCount++;  

  19.         }  

  20.         // create the page object  

  21.         final CurrentPage<E> page = new CurrentPage<E>();  

  22.         page.setPageNumber(pageNo);  

  23.         page.setPagesAvailable(pageCount);  

  24.         // fetch a single page of results  

  25.         final int startRow = (pageNo - 1) * pageSize;  

  26.         jt.query(sqlFetchRows, args, new ResultSetExtractor() {  

  27.             public Object extractData(ResultSet rs) throws SQLException,  

  28.                     DataAccessException {  

  29.                 final List pageItems = page.getPageItems();  

  30.                 int currentRow = 0;  

  31.                 while (rs.next() && currentRow < startRow + pageSize) {  

  32.                     if (currentRow >= startRow) {  

  33.                         pageItems.add(rowMapper.mapRow(rs, currentRow));  

  34.                     }  

  35.                     currentRow++;  

  36.                 }  

  37.                 return page;  

  38.             }  

  39.         });  

  40.         return page;  

  41.     }  

  42. }  

 

完了!下面看一看Dao的一个接口:

List<Client> getAllCompanyTest(int pageSize)throws DataAccessException;

接口的实现:

[java] view plaincopy

  1. @Override  

  2. public List<Client> getAllCompanyTest(int pageSize) throws DataAccessException {  

  3.     PaginationHelper<Client> ph = new PaginationHelper<Client>();  

  4.     List<Client> c=new ArrayList<Client>();  

  5.        CurrentPage<Client> p=ph.fetchPage(  

  6.                jdbcTemplate,    

  7.                "SELECT count(*) FROM angle_company WHERE state=?",  

  8.                "SELECT acid,corpname,contact,legal,tel,postcode,mail,address,summary,employee_eeid FROM angle_company WHERE state=?",  

  9.                new Object[]{JdbcSqlCollection.NORMALRECORD},                  

  10.                pageSize,  

  11.                JdbcSqlCollection.PAGERECORDS,  

  12.                new TestClientRowMap()  

  13.        );         

  14.        c=p.getPageItems();  

  15.     return c;  

  16. }  

最好还有一个ParameterizedRowMapper的实现类,就不贴原码了,下面是简单的伪代码

class TestClientRowMap implements ParameterizedRowMapper<Client>{

    @Override
    public Client mapRow(ResultSet rs, int arg1) throws SQLException {
        Client client=new Client();

        ...

         return client;

}


Spring JdbcTemplate 查询分页,古老的榕树,5-wow.com

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。