如何操作不同数据源的Map值及相关业务逻辑实现咨询

嘿，我来帮你拆解这两个需求，一步步落地实现：

一、从数据库查询Driver数据并存储到自定义结构 #

原来的代码是硬编码添加Driver数据，现在要改成从数据库查询。我以Java生态最常用的MyBatis为例，也会提JDBC的思路：

1. 先定义自定义数据结构 #

首先创建一个类来承载数据库查询到的Driver数据（根据你的实际表字段扩展）：

public class CustomDriver {
    private Integer id;
    // 可以添加其他字段，比如driverName、createTime等，对应数据库表字段
    
    // 构造器、Getter/Setter
    public CustomDriver(Integer id) {
        this.id = id;
    }
    
    // 省略Getter和Setter方法
}

2. 数据库查询逻辑 #

如果用MyBatis，先写Mapper接口：

public interface DriverMapper {
    // 根据id列表批量查询Driver数据
    List<CustomDriver> getDriversByIds(List<Integer> driverIds);
}

对应的XML映射文件写批量查询SQL：

<select id="getDriversByIds" parameterType="java.util.List" resultType="com.yourpackage.CustomDriver">
    SELECT id, driver_name, create_time 
    FROM driver_table 
    WHERE id IN
    <foreach collection="list" item="id" open="(" separator="," close=")">
        #{id}
    </foreach>
</select>

然后在业务代码里调用，把查询结果转到你的自定义Driver结构：

// 原来的硬编码id集合
List<Integer> targetDriverIds = Arrays.asList(30, 31, 32, 33, 34);
// 从数据库批量查询
List<CustomDriver> dbDrivers = driverMapper.getDriversByIds(targetDriverIds);
// 填充到你的自定义Driver容器
Driver<Integer> driver = new Driver<>();
dbDrivers.forEach(customDriver -> driver.add(customDriver.getId()));

如果用JDBC，就通过PreparedStatement执行IN查询，把结果集手动封装到CustomDriver里，逻辑是一样的，只是代码更繁琐些。

二、Map的业务逻辑处理（根据act值修改元素） #

首先注意你的Map里32被put了两次，最终value会是333（因为Map的key唯一，重复put会覆盖）。接下来处理act的逻辑：当act > 1时，每个Map元素的value减去act。

方式1：传统EntrySet遍历（兼容所有Java版本） #

// 初始化Map
Map<Integer, Integer> map = new HashMap<>();
map.put(30, 300);
map.put(31, 311);
map.put(32, 322);
map.put(32, 333); // 覆盖为333
map.put(34, 344);

// 假设act从其他数据源获取（比如配置、另一张表）
int act = 2; // 示例值，根据实际场景获取

if (act > 1) {
    // 遍历修改每个entry的value
    for (Map.Entry<Integer, Integer> entry : map.entrySet()) {
        entry.setValue(entry.getValue() - act);
    }
}

// 验证结果：{30=298, 31=309, 32=331, 34=342}
System.out.println(map);

方式2：Java 8+ Stream API（更简洁） #

如果用Java 8及以上，想用函数式风格处理，可以生成新的Map（不修改原Map）：

if (act > 1) {
    map = map.entrySet().stream()
            .collect(Collectors.toMap(
                    Map.Entry::getKey,
                    entry -> entry.getValue() - act,
                    (oldVal, newVal) -> newVal // 处理key冲突，这里实际不会触发
            ));
}

三、多数据源整合的注意事项 #

如果Driver数据和act值来自不同数据源（比如Driver从MySQL，act从Redis或另一数据库），要注意：

• 事务一致性：如果两个操作需要原子性，要考虑分布式事务（比如Seata）或者补偿机制。
• 性能优化：尽量批量查询，减少数据库交互；act如果是全局配置，可以缓存起来，不用每次查询。

内容的提问来源于stack exchange，提问作者R.deo