秒杀压测：1000 人抢 100 件，超卖了 37 件

只有第一次 returning 返回 id（= 抢到），之后每次都返回 0 行=重复请求在数据库层被无声吞掉。幂等键的颗粒度是业务定的：用户+活动还是用户+商品，想清楚再建。

-- 秒杀订单表：幂等键 = (user_id, activity_id)，一人一单
create table seckill_orders (
  id          bigint generated always as identity primary key,
  user_id     uuid not null,
  activity_id int  not null,
  created_at  timestamp not null default now(),
  unique (user_id, activity_id)
);

-- 同一用户连点五次 = 同一条语句发五遍，连跑五遍看效果
insert into seckill_orders (user_id, activity_id)
values ('00000000-0000-0000-0000-000000000042', 1)
on conflict (user_id, activity_id) do nothing
returning id;

select * from seckill_orders;   -- 无论跑几遍，永远只有一行

where 带的是「读到的旧版本号」，不是目标值--写成 stock >= 0 就变成原子扣减了，语义混掉。返回 0 行 = 冲突，重读、重算、重试的循环放在应用层；冲突密集时重试风暴会拖垮吞吐，所以乐观锁只适合冲突稀疏的场景。

-- products 加版本号
alter table products add column if not exists version int not null default 0;

-- 第一步：读（假设拿到 stock=100, version=5）
select id, stock, version from products order by id limit 1;

-- 第二步：CAS 写--把上面查到的 id 代进来
update products
set stock = stock - 1, version = version + 1
where id = '查到的id'::uuid
  and version = 5;      -- UPDATE 1：成功

-- 冲突现场：还拿旧版本 5 再试一次（另一个会话已把它改成 6）
update products
set stock = stock - 1, version = version + 1
where id = '查到的id'::uuid
  and version = 5;      -- UPDATE 0：被抢先

绝对正确、逻辑最直白，代价是串行化：吞吐由事务长度决定。锁住行之后千万别再调外部接口、发短信--那等于按住整个队列陪等。

-- 窗口 A（事务一）：
begin;
select id, stock from products
where id = '某商品id'::uuid
for update;                        -- 行锁到手，别人排队
-- 此处应用判断 stock > 0：锁保护下读到的值不会被人偷改
update products set stock = stock - 1
where id = '某商品id'::uuid;
commit;                            -- 放锁，下一个排队者进来

-- 窗口 B：在 A 未 commit 时跑同样的 select ... for update
-- 会一直卡住，直到 A commit 才返回

「判断 + 扣减」压进同一条 UPDATE，原子性由单语句事务保证，不存在读-改-写的竞态窗口。当初超卖 37 件的病根，就是把 stock > 0 的判断放在了应用层。

-- 把第一个商品的库存压到 1，再连扣三次
update products set stock = 1
where id = (select id from products order by id limit 1);

update products set stock = stock - 1
where id = (select id from products order by id limit 1)
  and stock >= 1
returning stock;                   -- 第一次返回 0
-- 同一条再跑两遍：返回 0 行 = 售罄

select stock from products
where id = (select id from products order by id limit 1);   -- 0，永远不会是 -1

记录指标：TPS、平均/最大延迟、成功扣减数（100 - stock）、抢到人数、超卖数（必须 = 0）。三个变体各跑一轮：原子扣减直接跑；悲观锁把两条语句包进 begin...commit；乐观锁在脚本外加重试循环--预期原子版吞吐最高。

-- bench.sql：pgbench 每个事务干两件事（幂等下单 + 原子扣减）
\set uid random(1, 10000)
insert into seckill_orders (user_id, activity_id)
values ('00000000-0000-0000-0000-' || lpad(:uid::text, 12, '0'), 1)
on conflict (user_id, activity_id) do nothing;

update products set stock = stock - 1
where id = '压测商品id'::uuid and stock >= 1;

-- 压测前重置现场：
-- update products set stock = 100 where id = '压测商品id';
-- truncate seckill_orders;

-- 跑法：pgbench -c 50 -j 4 -t 20 -f bench.sql shop

-- 压测后核对（超卖必须为 0）
select stock from products where id = '压测商品id';
select count(*) as 抢到人数 from seckill_orders;   -- 不得超过 100