• J2EE基础-通用分页

    前言

    上次我们分享了自定义JSP标签foreach和select(http://t.csdn.cn/lfuiV)，今天分享的内容是通用分页。

    目录

    一、Junit的运用

    A、创建

    B、使用

    二、通用分页

    分页工具类

    中文乱码处理类

    数据库工具类

    回调函数接口类

    Dao方法

    以前写的BookDao 

    测试结果：

    使用通用分页的BookDao

    分页

    MySQL分页语句

    BaseDao：

    测试

    一、Junit的运用

    Junit是一个Java语言的单元测试框架，能够针对单个方法进行测试

    A、创建

    在我们要测试方法时，创建一个Junit进行测试

    在当前类中Ctrl+N就能弹出次窗口，搜索Junit就能出来

    B、使用

    1. package com.oyang.dao;
    2.  
    3. import java.util.List;
    4.  
    5. import org.junit.After;
    6. import org.junit.Before;
    7. import org.junit.Test;
    8.  
    9. import com.oyang.entity.Book;
    10. import com.oyang.util.PageBean;
    11.  
    12. /**
    13.  * Junit 能够针对单个方法进行测试
    14.  * 相对于main方法而言，测试耦合新降低了
    15.  * @author yang 
    16.  *
    17.  * @date 2022年6月21日下午10:03:58
    18.  */
    19. public class BookDaoTest {
    20.  
    21. 	@Before
    22. 	public void setUp() throws Exception {
    23. 		System.out.println("对测试方法执行前调用");
    24. 	}
    25.  
    26. 	@After
    27. 	public void tearDown() throws Exception {
    28. 		System.out.println("对测试方法执行之后调用");
    29.  
    30. 	}
    31. 	@Test
    32. 	public void testList1() throws Exception {
    33. 		System.out.println("测试代码1");
    34. 	}
    35. }

    右键，点击debug

     测试结果：

     我们在运行结果能看见，跟main方法的执行差不多，但是它们相比的话Junit还是有优势的。

    优点：可以针对单个方法进行测试，相较于main方法而言，测试耦合性降低了

    二、通用分页

    分页工具类

    PageBean ：

    1. package com.oyang.util;
    2.  
    3. /**
    4.  * 分页工具类
    5.  *
    6.  */
    7. public class PageBean {
    8.  
    9. 	private int page = 1;// 页码
    10.  
    11. 	private int rows = 10;// 页大小
    12.  
    13. 	private int total = 0;// 总记录数
    14.  
    15. 	private boolean pagination = true;// 是否分页
    16.  
    17. 	public PageBean() {
    18. 		super();
    19. 	}
    20.  
    21. 	public int getPage() {
    22. 		return page;
    23. 	}
    24.  
    25. 	public void setPage(int page) {
    26. 		this.page = page;
    27. 	}
    28.  
    29. 	public int getRows() {
    30. 		return rows;
    31. 	}
    32.  
    33. 	public void setRows(int rows) {
    34. 		this.rows = rows;
    35. 	}
    36.  
    37. 	public int getTotal() {
    38. 		return total;
    39. 	}
    40.  
    41. 	public void setTotal(int total) {
    42. 		this.total = total;
    43. 	}
    44.  
    45. 	public void setTotal(String total) {
    46. 		this.total = Integer.parseInt(total);
    47. 	}
    48.  
    49. 	public boolean isPagination() {
    50. 		return pagination;
    51. 	}
    52.  
    53. 	public void setPagination(boolean pagination) {
    54. 		this.pagination = pagination;
    55. 	}
    56.  
    57. 	/**
    58. 	 * 获得起始记录的下标
    59. 	 * 
    60. 	 * @return
    61. 	 */
    62. 	public int getStartIndex() {
    63. 		return (this.page - 1) * this.rows;
    64. 	}
    65.  
    66. 	@Override
    67. 	public String toString() {
    68. 		return "PageBean [page=" + page + ", rows=" + rows + ", total=" + total + ", pagination=" + pagination + "]";
    69. 	}
    70.  
    71. }

    中文乱码处理类

    EncodingFiter ：

    1. package com.oyang.util;
    2.  
    3. import java.io.IOException;
    4. import java.util.Iterator;
    5. import java.util.Map;
    6. import java.util.Set;
    7.  
    8. import javax.servlet.Filter;
    9. import javax.servlet.FilterChain;
    10. import javax.servlet.FilterConfig;
    11. import javax.servlet.ServletException;
    12. import javax.servlet.ServletRequest;
    13. import javax.servlet.ServletResponse;
    14. import javax.servlet.http.HttpServletRequest;
    15. import javax.servlet.http.HttpServletResponse;
    16.  
    17. /**
    18.  * 中文乱码处理
    19.  * 
    20.  */
    21. public class EncodingFiter implements Filter {
    22.  
    23. 	private String encoding = "UTF-8";// 默认字符集
    24.  
    25. 	public EncodingFiter() {
    26. 		super();
    27. 	}
    28.  
    29. 	public void destroy() {
    30. 	}
    31.  
    32. 	public void doFilter(ServletRequest request, ServletResponse response,
    33. 			FilterChain chain) throws IOException, ServletException {
    34. 		HttpServletRequest req = (HttpServletRequest) request;
    35. 		HttpServletResponse res = (HttpServletResponse) response;
    36.  
    37. 		// 中文处理必须放到 chain.doFilter(request, response)方法前面
    38. 		res.setContentType("text/html;charset=" + this.encoding);
    39. 		if (req.getMethod().equalsIgnoreCase("post")) {
    40. 			req.setCharacterEncoding(this.encoding);
    41. 		} else {
    42. 			Map map = req.getParameterMap();// 保存所有参数名=参数值(数组)的Map集合
    43. 			Set set = map.keySet();// 取出所有参数名
    44. 			Iterator it = set.iterator();
    45. 			while (it.hasNext()) {
    46. 				String name = (String) it.next();
    47. 				String[] values = (String[]) map.get(name);// 取出参数值[注：参数值为一个数组]
    48. 				for (int i = 0; i < values.length; i++) {
    49. 					values[i] = new String(values[i].getBytes("ISO-8859-1"),
    50. 							this.encoding);
    51. 				}
    52. 			}
    53. 		}
    54.  
    55. 		chain.doFilter(request, response);
    56. 	}
    57.  
    58. 	public void init(FilterConfig filterConfig) throws ServletException {
    59. 		String s = filterConfig.getInitParameter("encoding");// 读取web.xml文件中配置的字符集
    60. 		if (null != s && !s.trim().equals("")) {
    61. 			this.encoding = s.trim();
    62. 		}
    63. 	}
    64.  
    65. }

    数据库工具类

    DBAccess ：

    1. package com.oyang.util;
    2.  
    3. import java.io.InputStream;
    4. import java.sql.Connection;
    5. import java.sql.DriverManager;
    6. import java.sql.ResultSet;
    7. import java.sql.SQLException;
    8. import java.sql.Statement;
    9. import java.util.Properties;
    10.  
    11. /**
    12.  * 提供了一组获得或关闭数据库对象的方法
    13.  * 
    14.  */
    15. public class DBAccess {
    16. 	private static String driver;
    17. 	private static String url;
    18. 	private static String user;
    19. 	private static String password;
    20.  
    21. 	static {// 静态块执行一次，加载 驱动一次
    22. 		try {
    23. 			InputStream is = DBAccess.class
    24. 					.getResourceAsStream("config.properties");
    25.  
    26. 			Properties properties = new Properties();
    27. 			properties.load(is);
    28.  
    29. 			driver = properties.getProperty("driver");
    30. 			url = properties.getProperty("url");
    31. 			user = properties.getProperty("user");
    32. 			password = properties.getProperty("pwd");
    33.  
    34. 			Class.forName(driver);
    35. 		} catch (Exception e) {
    36. 			e.printStackTrace();
    37. 			throw new RuntimeException(e);
    38. 		}
    39. 	}
    40.  
    41. 	/**
    42. 	 * 获得数据连接对象
    43. 	 * 
    44. 	 * @return
    45. 	 */
    46. 	public static Connection getConnection() {
    47. 		try {
    48. 			Connection conn = DriverManager.getConnection(url, user, password);
    49. 			return conn;
    50. 		} catch (SQLException e) {
    51. 			e.printStackTrace();
    52. 			throw new RuntimeException(e);
    53. 		}
    54. 	}
    55.  
    56. 	public static void close(ResultSet rs) {
    57. 		if (null != rs) {
    58. 			try {
    59. 				rs.close();
    60. 			} catch (SQLException e) {
    61. 				e.printStackTrace();
    62. 				throw new RuntimeException(e);
    63. 			}
    64. 		}
    65. 	}
    66.  
    67. 	public static void close(Statement stmt) {
    68. 		if (null != stmt) {
    69. 			try {
    70. 				stmt.close();
    71. 			} catch (SQLException e) {
    72. 				e.printStackTrace();
    73. 				throw new RuntimeException(e);
    74. 			}
    75. 		}
    76. 	}
    77.  
    78. 	public static void close(Connection conn) {
    79. 		if (null != conn) {
    80. 			try {
    81. 				conn.close();
    82. 			} catch (SQLException e) {
    83. 				e.printStackTrace();
    84. 				throw new RuntimeException(e);
    85. 			}
    86. 		}
    87. 	}
    88.  
    89. 	public static void close(Connection conn, Statement stmt, ResultSet rs) {
    90. 		close(rs);
    91. 		close(stmt);
    92. 		close(conn);
    93. 	}
    94.  
    95. 	public static boolean isOracle() {
    96. 		return "oracle.jdbc.driver.OracleDriver".equals(driver);
    97. 	}
    98.  
    99. 	public static boolean isSQLServer() {
    100. 		return "com.microsoft.sqlserver.jdbc.SQLServerDriver".equals(driver);
    101. 	}
    102. 	
    103. 	public static boolean isMysql() {
    104. 		return "com.mysql.cj.jdbc.Driver".equals(driver);
    105. 	}
    106.  
    107. 	public static void main(String[] args) {
    108. 		Connection conn = DBAccess.getConnection();
    109. 		System.out.println(conn);
    110. 		DBAccess.close(conn);
    111. 		System.out.println("isOracle：" + isOracle());
    112. 		System.out.println("isSQLServer：" + isSQLServer());
    113. 		System.out.println("isMysql：" + isMysql());
    114. 		System.out.println("数据库连接(关闭)成功");
    115. 	}
    116. }

    回调函数接口类

    CallBack<T>：谁调用，谁处理

    1. package com.oyang.util;
    2.  
    3. import java.sql.ResultSet;
    4. import java.util.List;
    5.  
    6. /**
    7.  * 回调函数接口类的作用？
    8.  * 谁调用谁处理
    9.  * 
    10.  * @author yang 
    11.  *
    12.  * @date 2022年6月21日下午8:13:46
    13.  */
    14. public interface CallBack<T> {
    15. 	
    16. 	List<T> foreach(ResultSet rs);
    17. 	
    18. }

    Dao方法

    以前写的BookDao 

    1. package com.oyang.dao;
    2.  
    3. import java.sql.Connection;
    4. import java.sql.ResultSet;
    5. import java.sql.SQLException;
    6. import java.util.ArrayList;
    7. import java.util.List;
    8.  
    9. import com.oyang.entity.Book;
    10. import com.oyang.util.BaseDao;
    11. import com.oyang.util.DBAccess;
    12. import com.oyang.util.PageBean;
    13. import com.oyang.util.StringUtils;
    14.  
    15. public class BookDao extends BaseDao<Book>{
    16. 	//以前
    17. 	public List<Book> list(Book book,PageBean PageBean) throws Exception {
    18. 		 List<Book> list=new ArrayList<Book>();
    19. 		 /**
    20. 		  * 1.拿到数据库连接
    21. 		  * 2.拿到域定义对象  PreparedStatement
    22. 		  * 3.执行SQL语句
    23. 		  */
    24. 		Connection con = DBAccess.getConnection();//重复代码1
    25. 		String sql="select *from t_mvc_book where 1=1 ";
    26. 		String bname = book.getBname();
    27. 		if(StringUtils.isNotBlank(bname)) {
    28. 			sql+=" and bname like '%"+bname+"%' ";
    29. 		}
    30. 		int bid = book.getBid();
    31. 		if(bid!=0) {
    32. 			sql+=" and bid ="+bid;
    33. 		}
    34. 		java.sql.PreparedStatement ps = con.prepareStatement(sql);//重复代码2
    35. 		ResultSet rs=ps.executeQuery();//重复代码3
    36. 		while(rs.next()) {
    37. 			list.add(new Book(rs.getInt("bid"), rs.getString("bname"), rs.getFloat("price")));
    38. 		}
    39. 			return list;
    40. 	}
    41. }

    测试结果：

    使用通用分页的BookDao

    1. package com.oyang.dao;
    2.  
    3. import java.sql.Connection;
    4. import java.sql.ResultSet;
    5. import java.sql.SQLException;
    6. import java.util.ArrayList;
    7. import java.util.List;
    8.  
    9. import com.oyang.entity.Book;
    10. import com.oyang.util.BaseDao;
    11. import com.oyang.util.DBAccess;
    12. import com.oyang.util.PageBean;
    13. import com.oyang.util.StringUtils;
    14.  
    15. public class BookDao extends BaseDao<Book>{
    16. 	//版本一
    17. 	public List<Book> list2(Book book,PageBean PageBean) throws Exception {
    18. 		String sql="select *from t_mvc_book where 1=1 ";
    19. 		String bname = book.getBname();
    20. 		if(StringUtils.isNotBlank(bname)) {
    21. 			sql+=" and bname like '%"+bname+"%' ";
    22. 		}
    23. 		int bid = book.getBid();
    24. 		if(bid!=0) {
    25. 			sql+=" and bid ="+bid;
    26. 		}
    27. 			return super.executeQuery(sql, PageBean, rs->{
    28. 				 List<Book> list=new ArrayList<Book>();
    29. 				 try {
    30. 					while(rs.next()) {
    31. 							list.add(new Book(rs.getInt("bid"), rs.getString("bname"), rs.getFloat("price")));
    32. 						}
    33. 				} catch (SQLException e) {
    34. 					// TODO Auto-generated catch block
    35. 					e.printStackTrace();
    36. 				}
    37. 				return list; 
    38. 			}); 
    39. 	}
    40. }

    分页

    MySQL分页语句

    BaseDao：

    1. package com.oyang.util;
    2.  
    3. import java.sql.Connection;
    4. import java.sql.ResultSet;
    5. import java.util.ArrayList;
    6. import java.util.List;
    7.  
    8. import com.oyang.entity.Book;
    9.  
    10. /**
    11.  * T代表的实体类，可以说是Book/User/Goods...
    12.  * @author yang 
    13.  *
    14.  * @date 2022年6月21日下午7:11:08
    15.  */
    16. public class BaseDao<T> {//不知道查什么，就用泛型替代
    17. 	public List<T> executeQuery(String sql,PageBean PageBean,CallBack<T> CallBack) throws Exception {
    18. 		//SELECT * FROM `t_mvc_book` where bname like '%圣墟%' 
    19. 		//从上面得到select count(1) as y from (SELECT * FROM `t_mvc_book` where bname like '%圣墟%') a;
    20. 		//目的就是为了得到总记录数->得到总页数
    21. 		//SELECT * FROM `t_mvc_book` where bname like '%圣墟%'  limit 10,10;
    22. 		/**
    23. 		  * 1.拿到数据库连接
    24. 		  * 2.拿到域定义对象  PreparedStatement
    25. 		  * 3.执行SQL语句
    26. 		  */
    27. 		Connection con = null;//重复代码1
    28. 		java.sql.PreparedStatement ps = null;//重复代码2
    29. 		ResultSet rs=null;//重复代码3
    30. 		if(PageBean!=null&&PageBean.isPagination()) {//分页时
    31. 			String countSQL=getCountSQL(sql);
    32. 			 con=DBAccess.getConnection();//重复代码1
    33. 			 ps=con.prepareStatement(countSQL);//重复代码2
    34. 			 rs= ps.executeQuery();//重复代码3
    35. 			 if(rs.next()) {
    36. 				 //当前实体类就包含了总记录数
    37. 				 PageBean .setTotal(rs.getString("y"));
    38. 			 }
    39. 			 String pageSQL=getpageSQL(sql,PageBean);
    40. 			 con=DBAccess.getConnection();//重复代码1
    41. 			 ps=con.prepareStatement(pageSQL);//重复代码2
    42. 			 rs= ps.executeQuery();//重复代码3
    43. 		}else {// 不分页
    44. 			 con=DBAccess.getConnection();//重复代码1
    45. 			 ps=con.prepareStatement(sql);//重复代码2
    46. 			 rs= ps.executeQuery();//重复代码3
    47. 		}
    48. 		//查询不同的表，必然要处理不同的结果集,谁调用谁处理
    49. 		//接口是调用方来实现
    50. 		return CallBack.foreach(rs);
    51. 	}
    52.  
    53. 		/**
    54. 		 * 拼装第N页的数据的SQL
    55. 		 * @param sql 
    56. 		 * @return 
    57. 		 */
    58. 		private String getpageSQL(String sql, PageBean pageBean) {
    59. 			// TODO Auto-generated method stub
    60. 			return sql+" limit "+pageBean.getStartIndex() + ","+pageBean.getRows();
    61. 		}
    62.  
    63.  
    64. 		/**
    65. 		 * 拼装符合条件总记录数的sql
    66. 		 * @param sql
    67. 		 * @param pageBean
    68. 		 * @return
    69. 		 */
    70. 		private String getCountSQL(String sql) {
    71. 			// TODO Auto-generated method stub
    72. 			return "select count(1) as y from ("+sql+") t ";
    73. 		}
    74.  
    75. }

    测试

    打印结果：

     

     OK，今日的学习就到此结束啦，如果对个位看官有帮助的话可以留下免费的赞哦(收藏或关注也行),如果文章中有什么问题或不足以及需要改正的地方可以私信博主，博主会做出改正的。个位看官，小陽在此跟大家说拜拜啦！ 

  • 相关阅读:
    pcl--第五节 点云表面法线估算
    【C++】内联函数&auto&范围for循环&nullptr
    我的学校网页期末作业（纯html+css实现）
    动态住宅代理VS静态住宅代理，怎么选择？
    ORACLE设置快照回滚点
    Windows任务计划程序Task Scheduler笔记
    Oracle中ALTER TABLE的五种用法（一）
    3.蓝牙模块HC-08
    C# Sqlite数据库的搭建及使用技巧
    TensorFlow2从磁盘读取图片数据集的示例(tf.data.Dataset.list_files)
  • 原文地址：https://blog.csdn.net/weixin_65211978/article/details/125407191