zoukankan      html  css  js  c++  java
  • JDBC实现动态查询

     

    一 概述

    1.什么是动态查询?

    从多个查询条件中随机选择若干个组合成一个DQL语句进行查询,这一过程叫做动态查询。

    2.动态查询的难点

    可供选择的查询条件多,组合情况多,难以一一列举。

    3.最终查询语句的构成

    一旦用户向查询条件中输入数据,该查询条件就成为最终条件的一部分。

    二 基本原理

    1.SQL基本框架

    无论查询条件如何,查询字段与数据库是固定不变的,这些固定不变的内容构成SQL语句的基本框架,如

    select column... from table。

    2.StringBuilder形成DQL

    获取表单输入,如果请求参数非空,根据该请求参数生成查询条件,如“name=?”,“age>?”,将查询条件追加到基本框架中。利用StringBuilder来追加查询条件,这时出现一个问题,怎么判断生成的查询条件中是否需要添加“and”?
    如果该查询条件是第一个查询条件,不需要添加"and",否则需要添加“and”。问题变得复杂起来,每一次生成查询条件时都需要判断前面是否存在查询条件。
    我们可以考虑在SQL基本框架中添加一个查询条件,该查询条件的存在不影响查询结果,只充当占位角色,避免动态添加查询条件时判断是否需要添加“and”。根据这些要求,这一查询条件必须恒为真,这里我们取“1=1”,SQL基本框架就变成了

    select column...from table where 1=1

    每一个动态查询条件前段都添加“and”。

    3.List集合为占位符赋值

    有了DQL语句,接着需要考虑怎么为占位符赋值。可以在生成查询条件的同时,将占位符对应的参数收集起来,存入一个有序集合中,这里选择List集合,这样占位符就与List集合中的元素形成了顺序上的对应关系,第n个占位符对应第n个元素,遍历集合就可以为占位符赋值了。
    为占位符赋值时,不仅仅需要将数据传递给占位符,还需要选择与字段一致的数据类型,List集合仅仅存储数据已经不能够满足要求了,还需要添加字段信息,以区分不同的字段,选择不同的数据类型。这里集合中的元素采用“column+data”的形式。

    三 Demo

    1.数据库

    2.页面

    <!DOCTYPE html>
    <html>
    <head>
    <meta charset="UTF-8">
    <style>
    span {
        display: inline-block;
        width: 75px;
        margin-bottom: 15px;
    }
    </style>
    <title>动态查询</title>
    
    </head>
    <body>
        <form action="http://localhost:8080/JavaSETest/dynamicQueryServlet">
            <div>
                <span>姓名:</span><input type="text" name="name">
            </div>
            <div>
                <span>性别:</span><input type="text" name="sex">
            </div>
            <div>
                <span>年龄:</span><input type="text" name="age">
            </div>
            <div>
                <span>部门编号:</span><input type="text" name="depNo">
            </div>
            <div>
                <input type="submit"value="查询">&nbsp;<input type="reset"value="重置">
            </div>
        </form>
    </body>
    </html>

    3.服务器端(Servlet)

    package com.javase.jdbc;
    
    import java.io.IOException;
    import java.io.PrintWriter;
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.util.ArrayList;
    import java.util.List;
    
    import javax.servlet.ServletException;
    import javax.servlet.annotation.WebServlet;
    import javax.servlet.http.HttpServlet;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    @WebServlet("/dynamicQueryServlet")
    public class DynamicQueryServlet extends HttpServlet {
        private static final long serialVersionUID = 1L;
    
        @Override
        protected void doGet(HttpServletRequest request, HttpServletResponse response)
                throws ServletException, IOException {
            response.setContentType("text/html;charset=UTF-8");
            // 获取请求参数
            String name = request.getParameter("name");
            String sex = request.getParameter("sex");
            String age = request.getParameter("age");
            String depNo = request.getParameter("depNo");
    
            // 关键是"where 1=1",不需要再判断追加的查询条件前是否需要添加and,统一在前面添加and
            String baseSQL = "select name,sex,age,depNo from tb_employee where 1=1";
            StringBuilder builder = new StringBuilder();// 用于拼接SQL语句
            // 用于在占位符与参数值之间建立映射,占位符与参数值在各自序列中的排序一相同,例如name的占位符在SQL语句中排第一,name的参数值在
            // 集合中排第一。
            List<String> params = new ArrayList<String>();
            builder.append(baseSQL);
            if (isNotEmpty(name)) {
                builder.append(" and name=? ");
                params.add("name," + name);// 集合中不能仅仅存储具体的数据,还要存储字段名,以便后续根据字段名选择数据类型
            }
            if (isNotEmpty(sex)) {
                builder.append(" and sex=? ");
                params.add("sex," + sex);//List集合中不仅存储了表单输入数据,而且存储了对应字段
            }
            if (isNotEmpty(age)) {
                builder.append(" and age=? ");
                params.add("age," + age);
            }
            if (isNotEmpty(depNo)) {
                builder.append(" and depNo=?");
                params.add("depNo," + depNo);
            }
    
            Connection conn = null;
            PreparedStatement ps = null;
            ResultSet res = null;
            StringBuilder resStr = new StringBuilder();
            try {
                conn = getConnection();
                ps = conn.prepareStatement(builder.toString());
                for (int i = 0; i < params.size(); i++) {
                    String str = params.get(i);
                    String[] arr = str.split(",");//arr[0]储存字段信息,用于区分字段;arr[1]存储数据,用于为占位符赋值
                    // 因为为占位符赋值时,需要根据字段类型选择数据类型,所以在此判断类型
                    if (arr[0].equals("age")) {
                        int a = Integer.parseInt(arr[1]);
                        ps.setInt(i + 1, a);
                    } else {
                        ps.setString(i + 1, arr[1]);
                    }
                }
                res = ps.executeQuery();
                while (res.next()) {
                    String targetName = res.getString("name");
                    String targetSex = res.getString("sex");
                    int targetAge = res.getInt("age");
                    String targetDepNo = res.getString("depNo");
                    String temp = "name=" + targetName + "--" + "sex=" + targetSex + "--" + "age=" + targetAge + "--"
                            + "depNo=" + targetDepNo;
                    resStr.append(temp + "<br>");
                }
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
            } finally {
                if (res != null)
                    try {
                        res.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                if (ps != null)
                    try {
                        ps.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                if (conn != null)
                    try {
                        conn.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
            }
    
            PrintWriter out = response.getWriter();
            int length = resStr.length();
            if (length == 0)
                out.write("查询为空");
            else
                out.write(builder.toString() + "<br>" + resStr.toString());
        }
    
        /**
         * 判断请求参数是否存在,是否有数据输入
         * 
         * @param str
         * @return
         */
        private boolean isNotEmpty(String str) {
            if (str == null | str.equals("")) {
                return false;
            }
            return true;
        }
    
        public static Connection getConnection() throws ClassNotFoundException, SQLException {
            Class.forName("com.mysql.jdbc.Driver");
            return DriverManager.getConnection("jdbc:mysql://localhost:3366/test01", "root", "123");
        }
    
    }
  • 相关阅读:
    局域网组网总目录
    VLAN之间的通信
    DHCP
    ACL
    linux 程序后台运行
    VLAN
    VTP
    dubbox生产者与消费者案例
    String data jpa执行的增删改查
    StringBoot整合Mytais实现数据查询与分页
  • 原文地址:https://www.cnblogs.com/tonghun/p/7132469.html
Copyright © 2011-2022 走看看