首页 > > 网络编程 > Mysql >

JDBC实现动态查询

2018-06-17 23:54:20来源：未知阅读 ()

一概述

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");
    }

}