首先,需要了解spring jdbc查询时,有三种回调方式来处理查询的结果集。可以参考 使用spring的JdbcTemplate进行查询的三种回调方式的比较,写得还不错。

1.返回对象(queryForObject)

有两种办法,即两个容易混淆的方法:

//
public Object queryForObject(String sql, Map<String, ?> paramMap, RowMapper rowMapper) {...}
//
public Object queryForObject(String sql, Map<String, ?> paramMap, Class requiredType) {...}

第一种方法是需要一个实现了RowMapper接口的对象实例作为第三个参数,实现RowMapper接口的类如下(其中类User.java有id、username、password、dept四个属性。):

public class UserRowMapper implements RowMapper<User>{
@Override
public User mapRow(ResultSet rs, int rowNum) throws SQLException {
User user = new User();
user.setId(rs.getInt(1));
user.setUsername(rs.getString(2));
user.setPassword(rs.getString(3));
user.setDept(4);
return user;
}
}

UserRowMapper.java类在dao中使用方法如下:

public User queryForObject(String sql, Map<String, Object> params) {
return this.getNamedParameterJdbcTemplate().queryForObject(sql,params,new UserRowMapper());
}

在JUnit测试,代码如下:

@Test
public void getUser(){
String sql = "select * from user where id = :id";
Map<String,Object> map = new HashMap<>();
map.put("id", 1);
User user = dao.queryForObject(sql, map);
System.out.println(user.getId());
}

输出结果为:1。

第二种方法,需要传一个类的类作为参数,在dao中使用方法如下:

public Object queryForObject(String sql, Map<String, Object> params,Class<T> ObjectClass) {
try {
return this.getNamedParameterJdbcTemplate().queryForObject(sql,params,new BeanPropertyRowMapper<T>(ObjectClass));
} catch (EmptyResultDataAccessException e) {
return null;//当查询记录为0时,会抛出EmptyResultDataAccessException异常,所以可以捕获它并做适当的处理,如返回null
    }
}

用JUnit测试,代码如下:

@Test
public void getUser(){
String sql = "select * from user where id = :id";
Map<String,Object> map = new HashMap<>();
map.put("id", 100);
User user = (User) dao.queryForObject(sql, map, User.class);
System.out.println(user.getId());
}

2.返回对象列表

通过实现接口org.springframework.jdbc.core.ResultSetExtractor来定制能实现需要的功能的类。此处以能返回一个List<User>的类作为示例,是仿造上面BeanPropertyRowMapper.java的源码实现的,但BeanPropertyRowMapper只处理一行记录:

public class BeanPropertyRowsMapper<T> implements ResultSetExtractor<List<T>> {

    private Class<T> clazz;
private Map<String,PropertyDescriptor> mappedFields; public BeanPropertyRowsMapper(Class<T> clazz){
initialize(clazz);
} public Class<T> getClazz() {
return clazz;
} public void initialize(Class<T> clazz){
this.clazz = clazz;
this.mappedFields = new HashMap<String, PropertyDescriptor>();
PropertyDescriptor[] pds = BeanUtils.getPropertyDescriptors(clazz);
for (PropertyDescriptor pd : pds) {
if (pd.getWriteMethod() != null) {
this.mappedFields.put(pd.getName().toLowerCase(), pd);
//将数据库中格式为"xxx_xxx"变成驼峰式"xxxXxx"才需要用到下面的代码
// String underscoredName = underscoreName(pd.getName());
// if (!pd.getName().toLowerCase().equals(underscoredName)) {
// this.mappedFields.put(underscoredName, pd);
// }
}
}
} // private String underscoreName(String name) {
// if (!StringUtils.hasLength(name)) {
// return "";
// }
// StringBuilder result = new StringBuilder();
// result.append(name.substring(0, 1).toLowerCase());
// for (int i = 1; i < name.length(); i++) {
// String s = name.substring(i, i + 1);
// String slc = s.toLowerCase();
// if (!s.equals(slc)) {
// result.append("_").append(slc);
// }
// else {
// result.append(s);
// }
// }
// return result.toString();
// } public List<T> extractData(ResultSet rs) throws SQLException, DataAccessException {
List<T> list = new ArrayList<T>();
Class<T> clazz = getClazz(); try {
while(rs.next()){
T t = BeanUtils.instantiate(clazz);
BeanWrapper bw = PropertyAccessorFactory.forBeanPropertyAccess(t);
ResultSetMetaData rsmd = rs.getMetaData();
int columnCount = rsmd.getColumnCount();
for(int i = 1;i<=columnCount;i++){
String column = StringUtils.capitalize(JdbcUtils.lookupColumnName(rsmd, i));
PropertyDescriptor pd = this.mappedFields.get(column.replaceAll(" ", "").toLowerCase());
if(pd != null){Object value = JdbcUtils.getResultSetValue(rs, i, pd.getPropertyType());
bw.setPropertyValue(pd.getName(),value);
}
}
list.add(t);
}
} catch (IllegalArgumentException e) {
e.printStackTrace();
}
return list;
}
}

BeanPropertyRowsMapper类在dao中使用方法如下:

public List<User> getUsers(String sql,Map<String, Object> params){
return this.getNamedParameterJdbcTemplate().query(sql, params, new BeanPropertyRowsMapper<User>(User.class));
}

用JUnit测试,代码如下:

@Test
public void getUsers(){
String sql = "select * from user where id < :id";
Map<String,Object> map = new HashMap<>();
map.put("id", 10);
List<User> list = dao.getUsers(sql, map);
System.out.println(list.size());
}

BeanPropertyRowsMapper类使用到了泛型,所以可以通用,只需在实例化的时候传递一个javabean的Class给构造方法即可。注意:javabean中的属性名与查询的结果集的列名必须一致或由数据库的列名转成的“驼峰式”,且必须有set方法,否则不一致的或没有set方法的属性不会有查询结果列与之对应,即该属性不会有值。

但是有时结果集只有很少的几列,比如只查询username(用户名)或者是用户名和密码的Map集合等,只需在extractData(ResultSet rs)方法中修改即可。下面来看实现ResultSetExtractor接口的另一种用法,示例如下:

private class UsernameList implements ResultSetExtractor<List<String>> {

    public List<String> extractData(ResultSet rs) throws SQLException, DataAccessException {
List<String> list = null;
while (rs.next()) {
if (list == null) {
list = new ArrayList<String>();
}
list.add(rs.getString(1));
}
return list;
}
}

在dao的使用方法如下:

public List<String> getUsernames(String sql,Map<String, Object> params){
return this.getNamedParameterJdbcTemplate().query(sql, params,new UsernameList());
}

用JUnit测试,代码如下:

@Test
public void getUsernames(){
String sql = "select username from user where id < 10";
Map<String,Object> map = new HashMap<>();
map.put("id", 10);
List<String>list = dao.getUsernames(sql, map);
System.out.println(list);
}

测试结果是打印了几个用户名。

第一种可用来返回javabean集合,第二种可用来处理只返回少数列的情况。

spring jdbc 查询结果返回对象、对象列表的更多相关文章

  1. 让JPA的Query查询接口返回Map对象

    在JPA 2.0 中我们可以使用entityManager.createNativeQuery()来执行原生的SQL语句. 但当我们查询结果没有对应实体类时,query.getResultList() ...

  2. Spring MVC学习笔记——返回JSON对象

    1.想要GET请求返回JSON对象,首先需要导入jackson-all-1.9.4.jar包 2.在控制器中添加不同的show()方法 //show()方法返回JSON对象 @RequestMappi ...

  3. Spring JDBC查询数据

    以下示例将展示如何使用Spring jdbc进行查询数据记录,将从student表中查询记录. 语法: String selectQuery = "select * from student ...

  4. spring jdbc查询 依赖JdbcTemplate这个类模版封装JDBC的操作

    package cn.itcast.spring.jdbc; import java.util.List; import org.springframework.jdbc.core.support.J ...

  5. Spring JDBC查询返回对象代码跟踪

    在封装方法的时候突然发现通过 ResultSetMetaData的getColumnCount()获取到的列明会多一列(ROWSTAT),而且每次的值都是1,目前没有找到相关信息,在国外网站上看到有类 ...

  6. SpringBoot JDBC 源码分析之——NamedParameterJdbcTemplate 查询数据返回bean对象

    1,NamedParameterJdbcTemplate 查询列表 /***测试***/ public void queyBeanTest(){ String s = "select * f ...

  7. Hibernate查询,返回new对象(注意这个新定义的类要有构造函数),使用sql带条件分页查询并且把结果显示到一个对象的集里面的解决方案

     IIndexDao package com.ucap.netcheck.dao; import com.ucap.netcheck.combination.beans.IndexCombinat ...

  8. tp5将查询数据返回为对象转为数组

    use think\Model; collection()->toArray(); $result = collection(model("Menu")->order( ...

  9. Spring Data Jpa 查询返回自定义对象

    转载请注明出处:http://www.wangyongkui.com/java-jpa-query. 今天使用Jpa遇到一个问题,发现查询多个字段时返回对象不能自动转换成自定义对象.代码如下: //U ...

随机推荐

  1. Asp.Net Core 简单的使用加密的Cookie保存用户状态

    在以前的Asp.Net中可以用 FormsAuthentication 类的一系列方法来使用加密的Cookie存储用户身份,使用简单,可控性强.在Asp.Net Core中是否也可以的?答案是当然的. ...

  2. 【spoj8222】Substrings

    #include <iostream> #include <cstdio> #include <cstring> #include <cmath> #i ...

  3. android 之 adb 启动问题的一般解决办法

    有时,当我们打开eclipse准备运行Android项目时,虚拟机会启动不了,并且会出现下面的报错. [2015-10-07 16:47:46 - Game2048] ---------------- ...

  4. [WPF疑难]避免窗口最大化时遮盖任务栏

    原文 [WPF疑难]避免窗口最大化时遮盖任务栏 [WPF疑难]避免窗口最大化时遮盖任务栏 周银辉 WPF窗口最大化时有个很不好的现象是:如果窗口的WindowStyle被直接或间接地设置为None后( ...

  5. 用xml建立仓库的逻辑层的操作

    package com.repositoryclient.xml; import java.io.FileNotFoundException; import java.io.FileOutputStr ...

  6. 笔试题&amp;amp;面试题:设计一个复杂度为n的算法找到单向链表倒数第m个元素

    设计一个复杂度为n的算法找到单向链表倒数第m个元素.最后一个元素假定是倒数第0个. 提示:双指针查找 相对于双向链表来说,单向链表仅仅能从头到尾依次訪问链表的各个节点,所以假设要找链表的倒数第m个元素 ...

  7. 数据源C3P0配置

    1.导入jar包(dbutil->QueryRunner) 2.C3P0Util工具类 package com.learning.utils; import java.beans.Propert ...

  8. 【转载】Windows上那些值得推荐的良心软件-整理 easybcd 引导工具 easyuefi 引导工具

    您查询的关键词是:清理dism知乎 以下是该网页在北京时间 2019年03月17日 21:56:16 的快照: 如果打开速度慢,可以尝试快速版:如果想更新或删除快照,可以投诉快照. 百度和网页 htt ...

  9. URL的解析,C语言实现

    源: URL的解析,C语言实现 c语言实现urlencode和decode

  10. [多线程]多线程(Thread、Runnable、Callable)

    1.继承Thread类,重写run方法 线程 是程序中的执行线程.Java 虚拟机允许应用程序并发地运行多个执行线程. 每个线程都有一个优先级,高优先级线程的执行优先于低优先级线程.每个线程都可以或不 ...