JdbcTemplate类声明了几个重载的query()模板方法来控制整个查询过程,就像进行更新数据操作一样,通过实现PreparedStatementCreator和PreparedStatementSetter接口,也可以覆盖语句创建任务。

1,用RowCallbackHandler提取数据

RowCallbackHandler是允许处理结果集当前行的主要接口,JdbcTemplate中的一个query()方法能替你迭代结果集,并为每一行调用RowCallbackHandler,因此,对于返回结果集中的每一行,processRow()方法都会被调用一次

  1. public class JdbcUserDao implements UserDao{
  2. public User findByUserId(int id){
  3. String sql ="select *from user where id =?";
  4. JdbcTemplate jdbcTemplate  = new JdbcTemplate(dataSource);
  5. final User user = new User();
  6. jdbcTemplate.query(sql,new Objcet[]{id},new RowCallbackHandler(){
  7. public void processRow(ResultSet rs)throws Exception{
  8. user.setUsername(rs.getString("username"));
  9. user.setPassword(rs.getString("password"));
  10. }
  11. });
  12. return user;
  13. }
  14. }
public class JdbcUserDao implements UserDao{

	public User findByUserId(int id){

		String sql ="select *from user where id =?";
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); final User user = new User();
jdbcTemplate.query(sql,new Objcet[]{id},new RowCallbackHandler(){ public void processRow(ResultSet rs)throws Exception{ user.setUsername(rs.getString("username"));
user.setPassword(rs.getString("password"));
}
}); return user;
}
}

由于最多只能返回SQL查询结果中的一行记录,因此可以以局部变量的形式创建一个User对象,并从结果集中提取数据来设置它的属性,对于不止一行的结果集来说,应该将对象收集成一个列表,

2,用RowMapper提取数据

RowMapper比RowCallbackHandler更为通用,它的目的是将结果集的单独一行映射到自定义的对象上,因此它适用于单行和多行结果集,从重用的角度考虑,最好将RowMapper接口实现为一般通用的类,而非内部类,在这个接口的mapRow()方法中,必须构建表示行数据的对象,并将它作为方法的返回值

  1. public class UserRowMapper implements RowMapper{
  2. public Object mapRow(ResultSet rs ,int rowNum)throws SQLException{
  3. User user  = new User();
  4. user.setId(rs.getInt("id"));
  5. user.setUsername(rs.getString("username"));
  6. user.setPassword(rs.getString("password"));
  7. return user;
  8. }
  9. }
public class UserRowMapper implements RowMapper{

	public Object mapRow(ResultSet rs ,int rowNum)throws SQLException{

		User user  = new User();
user.setId(rs.getInt("id"));
user.setUsername(rs.getString("username"));
user.setPassword(rs.getString("password")); return user;
}
}

RowMapper可以用于单行或者多行的结果集,比如在像findByUserId()这样的方法中,查询唯一对象时,必须调用JdbcTemplate的queryForObject()方法,

  1. public class JdbcUserDao implements UserDao{
  2. ...........
  3. public User findByUserId(int id){
  4. String sql ="select *from user where id =?";
  5. JdbcTemplate jdbcTemplate  = new JdbcTemplate(dataSource);
  6. User user =(User)jdbcTemplate.queryForObject(sql,new Object[]{id},new UseRowMapper());
  7. return user;
  8. }
  9. }
public class JdbcUserDao implements UserDao{

	...........

	public User findByUserId(int id){

		String sql ="select *from user where id =?";
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); User user =(User)jdbcTemplate.queryForObject(sql,new Object[]{id},new UseRowMapper());
return user;
}
}

spring2.5提供了一个更便利的RowMapper实现--BeanPropertyRowMapper,它可以自动的将某一行数据映射到指定类的新实例中,它首先将这个类实例化,然后通过名称匹配的方法,将每个列的值都映射到属性中。

  1. public class JdbcUserDao implements UserDao{
  2. public User findByUserId(int id){
  3. String sql ="select *from user where id = ?";
  4. JdbcTemplate jdbcTemplate  = new JdbcTemplate(dataSource);
  5. User user =(User)jdbcTemplate.queryForObject(sql,new Object[]                                   {id},BeanPropertyRowMapper.newInstance(User.class));
  6. return user;
  7. }
  8. }
public class JdbcUserDao implements UserDao{

	public User findByUserId(int id){

		String sql ="select *from user where id = ?";
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); User user =(User)jdbcTemplate.queryForObject(sql,new Object[] {id},BeanPropertyRowMapper.newInstance(User.class));
return user;
}
}

3,查询多行

现在我们来看看如何查询一个带有多行记录的结果集。

  1. public interface UserDao{
  2. public List<User> findAll();
  3. }
public interface UserDao{

	public List<User> findAll();
}

没哟RowMapper的帮助,仍然可以调用queryForList()方法,传递一个sql语句,返回的结果集是Map列表,每个Map保存结果集中的一个行,用列名称做键。

  1. public class JdbcUserDao implements UserDao{
  2. public List<User> findAll(){
  3. String sql ="select *from user";
  4. JdbcTemplate jdbcTemplate  = new JdbcTemplate(dataSource);
  5. List<User> lists = new ArrayList<User>();
  6. List<Map> rows = jdbcTemplate.queryForList(sql);
  7. for(Map row: rows){
  8. User user  = new User();
  9. user.setId((int)row.get("id"));
  10. user.setUsername((String)row.get("username"));
  11. user.setPasword((String)row.get("password"));
  12. lists.add(user);
  13. }
  14. return lists;
  15. }
  16. }
