关于在 Spring Framework 应用程序中 JDBC 中使用 RowMapper 的一些疑问

2022-09-03 12:14:07

我正在研究如何在Spring Framework中使用JDBC对数据库执行查询。

我正在遵循本教程:http://www.tutorialspoint.com/spring/spring_jdbc_example.htm

在本教程中,我定义了一个StudentAO接口,该接口仅定义我想要的CRUD方法。

然后定义 Student 类,该类是我要在 Student 数据库表上保留的实体。

然后定义 StudentMapper 类,该类是 RowMapper 接口的特定实现,在本例中,该接口用于将 ResultSet 中的特定记录(由查询返回)映射到 Student 对象。

然后我有StudentJDBCTemplate,它代表了我的StudentDAO接口的实现,在这个类中,我实现了在接口中定义的CRUD方法。

好的,现在我对StudentMapper类的工作原理有疑问:在这个StudentJDBCTemplate类中,定义了返回学生数据库表中所有记录列表的方法,这个:

   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, 
                                new StudentMapper());
      return students;
   }

如何查看,此方法返回一个学生对象列表,并按以下方式工作:

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

然后,此查询由 jdbcTemplateObject 对象上的查询方法调用执行(这是 JdbcTemplate Spring 类的一个 istance**

此方法采用两个参数:SQL 字符串(包含必须执行的 SQL 查询)和新的 StudentMapper 对象,该对象采用查询返回的 ResultSet 对象并将其记录映射到新的 Student 对象上

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

我的疑问与我的 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<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;
   }
}

那么,谁来称呼这个 mapRow 方法呢?它是否由Spring框架自动调用?(因为在此示例中从不手动调用...)

断续器

安德里亚

然后,此查询由 jdbcTemplateObject 对象上的查询方法调用执行(这是 JdbcTemplate Spring 类的一个 istance**


答案 1

当您将您的实例传递给该方法时RowMapperJdbcTemplate

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

根据您调用的方法,将在内部使用映射器及其从 JDBC 连接获取的结果集来创建请求类型的对象。例如,由于您调用了 ,该方法将使用 String SQL 来查询数据库,并将循环遍历每个“行”,如下所示:JdbcTemplateJdbcTemplate#query(String, RowMapper)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;

因此,的方法将使用 u 提供并调用其方法来创建预期的返回对象。SpringJdbcTemplateRowMappermapRow

您可能希望将 Martin Fowler 的数据映射器表数据网关结合使用,以了解这些东西是如何分布的,以及如何提供低耦合


答案 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;
        }
    });

推荐