15

我正在研究如何在 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;
   }

你怎么看，这个方法返回一个学生对象列表，并以下列方式工作：

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

然后这个查询是通过jdbcTemplateObject对象上的查询方法调用来执行的（即JdbcTemplate Spring类的一个实例**

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

在这里阅读：http : //static.springsource.org/spring/docs/current/javadoc-api/org/springframework/jdbc/core/JdbcTemplate.html 说：执行给定静态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<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 Framework 自动调用的吗？（因为在此示例中从未手动调用...）

肿瘤坏死因子

安德烈亚

然后这个查询是通过jdbcTemplateObject对象上的查询方法调用来执行的（即JdbcTemplate Spring类的一个实例**

4

4 回答 4

23

当您将您的实例传递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结合使用，以了解这些东西如何分布并提供低耦合。

于 2013-02-27T17:57:53.333 回答
4

这是我与 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;
        }
    });
于 2013-02-27T18:02:29.657 回答
2

在 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());
}
于 2013-10-30T11:16:31.620 回答
1

那么，谁调用这个 mapRow 方法呢？它是由 Spring Framework 自动调用的吗？（因为在此示例中从未手动调用...）

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

  1. 连接参数，
  2. SQL 语句
  3. 声明参数并提供参数值
  4. 完成每次迭代的工作。
于 2013-02-27T17:56:05.907 回答