public class JdbcUserDao implements UserDao{

	public List<User> findAll(){

		String sql ="select *from user";
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); List<User> lists = new ArrayList<User>();
List<Map> rows = jdbcTemplate.queryForList(sql); for(Map row: rows){ User user = new User();
user.setId((int)row.get("id"));
user.setUsername((String)row.get("username"));
user.setPasword((String)row.get("password"));
lists.add(user);
}
return lists;
}
}

通过下面的代码测试findAll方法

  1. public class Main{
  2. public static void main(String[] args){
  3. UserDao userdao = new JdbcUserDao();
  4. List<User> user =userdao.findAll();
  5. for(User u: user){
  6. System.out.println("id :"+user.getId());
  7. System.out.println("username :"+user.getUsername());
  8. System.out.println("password :"+user.getPassword());
  9. }
  10. }
  11. }
public class Main{

	public static void main(String[] args){

		UserDao userdao = new JdbcUserDao();
List<User> user =userdao.findAll(); for(User u: user){ System.out.println("id :"+user.getId());
System.out.println("username :"+user.getUsername());
System.out.println("password :"+user.getPassword());
}
}
}

如果使用RowMapper对象映射结果对象中的数据行,就能从query()方法中得到一个映射对象的列表,

  1. public class JdbcUserDao implements UserDao{
  2. public List<User> findAll(){
  3. String sql = "select *from user";
  4. JdbcTemplate jdbcTemplate  = new JdbcTemplate(dataSource);
  5. List<User> users = jdbcTemplate.query(sql,BeanPropertyRowMapper.newInstance(User.class));
  6. return users;
  7. }
  8. }
public class JdbcUserDao implements UserDao{

	public List<User> findAll(){

		String sql = "select *from user";
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); List<User> users = jdbcTemplate.query(sql,BeanPropertyRowMapper.newInstance(User.class));
return users;
}
}

4,查询单值

最后,看看如何查询单行和单列的结果集。

  1. public interface UserDao{
  2. public String getUsername(int id);
  3. public int countAll();
  4. }
public interface UserDao{

	public String getUsername(int id);
public int countAll();
}

要查询单独的字符串值,可以调用重载的queryForObject方法,对于整型值而言,可以调用queryForInt()方法,

  1. public class JdbcUserDao implements UserDao{
  2. public String getUsername(int id){
  3. String sql = "select username from user where id =?";
  4. JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
  5. String username =(String)jdbcTempalte.queryForObject(sql,new Object[]{id},String.class);
  6. return username;
  7. }
  8. public int countAll(){
  9. String sql ="select count(*) from user";
  10. JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
  11. int count = jdbcTemplate.queryForInt(sql);
  12. return count;
  13. }
  14. }
public class JdbcUserDao implements UserDao{

	public String getUsername(int id){

		String sql = "select username from user where id =?";
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); String username =(String)jdbcTempalte.queryForObject(sql,new Object[]{id},String.class);
return username;
} public int countAll(){ String sql ="select count(*) from user";
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); int count = jdbcTemplate.queryForInt(sql);
return count;
}
}

可以通过下面的代码测试上面的数据

  1. public class Main{
  2. public static void main(String[] args){
  3. UserDao dao =new JdbcUserDao();
  4. int count = dao.countAll();
  5. System.out.println("user count :"+count);
  6. String username = dao.getUsername(1);
  7. System

最新文章

  1. Java 为值传递而不是引用传递
  2. 怎么样修改PHPStorm中文件修改后标签和文件名的颜色与背景色
  3. rabbitmq消息队列——&quot;工作队列&quot;
  4. 三、jQuery--jQuery基础--jQuery基础课程--第6章 jQuery 事件与应用
  5. Eclipse安装maven插件报错
  6. HDU 4000 Fruit Ninja 树状数组 + 计数
  7. HTMLayout界面CSSS样式解析笔记
  8. python之7-1类
  9. UltimateDefrag磁盘碎片整理软件 v3.0.100.19汉化版
  10. 初识Object-C
  11. PHP二维数组合并,根据某个key合并
  12. Ubuntu1204 vim中文乱码解决方法
  13. MySQL在windows上多次安装失败
  14. Cannot obtain the required interface (&quot;IID_IDBCreateCommand&quot;) from OLE DB provider &quot;OraOLEDB.Oracle&quot; for linked server xxxx
  15. 【Linux学习七】软件安装
  16. [Mysql]——通过例子理解事务的4种隔离级别(转)
  17. 查看Linux进程CPU过高具体的线程堆栈(不中断程序)
  18. 【阿里云】WindowsServer2012 搭建FTP站点 图文记录
  19. FoxitReader软件下载并安装(图文详解)
  20. CentOS7.6下模拟iSCSI,Windows来连

热门文章

  1. php yield
  2. &quot;ORA-00942: 表或视图不存在 &quot;的原因和解决方法
  3. CentOS 6.7 final编译安装Python 2.7.11
  4. modelsim命令行仿真提示“vsim 不是内部或外部命令,也不是可运行的程序或批处理文件”的解决办法
  5. not exists 跟not in 纪念一下
  6. [Mime] 在c#程序中放音乐的帮助类 (转载)
  7. 调用支付宝接口Android客户端没有支付宝APP的情况下解决无法调用支付宝页面的问题
  8. Windows Azure 试用 for 世纪互联运维
  9. C# Ref 与out 的区别
  10. jQuery UI 日期控件--datepicker