Mybatis超详细插件机制解析，弄懂拦截器So easy

  private void setPageParameter(String sql, Connection connection, MappedStatement mappedStatement, 

                 BoundSql boundSql, Page page) { 

    // 记录总记录数 

    String countSql = "select count(0) from (" + sql + ") temp"; 

    PreparedStatement countStmt = null; 

    ResultSet rs = null; 

    try { 

      countStmt = connection.prepareStatement(countSql); 

      BoundSql countBS = new BoundSql(mappedStatement.getConfiguration(), countSql, 

          boundSql.getParameterMappings(), boundSql.getParameterObject()); 

      setParameters(countStmt, mappedStatement, countBS, boundSql.getParameterObject()); 

      rs = countStmt.executeQuery(); 

      int totalCount = 0; 

      if (rs.next()) { 

        totalCount = rs.getInt(1); 

      } 

      page.setTotal(totalCount); 

      int totalPage = totalCount / page.getPageSize() + ((totalCount % page.getPageSize() == 0) ? 0 : 1); 

      page.setPages(totalPage); 

    } catch (SQLException e) { 

      log.error("Ignore this exception", e); 

    } finally { 

      try { 

        rs.close(); 

      } catch (SQLException e) { 

        log.error("Ignore this exception", e); 

      } 

      try { 

        countStmt.close(); 

      } catch (SQLException e) { 

        log.error("Ignore this exception", e); 

      } 

    } 

  } 

  /** 

   * 代入参数值 

   * 

   * @param ps 

   * @param mappedStatement 

   * @param boundSql 

   * @param parameterObject 

   * @throws SQLException 

   */ 

  private void setParameters(PreparedStatement ps, MappedStatement mappedStatement, BoundSql boundSql, 

                Object parameterObject) throws SQLException { 

    ParameterHandler parameterHandler = new DefaultParameterHandler(mappedStatement, parameterObject, boundSql); 

    parameterHandler.setParameters(ps); 

  } 

  @Data //采用lombok插件编译 

  public static class Page<E> { 

    private int pageNum; 

    private int pageSize; 

    private int startRow; 

    private int endRow; 

    private long total; 

    private int pages; 

    private List<E> result; 

    public Page(int pageNum, int pageSize) { 

      this.pageNum = pageNum; 

      this.pageSize = pageSize; 

      this.startRow = pageNum > 0 ? (pageNum - 1) * pageSize : 0; 

      this.endRow = pageNum * pageSize; 

    } 

（编辑：应用网_阳江站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!