因为有时候需要根据前台的多个条件来过滤数据！因此需要根据是否有值以及当前值是以什么方式来过滤。这样我们不可能一个一个值来判断吧！这样代码就有些难看了！而jFinal也没有提供这样的方法，而网上的一些解决方法感觉不太好用麻烦而且不够灵活！基于这个考虑我就自己写了一个工具类！目前来说用着还挺方便的！如果有什么不对或者改进的地方请指正，大家共同进步!
1 /** 2 * 用于生成JFinal的SQL查询语句<br> 3 * 类名称：Conditions<br> 4 * 创建人：yangxp<br> 5 * 创建时间：2014-1-19 上午11:22:26<br> 6 * 7 * @version v1.0.9 8 * 9 */ 10 public class Conditions { 11 static Logger log = Logger.getLogger(Conditions.class); 12 13 public static final String EQUAL = "EQUAL"; // 相等 14 15 public static final String NOT_EQUAL = "NOT_EQUAL"; // 不相等 16 17 public static final String LESS_THEN = "LESS_THEN"; // 小于 18 19 public static final String LESS_EQUAL = "LESS_EQUAL"; // 小于等于 20 21 public static final String GREATER_EQUAL = "GREATER_EQUAL"; // 大于等于 22 23 public static final String GREATER_THEN = "GREATER_THEN"; // 大于 24 25 public static final String FUZZY = "FUZZY"; // 模糊匹配 %xxx% 26 27 public static final String FUZZY_LEFT = "FUZZY_LEFT"; // 左模糊 %xxx 28 29 public static final String FUZZY_RIGHT = "FUZZY_RIGHT"; // 右模糊 xxx% 30 31 public static final String NOT_EMPTY = "NOT_EMPTY"; // 不为空值的情况 32 33 public static final String EMPTY = "EMPTY"; // 空值的情况 34 35 public static final String IN = "IN"; // 在范围内 36 37 public static final String NOT_IN = "NOT_IN"; // 不在范围内 38 39 // 用于接收SQL语句 40 private ThreadLocal<String> sql = new ThreadLocal<String>(); 41 42 // 用于接收参数数组 43 private ThreadLocal<ArrayList<Object>> paramList = new ThreadLocal<ArrayList<Object>>(); 44 45 // 用于存放设置的条件 46 private ThreadLocal<Map<String, Object[]>> conditionMap = new ThreadLocal<Map<String, Object[]>>(); 47 48 // 用于存放需要排除的字段 49 private ThreadLocal<Map<String, String>> excludeFieldMap = new ThreadLocal<Map<String, String>>(); 50 51 // 构造方法(表示没有设置查询类型的字段全部按照等于来处理) 52 public Conditions() { 53 conditionMap.set(new HashMap<String, Object[]>()); 54 excludeFieldMap.set(new HashMap<String, String>()); 55 } 56 57 // 构造方法(设置后表示字段所有的查询方式按照设置类型来处理，除非后面针对字段的重新设置) 58 public Conditions(String type) { 59 Map<String, Object[]> map = new HashMap<String, Object[]>(); 60 map.put("GLOBALTYPE", new String[] { type }); 61 conditionMap.set(map); 62 excludeFieldMap.set(new HashMap<String, String>()); 63 } 64 65 /*************************************************************************** 66 * 设置字段的查询类型 67 * 68 * @param QueryType 69 * 查询类型 70 * @param fieldName 71 * 字段名称数组 72 */ 73 public void setFiledQuery(String QueryType, String... filedName) { 74 if (StringUtils.isNotBlank(QueryType) && !Common.isNullOrEmpty(filedName)) { 75 Map<String, Object[]> map = conditionMap.get(); 76 map.put(QueryType, filedName); 77 conditionMap.set(map); 78 } 79 } 80 81 /*************************************************************************** 82 * 设置需要排除的字段 83 * 84 * setexcludeField<br> 85 * 86 * @param 参数说明 87 * @return 返回对象 88 * @Exception 异常对象 89 * 90 */ 91 public void setExcludeField(String... filedName) { 92 if (!Common.isNullOrEmpty(filedName)) { 93 Map<String, String> map = excludeFieldMap.get(); 94 for (String str : filedName) { 95 map.put(str, str); 96 } 97 excludeFieldMap.set(map); 98 } 99 } 100 101 /*************************************************************************** 102 * 查询空值或者不为空值的情况 setNullFieldQuery 103 * 104 * @param 参数说明 105 * @return 返回对象 106 * @Exception 异常对象 107 */ 108 public void setNullOrNotNullFieldQuery(String QueryType, String... filedName) { 109 if (StringUtils.isNotBlank(QueryType) && !Common.isNullOrEmpty(filedName)) { 110 if (!NOT_EMPTY.equals(QueryType) && !EMPTY.equals(QueryType)) { 111 log.error("空值或者非空查询的类型只能为：EMPTY、NOT_EMPTY"); 112 throw new RuntimeException("空值或者非空查询的类型只能为：EMPTY、NOT_EMPTY"); 113 } 114 Map<String, Object[]> map = conditionMap.get(); 115 map.put(QueryType, filedName); 116 conditionMap.set(map); 117 } 118 } 119 120 /*************************************************************************** 121 * <b>传值查询</b><br> 122 * 注：如果QueryType为<b>in</b>或者<b>not in</b>那么filedValue必须为一个list对象 123 * 124 * @param QueryType 125 * 查询类型 126 * @param fieldName 127 * 字段名称 128 * @param filedValue 129 * 字段值 130 */ 131 public void setValueQuery(String QueryType, String fieldName, Object filedValue) { 132 if (StringUtils.isNotBlank(QueryType) && StringUtils.isNotBlank(fieldName) && !Common.isNullOrEmpty(filedValue)) { 133 Object[] param = new Object[2]; 134 param[0] = fieldName; // 字段名 135 param[1] = filedValue;// 字段值 136 Map<String, Object[]> map = conditionMap.get(); 137 map.put(QueryType + "#" + fieldName, param);// 避免类型重复被覆盖掉就加上字段名 138 conditionMap.set(map); 139 } 140 } 141 142 /*************************************************************************** 143 * 用于生成SQL条件语句不带别名 144 * 145 * @param modelClass 146 * 必须继承于Model 147 */ 148 public void modelToCondition(Model<?> modelClass) { 149 modelToCondition(modelClass, null); 150 } 151 152 /*************************************************************************** 153 * 用于生成SQL条件语句不带别名 154 * 155 * @param RecordClass 156 * 必须是一个Record类 157 */ 158 public void recordToCondition(Record recordClass) { 159 recordToCondition(recordClass, null); 160 } 161 162 /*************************************************************************** 163 * 用于生成SQL条件语句带别名 164 * 165 * @param modelClass 166 * 必须继承于Model 167 * @param alias 168 * 别名 169 */ 170 public void modelToCondition(Model<?> modelClass, String alias) { 171 alias = StringUtils.isNotBlank(alias) ? alias + "." : ""; 172 if (modelClass != null) { 173 // 所有的字段 174 String[] fieldNames = modelClass.getAttrNames(); 175 // 字段名和值的map集合 176 Map<String, Object> valueMap = Common.modelToMap(modelClass); 177 178 // 构建查询条件 179 buildCondition(alias, fieldNames, valueMap); 180 } else { 181 if (!conditionMap.get().isEmpty()) { 182 buildCondition(alias, new String[] {}, new HashMap<String, Object>()); 183 } else { 184 sql.set(""); 185 paramList.set(new ArrayList<Object>()); 186 } 187 } 188 } 189 190 /*************************************************************************** 191 * 用于生成SQL条件语句不带别名 192 * 193 * @param RecordClass 194 * 必须是一个Record类 195 * @param alias 196 * 别名 197 */ 198 public void recordToCondition(Record recordClass, String alias) { 199 // 别名 200 alias = StringUtils.isNotBlank(alias) ? alias + "." : ""; 201 if (recordClass != null) { 202 // 所有的字段 203 String[] fieldNames = recordClass.getColumnNames(); 204 // 字段名和值的map集合 205 Map<String, Object> valueMap = Common.recordToMap(recordClass); 206 207 // 构建查询条件 208 buildCondition(alias, fieldNames, valueMap); 209 } else { 210 if (!conditionMap.get().isEmpty()) { 211 buildCondition(alias, new String[] {}, new HashMap<String, Object>()); 212 } else { 213 sql.set(""); 214 paramList.set(new ArrayList<Object>()); 215 } 216 } 217 } 218 219 /*************************************************************************** 220 * 构建条件语句 221 * 222 * @param resultMap 223 * 用于返回结果的map 224 * @param alias 225 * 别名 226 * @param fieldNames 227 * 所有查询的字段名称 228 * @param valueMap 229 * 所有的值的map 230 */ 231 private void buildCondition(String alias, String[] fieldNames, Map<String, Object> valueMap) { 232 try { 233 // 构建条件前先清空变量 234 sql.set(""); 235 paramList.set(new ArrayList<Object>()); 236 // 用于存放参数列表 237 ArrayList<Object> paramArrayList = new ArrayList<Object>(); 238 StringBuilder sb = new StringBuilder(); 239 // 所有的字段名称 240 Map<String, String> usedFieldMap = new HashMap<String, String>(); 241 if (!conditionMap.get().isEmpty()) { 242 for (Entry<String, Object[]> map : conditionMap.get().entrySet()) { 243 String queryType = map.getKey(); 244 Object[] array = map.getValue(); 245 if (queryType.indexOf("#") > 0) {// 传值查询 246 String fieldQueryType = queryType.split("#")[0]; 247 String fieldName = array[0] != null ? array[0].toString() : ""; 248 Object fieldValue = array[1]; 249 250 // 将设置过的字段保存到数组中 251 usedFieldMap.put(fieldName, fieldName); 252 // 构建SQL语句 253 buildSQL(sb, fieldQueryType, fieldName, fieldValue, alias, paramArrayList); 254 } else {// 字段查询 255 if (!"GLOBALTYPE".equals(queryType)) { 256 for (Object field : array) { 257 String filedName = field != null ? field.toString() : ""; 258 if (!excludeFieldMap.get().containsKey(filedName)) { 259 Object fieldValue = valueMap.get(filedName); 260 // 将设置过的字段保存到数组中 261 usedFieldMap.put(filedName, filedName); 262 // 构建查询语句 263 buildSQL(sb, queryType, filedName, fieldValue, alias, paramArrayList); 264 } 265 } 266 } 267 } 268 } 269 } 270 // 对没有设置条件的字段进行查询类型设置 271 String queryType = EQUAL; 272 if (conditionMap.get().containsKey("GLOBALTYPE")) { 273 String[] typeArray = (String[]) conditionMap.get().get("GLOBALTYPE"); 274 queryType = typeArray[0]; 275 } 276 // 对未使用过的字段进行build 277 for (String field : fieldNames) { 278 if (!usedFieldMap.containsKey(field)) { 279 Object fieldValue = valueMap.get(field); 280 // 构建查询语句 281 buildSQL(sb, queryType, field, fieldValue, alias, paramArrayList); 282 } 283 } 284 285 // 合并传入的参数到参数对象中 286 sql.set(sb.toString()); 287 paramList.set(paramArrayList); 288 conditionMap.set(new HashMap<String, Object[]>());// 清空本次的条件map 289 excludeFieldMap.set(new HashMap<String, String>());// 清空本次的排除字段 290 } catch (Exception e) { 291 log.error("Conditions构建SQL语句出现错误,请仔细检查!",e); 292 e.printStackTrace(); 293 } 294 } 295 296 /*************************************************************************** 297 * 构建SQL语句 298 * 299 * @param sb 300 * 用于拼接SQL语句 301 * @param queryType 302 * 查询类型 303 * @param fieldName 304 * 字段名称 305 * @param fieldValue 306 * 字段值 307 * @param alias 308 * 别名 309 * @return 310 */ 311 @SuppressWarnings("unchecked") 312 private void buildSQL(StringBuilder sb, String queryType, String fieldName, Object fieldValue, String alias, ArrayList<Object> params) { 313 // 非空的时候进行设置 314 if (!Common.isNullOrEmpty(fieldValue) && !Common.isNullOrEmpty(fieldName)) { 315 if (EQUAL.equals(queryType)) { 316 sb.append(" and " + alias + fieldName + " = ? "); 317 params.add(fieldValue); 318 } else if (NOT_EQUAL.equals(queryType)) { 319 sb.append(" and " + alias + fieldName + " <> ? "); 320 params.add(fieldValue); 321 } else if (LESS_THEN.equals(queryType)) { 322 sb.append(" and " + alias + fieldName + " < ? "); 323 params.add(fieldValue); 324 } else if (LESS_EQUAL.equals(queryType)) { 325 sb.append(" and " + alias + fieldName + " <= ? "); 326 params.add(fieldValue); 327 } else if (GREATER_THEN.equals(queryType)) { 328 sb.append(" and " + alias + fieldName + " > ? "); 329 params.add(fieldValue); 330 } else if (GREATER_EQUAL.equals(queryType)) { 331 sb.append(" and " + alias + fieldName + " >= ? "); 332 params.add(fieldValue); 333 } else if (FUZZY.equals(queryType)) { 334 sb.append(" and " + alias + fieldName + " like ? "); 335 params.add("%" + fieldValue + "%"); 336 } else if (FUZZY_LEFT.equals(queryType)) { 337 sb.append(" and " + alias + fieldName + " like ? "); 338 params.add("%" + fieldValue); 339 } else if (FUZZY_RIGHT.equals(queryType)) { 340 sb.append(" and " + alias + fieldName + " like ? "); 341 params.add(fieldValue + "%"); 342 } else if (IN.equals(queryType)) { 343 try { 344 List list = (List) fieldValue; 345 StringBuffer instr = new StringBuffer(); 346 sb.append(" and " + alias + fieldName + " in ("); 347 for (Object obj : list) { 348 instr.append(StringUtils.isNotBlank(instr) ? ",?" : "?"); 349 params.add(obj); 350 } 351 sb.append(instr + ") "); 352 } catch (Exception e) { 353 throw new RuntimeException("使用IN条件的时候传入的值必须是个List对象，否则将会转换出错!例如将 in('1','2','3')中的'1','2','3'分为三个分别添加到List中做为值传入.",e); 354 } 355 } else if (NOT_IN.equals(queryType)) { 356 try { 357 List list = (List) fieldValue; 358 StringBuffer instr = new StringBuffer(); 359 sb.append(" and " + alias + fieldName + " not in ("); 360 for (Object obj : list) { 361 instr.append(StringUtils.isNotBlank(instr) ? ",?" : "?"); 362 params.add(obj); 363 } 364 sb.append(instr + ") "); 365 } catch (Exception e) { 366 throw new RuntimeException("使用NOT IN条件的时候传入的值必须是个List对象，否则将会转换出错!例如将 not in('1','2','3')中的'1','2','3'分为三个分别添加到List中做为值传入.",e); 367 } 368 } 369 } else { 370 if (EMPTY.equals(queryType)) { 371 sb.append(" and " + alias + fieldName + " is null "); 372 } else if (NOT_EMPTY.equals(queryType)) { 373 sb.append(" and " + alias + fieldName + " is not null "); 374 } 375 } 376 } 377 378 public String getSql() { 379 return sql.get(); 380 } 381 382 public List<Object> getParamList() { 383 return paramList.get(); 384 } 385 }