JavaWeb+Druid连接池+MySQL实现商品的多条件搜索与分页(超详细的~)

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,高可用系列 2核4GB
简介: JavaWeb+Druid连接池+MySQL实现商品的多条件搜索与分页(超详细的~)

引言

Hello, 大家好,我是Bug终结者,一周一更如约而至,同时文章持续更新,每周为大家带来我学习路上的一些经验,与代码分享,同时驱使自己进步,成为更好的自己。
同时,疫情又紧张了起来,小伙伴们都做好防护,戴好口罩,不给病毒留任何 趁虚而入的机会!身体健康第一!

所用技术栈

JavaWeb, Druid连接池, MySQL5.7

项目结构
在这里插入图片描述

为什么需要多条件搜索
答:因为在数据量过大时,展示的数据太多,这对用户造成很不好的操作,想要拿到一条数据,却不知如何下手,难道去数据库里找吗?

于是多条件搜索,多个条件并到一块,来显示符合条件的数据记录,这大大的提高的用户的操作体验,所以说,使用多条件搜索对用户友好,提高的程序的可维护性。

为什么需要分页
答:因为数据量过大展示的数据过多,一打开页面,让一次性展示出来这对服务器来说是个灾难,所以以分页展示来减轻服务器的压力,同时方便了操作,多条件搜索与分页结合可以说是完美搭配,大大提示程序的操作感,提高查询数据的速度。

@TOC

数据表

/*
SQLyog Ultimate v12.09 (64 bit)
MySQL - 5.7.24 
*********************************************************************
*/
/*!40101 SET NAMES utf8 */;

CREATE TABLE `t_goods` (
  `order_id` int(11) NOT NULL AUTO_INCREMENT,
  `goods_name` varchar(32) COLLATE utf8mb4_unicode_ci NOT NULL,
  `goods_price` decimal(10,3) DEFAULT NULL,
  `goods_addr` varchar(32) COLLATE utf8mb4_unicode_ci DEFAULT NULL,
  PRIMARY KEY (`order_id`)
) ENGINE=InnoDB AUTO_INCREMENT=12 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci


insert into `t_goods` (`order_id`, `goods_name`, `goods_price`, `goods_addr`) values('1','华为手机','2999.000','中国大陆');
insert into `t_goods` (`order_id`, `goods_name`, `goods_price`, `goods_addr`) values('2','苹果手机','5999.000','美国');
insert into `t_goods` (`order_id`, `goods_name`, `goods_price`, `goods_addr`) values('3','小米手机','1999.000','中国大陆');
insert into `t_goods` (`order_id`, `goods_name`, `goods_price`, `goods_addr`) values('4','三星手机','3999.000','韩国');
insert into `t_goods` (`order_id`, `goods_name`, `goods_price`, `goods_addr`) values('5','苹果','1.000','中国大陆');
insert into `t_goods` (`order_id`, `goods_name`, `goods_price`, `goods_addr`) values('6','香蕉','3.000','菲律宾');
insert into `t_goods` (`order_id`, `goods_name`, `goods_price`, `goods_addr`) values('7','桃','1.000','中国大陆');
insert into `t_goods` (`order_id`, `goods_name`, `goods_price`, `goods_addr`) values('8','DELL电脑','5999.000','美国');
insert into `t_goods` (`order_id`, `goods_name`, `goods_price`, `goods_addr`) values('9','联想电脑','4999.000','中国大陆');
insert into `t_goods` (`order_id`, `goods_name`, `goods_price`, `goods_addr`) values('10','苹果电脑','9999.000','美国');

分页

分页思路:

1.在展示商品页面写上前一页与后一页,这里我用的是组件,bootstarp
2.在servlet页面调用service层page方法,传入参数为当期页,每页的固定记录数,返回分页对象
3.service实现类调用dao层page方法返回list商品集合,调用getCount方法获取当期商品的总记录数,构造PageInfo对象将截取到的商品集合,总记录数,当前页,每页的固定数传入
4.PageInfo类中初始化参数,计算共多少页,修正当前页,如果小于1,固定为1,如果大于当前页,哪就为当前页,计算前一页与后一页,与修正当前页思路相同。

PageInfo类

package com.wanshi.bean;

import java.util.List;

public class PageInfo {

    private List goodsList;
    
    private Integer pageNumb;
    private Integer pageSize;
    private Integer pageCount;
    private Integer rowCount;
    private Integer prevPageNumb;
    private Integer nextPageNumb;
    
