`
knight_black_bob
  • 浏览: 853102 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

mybatis pagehelp

阅读更多

 

 

使用 github 上 分页 插件

<dependency>
			<groupId>com.github.pagehelper</groupId>
			<artifactId>pagehelper</artifactId>
		</dependency>

 

 

在mybatis-config.xml 中添加 plugin

 

 <plugin interceptor="com.curiousby.util.PagePluginWrapper">
			<property name="dialect" value="mysql"/>
			<property name="pageSqlId" value=".*listPage.*"/>
		</plugin>

 

配置datasources

<!-- 配置mybitasSqlSessionFactoryBean -->
	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
		<property name="dataSource" ref="dataSource" />
		<property name="configLocation" value="classpath:mybatis-config.xml"></property>
		<property name="typeAliasesPackage" value="com.curiousby.entity"></property>
		<property name="mapperLocations" value="classpath:mapping/*.xml"></property>
	</bean>

 

 

package com.curiousby.util;

import java.lang.reflect.Field;
import java.util.HashMap;
import java.util.Properties;

import javax.xml.bind.PropertyException;

import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.mapping.BoundSql;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Signature;
import org.apache.ibatis.session.ResultHandler;
import org.apache.ibatis.session.RowBounds;
import org.springframework.util.StringUtils;

import com.github.pagehelper.PageHelper;

/**
 * @see com.curiosuby.util.PagePluginWrapper
 * @author baoyou E-mail:curiousby@163.com
 * @version 2017年3月14日 下午5:52:11
 * desc:
 */
@Intercepts(@Signature(type = Executor.class, method = "query", args = { MappedStatement.class,
        Object.class, RowBounds.class, ResultHandler.class }))
public class PagePluginWrapper extends PageHelper {

    // private static final Logger log = LoggerFactory.getLogger(PagePluginWrapper.class);

    private String pageSqlId = "";

    /**
     * 
     */
    public Object intercept(Invocation ivk) throws Throwable {
        // log.info("pageSqlId:" + pageSqlId);
        if (ivk.getTarget() instanceof Executor) {
            return this.invokePageIntercept(ivk);
        }
        return ivk.proceed();
    }

    private Object invokePageIntercept(Invocation ivk) throws Throwable {
        // log.info("invokePageIntercept");
        MappedStatement mappedStatement = (MappedStatement) ivk.getArgs()[0];
        // log.info("mappedStatement id:" + mappedStatement.getId());
        if (mappedStatement.getId().matches(pageSqlId)) { // 拦截需要分页的SQL
            Object parameter = ivk.getArgs()[1];
            BoundSql boundSql = mappedStatement.getSqlSource().getBoundSql(parameter);
            Object parameterObject = boundSql.getParameterObject();// 分页SQL<select>中parameterType属性对应的实体参数,即Mapper接口中执行分页方法的参数,该参数不得为空
            if (parameterObject == null) {
                throw new NullPointerException("parameterObject尚未实例化!");
            } else {
                boolean pagable = setPage(parameterObject);
                if (pagable) {
                    Object obj = super.intercept(ivk);
                    if (obj instanceof com.github.pagehelper.Page) {
                        com.github.pagehelper.Page page = (com.github.pagehelper.Page) obj;
                        this.setTotalPage(parameterObject, page);
                        return page.getResult();
                    }
                }
            }
        }
        return ivk.proceed();
    }

    private void setTotalPage(Object parameterObject, com.github.pagehelper.Page resultPage)
            throws Throwable {
        //log.info("setTotalPage");
        Page page = null;
        Integer totalResult = Integer.valueOf("" + resultPage.getTotal());
        if (parameterObject instanceof Page) { // 参数就是Page实体
            page = (Page) parameterObject;
            page.setTotalResult(totalResult);
        } else if (parameterObject instanceof java.util.HashMap) { // 参数是HashMap
            HashMap<Object, Object> parms = (HashMap<Object, Object>) parameterObject;
            parms.put("count", totalResult);
        } else { // 参数为某个实体,该实体拥有Page属性
            Field pageField = ReflectHelper.getFieldByFieldName(parameterObject, "page");
            if (pageField != null) {
                page = (Page) ReflectHelper.getValueByFieldName(parameterObject, "page");
                if (page == null) {
                    page = new Page();
                }
                page.setTotalResult(totalResult);
                ReflectHelper.setValueByFieldName(parameterObject, "page", page); // 通过反射,对实体对象设置分页对象
            } else {
                throw new NoSuchFieldException(parameterObject.getClass().getName()
                        + "不存在 page 属性!");
            }
        }
    }

    /**
     * 是否有分页参数,没有则不分页
     * @param parameterObject
     * @return
     * @throws Throwable
     */
    private boolean setPage(Object parameterObject) throws Throwable {
        // log.info("setpage");
        Page page = null;
        Integer pageNo = 1;
        Integer maxRow = 10;
        if (parameterObject instanceof Page) { // 参数就是Page实体
            page = (Page) parameterObject;
            pageNo = page.getCurrentPageDef();
            maxRow = page.getShowCount();
        } else if (parameterObject instanceof java.util.HashMap) { // 参数是HashMap
            HashMap<Object, Object> parms = (HashMap<Object, Object>) parameterObject;
            if (!parms.containsKey("pageNo") || !parms.containsKey("maxRow")) {
                return false;
            }
            pageNo = (Integer) parms.get("pageNo");
            maxRow = (Integer) parms.get("maxRow");
        } else { // 参数为某个实体,该实体拥有Page属性
            Field pageField = ReflectHelper.getFieldByFieldName(parameterObject, "page");
            if (pageField != null) {
                page = (Page) ReflectHelper.getValueByFieldName(parameterObject, "page");
                if (page == null) {
                    return false;
                } else {
                    pageNo = page.getCurrentPageDef();
                    maxRow = page.getShowCount();
                }
            } else {
                throw new NoSuchFieldException(parameterObject.getClass().getName()
                        + "不存在 page 属性!");
            }
        }
        //log.info("page:pageNo=" + pageNo + ",maxRow=" + maxRow);
        super.startPage(pageNo, maxRow);
        return true;
    }

    public void setProperties(Properties p) {
        super.setProperties(p);
        pageSqlId = p.getProperty("pageSqlId");
        if (StringUtils.isEmpty(pageSqlId)) {
            try {
                throw new PropertyException("pageSqlId property is not found!");
            } catch (PropertyException e) {
                e.printStackTrace();
            }
        }
    }
}

 

ReflectHelper

package com.curiousby.util;

import java.lang.reflect.Field;

/**
 * 反射 工具
 * @author baoyou E-mail:curiousby@163.com
 * @version 2017年3月14日 下午4:50:14
 * desc:
 */
public class ReflectHelper {
    /**
     * 获取obj对象fieldName的Field
     * @param obj
     * @param fieldName
     * @return
     */
    public static Field getFieldByFieldName(Object obj, String fieldName) {
        for (Class<?> superClass = obj.getClass(); superClass != Object.class; superClass = superClass
                .getSuperclass()) {
            try {
                return superClass.getDeclaredField(fieldName);
            } catch (NoSuchFieldException e) {
            }
        }
        return null;
    }

    /**
     * 获取obj对象fieldName的属性值
     * @param obj
     * @param fieldName
     * @return
     * @throws SecurityException
     * @throws NoSuchFieldException
     * @throws IllegalArgumentException
     * @throws IllegalAccessException
     */
    public static Object getValueByFieldName(Object obj, String fieldName)
            throws SecurityException, NoSuchFieldException,
            IllegalArgumentException, IllegalAccessException {
        Field field = getFieldByFieldName(obj, fieldName);
        Object value = null;
        if(field!=null){
            if (field.isAccessible()) {
                value = field.get(obj);
            } else {
                field.setAccessible(true);
                value = field.get(obj);
                field.setAccessible(false);
            }
        }
        return value;
    }

    /**
     * 设置obj对象fieldName的属性值
     * @param obj
     * @param fieldName
     * @param value
     * @throws SecurityException
     * @throws NoSuchFieldException
     * @throws IllegalArgumentException
     * @throws IllegalAccessException
     */
    public static void setValueByFieldName(Object obj, String fieldName,
            Object value) throws SecurityException, NoSuchFieldException,
            IllegalArgumentException, IllegalAccessException {
        Field field = obj.getClass().getDeclaredField(fieldName);
        if (field.isAccessible()) {
            field.set(obj, value);
        } else {
            field.setAccessible(true);
            field.set(obj, value);
            field.setAccessible(false);
        }
    }
}

 

page

package com.curiousby.util;

import java.io.Serializable;
/**
 * 反射 工具
 * @author baoyou E-mail:curiousby@163.com
 * @version 2017年3月14日 下午4:50:14
 * desc:
 */
public class Page implements Serializable {

    private int showCount = 10; // 每页显示记录数
    private int totalPage; // 总页数
    private int totalResult; // 总记录数
    private int currentPage; // 当前页
    private int currentResult; // 当前记录起始索引
    private boolean entityOrField; // true:需要分页的地方,传入的参数就是Page实体;false:需要分页的地方,传入的参数所代表的实体拥有Page属性
    private String pageStr; // 最终页面显示的底部翻页导航,详细见:getPageStr();

    public Page() {

    }

    public Page(int showCount, int currentPage) {
        this.showCount = showCount;
        this.currentPage = currentPage;
    }

    public int getTotalPage() {
        if (totalResult % showCount == 0) {
            totalPage = totalResult / showCount;
        } else {
            totalPage = totalResult / showCount + 1;
        }
        return totalPage;
    }

    public void setTotalPage(int totalPage) {
        this.totalPage = totalPage;
    }

    public int getTotalResult() {
        return totalResult;
    }

    public void setTotalResult(int totalResult) {
        this.totalResult = totalResult;
    }

    public int getCurrentPage() {
        if (currentPage <= 0) {
            currentPage = 1;
        }
        if (currentPage > getTotalPage()) {
            currentPage = getTotalPage();
        }
        return currentPage;
    }

    public int getCurrentPageDef() {
        return currentPage == 0 ? 1 : currentPage;
    }

    public void setCurrentPage(int currentPage) {
        this.currentPage = currentPage;
    }

    public String getPageStr() {
        StringBuffer sb = new StringBuffer();
        if (totalResult > 0) {
            sb.append("    <ul>\n");
            if (currentPage == 1) {
                sb.append("    <li class=\"pageinfo\">首页</li>\n");
                sb.append("    <li class=\"pageinfo\">上页</li>\n");
            } else {
                sb.append("    <li><a href=\"#@\" onclick=\"nextPage(1)\">首页</a></li>\n");
                sb.append("    <li><a href=\"#@\" onclick=\"nextPage(" + (currentPage - 1)
                        + ")\">上页</a></li>\n");
            }
            int showTag = 3; // 分页标签显示数量
            int startTag = 1;
            if (currentPage > showTag) {
                startTag = currentPage - 1;
            }
            int endTag = startTag + showTag - 1;
            for (int i = startTag; i <= totalPage && i <= endTag; i++) {
                if (currentPage == i) {
                    sb.append("<li class=\"current\">" + i + "</li>\n");
                } else {
                    sb.append("    <li><a href=\"#@\" onclick=\"nextPage(" + i + ")\">" + i
                            + "</a></li>\n");
                }
            }
            if (currentPage == totalPage) {
                sb.append("    <li class=\"pageinfo\">下页</li>\n");
                sb.append("    <li class=\"pageinfo\">尾页</li>\n");
            } else {
                sb.append("    <li><a href=\"#@\" onclick=\"nextPage(" + (currentPage + 1)
                        + ")\">下页</a></li>\n");
                sb.append("    <li><a href=\"#@\" onclick=\"nextPage(" + totalPage
                        + ")\">尾页</a></li>\n");
            }
            sb.append("    <li class=\"pageinfo\">第" + currentPage + "页</li>\n");
            sb.append("    <li class=\"pageinfo\">共" + totalPage + "页</li>\n");
            sb.append("</ul>\n");
            sb.append("<script type=\"text/javascript\">\n");
            sb.append("function nextPage(page){");
            sb.append("    if(true && document.forms[0]){\n");
            sb.append("        var url = document.forms[0].getAttribute(\"action\");\n");
            sb.append("        if(url.indexOf('?')>-1){url += \"&"
                    + (entityOrField ? "currentPage" : "page.currentPage") + "=\";}\n");
            sb.append("        else{url += \"?"
                    + (entityOrField ? "currentPage" : "page.currentPage") + "=\";}\n");
            sb.append("        document.forms[0].action = url+page;\n");
            sb.append("        document.forms[0].submit();\n");
            sb.append("    }else{\n");
            sb.append("        var url = document.location+'';\n");
            sb.append("        if(url.indexOf('?')>-1){\n");
            sb.append("            if(url.indexOf('currentPage')>-1){\n");
            sb.append("                var reg = /currentPage=\\d*/g;\n");
            sb.append("                url = url.replace(reg,'currentPage=');\n");
            sb.append("            }else{\n");
            sb.append("                url += \"&"
                    + (entityOrField ? "currentPage" : "page.currentPage") + "=\";\n");
            sb.append("            }\n");
            sb.append("        }else{url += \"?"
                    + (entityOrField ? "currentPage" : "page.currentPage") + "=\";}\n");
            sb.append("        document.location = url + page;\n");
            sb.append("    }\n");
            sb.append("}\n");
            sb.append("</script>\n");
        }
        pageStr = sb.toString();
        return pageStr;
    }

    public void setPageStr(String pageStr) {
        this.pageStr = pageStr;
    }

    public int getShowCount() {
        return showCount;
    }

    public void setShowCount(int showCount) {
        this.showCount = showCount;
    }

    public int getCurrentResult() {
        currentResult = (getCurrentPage() - 1) * getShowCount();
        if (currentResult < 0) {
            currentResult = 0;
        }
        return currentResult;
    }

    public void setCurrentResult(int currentResult) {
        this.currentResult = currentResult;
    }

    public boolean isEntityOrField() {
        return entityOrField;
    }

    public void setEntityOrField(boolean entityOrField) {
        this.entityOrField = entityOrField;
    }

}

 

package com.curiousby.util;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/** 
 * 分页返回数据
 * @see com.curiousby.RestPage
 * @author baoyou E-mail:curiousby@163.com
 * @version 2017年3月14日 下午4:50:33
 * desc:
 * @param <T>
 */
public class RestPage<T> implements Serializable {

    private static final long serialVersionUID = 5826522161371444844L;
    private List<T> list; // 对象记录结果集
    private int pages = 0; // 总页数
    private int limit = 10; // 每页显示记录数
    private int pageNumber = 1; // 当前页
    private long totalResults = 0; // 总记录数
    private int navigatePages = 5; // 导航页码数
    private boolean isLastPage = false; // 是否为最后一页
    private boolean isFirstPage = false; // 是否为第一页
    private boolean hasNextPage = false; // 是否有下一页
    private boolean hasPreviousPage = false; // 是否有前一页
    private Integer[] navigatePageNumbers; // 所有导航页号

    private HashMap<String, Object> otherHash; //新增结果集

    public RestPage() {
    }

    public RestPage(long total, int pageNumber) {
        init(total, pageNumber, limit);
    }

    public RestPage(long total, int pageNumber, int limit) {
        init(total, pageNumber, limit);
    }

    public RestPage(Page page) {
        if (page != null) {
            init(page.getTotalResult(), page.getCurrentPage(), page.getShowCount());
        } else {
            init(0, 0, 0);
        }
    }

    /**
     * @param params[count,pageNo,maxRow]
     */
    public RestPage(Map<String, Object> params) {
        if (null == params.get("count")) {
            init(0, params.get("pageNo") == null ? 0 : (Integer) params.get("pageNo"),
                    params.get("maxRow") == null ? 0 : (Integer) params.get("maxRow"));
        } else {
            init(Long.parseLong(params.get("count").toString()), (Integer) params.get("pageNo"),
                    (Integer) params.get("maxRow"));
        }
    }

    private void init(long total, int pageNumber, int limit) {
        // 设置基本参数
        this.totalResults = total;
        this.limit = limit;
        if (this.totalResults != 0) {
            this.pages = (int) ((this.totalResults - 1) / this.limit + 1);
        } else {
            this.pages = 0;
        }

        // 根据输入可能错误的当前号码进行自动纠正
        if (pageNumber < 1) {
            this.pageNumber = 1;
        } else if (pageNumber > this.pages) {
            this.pageNumber = this.pages;
        } else {
            this.pageNumber = pageNumber;
        }

        // 基本参数设定之后进行导航页面的计算
        calcNavigatePageNumbers();

        // 以及页面边界的判定
        judgePageBoudary();
    }

    /**
     * 计算导航页
     */
    private void calcNavigatePageNumbers() {
        // 当总页数小于或等于导航页码数时
        if (pages <= navigatePages) {
            navigatePageNumbers = new Integer[pages];
            for (int i = 0; i < pages; i++) {
                navigatePageNumbers[i] = i + 1;
            }
        } else { // 当总页数大于导航页码数时
            navigatePageNumbers = new Integer[navigatePages];
            int startNum = pageNumber - navigatePages / 2;
            int endNum = pageNumber + navigatePages / 2;

            if (startNum < 1) {
                startNum = 1;
                // (最前navigatePages页
                for (int i = 0; i < navigatePages; i++) {
                    navigatePageNumbers[i] = startNum++;
                }
            } else if (endNum > pages) {
                endNum = pages;
                // 最后navigatePages页
                for (int i = navigatePages - 1; i >= 0; i--) {
                    navigatePageNumbers[i] = endNum--;
                }
            } else {
                // 所有中间页
                for (int i = 0; i < navigatePages; i++) {
                    navigatePageNumbers[i] = startNum++;
                }
            }
        }
    }

    /**
     * 判定页面边界
     */
    private void judgePageBoudary() {
        isFirstPage = pageNumber == 1;
        isLastPage = pageNumber == pages && pageNumber != 1;
        hasPreviousPage = pageNumber > 1;
        hasNextPage = pageNumber < pages;
    }

    public void setList(List<T> list) {
        this.list = list;
    }

    /** 
     * 设置结果集返回分页对象
     * @return RestPage<T>
     */
    public RestPage<T> setListAndReturn(List<T> list) {
        this.list = list;
        return this;
    }

    /**
     * 得到当前页的内容
     * @return {List}
     */
    public List<T> getList() {
        return null == list ? new ArrayList<T>() : list;
    }

    public HashMap<String, Object> getOtherHash() {
        return otherHash;
    }

    public RestPage<T> setOtherHash(HashMap<String, Object> otherHash) {
        this.otherHash = otherHash;
        return this;
    }

    /** 
     * 得到记录总数
     * @return long
     */
    public long getTotalResults() {
        return totalResults;
    }

    /**
     * 得到每页显示多少条记录
     * @return {int}
     */
    public int getLimit() {
        return limit;
    }

    /**
     * 得到页面总数
     * 
     * @return {int}
     */
    public int getPages() {
        return pages;
    }

    /**
     * 得到当前页号
     * 
     * @return {int}
     */
    public int getPageNumber() {
        return pageNumber;
    }

    /**
     * 得到所有导航页号
     * 
     * @return {int[]}
     */
    public Integer[] getNavigatePageNumbers() {
        return navigatePageNumbers;
    }

    public boolean isFirstPage() {
        return isFirstPage;
    }

    public boolean isLastPage() {
        return isLastPage;
    }

    /**
     * 
     * @return
     */
    public boolean hasPreviousPage() {
        return hasPreviousPage;
    }

    /**
     * 
     * @return
     */
    public boolean hasNextPage() {
        return hasNextPage;
    }

    /**
     * 
     */
    public String toString() {
        StringBuffer sb = new StringBuffer();
        sb.append("[").append("total=").append(totalResults).append(",pages=").append(pages)
                .append(",pageNumber=").append(pageNumber).append(",limit=").append(limit)
                .append(",isFirstPage=").append(isFirstPage).append(",isLastPage=")
                .append(isLastPage).append(",hasPreviousPage=").append(hasPreviousPage)
                .append(",hasNextPage=").append(hasNextPage).append(",navigatePageNumbers=");
        int len = navigatePageNumbers.length;
        if (len > 0) {
            sb.append(navigatePageNumbers[0]);
        }
        for (int i = 1; i < len; i++) {
            sb.append(" " + navigatePageNumbers[i]);
        }
        sb.append(",list.size=" + list.size());
        sb.append("]");
        return sb.toString();
    }
}

 

pageinfo

public class PageInfo {
    int pageNum = Constants.DEFAUL_PAGE_NUM; // 页号
    int pageSize = Constants.DEFAUL_PAGE_SIZE; // 每页数据条数

    public int getPageNum() {
        return pageNum;
    }

    public void setPageNum(int pageNum) {
        this.pageNum = pageNum;
    }

    public int getPageSize() {
        return pageSize;
    }

    public void setPageSize(int pageSize) {
        this.pageSize = pageSize;
    }

}

 

 

mapper

public interface UserMapper {
   
    
    
    RestPage<User> listPage(Map<String, Object> map) ;
    
}

 

controller

 @RequestMapping(value = "/all")
     @ResponseBody
     public  RestPage<User> all(PageInfo page){
        Map<String, Object> filter = new HashMap<String, Object>();
        page.setPageSize(1);
        filter.put("pageNo", page.getPageNum());
        filter.put("maxRow", page.getPageSize());
        RestPage<User> listPage = userService.listPage(filter); 
        
        
        return listPage;
     }

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

捐助开发者

在兴趣的驱动下,写一个免费的东西,有欣喜,也还有汗水,希望你喜欢我的作品,同时也能支持一下。 当然,有钱捧个钱场(右上角的爱心标志,支持支付宝和微信捐助),没钱捧个人场,谢谢各位。



 
 
 谢谢您的赞助,我会做的更好!

 

  

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics