SQL 维护脚本

Question

我有一张表格，表格如下

GROUP_ID | FOO | BAR | DATETIME

我有一个每天晚上更新这个表的 cron。但是我想，在我的脚本结束时运行一个 sql 命令，这将确保每个 group_id 的 50 个最新行都存在，并且其他任何行都被删除。

例如：如果有 60 行 GROUP_ID = 1，我希望在运行后只剩下 50 个最近的行。如果只有 20 行 GROUP_ID = 2，则将它们全部保留。

这是否可能仅在 SQL 中实现，或者我需要在 PHP 中执行此操作（我的大多数应用程序都是用它构建的）

我正在运行 MySQL

谢谢

Answer 1

试穿一下尺寸：

DELIMITER $$
DECLARE groupCursor CURSOR FOR
SELECT GROUP_ID FROM mytable WHERE 
(SELECT COUNT(*) FROM mytable WHERE GROUP_ID=GROUP_ID) > 50;

DECLARE CONTINUE HANDLER FOR NOT FOUND done = 1;

DECLARE groupID INT;

read_loop: LOOP
FETCH groupCursor INTO groupID;
IF done THEN
   LEAVE read_loop;
ELSE
   DELETE FROM mytable
   WHERE GROUP_ID = groupID
   AND DATETIME < (SELECT MIN(DATETIME) FROM mytable WHERE GROUP_ID=groupID 
   ORDER BY DATETIME DESC LIMIT 50)
END IF;
END LOOP;
CLOSE groupCursor$$
DELIMITER ;

更新根据下面的讨论，这里是一个存储过程 CREATE 脚本，它应该是无语法错误的。

-- --------------------------------------------------------------------------------
-- Routine DDL
-- --------------------------------------------------------------------------------
DELIMITER $$

CREATE PROCEDURE `mydb`.`maintenanceTaskDelete` ()
BEGIN

DECLARE groupCursor CURSOR FOR SELECT GROUP_ID FROM mytable;
DECLARE done BIT DEFAULT 0;
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;

DECLARE groupID INT;

read_loop: LOOP
FETCH groupCursor INTO groupID;
IF done THEN
   LEAVE read_loop;
ELSE
   DELETE FROM mytable
   WHERE GROUP_ID = groupID
   AND DATETIME < (SELECT MIN(DATETIME) FROM mytable WHERE GROUP_ID=groupID 
   ORDER BY DATETIME DESC LIMIT 50);
END IF;
END LOOP;
CLOSE groupCursor;

END$$

要调用例程，您需要做的就是： CALL maintenanceTaskDelete();

Answer 2

尝试：

delete from yourtable 
where PK in (select pk 
             from (select 
                       pk, 
                       row_number() over(partition by GROUP_ID order by GROUP_ID, activity_date) as RowNumber
                   from yourtable
                   ) dt
             where RowNumber>50
            )

编辑 我刚刚看到这是针对 mysql 而不是 ms sql。 mysql没有row_number()。