百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

巧用MySQL窗口函数删除重复数据(mysql怎么删除重复数据)

wptr33 2025-04-07 20:06 12 浏览

MySQL 去重删除:如何删除重复数据并保留最新记录

引言

在数据库的日常维护中或者在平时的开发过程中,由于操作失误或设计缺陷,可能会导致数据表中出现重复记录。如果这些数据没有主键约束或唯一索引,数据库不会自动防止重复数据的插入。这种情况不仅影响数据的准确性,还可能影响查询性能。

本文将介绍一种高效的方法来删除 MySQL 表中的重复数据,并保留每组数据中 updated_at 最新的那一条记录。我们以 user_life_targets 这张表为例,详细讲解如何使用 SQL 解决这个问题。

问题描述

假设有如下表 user_life_targets,其结构如下:

CREATE TABLE `user_life_targets` (
  `id` bigint NOT NULL,
  `user_id` bigint NOT NULL DEFAULT '0',
  `life_id` bigint NOT NULL DEFAULT '0',
  `task_id` bigint NOT NULL DEFAULT '0',
  `updated_at` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  KEY `idx_u_l_t` (`user_id`,`life_id`,`task_id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

由于某些原因,该表中可能出现了重复的 user_id, life_id, task_id 组合的数据,我们需要删除这些重复数据,并且 保留 updated_at 最新的那条记录

解决方案

1. 使用 ROW_NUMBER() 窗口函数进行去重

MySQL 8.0 及以上版本支持 ROW_NUMBER() 窗口函数,我们可以利用它为重复数据编号,并删除 updated_at 不是最新的记录。

SQL 实现:

WITH ranked_targets AS (
    SELECT 
        id,
        user_id,
        life_id,
        task_id,
        updated_at,
        ROW_NUMBER() OVER (PARTITION BY user_id, life_id, task_id ORDER BY updated_at DESC) AS rn
    FROM `user_life_targets`
)
DELETE FROM `user_life_targets`
WHERE id IN (
    SELECT id FROM ranked_targets WHERE rn > 1
);

2. 解析 SQL 逻辑

步骤解析

  1. 创建临时数据集 ranked_targets
  2. ROW_NUMBER() OVER (PARTITION BY user_id, life_id, task_id ORDER BY updated_at DESC)
  3. 这个函数会按照 (user_id, life_id, task_id) 进行分组,并且按照 updated_at 降序排序。
  4. ROW_NUMBER() 给每组数据分配唯一的编号,最新的数据编号为 1。
  5. 删除重复数据
  6. 通过 DELETE 语句,删除 ranked_targets 中 rn > 1 的数据,只保留 rn = 1 的记录(即 updated_at 最新的记录)。

适用于 MySQL 5.7 及以下版本的方法

如果你的 MySQL 版本不支持 WITH 语法(即 MySQL 8.0 以下版本),可以使用 DELETE + 子查询的方式删除数据:

DELETE FROM user_life_targets 
WHERE id NOT IN (
    SELECT id FROM (
        SELECT id FROM user_life_targets t1
        WHERE updated_at = (
            SELECT MAX(updated_at) 
            FROM user_life_targets t2
            WHERE t1.user_id = t2.user_id AND t1.life_id = t2.life_id AND t1.task_id = t2.task_id
        )
    ) AS latest_records
);

解释

  • 通过子查询 SELECT MAX(updated_at) 找到相同 (user_id, life_id, task_id) 组合中最新的 updated_at 记录。
  • 外层 DELETE 语句删除不在最新记录列表中的数据。
  • 由于 MySQL 5.7 及以下不允许在 DELETE 语句中直接使用 JOIN,因此使用子查询方式删除。

性能优化建议

  1. 创建合适的索引
  2. 确保 (user_id, life_id, task_id, updated_at) 上有索引,提高查询效率。
  3. 例如: CREATE INDEX idx_user_life_task ON user_life_targets(user_id, life_id, task_id, updated_at);
  4. 避免 IN 过大
  5. DELETE FROM ... WHERE id NOT IN (...) 在大数据量下可能会较慢。
  6. 如果数据量特别大,可以考虑使用临时表存储要保留的 id,然后使用 DELETE JOIN 方式删除。
  7. 备份数据
  8. 在执行 DELETE 之前,建议先进行数据备份,防止误删。
  9. 备份方式: CREATE TABLE backup_user_life_targets AS SELECT * FROM user_life_targets;

结论

本篇文章介绍了如何在 MySQL 中删除重复数据,并保留 updated_at 最新的一条记录。

方法总结:

  • MySQL 8.0 及以上 推荐使用 ROW_NUMBER() 窗口函数。
  • MySQL 5.7 及以下 版本可以使用 DELETE + 子查询方式。
  • 在执行 DELETE 之前,建议先进行数据备份。

希望本篇文章能帮助你在实际项目中高效管理数据库数据,避免数据冗余导致的问题!

相关推荐

每天一个编程技巧!掌握这7个神技,代码效率飙升200%

“同事6点下班,你却为改BUG加班到凌晨?不是你不努力,而是没掌握‘偷懒’的艺术!本文揭秘谷歌工程师私藏的7个编程神技,每天1分钟,让你的代码从‘能用’变‘逆天’。文末附《Python高效代码模板》,...

Git重置到某个历史节点(Sourcetree工具)

前言Sourcetree回滚提交和重置当前分支到此次提交的区别?回滚提交是指将改动的代码提交到本地仓库,但未推送到远端仓库的时候。...

git工作区、暂存区、本地仓库、远程仓库的区别和联系

很多程序员天天写代码,提交代码,拉取代码,对git操作非常熟练,但是对git的原理并不甚了解,借助豆包AI,写个文章总结一下。Git的四个核心区域(工作区、暂存区、本地仓库、远程仓库)是版本控制的核...

解锁人生新剧本的密钥:学会让往事退场

开篇:敦煌莫高窟的千年启示在莫高窟321窟的《降魔变》壁画前,讲解员指着斑驳色彩说:"画师刻意保留了历代修补痕迹,因为真正的传承不是定格,而是流动。"就像我们的人生剧本,精彩章节永远...

Reset local repository branch to be just like remote repository HEAD

技术背景在使用Git进行版本控制时,有时会遇到本地分支与远程分支不一致的情况。可能是因为误操作、多人协作时远程分支被更新等原因。这时就需要将本地分支重置为与远程分支的...

Git恢复至之前版本(git恢复到pull之前的版本)

让程序回到提交前的样子:两种解决方法:回退(reset)、反做(revert)方法一:gitreset...

如何将文件重置或回退到特定版本(怎么让文件回到初始状态)

技术背景在使用Git进行版本控制时,经常会遇到需要将文件回退到特定版本的情况。可能是因为当前版本出现了错误,或者想要恢复到之前某个稳定的版本。Git提供了多种方式来实现这一需求。...

git如何正确回滚代码(git命令回滚代码)

方法一,删除远程分支再提交①首先两步保证当前工作区是干净的,并且和远程分支代码一致$gitcocurrentBranch$gitpullorigincurrentBranch$gi...

[git]撤销的相关命令:reset、revert、checkout

基本概念如果不清晰上面的四个概念,请查看廖老师的git教程这里我多说几句:最开始我使用git的时候,我并不明白我为什么写完代码要用git的一些列指令把我的修改存起来。后来用多了,也就明白了为什么。gi...

利用shell脚本将Mysql错误日志保存到数据库中

说明:利用shell脚本将MYSQL的错误日志提取并保存到数据库中步骤:1)创建数据库,创建表CreatedatabaseMysqlCenter;UseMysqlCenter;CREATET...

MySQL 9.3 引入增强的JavaScript支持

MySQL,这一广泛采用的开源关系型数据库管理系统(RDBMS),发布了其9.x系列的第三个更新版本——9.3版,带来了多项新功能。...

python 连接 mysql 数据库(python连接MySQL数据库案例)

用PyMySQL包来连接Python和MySQL。在使用前需要先通过pip来安装PyMySQL包:在windows系统中打开cmd,输入pipinstallPyMySQL ...

mysql导入导出命令(mysql 导入命令)

mysql导入导出命令mysqldump命令的输入是在bin目录下.1.导出整个数据库  mysqldump-u用户名-p数据库名>导出的文件名  mysqldump-uw...

MySQL-SQL介绍(mysql sqlyog)

介绍结构化查询语言是高级的非过程化编程语言,允许用户在高层数据结构上工作。它不要求用户指定对数据的存放方法,也不需要用户了解具体的数据存放方式,所以具有完全不同底层结构的不同数据库系统,可以使用相同...

MySQL 误删除数据恢复全攻略:基于 Binlog 的实战指南

在MySQL的世界里,二进制日志(Binlog)就是我们的"时光机"。它默默记录着数据库的每一个重要变更,就像一位忠实的史官,为我们在数据灾难中提供最后的救命稻草。本文将带您深入掌握如...