Spring RowMapper接口到底如何工作？

Question

我正在学习Spring核心认证，我对Spring如何处理JDBC查询有一些疑问：

String sql = "SELECT count(*) FROM T_REWARD";
int rowsNumber = jdbcTemplate.queryForObject(sql, Integer.class);

因此，为了获得一个作为int值的简单对象，我使用queryForObject（）方法，将sql stattment和我期望从该方法接收的对象类型传递给它。

好的，这很简单，我认为这是可以的。

2）查询输入到Map对象中的整个表行：因此，如果我不需要单个值（可以在表的特定行的单个列中，或者类似前面的示例），我可以使用queryForMap（..）和queryForList（）方法，方法如下：

String sql = "select * from T_REWARD where CONFIRMATION_NUMBER = ?";
Map<String, Object> values = jdbcTemplate.queryForMap(sql,confirmation.getConfirmationNumber());

String sql = “select * from PERSON”;
return jdbcTemplate.queryForList(sql);

我认为这也很清楚。

然后，我可以使用JdbcTemplate将ResultSet映射到一个域对象，这对我来说并不清楚。

阅读文档会发现，JdbcTemplate使用回调方法支持此功能。我和这个回调方法到底是什么？

public interface RowMapper<T> {
    T mapRow(ResultSet rs, int rowNum)
    throws SQLException;
}

public Restaurant findByMerchantNumber(String merchantNumber) {
    String sql = "select MERCHANT_NUMBER, NAME, BENEFIT_PERCENTAGE, BENEFIT_AVAILABILITY_POLICY from T_RESTAURANT where MERCHANT_NUMBER = ?";

    return jdbcTemplate.queryForObject(sql, new RestaurantRowMapper(), merchantNumber);

class RestaurantRowMapper implements RowMapper<Restaurant> {
    public Restaurant mapRow(ResultSet rs, int i) throws SQLException {
        return mapRestaurant(rs);
    }
}

private Restaurant mapRestaurant(ResultSet rs) throws SQLException {
    // get the row column data
    String name = rs.getString("NAME");
    String number = rs.getString("MERCHANT_NUMBER");
    Percentage benefitPercentage = Percentage.valueOf(rs.getString("BENEFIT_PERCENTAGE"));
    // map to the object
    Restaurant restaurant = new Restaurant(number, name);
    restaurant.setBenefitPercentage(benefitPercentage);
    restaurant.setBenefitAvailabilityPolicy(mapBenefitAvailabilityPolicy(rs));
    return restaurant;
}

我的主要疑问是：我知道使用queryForObject（）方法，我会将我期望作为输出的对象类型（例如Interger或Long）作为输入参数传递给它。

如果我希望获得一个表示表的整行的域对象（例如，映射到Restaure和对象的餐厅表的一行），我认为我应该使用这个对象（作为餐厅对象），但在前面的示例中，我使用**row mapper对象而不是域对象：

return jdbcTemplate.queryForObject(sql, new RestaurantRowMapper(), merchantNumber);

这个内部类只包含返回预期域对象的mapRow（）方法

class RestaurantRowMapper implements RowMapper<Restaurant> {
    public Restaurant mapRow(ResultSet rs, int i) throws SQLException {
        return mapRestaurant(rs);
    }
}

TNX

Answer 1

QueryForObject方法如下所示：

public <T> T queryForObject(String sql, RowMapper<T> rowMapper, Object... args) throws DataAccessException {
    List<T> results = query(sql, args, new RowMapperResultSetExtractor<T>(rowMapper, 1));
    return DataAccessUtils.requiredSingleResult(results);
}

queryforobject-method在内部调用jdbctemplate对象的方法query。查询-方法定义为：

public <T> T query(
        PreparedStatementCreator psc, final PreparedStatementSetter pss, final ResultSetExtractor<T> rse)
        throws DataAccessException;

如您所见，ResultSetExtractor 被传递给查询-method，Spring可以方便地将RowMapperResultSetExtractor 转换为类型为New RowMapperResultSetExtractor (rowMapper，1) 的对象。RowMapperResultsetExtractor是保存魔法密钥的对象。调用该对象时，它将按照以下代码段迭代所有行：

public List<T> extractData(ResultSet rs) throws SQLException {
    List<T> results = (this.rowsExpected > 0 ? new ArrayList<T>(this.rowsExpected) : new ArrayList<T>());
    int rowNum = 0;
    while (rs.next()) {
        results.add(this.rowMapper.mapRow(rs, rowNum++));
    }
    return results;
}

因此，您的原始rowmapper是对每一行调用的回调。此外，正如您在这里看到的，将为所有匹配结果调用rowmapper，并将创建的restaurant-object添加到结果列表中。但是，由于您只查询一个对象，所以下面的语句最终用于返回您的Restaurany对象。

        return DataAccessUtils.requiredSingleResult(results);

因此，总而言之:jdbctempalte实现策略模式（类似于模板方法模式）。通过提供一个策略接口(rowmapper)，您可以让jdbctemplate为您做繁重的工作（处理异常、连接等）。rowmapper将每个命中映射为一个POJO(餐厅)，所有命中都被收集到列表中。方法QueryForObject然后从该列表中获取第一行并将其返回给调用方。返回值基于rowmapper的泛型类型，在您的示例中是restaurant。