JDBCTemplate使用BeanPropertyRowMapper设置嵌套POJO

Question

给出以下POJO示例：（假设所有属性都是getter和setter）

class User {
    String user_name;
    String display_name;
}

class Message {
    String title;
    String question;
    User user;
}

可以轻松地查询数据库（在我的例子中是postgres)，并使用BeanPropertyRowMapper填充消息类列表，其中db字段与POJO中的属性匹配：（假设db表具有与POJO属性对应的字段）。

NamedParameterDatbase.query("SELECT * FROM message", new BeanPropertyRowMapper(Message.class));

SELECT * FROM message, user WHERE user_id = message_id

生成已填充关联用户的消息列表

用例：

最终，这些类作为序列化对象从Spring控制器传递回来，这些类被嵌套，这样得到的JSON/XML就有了一个合适的结构。

SELECT title AS "message.title", question AS "message.question", user_name AS "user.user_name", display_name AS "user.display_name" FROM message, user WHERE user_id = message_id

然后，自定义行映射器创建几个bean映射，并根据列的前缀设置它们的属性：（使用元数据获取列名）。

public Object mapRow(ResultSet rs, int i) throws SQLException {

    HashMap<String, BeanMap> beans_by_name = new HashMap();

    beans_by_name.put("message", BeanMap.create(new Message()));
    beans_by_name.put("user", BeanMap.create(new User()));

    ResultSetMetaData resultSetMetaData = rs.getMetaData();

    for (int colnum = 1; colnum <= resultSetMetaData.getColumnCount(); colnum++) {

        String table = resultSetMetaData.getColumnName(colnum).split("\\.")[0];
        String field = resultSetMetaData.getColumnName(colnum).split("\\.")[1];

        BeanMap beanMap = beans_by_name.get(table);

        if (rs.getObject(colnum) != null) {
            beanMap.put(field, rs.getObject(colnum));
        }
    }

    Message m = (Task)beans_by_name.get("message").getBean();
    m.setUser((User)beans_by_name.get("user").getBean());

    return m;
}

同样，对于一个两个类的联接来说，这似乎有些过头了，但是IRL用例涉及到多个表和几十个字段。

Answer 1

也许您可以传入一个自定义的rowmapper，它可以将聚合联接查询的每一行（在消息和用户之间）映射到消息和嵌套的用户。类似于这样：

List<Message> messages = jdbcTemplate.query("SELECT * FROM message m, user u WHERE u.message_id = m.message_id", new RowMapper<Message>() {
    @Override
    public Message mapRow(ResultSet rs, int rowNum) throws SQLException {
        Message message = new Message();
        message.setTitle(rs.getString(1));
        message.setQuestion(rs.getString(2));

        User user = new User();
        user.setUserName(rs.getString(3));
        user.setDisplayName(rs.getString(4));

        message.setUser(user);

        return message;
    }
});