    public PageInfo(List<Goods> goodsList, Integer rowCount, Integer pageNumb, Integer pageSize) {
        // TODO Auto-generated constructor stub
        //先将商品集合,商品总记录数,每页的记录数赋值
        this.goodsList = goodsList;
        this.rowCount = rowCount;
        this.pageSize = pageSize;
    
        //计算共有几页
        this.pageCount = this.rowCount / this.pageSize;
        //如果页数不够,那就再补上一页
        if (this.rowCount % this.pageSize != 0) {
            this.pageCount ++;
        }
        //修正当前页
        this.pageNumb = pageNumb;
        if (this.pageNumb < 1) {
            this.pageNumb = 1;
        }
        if (this.pageNumb > this.pageCount) {
            this.pageNumb = this.pageCount;
        }
        
        //前一页
        this.prevPageNumb = this.pageNumb - 1;
        if (this.prevPageNumb < 1) {
            this.prevPageNumb = 1;
        }
        //后一页
        this.nextPageNumb = this.pageNumb + 1;
        if (this.nextPageNumb > this.pageCount) {
            this.nextPageNumb = this.pageCount;
        }
    }

    public List getGoodsList() {
        return goodsList;
    }

    public Integer getPageNumb() {
        return pageNumb;
    }

    public Integer getPageSize() {
        return pageSize;
    }

    public Integer getRowCount() {
        return rowCount;
    }

    public Integer getPrevPageNumb() {
        return prevPageNumb;
    }

    public Integer getNextPageNumb() {
        return nextPageNumb;
    }

    public Integer getPageCount() {
        return pageCount;
    }
    
}

多条件查询

1.获取要查询的条件,作为参数传入page方法,
2.传入dao层后,dao层实现类判断不为null时,搜索查询该条件的记录
具体代码如下

GoodsDaoImpl实现类

package com.wanshi.dao.impl;

import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import org.apache.commons.lang.math.NumberUtils;

import com.alibaba.druid.util.StringUtils;
import com.wanshi.bean.Goods;
import com.wanshi.dao.GoodsDao;

public class GoodsDaoImpl extends BaseDao implements GoodsDao{

    @Override
    public List<Goods> queryAllGoods() throws Exception {
        // TODO Auto-generated method stub
        QueryRunner qur = initQueryRunner();
        String sql = "select * from t_goods";
        List<Goods> goodsList = qur.query(sql, new BeanListHandler<Goods>(Goods.class));
        return goodsList;
    }

    public String strSql(String goodsName, String strMinPrice, String strMaxPrice, String goodsAddr) {
        String sql = "";
        if (!StringUtils.isEmpty(goodsName)) {
            sql += " and goods_name like '%"+goodsName+"%'";
        }
        if ((!StringUtils.isEmpty(strMinPrice) && NumberUtils.isNumber(strMinPrice))
                && (!StringUtils.isEmpty(strMaxPrice) && NumberUtils.isNumber(strMaxPrice))) {
            sql += "and goods_price between "+Double.valueOf(strMinPrice)+" and "+Double.valueOf(strMaxPrice)+" ";
        }
        if (!StringUtils.isEmpty(goodsAddr)) {
            sql += "and goods_addr like '%"+goodsAddr+"%'";
        }
        return sql;
    }
    
    @Override
    public List<Goods> page(Integer pageNumb, Integer pageSize, String goodsName, String strMinPrice, String strMaxPrice, String goodsAddr) throws Exception {
        // TODO Auto-generated method stub
        QueryRunner qur = initQueryRunner();
        String sql = "select * from t_goods where 1 = 1 ";
        sql += strSql(goodsName, strMinPrice, strMaxPrice, goodsAddr);
        sql += " limit ?, ?";
        return qur.query(sql, new BeanListHandler<Goods>(Goods.class), (pageNumb - 1) * pageSize, pageSize);
    }

    @Override
    public Integer getCount(String goodsName, String strMinPrice, String strMaxPrice, String goodsAddr) throws Exception {
        // TODO Auto-generated method stub
        QueryRunner qur = initQueryRunner();
        String sql = "select count(1) from t_goods where 1 = 1 ";
        sql += strSql(goodsName, strMinPrice, strMaxPrice, goodsAddr);
        Long count = qur.query(sql, new ScalarHandler<Long>());
        System.out.println(sql);
        System.out.println(count);
        return count.intValue();
    }

}

GetGoodsListServlet类

package com.wanshi.web;

import java.io.IOException;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.lang.StringUtils;

import com.wanshi.bean.PageInfo;
import com.wanshi.service.GoodsService;
import com.wanshi.service.impl.GoodsServiceImpl;

@WebServlet("/getGoodsList")
public class GetGoodsListServlet extends HttpServlet{

