ASP.NET中如何实现采购触发库存扣减？能否用纯SQL替代触发器？

一、纯SQL实现（推荐，与你在DBeaver的逻辑一致） #

完全可以用纯SQL的触发器方案实现，而且推荐直接复用你已在数据库中创建的触发器逻辑，不需要修改ASP.NET代码：

• 触发器属于数据库层面的逻辑，不管是通过DBeaver、ASP.NET还是其他客户端操作数据，只要新增采购记录，都会自动触发库存扣减，能避免代码层遗漏或重复处理的问题
• 数据库原生的触发器能更可靠地保证数据一致性，应对并发请求时的锁和数据同步问题也更稳妥

如果需要重新编写适配的触发器（根据你的表结构调整），示例SQL逻辑如下：

-- 创建采购表插入后触发的库存更新触发器
CREATE TRIGGER trg_Purchase_AfterInsert
ON Purchase
AFTER INSERT
AS
BEGIN
    SET NOCOUNT ON;
    -- 关联商品ID，扣减对应库存
    UPDATE Item
    SET ItemNum = ItemNum - inserted.PurchaseNum
    FROM Item
    INNER JOIN inserted ON Item.ItemID = inserted.ItemID
    -- 可选：添加库存不小于采购数量的判断，避免出现负数
    WHERE Item.ItemNum >= inserted.PurchaseNum;
END

触发器生效后，ASP.NET中原有的新增采购记录CRUD代码无需改动，插入操作完成后数据库会自动完成库存扣减。

二、ASP.NET代码层实现 #

如果不想依赖数据库触发器，也可以在ASP.NET的采购新增逻辑中，通过事务同时执行两个操作，确保数据一致性：

EF Core示例 #

using (var transaction = _dbContext.Database.BeginTransaction())
{
    try
    {
        // 1. 新增采购记录
        var purchase = new Purchase 
        { 
            ItemID = targetItemId, 
            PurchaseNum = purchaseQuantity, 
            /* 填充其他字段 */ 
        };
        _dbContext.Purchases.Add(purchase);
        await _dbContext.SaveChangesAsync();

        // 2. 更新对应商品库存
        var targetItem = await _dbContext.Items.FindAsync(targetItemId);
        if (targetItem != null && targetItem.ItemNum >= purchaseQuantity)
        {
            targetItem.ItemNum -= purchaseQuantity;
            await _dbContext.SaveChangesAsync();
        }
        else
        {
            throw new Exception("库存不足，无法完成采购");
        }

        // 提交事务
        await transaction.CommitAsync();
    }
    catch (Exception ex)
    {
        // 回滚事务
        await transaction.RollbackAsync();
        throw ex;
    }
}

ADO.NET示例 #

using (var conn = new SqlConnection("你的数据库连接字符串"))
{
    conn.Open();
    using (var transaction = conn.BeginTransaction())
    {
        try
        {
            // 插入采购记录
            var insertCmd = new SqlCommand(
                "INSERT INTO Purchase (ItemID, PurchaseNum, ...) VALUES (@ItemID, @PurchaseNum, ...)",
                conn, transaction);
            insertCmd.Parameters.AddWithValue("@ItemID", targetItemId);
            insertCmd.Parameters.AddWithValue("@PurchaseNum", purchaseQuantity);
            // 绑定其他参数
            insertCmd.ExecuteNonQuery();

            // 更新库存
            var updateCmd = new SqlCommand(
                "UPDATE Item SET ItemNum = ItemNum - @PurchaseNum WHERE ItemID = @ItemID AND ItemNum >= @PurchaseNum",
                conn, transaction);
            updateCmd.Parameters.AddWithValue("@ItemID", targetItemId);
            updateCmd.Parameters.AddWithValue("@PurchaseNum", purchaseQuantity);
            int affectedRows = updateCmd.ExecuteNonQuery();
            if (affectedRows == 0)
            {
                throw new Exception("库存不足或商品不存在");
            }

            transaction.Commit();
        }
        catch (Exception ex)
        {
            transaction.Rollback();
            throw ex;
        }
    }
}

方案对比 #

• 纯SQL触发器：无需修改ASP.NET业务代码，逻辑集中在数据库，跨客户端生效，数据一致性保障更可靠
• ASP.NET代码层：需要修改业务代码，逻辑分散在应用层，适合需要在代码中加入额外业务判断（如日志、权限校验）的场景

内容的提问来源于stack exchange，提问作者wingck