Spring RowMapper接口如何工作？

Question

我正在研究Spring Core认证，并且对Spring如何处理JDBC查询有一些疑问：

因此，我知道可以根据希望获取的数据类型以多种方式从数据库表中获取数据：

1）查询 简单类型* （如int，long或String）：我使用 jdbcTemplate 类的 queryForObject（）
方法，类似这样：
*

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

因此，要获取一个简单的对象作为int值，我使用 queryForObject（） 方法，将其传递给 sql语句
和我希望从该方法的输出中接收到的对象类型。

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

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

2.1） queryForMap（） ：如果我希望将 一行 放入一个 Map对象中
，其中每个列的值都映射到我的Map中，则可以使用它，例如：

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

2.2） queryForList（） ：如果希望更多行作为查询的输出，则可以使用它。因此，我将获得一个 Map对象列表，
其中每个Map对象代表查询输出的特定行。像这样：

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

我认为这也很清楚。

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

阅读文档可得知JdbcTemplate使用 回调方法 支持此功能。 回调方法的 确切含义是什么？

我知道Spring提供了 RowMapper接口， 用于 将ResultSet的单行映射到对象 ：

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

并且我有以下使用此方法的示例组合，它们使用新的RestaurandRowMapper对象作为 queryForObject（） 方法的返回对象：

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）作为输入参数传递给它。

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

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

因此，我认为Spring会自动调用 mapRow（） 方法，该方法返回 Restaurand域对象 ，该 对象
将自动替换为queryForObject（）方法或类似的方法。但是我不确定它是否可以正常工作。

我想念什么？您能解释一下后台到底发生了什么吗？

特纳克斯

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内部调用该方法query的上JdbcTemplate对象。所述query-method定义为：

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

如您所见，a
ResultSetExtractor<T>传递给query-method，Spring方便地将您转换RowMapper<T>为type对象new RowMapperResultSetExtractor<T>(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添加到结果列表中。但是，由于仅查询 一个 对象，因此以下语句最终用于返回单个Restaurant对象。

        return DataAccessUtils.requiredSingleResult(results);

因此，总结一下：JdbcTempalte实现了Strategy
Pattern（类似于Template方法模式）。并且通过提供一个
Strategy接口
（RowMapper），您可以JdbcTemplate为您完成繁重的工作（处理异常，连接等）。该RowMapper地图将每个Restaurant匹配项都映射为POJO
，所有匹配项都被收集到中List。queryForObject然后，该方法从中获取第一行，List并将其返回给调用方。返回值基于的通用类型RowMapper，在您的情况下为Restaurant。