    private static final Integer pageSize = 3;
    
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        //获取查询条件
        String strPageNumb = req.getParameter("pageNumb");
        String goodsName = req.getParameter("goods_name");
        String strMinPrice = req.getParameter("goods_min_price");
        String strMaxPrice = req.getParameter("goods_max_price");
        String goodsAddr = req.getParameter("goods_addr");
        Integer pageNumb = 1;
        if (!StringUtils.isEmpty(strPageNumb)) {
            pageNumb = Integer.valueOf(strPageNumb);
        }
        GoodsService goodsService = new GoodsServiceImpl();
        //转发至列表页
        try {
            PageInfo pager = goodsService.page(pageNumb, pageSize, goodsName, strMinPrice, strMaxPrice, goodsAddr);
            req.setAttribute("goods_name", goodsName);
            req.setAttribute("min_price", strMinPrice);
            req.setAttribute("max_price", strMaxPrice);
            req.setAttribute("goods_addr", goodsAddr);
            req.setAttribute("pager", pager);
            req.getRequestDispatcher("/WEB-INF/list.jsp")
            .forward(req, resp);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

效果展示
在这里插入图片描述
查询商品名称包含苹果的
在这里插入图片描述
查询0-6000的价格并且是苹果的商品
在这里插入图片描述
查询产地为中国的商品
在这里插入图片描述

ok,效果展示到这里,今天的分享到此结束了,如果代码有我未找出的bug,愿各位大神在评论区指出,项目仅为学习中的经验分享,同时提升了能力,从而进入下一步的学习阶段,好了,我们下周见!

若有需要源码的,评论区留言

卑微博主在线求个赞~😁

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
22天前
|
SQL 关系型数据库 MySQL
JavaWeb基础1——MySQL
SQL语句、DDL、DML、DQL(分组查询、子查询等)、Navicat、约束、 一对多等数据库设计、多表查询(联合查询/连接查询)、事务、函数
JavaWeb基础1——MySQL
|
3月前
|
SQL 监控 druid
MySQL连接池DataSource怎样使用?
**摘要:** 本文深入讨论了数据库连接池的重要性,特别是DruidDataSource,它是阿里巴巴的高性能Java数据库连接池。DruidDataSource不仅提供连接管理,还包括SQL监控和性能优化功能。文中通过代码示例展示了如何配置和使用DruidDataSource,包括在Java应用和Spring Boot中的集成,并提到了SQL执行监控和连接池参数的合理设置,强调了定期监控和使用内置监控工具以优化应用性能。
MySQL连接池DataSource怎样使用?
|
3月前
|
SQL 监控 druid
MySQL连接池DataSource是什么?
**摘要:** 本文探讨了数据库连接池在高并发Web应用中的重要性,聚焦于DruidDataSource,一个高效的Java数据库连接池组件。DruidDataSource提供连接池管理、SQL监控及性能优化功能。文中通过代码示例展示了如何配置和使用DruidDataSource,包括在Java应用中的直接配置和在Spring Boot中的集成。此外,还提到了使用技巧,如合理设置连接池参数、定期监控调整以及利用Druid的内置监控工具优化性能。
|
3月前
|
关系型数据库 MySQL
MySQL 保姆级教程(七):用正则表达式进行搜索
MySQL 保姆级教程(七):用正则表达式进行搜索
|
3月前
|
SQL 监控 druid
MySQL连接池DataSource怎么使用?
**摘要:** 本文探讨了数据库连接池在高并发Web应用中的重要性,特别聚焦于阿里巴巴的DruidDataSource。DruidDataSource是一个高效的Java数据库连接池,包含监控、SQL防护和日志功能。文中通过示例展示了如何配置和使用DruidDataSource,包括在Java应用中的直接配置和在Spring Boot中的集成,并提到了启用SQL监控。此外,还分享了设置连接池参数的技巧,如合理设定初始、最大和最小连接数,并强调了定期监控和使用内置监控工具优化性能的重要性。
|
4月前
|
Java 关系型数据库 MySQL
JavaWeb基础第一章(MySQL数据库与JDBC)
JavaWeb基础第一章(MySQL数据库与JDBC)
|
4月前
|
SQL 供应链 关系型数据库
MySQL数据库基础练习系列4、商品库存管理系统
MySQL数据库基础练习系列4、商品库存管理系统
65 1
|
4月前
|
关系型数据库 MySQL 分布式数据库
PolarDB操作报错合集之无法创建mysql的连接池什么导致的
在使用阿里云的PolarDB(包括PolarDB-X)时,用户可能会遇到各种操作报错。下面汇总了一些常见的报错情况及其可能的原因和解决办法:1.安装PolarDB-X报错、2.PolarDB安装后无法连接、3.PolarDB-X 使用rpm安装启动卡顿、4.PolarDB执行UPDATE/INSERT报错、5.DDL操作提示“Lock conflict”、6.数据集成时联通PolarDB报错、7.编译DN报错(RockyLinux)、8.CheckStorage报错(源数据库实例被删除)、9.嵌套事务错误(TDDL-4604)。
|
4月前
|
SQL 存储 关系型数据库
Javaweb - MySQL 精华篇
Javaweb - MySQL 精华篇
24 0
|
4月前
|
SQL 网络协议 关系型数据库
mysql连接池的实现
mysql连接池的实现
20 0
下一篇
无影云桌面