C3P0---多条件查询

举报
brucexiaogui 发表于 2021/12/30 01:18:22 2021/12/30
【摘要】 C3P0---多条件查询 一、多条件查询实现原理介绍 1、使用c3p0连接池技术,首先创建一个c3p0连接池。(c3p0连接池实现的原理是通过读取配置文件,实例化ComboPooledDataSource()类创建DataSource类型的连接池) 2、写一个查询功能的servlet,接受用户查询的条件-------执行查询...

C3P0---多条件查询


一、多条件查询实现原理介绍

1、使用c3p0连接池技术,首先创建一个c3p0连接池。(c3p0连接池实现的原理是通过读取配置文件,实例化ComboPooledDataSource()类创建DataSource类型的连接池)

2、写一个查询功能的servlet,接受用户查询的条件-------执行查询------将结果封装到List<Bean>中转发到前端页面展示

3、写一个javaBean包含数据表格字段名称,实现servlet查询到的结果封装到javaBean中,同时提供jsp 展示页面读取javaBean中的数据。

4、写一个jsp页面实现用户提交查询条件和接收servlet返回的结果,遍历结果集展示查询的数据。


二、多条件查询的结构


三、1:先创建C3p0配置文件

c3p0-config.xml配置文件的名称和路径要和上面多条件查询截图一致,名称不可以随意写,位置必须在ClassPath路径。下面是配置文件内容:


  
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <c3p0-config><!-- 配置的根元素 -->
  3. <!-- 默认配置,如果没有指定则使用这个配置 -->
  4. <default-config>
  5. <!-- 连接的超时间时间,以秒 -->
  6. <property name="checkoutTimeout">3000</property>
  7. <!-- 空闲检查间隔,检查是否connection没有人用 -->
  8. <property name="idleConnectionTestPeriod">1000</property>
  9. <!-- 初始化的池大小 -->
  10. <property name="initialPoolSize">3</property>
  11. <!-- 最多有几个连接 -->
  12. <property name="maxPoolSize">5</property>
  13. <!-- 最少有几个连接 -->
  14. <property name="minPoolSize">3</property>
  15. <property name="autoCommitOnClose">true</property>
  16. <!-- 如果池中数据连接不够时一次增长多少个 -->
  17. <property name="acquireIncrement">2</property>
  18. <!-- connection最大的空闲时间 -->
  19. <property name="maxIdleTime">1000</property>
  20. <!--
  21. connection是从java代码到数据库的连接。所有statement都在上面传递sql语句。
  22. 那到这个connectoin最多可以同时让多少statement在上面传递数据呢?
  23. -->
  24. <property name="maxStatements">50</property>
  25. <!-- 以下连接信息 -->
  26. <property name="driverClass">com.mysql.jdbc.Driver</property>
  27. <property name="jdbcUrl">
  28. <![CDATA[jdbc:mysql://127.0.0.1:3306/long1?useUnicode=true&characterEncoding=UTF-8]]>
  29. </property>
  30. <property name="user">root</property>
  31. <property name="password">123456</property>
  32. </default-config>
  33. <named-config name="myconfig">
  34. <!-- 以下连接信息 -->
  35. <property name="driverClass">com.mysql.jdbc.Driver</property>
  36. <property name="jdbcUrl">
  37. <![CDATA[jdbc:mysql://127.0.0.1:3306/long1?useUnicode=true&characterEncoding=UTF-8]]>
  38. </property>
  39. <property name="user">root</property>
  40. <property name="password">123456</property>
  41. </named-config>
  42. </c3p0-config>


三、2:实现创建c3p0连接池实例:


  
  1. package com.test.c3p0;
  2. import java.sql.Connection;
  3. import java.sql.SQLException;
  4. import javax.sql.DataSource;
  5. import com.mchange.v2.c3p0.ComboPooledDataSource;
  6. public class C3p0Create {
  7. //1、申明一个datasource变量
  8. private static DataSource datasource;
  9. //2、获取c3p0链接池对象
  10. static{
  11. //以下实例化comboPooledDataSource默认读取classpath下的c3p0-config.xml
  12. //可以接收一个字符串,说明连接c3p0-config.xml中的哪一个命名的连接
  13. datasource = new ComboPooledDataSource();
  14. }
  15. //3、创建DataSource和Connection两个连接池的方法
  16. public static DataSource getDataSource(){
  17. return datasource;
  18. }
  19. public static Connection getConnection(){
  20. Connection con = null;
  21. try {
  22. con = datasource.getConnection();
  23. } catch (SQLException e) {
  24. e.printStackTrace();
  25. }
  26. return con;
  27. }
  28. }


四、创建javaBean为下面实现查询servlet做准备

1:创建一个javaBean,字段名称和数据表字段名称一致。

2:数据表格字段:

3:javaBean内容如下:


  
  1. package com.test.bean;
  2. public class StudentBean {
  3. private Integer id;
  4. private String namee;
  5. private String sex;
  6. private Integer birth;
  7. private String department;
  8. private String address;
  9. public Integer getId() {
  10. return id;
  11. }
  12. public void setId(Integer id) {
  13. this.id = id;
  14. }
  15. public String getNamee() {
  16. return namee;
  17. }
  18. public void setNamee(String namee) {
  19. this.namee = namee;
  20. }
  21. public String getSex() {
  22. return sex;
  23. }
  24. public void setSex(String sex) {
  25. this.sex = sex;
  26. }
  27. public Integer getBirth() {
  28. return birth;
  29. }
  30. public void setBirth(Integer birth) {
  31. this.birth = birth;
  32. }
  33. public String getDepartment() {
  34. return department;
  35. }
  36. public void setDepartment(String department) {
  37. this.department = department;
  38. }
  39. public String getAddress() {
  40. return address;
  41. }
  42. public void setAddress(String address) {
  43. this.address = address;
  44. }
  45. }


五、创建查询Servlet(核心部件)



  
  1. package com.test.servlet;
  2. import java.io.IOException;
  3. import java.io.PrintWriter;
  4. import java.sql.SQLException;
  5. import java.util.ArrayList;
  6. import java.util.List;
  7. import javax.servlet.ServletException;
  8. import javax.servlet.http.HttpServlet;
  9. import javax.servlet.http.HttpServletRequest;
  10. import javax.servlet.http.HttpServletResponse;
  11. import org.apache.commons.dbutils.QueryRunner;
  12. import org.apache.commons.dbutils.handlers.BeanListHandler;
  13. import com.test.bean.StudentBean;
  14. import com.test.c3p0.C3p0Create;
  15. public class QueryC3P0 extends HttpServlet {
  16. public void doPost(HttpServletRequest request, HttpServletResponse response)
  17. throws ServletException, IOException {
  18. response.setContentType("text/html;charset=UTF-8");
  19. PrintWriter out = response.getWriter();
  20. //1、设置编码格式
  21. request.setCharacterEncoding("UTF-8");
  22. //2、接收参数
  23. String id = request.getParameter("id");
  24. String namee = request.getParameter("namee");
  25. String sex = request.getParameter("sex");
  26. String birth = request.getParameter("birth");
  27. String department = request.getParameter("department");
  28. String address = request.getParameter("address");
  29. //输出用户查询的条件
  30. System.out.println("服务端接收的参数为:ID=="+id+"Name=="+namee+"Sex=="+sex+"Birth=="+birth+"department=="+department+"address=="+address);
  31. //3、申明参数的集合类
  32. List<Object> paramenter = new ArrayList<Object>();
  33. //4、创建sql语句
  34. String sql = "select * from student where 1=1";
  35. //5、查询条件判断
  36. if(id!=null && !id.trim().equals("")){
  37. //sql链接符必须空格,负责sql语法报错。例如下面" and id=?" 在and前面有一个空格
  38. sql+= " and id=?";
  39. paramenter.add(id);
  40. }
  41. if(namee!=null && !namee.trim().equals("")){
  42. sql+= " and namee like ?";
  43. paramenter.add("%"+namee+"%");
  44. }
  45. if(sex!=null && !sex.trim().equals("")){
  46. sql+=" and sex=?";
  47. paramenter.add(sex);
  48. }
  49. if(birth!=null && !birth.trim().equals("")){
  50. sql+=" and birth=?";
  51. paramenter.add(birth);
  52. }
  53. if(department!=null && !department.trim().equals("")){
  54. sql+=" and department like ?";
  55. paramenter.add("%"+department+"%");
  56. }
  57. if(address!=null && !address.trim().equals("")){
  58. sql+=" and address like ?";
  59. paramenter.add("%"+address+"%");
  60. }
  61. System.out.println("查询的SQL语句为:"+sql);
  62. //6、申明QueryRunner对象执行SQL语句,同时获取c3p0连接池
  63. QueryRunner run = new QueryRunner(C3p0Create.getDataSource());
  64. System.out.println("QueryRunner获取连接池对象为:==========="+run);
  65. //7、执行sql语句,获取结果
  66. try {
  67. List<StudentBean> list = run.query(sql, new BeanListHandler<StudentBean>(StudentBean.class),paramenter.toArray());
  68. //结果放到request属性中
  69. request.setAttribute("parame", list);
  70. } catch (SQLException e) {
  71. e.printStackTrace();
  72. }
  73. //8、转发到前端页面
  74. request.getRequestDispatcher("/jsp/query.jsp").forward(request,response);
  75. }
  76. }

六、创建提交查询提交和显示查询结果jsp页面


  
  1. <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
  2. <%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c"%>
  3. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  4. <html>
  5. <head>
  6. <title>My JSP 'index.jsp' starting page</title>
  7. <meta http-equiv="pragma" content="no-cache">
  8. <meta http-equiv="cache-control" content="no-cache">
  9. <meta http-equiv="expires" content="0">
  10. <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
  11. <meta http-equiv="description" content="This is my page">
  12. </head>
  13. <body>
  14. <p>以下是查询条件:</p>
  15. <form action="<c:url value='/QueryC3P0'/>" method="post">
  16. 编号:<input type="text" name="id"/><br/>
  17. 姓名:<input type="text" name="namee"/><br/>
  18. 性别:<select name="sex">
  19. <option value="">不限</option>
  20. <option value="男" <c:if test="${sex=='1'}">selected</c:if>>男</option>
  21. <option value="女" <c:if test="${sex=='0'}">selected</c:if>>女</option>
  22. </select>
  23. <br/>
  24. 出生:<input type="text" name="birth"/><br/>
  25. 院系:<input type="text" name="department"/><br/>
  26. 地址:<input type="text" name="address"/><br/>
  27. <input type="submit"/>
  28. </form>
  29. <hr/>
  30. <table border="1" width="80%">
  31. <tr>
  32. <td>ID</td>
  33. <td>Name</td>
  34. <td>sex</td>
  35. <td>birth</td>
  36. <td>department</td>
  37. <td>address</td>
  38. </tr>
  39. <c:forEach items="${parame}" var="p">
  40. <tr>
  41. <td>${p.id}</td>
  42. <td>${p.namee}</td>
  43. <%-- <td>${p.sex==0?'<font color="green"></font>':'<font color="red"></font>'}</td> --%>
  44. <td>${p.sex}</td>
  45. <td>${p.birth}</td>
  46. <td>${p.department}</td>
  47. <td>${p.address}</td>
  48. </tr>
  49. </c:forEach>
  50. </table>
  51. </body>
  52. </html>


七、测试查询结果

1、输入查询地址:http://127.0.0.1:8080/test18_1/jsp/query.jsp

2、测试结果:

文章来源: brucelong.blog.csdn.net,作者:Bruce小鬼,版权归原作者所有,如需转载,请联系作者。

原文链接:brucelong.blog.csdn.net/article/details/78105341

【版权声明】本文为华为云社区用户转载文章,如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。