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="查询"> <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); } 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实现动态查询的实例详解,希望对大家有所帮助