当前位置：首页 > Java

java如何分批入出库

2026-03-18 13:59:11Java

分批入库实现方法

使用Java实现分批入库可以通过JDBC的批处理功能或框架如MyBatis、JPA的批量操作。JDBC批处理示例：

java如何分批入出库

// 使用PreparedStatement批处理
String sql = "INSERT INTO inventory (item_id, quantity) VALUES (?, ?)";
try (Connection conn = dataSource.getConnection();
     PreparedStatement pstmt = conn.prepareStatement(sql)) {

    conn.setAutoCommit(false); // 关闭自动提交

    for (Item item : itemList) {
        pstmt.setString(1, item.getId());
        pstmt.setInt(2, item.getQuantity());
        pstmt.addBatch(); // 添加到批处理

        if (i % BATCH_SIZE == 0) { // 每BATCH_SIZE条执行一次
            pstmt.executeBatch();
        }
    }
    pstmt.executeBatch(); // 执行剩余记录
    conn.commit(); // 提交事务

} catch (SQLException e) {
    conn.rollback(); // 回滚事务
}

MyBatis批量插入

配置MyBatis的批量执行器并在Mapper接口中定义批量方法：

java如何分批入出库

<!-- application.yml -->
mybatis:
  executor-type: batch

// Mapper接口
@Insert("<script>" +
        "INSERT INTO inventory (item_id, quantity) VALUES " +
        "<foreach collection='list' item='item' separator=','>" +
        "(#{item.id}, #{item.quantity})" +
        "</foreach>" +
        "</script>")
void batchInsert(@Param("list") List<Item> items);

分批出库实现方法

采用乐观锁保证出库原子性，结合分页查询处理大量数据：

// 乐观锁更新示例
@Transactional
public boolean deductStock(String itemId, int quantity) {
    Inventory inventory = inventoryMapper.selectForUpdate(itemId);
    if (inventory.getQuantity() >= quantity) {
        int updated = inventoryMapper.updateQuantity(
            itemId, 
            inventory.getQuantity() - quantity,
            inventory.getVersion() // 版本号
        );
        return updated > 0;
    }
    return false;
}

// 分页处理出库
public void batchDeductStock(List<String> itemIds) {
    int pageSize = 100;
    int total = itemIds.size();

    for (int i = 0; i < total; i += pageSize) {
        List<String> subList = itemIds.subList(i, Math.min(i + pageSize, total));
        processSubBatch(subList); // 处理当前批次
    }
}