前言
前段时间我踩过一个坑:在mysql8的一张innodb引擎的表中,加了唯一索引,但最后发现数据竟然还是重复了。
到底怎么回事呢?
本文通过一次踩坑经历,聊聊唯一索引一些有意思的知识点。
1.还原问题现场
前段时间,为了防止商品组产生重复的数据,我专门加了一张防重表。
问题就出在商品组的防重表上。
具体表结构如下:
CREATE TABLE
product_group_unique(<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
idbigint NOT NULL,<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
category_idbigint NOT NULL,<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
unit_idbigint NOT NULL,<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
model_hashvarchar(255) COLLATE utf8mb4_bin DEFAULT NULL,<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
in_datedatetime NOT NULL,<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> PRIMARY KEY (
id)<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
为了保证数据的唯一性,我给那种商品组防重表,建了唯一索引:
alter table product_group_unique add unique index <br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />ux_category_unit_model(category_id,unit_id,model_hash);<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
根据分类编号、单位编号和商品组属性的 hash 值,可以唯一确定一个商品组。
给商品组防重表创建了唯一索引之后,第二天查看数据,发现该表中竟然产生了重复的数据:
表中第二条数据和第三条数据重复了。
这是为什么呢?
2.唯一索引字段包含 null
如果你仔细查看表中的数据,会发现其中一个比较特殊地方:商品组属性的 hash 值(model_hash 字段)可能为null,即商品组允许不配置任何属性。
在 product_group_unique 表中插入了一条 model_hash 字段等于 100 的重复数据:
执行结果:
从上图中看出,mysql 的唯一性约束生效了,重复数据被拦截了。
接下来,我们再插入两条 model_hash 为 null 的数据,其中第三条数据跟第二条数据中 category_id、unit_id 和 model_hash 字段值都一样。
从图中看出,竟然执行成功了。
换句话说,如果唯一索引的字段中,出现了 null 值,则唯一性约束不会生效。
最终插入的数据情况是这样的:
当 model_hash 字段不为空时,不会产生重复的数据。
当 model_hash 字段为空时,会生成重复的数据。
我们需要特别注意:创建唯一索引的字段,都不能允许为 null,否则 mysql 的唯一性约束可能会失效。
3.逻辑删除表加唯一索引
我们都知道唯一索引非常简单好用,但有时候,在表中它并不好加。
不信,我们一起往下看。
通常情况下,要删除表的某条记录的话,如果用delete语句操作的话。
例如:
delete from product where id=123;<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
这种 delete 操作是物理删除,即该记录被删除之后,后续通过 sql 语句基本查不出来。(不过通过其他技术手段可以找回,那是后话了。)
还有另外一种是逻辑删除,主要是通过update语句操作的。
例如:
update product set delete_status=1,edit_time=now(3) <br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />where id=123;<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
逻辑删除需要在表中额外增加一个删除状态字段,用于记录数据是否被删除。在所有的业务查询的地方,都需要过滤掉已经删除的数据。
通过这种方式删除数据之后,数据仍然还在表中,只是从逻辑上过滤了删除状态的数据而已。
其实对于这种逻辑删除的表,是没法加唯一索引的。
为什么呢?
假设之前给商品表中的name和model加了唯一索引,如果用户把某条记录删除了,delete_status 设置成 1 了。后来,该用户发现不对,又重新添加了一模一样的商品。
由于唯一索引的存在,该用户第二次添加商品会失败,即使该商品已经被删除了,也没法再添加了。
这个问题显然有点严重。
有人可能会说:把name、model和delete_status三个字段同时做成唯一索引不就行了?
答:这样做确实可以解决用户逻辑删除了某个商品,后来又重新添加相同的商品时添加不了的问题。但如果第二次添加的商品,又被删除了。该用户第三次添加相同的商品,不也出现问题了?
由此可见,如果表中有逻辑删除功能,是不方便创建唯一索引的。
但如果真的想给包含逻辑删除的表增加唯一索引,该怎么办呢?
3.1 删除状态 +1
通过前面知道,如果表中有逻辑删除功能,是不方便创建唯一索引的。
其根本原因是,记录被删除之后,delete_status 会被设置成 1,默认是 0。相同的记录第二次删除的时候,delete_status 被设置成 1,但由于创建了唯一索引(把 name、model 和 delete_status 三个字段同时做成唯一索引),数据库中已存在 delete_status 为 1 的记录,所以这次会操作失败。
我们为啥不换一种思考:不要纠结于 delete_status 为 1,表示删除,当 delete_status 为 1、2、3 等等,只要大于 1 都表示删除。
这样的话,每次删除都获取那条相同记录的最大删除状态,然后加 1。
这样数据操作过程变成:
添加记录 a,delete_status=0。
删除记录 a,delete_status=1。
添加记录 a,delete_status=0。
删除记录 a,delete_status=2。
添加记录 a,delete_status=0。
删除记录 a,delete_status=3。
由于记录 a,每次删除时,delete_status 都不一样,所以可以保证唯一性。
该方案的优点是:不用调整字段,非常简单和直接。
缺点是:可能需要修改 sql 逻辑,特别是有些查询 sql 语句,有些使用 delete_status=1 判断删除状态的,需要改成 delete_status>=1。
3.2 增加时间戳字段
导致逻辑删除表,不好加唯一索引最根本的地方在逻辑删除那里。
我们为什么不加个字段,专门处理逻辑删除的功能呢?
答:可以增加时间戳字段。
把 name、model、delete_status 和 timeStamp,四个字段同时做成唯一索引。
在添加数据时,timeStamp 字段写入默认值1。
然后一旦有逻辑删除操作,则自动往该字段写入时间戳。
这样即使是同一条记录,逻辑删除多次,每次生成的时间戳也不一样,也能保证数据的唯一性。
时间戳一般精确到秒。
除非在那种极限并发的场景下,对同一条记录,两次不同的逻辑删除操作,产生了相同的时间戳。
这时可以将时间戳精确到毫秒。
该方案的优点是:可以在不改变已有代码逻辑的基础上,通过增加新字段实现了数据的唯一性。
缺点是:在极限的情况下,可能还是会产生重复数据。
3.3 增加 id 字段
其实,增加时间戳字段基本可以解决问题。但在极限的情况下,可能还是会产生重复数据。
有没有办法解决这个问题呢?
答:增加主键字段:delete_id。
该方案的思路跟增加时间戳字段一致,即在添加数据时给 delete_id 设置默认值 1,然后在逻辑删除时,给 delete_id 赋值成当前记录的主键 id。
把 name、model、delete_status 和 delete_id,四个字段同时做成唯一索引。
这可能是最优方案,无需修改已有删除逻辑,也能保证数据的唯一性。
4. 重复历史数据如何加唯一索引?
前面聊过如果表中有逻辑删除功能,不太好加唯一索引,但通过文中介绍的三种方案,可以顺利地加上唯一索引。
但来自灵魂的一问:如果某张表中,已存在历史重复数据,该如何加索引呢?
最简单的做法是,增加一张防重表,然后把数据初始化进去。
可以写一条类似这样的 sql:
insert into product_unqiue(id,name,category_id,unit_id,model) <br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />select max(id), select name,category_id,unit_id,model from product<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />group by name,category_id,unit_id,model;<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
这样做可以是可以,但今天的主题是直接在原表中加唯一索引,不用防重表。
那么,这个唯一索引该怎么加呢?
其实可以借鉴上一节中,增加id字段的思路。
增加一个 delete_id 字段。
不过在给 product 表创建唯一索引之前,先要做数据处理。
获取相同记录的最大 id:
select max(id), select name,category_id,unit_id,model from product<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />group by name,category_id,unit_id,model;<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
然后将 delete_id 字段设置成 1。
然后将其他的相同记录的 delete_id 字段,设置成当前的主键。
这样就能区分历史的重复数据了。
当所有的 delete_id 字段都设置了值之后,就能给 name、model、delete_status 和 delete_id,四个字段加唯一索引了。
完美。
5.给大字段加唯一索引
接下来,我们聊一个有趣的话题:如何给大字段增加唯一索引。
有时候,我们需要给几个字段同时加一个唯一索引,比如给 name、model、delete_status 和 delete_id等。
但如果 model 字段很大,这样就会导致该唯一索引可能会占用较多存储空间。
我们都知道唯一索引,也会走索引。
如果在索引的各个节点中存大数据,检索效率会非常低。
由此,有必要对唯一索引长度做限制。
目前 mysql innodb 存储引擎中索引允许的最大长度是 3072 bytes,其中 unqiue key 最大长度是 1000 bytes。
如果字段太大了,超过了 1000 bytes,显然是没法加唯一索引的。
此时,有没有解决办法呢?
5.1 增加 hash 字段
我们可以增加一个 hash 字段,取大字段的 hash 值,生成一个较短的新值。该值可以通过一些 hash 算法生成,固定长度 16 位或者 32 位等。
我们只需要给 name、hash、delete_status 和 delete_id 字段,增加唯一索引。
这样就能避免唯一索引太长的问题。
但它也会带来一个新问题:
一般 hash 算法会产生 hash 冲突,即两个不同的值,通过 hash 算法生成值相同。
当然如果还有其他字段可以区分,比如:name,并且业务上允许这种重复的数据,不写入数据库,该方案也是可行的。
5.2 不加唯一索引
如果实在不好加唯一索引,就不加唯一索引,通过其他技术手段保证唯一性。
如果新增数据的入口比较少,比如只有 job,或者数据导入,可以单线程顺序执行,这样就能保证表中的数据不重复。
如果新增数据的入口比较多,最终都发 mq 消息,在 mq 消费者中单线程处理。
5.3 redis 分布式锁
由于字段太大了,在 mysql 中不好加唯一索引,为什么不用redis分布式锁呢?
但如果直接加给 name、model、delete_status 和 delete_id 字段,加redis分布式锁,显然没啥意义,效率也不会高。
我们可以结合 5.1 章节,用 name、model、delete_status 和 delete_id 字段,生成一个 hash 值,然后给这个新值加锁。
即使遇到 hash 冲突也没关系,在并发的情况下,毕竟是小概率事件。
6.批量插入数据
有些小伙伴,可能认为,既然有 redis 分布式锁了,就可以不用唯一索引了。
那是你没遇到批量插入数据的场景。
假如通过查询操作之后,发现有一个集合:list 的数据,需要批量插入数据库。
如果使用 redis 分布式锁,需要这样操作:
for(Product product: list) {<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> try {<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> String hash = hash(product);<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> rLock.lock(hash);<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> //查询数据<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> //插入数据<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> } catch (InterruptedException e) {<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> log.error(e);<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> } finally {<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> rLock.unlock();<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" /> }<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />}<br data-filtered="filtered" style="margin: 0px;padding: 0px;outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;" />
需要在一个循环中,给每条数据都加锁。
这样性能肯定不会好。
当然有些小伙伴持反对意见,说使用 redis 的pipeline批量操作不就可以了?
也就是一次性给 500 条,或者 1000 条数据上锁,最后使用完一次性释放这些锁?
想想都有点不靠谱,这个锁得有多大呀。
极容易造成锁超时,比如业务代码都没有执行完,锁的过期时间就已经到了。
针对这种批量操作,如果此时使用 mysql 的唯一索引,直接批量 insert 即可,一条 sql 语句就能搞定。
数据库会自动判断,如果存在重复的数据,会报错。如果不存在重复数据,才允许插入数据。
对嵌入式有兴趣的在校生,挑战一下你的动手能力!买课程,送硬件,而且还有额外惊喜!
(实现效果:手靠越近,风扇转越慢;手靠越远,风扇转越快)
1. 买课程送硬件(顺丰包邮),硬件+邮费成本已经超过40元!
2. 课程全部看完+做完项目,凭学生证全额退款(硬件赠送)!
3. 学技术,提认知,让你成为一个认知比同学更牛逼的程序员!
4. 答疑群专人答疑,为你的学习保驾护航!
良许花了一个半月的时间研发了一门 Linux 命令课程,欢迎购买学习!
课程特色:
详细总结 150个高频使用命令,学完可应对工作中 95%命令需求;
答疑群提供无限次答疑服务,答疑群氛围很好;
总时长超 10小时,媲美大课时长。
长按下方卡片购买