一 概述
1.什么是动态查询?
从多个查询条件中随机选择若干个组合成一个DQL语句进行查询,这一过程叫做动态查询。
2.动态查询的难点
可供选择的查询条件多,组合情况多,难以一一列举。
3.最终查询语句的构成
一旦用户向查询条件中输入数据,该查询条件就成为最终条件的一部分。
二 基本原理
1.SQL基本框架
无论查询条件如何,查询字段与数据库是固定不变的,这些固定不变的内容构成SQL语句的基本框架,如
1
|
select column ... from table 。
|
2.StringBuilder形成DQL
获取表单输入,如果请求参数非空,根据该请求参数生成查询条件,如“name=?”,“age>?”,将查询条件追加到基本框架中。利用StringBuilder来追加查询条件,这时出现一个问题,怎么判断生成的查询条件中是否需要添加“and”?
如果该查询条件是第一个查询条件,不需要添加"and",否则需要添加“and”。问题变得复杂起来,每一次生成查询条件时都需要判断前面是否存在查询条件。
我们可以考虑在SQL基本框架中添加一个查询条件,该查询条件的存在不影响查询结果,只充当占位角色,避免动态添加查询条件时判断是否需要添加“and”。根据这些要求,这一查询条件必须恒为真,这里我们取“1=1”,SQL基本框架就变成了
1
|
select column...from table where 1 = 1
|
每一个动态查询条件前段都添加“and”。
3.List集合为占位符赋值
有了DQL语句,接着需要考虑怎么为占位符赋值。可以在生成查询条件的同时,将占位符对应的参数收集起来,存入一个有序集合中,这里选择List集合,这样占位符就与List集合中的元素形成了顺序上的对应关系,第n个占位符对应第n个元素,遍历集合就可以为占位符赋值了。
为占位符赋值时,不仅仅需要将数据传递给占位符,还需要选择与字段一致的数据类型,List集合仅仅存储数据已经不能够满足要求了,还需要添加字段信息,以区分不同的字段,选择不同的数据类型。这里集合中的元素采用“column+data”的形式。
三 Demo
1.数据库
2.页面
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
<!DOCTYPE html>
<html>
<head>
<meta charset= "UTF-8" >
<style>
span {
display: inline-block;
width: 75px;
margin-bottom: 15px;
}
</style>
<title>动态查询</title>
</head>
<body>
<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= "查询" > <input type= "reset" value= "重置" >
</div>
</form>
</body>
</html>
|
3.服务器端(Servlet)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
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);
}
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" );
}
}
|
以上所述是小编给大家介绍的Java中JDBC实现动态查询的实例详解,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对服务器之家网站的支持!
原文链接:http://www.cnblogs.com/tonghun/archive/2017/07/07/7132469.html