Spring Framework应用中JDBC使用RowMapper的一些疑惑

Posted 2023-02-26

【中文标题】Spring Framework应用中JDBC使用RowMapper的一些疑惑

【英文标题】：Some doubts about RowMapper use in JDBC in a Spring Framework application

【发布时间】：2013-02-13 15:30:21

【问题描述】：

我正在研究如何在 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<Student> listStudents() 
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, 
                                new StudentMapper());
      return students;
   

你怎么看，这个方法返回一个Student对象的List，工作方式如下：

它做的第一件事是在 SQL 字符串中定义返回 Student 数据库表中的所有记录的查询。

然后这个查询是通过jdbcTemplateObject对象（即JdbcTemplateSpring类**的一个实例**

此方法有两个参数：SQL 字符串（包含必须执行的 SQL 查询）和一个新的 StudentMapper 对象，该对象采用由返回的 ResultSet 对象查询并将其记录映射到新的 Student 对象上

在这里阅读：http://static.springsource.org/spring/docs/current/javadoc-api/org/springframework/jdbc/core/JdbcTemplate.html 说：执行给定静态 SQL 的查询，通过 RowMapper 将每一行映射到 Java 对象。

我的疑问与我的 StudentMapper 使用 ma​​pRow() 方法在 Student 对象上映射 ResultSet 记录有关，代码如下：

package com.tutorialspoint;

import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;

public class StudentMapper implements RowMapper<Student> 
   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;
   

那么，谁调用了这个 ma​​pRow 方法？它是由 Spring Framework 自动调用的吗？ （因为在这个例子中从不手动调用...）

Tnx

安德烈亚

然后这个查询是通过jdbcTemplateObject对象（即JdbcTemplateSpring类**的一个实例**

【参考方案1】：

当您将 RowMapper 的实例传递给 JdbcTemplate 方法时

List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());

JdbcTemplate 取决于您调用的方法，将在内部使用映射器及其从 JDBC 连接获得的结果集来创建您请求类型的对象。例如，由于您调用了JdbcTemplate#query(String, RowMapper)，该方法将使用您的 String SQL 来查询数据库，并将循环遍历 ResultSet 中的每个“行”，如下所示：

ResultSet rs = ... // execute query
List<Student> 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 的 Data Mapper 和 Table Data Gateway，了解这些东西是如何分布的，并提供 low coupling。

【参考方案2】：

这是我与 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<Animal> getAnimalsByPhylum(String phylum) 
        String sql = " SELECT species_name as species, phylum, family FROM animals"
                 +" WHERE phylum = :phylum";

        Map<String, Object> namedParameters = new HashMap<String, Object>();
        namedParameters.put("phylum", phylum);
        SqlParameterSource params = new MapSqlParameterSource(namedParameters);
        List<Animal> records = namedParameterJdbcTemplate.query(sql,
                params, BeanPropertyRowMapper.newInstance(Animal.class));

        return records;
    

当您需要对每行进行更多自定义时，另一种方法是使用 RowMapper（此示例仅使用匿名类）：

    List<Animal> records = namedParameterJdbcTemplate.query(sql,
            params, new RowMapper<Animal>()
        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;
        
    );

【讨论】：

牢记BeanPropertyRowMapper：“请注意，此类旨在提供便利而非高性能。为获得最佳性能，请考虑使用自定义 RowMapper 实现。”

【参考方案3】：

在 Spring 中使用 RowMapper

import java.sql.ResultSet;
import java.sql.SQLException;

import org.springframework.jdbc.core.RowMapper;

public class RowsMap implements RowMapper<EmpPojo>

    @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<EmpPojo> lm=jt.query("select * from emps", new RowsMap());
for(EmpPojo e:lm)

    System.out.println(e.getEid()+" "+e.getEname()+" "+e.getEsal());

【参考方案4】：

那么，谁调用了这个 mapRow 方法？是不是自动调用的 春天框架？ （因为在此示例中从未调用过 手动...）

这是由 spring 框架自动调用的。 您只需要指定

连接参数， SQL 语句 声明参数并提供参数值 完成每次迭代的工作。