关于RowMapper在Spring Framework应用程序中使用JDBC的一些疑问
我正在研究如何在Spring Framework中使用JDBC对数据库执行查询。
我正在学习本教程： http ： //www.tutorialspoint.com/spring/spring_jdbc_example.htm
在本教程中，我定义了一个StudentDAO接口，它只定义了我想要的CRUD方法。
然后定义Student类，它是我想要在Student数据库表上保留的实体。
然后定义StudentMapper类，它是RowMapper接口的特定实现，在这种情况下，用于将ResultSet中的特定记录（由查询返回）映射到Student对象。
然后我有StudentJDBCTemplate ，它支持我的StudentDAO接口的实现，在这个类中我实现了接口中定义的CRUD方法。
好的，现在我对StudentMapper类如何工作有疑问：在这个StudentJDBCTemplate类中，定义了返回Student数据库表中所有记录列表的方法，这个：
public List listStudents() { String SQL = "select * from Student"; List students = jdbcTemplateObject.query(SQL, new StudentMapper()); return students; } 你怎么看，这个方法返回一个List of Student对象，并按以下方式工作：
它首先要做的是定义返回 SQL String中Student数据库表中所有记录的查询。
然后通过jdbcTemplateObject对象上的查询方法调用执行此查询（这是JdbcTemplate Spring类的一个等级**
此方法有两个参数：SQL String（包含必须执行的SQL查询）和一个新的StudentMapper对象，它接受查询返回的ResultSet对象并将其记录映射到新的Student对象上
在这里阅读： http ：//static.springsource.org/spring/docs/current/javadoc-api/org/springframework/jdbc/core/JdbcTemplate.html sayas： 执行给定静态SQL的查询，将每一行映射到Java通过RowMapper对象。
我的疑问与我的StudentMapper使用mapRow（）方法在Student对象上映射ResultSet记录这一事实有关，这是代码：
package com.tutorialspoint; import java.sql.ResultSet; import java.sql.SQLException; import org.springframework.jdbc.core.RowMapper; public class StudentMapper implements RowMapper { public Student mapRow(ResultSet rs, int rowNum) throws SQLException { Student student = new Student(); student.setId(rs.getInt("id")); student.setName(rs.getString("name")); student.setAge(rs.getInt("age")); return student; } }
那么，谁调用这个mapRow方法呢？ 它是由Spring Framework自动调用的吗？ （因为在这个例子中永远不会手动调用…）
TNX
安德里亚
然后通过jdbcTemplateObject对象上的查询方法调用执行此查询（这是JdbcTemplate Spring类的一个等级**
将RowMapper的实例传递给JdbcTemplate方法时
List students = jdbcTemplateObject.query(SQL, new StudentMapper());
JdbcTemplate取决于您调用的方法，将在内部使用映射器以及从JDBC Connection获取的结果集，以创建所请求类型的对象。 例如，由于您调用了JdbcTemplate#query(String, RowMapper) ，该方法将使用您的String SQL查询数据库，并将循环遍历ResultSet中的每个“行”，如下所示：
ResultSet rs = ... // execute query List students = ...// some list int rowNum = 0; while(rs.next()) { Student student = rowMapper.mapRow(rs, rowNum); students.add(student); rowNum++; } return students;
因此， Spring的JdbcTemplate方法将使用您提供的RowMapper并调用其mapRow方法来创建预期的返回对象。
您可能希望将Martin Fowler的数据映射器与表数据网关结合使用，以了解这些内容如何分布并提供低耦合 。
这是我与BeanPropertyRowMapper一起使用的典型模式。 它节省了大量的编码。 您的查询需要对每列进行别名以匹配类中的属性名称。 在这种情况下， species_name as species ，其他列名称恰好匹配。
public class Animal { String species; String phylum; String family; ...getters and setters omitted } @Repository public class AnimalRepository { private NamedParameterJdbcTemplate namedParameterJdbcTemplate; @Autowired public void setDataSource(DataSource dataSource) { this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource); } public List getAnimalsByPhylum(String phylum) { String sql = " SELECT species_name as species, phylum, family FROM animals" +" WHERE phylum = :phylum"; Map namedParameters = new HashMap(); namedParameters.put("phylum", phylum); SqlParameterSource params = new MapSqlParameterSource(namedParameters); List records = namedParameterJdbcTemplate.query(sql, params, BeanPropertyRowMapper.newInstance(Animal.class)); return records; } }
另一种方法是在每行需要更多自定义时使用RowMapper（此示例仅使用匿名类）：
List records = namedParameterJdbcTemplate.query(sql, params, new RowMapper (){ public Animal mapRow(ResultSet rs, int i) throws SQLException { Animal animal = new Animal(); animal.setSpecies(rs.getString("species_name")); if (some condition) { animal.setPhylum(rs.getString("phylum")); } else { animal.setPhylum(rs.getString("phylum")+someThing()); } animal.setFamily(rs.getString("family")); return animal; } });
在Spring中使用RowMapper
import java.sql.ResultSet; import java.sql.SQLException; import org.springframework.jdbc.core.RowMapper; public class RowsMap implements RowMapper{ @Override public EmpPojo mapRow(ResultSet rs, int counts) throws SQLException { EmpPojo em=new EmpPojo(); em.setEid(rs.getInt(1)); em.setEname(rs.getString(2)); em.setEsal(rs.getDouble(3)); return em; } } Finally in Main class List lm=jt.query("select * from emps", new RowsMap()); for(EmpPojo e:lm) { System.out.println(e.getEid()+" "+e.getEname()+" "+e.getEsal()); }
那么，谁调用这个mapRow方法呢？ 它是由Spring Framework自动调用的吗？ （因为在这个例子中永远不会手动调用…）
这是由spring框架自动调用的。 所有你需要的是指定
- 连接参数，
- SQL语句
- 声明参数并提供参数值
- 为每次迭代做好工作。