具有动态查询功能的Jdbc消息源的Spring集成流程

CREATE TABLE users (
  id INT PRIMARY KEY,
  name VARCHAR(50),
  age INT,
  email VARCHAR(50)
);

<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
  <property name="driverClassName" value="com.mysql.jdbc.Driver" />
  <property name="url" value="jdbc:mysql://localhost:3306/mydb" />
  <property name="username" value="root" />
  <property name="password" value="password" />
</bean>

@Autowired
private JdbcTemplate jdbcTemplate;

<bean id="dynamicQuerySource" class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
  <constructor-arg ref="dataSource" />
</bean>

public List<User> getUsersByAge(int minAge, int maxAge) {
  String sql = "SELECT * FROM users WHERE age BETWEEN :minAge AND :maxAge";
  
  Map<String, Object> paramMap = new HashMap<>();
  paramMap.put("minAge", minAge);
  paramMap.put("maxAge", maxAge);
  
  return dynamicQuerySource.query(sql, paramMap, new UserRowMapper());
}

public class UserRowMapper implements RowMapper<User> {
  public User mapRow(ResultSet rs, int rowNum) throws SQLException {
    User user = new User();
    user.setId(rs.getInt("id"));
    user.setName(rs.getString("name"));
    user.setAge(rs.getInt("age"));
    user.setEmail(rs.getString("email"));
    return user;
  }
}

<bean id="userService" class="com.example.UserService">
  <property name="dynamicQuerySource" ref="dynamicQuerySource" />
</bean>

@Autowired
private UserService userService;

public void doQuery() {
  List<User> users = userService.getUsersByAge(20, 30);
  // 处理查询结果
}