使用Perl脚本检测SQL数据库记录中的分钟级缺失时段

我来帮你完善这个检查数据库完整性的Perl脚本——你的需求是检测SQLite数据库中每分钟一条的记录是否存在缺失，并输出易读的缺失时段起止时间。先整理你已有的代码，再一步步补全核心逻辑：

现有代码整理（补全数据库连接部分） #

#!/usr/bin/perl -w
use strict;
use DBI;
use Data::Dumper;
use POSIX qw(strftime);

my $lock = 0;
my @empty;

# 配置目标表名
my $dbtable = "USD_BCH";
# 连接SQLite数据库（请替换为你的实际数据库文件路径）
my $dbh = DBI->connect( 
    "dbi:SQLite:dbname=your_database_file.db", 
    "", 
    "", 
    { RaiseError => 1, AutoCommit => 1, PrintError => 0 }
) or die "无法连接数据库: $DBI::errstr";

核心功能补全步骤 #

1. 获取并排序所有记录的时间戳 #

首先从数据库中取出所有已存在记录的时间，转换为Unix时间戳（方便计算分钟间隔）并按时间排序。假设你的表中有一个存储记录时间的字段record_time（格式支持SQLite的strftime转换即可）：

# 查询并排序所有记录的Unix时间戳
my $sth = $dbh->prepare("SELECT strftime('%s', record_time) AS ts FROM $dbtable ORDER BY ts ASC");
$sth->execute();

my @timestamps;
while (my $row = $sth->fetchrow_hashref) {
    push @timestamps, $row->{ts};
}
$sth->finish();

2. 检测缺失的分钟时段 #

遍历时间戳数组，对比相邻记录的时间差：如果间隔超过60秒，说明中间存在缺失的分钟记录，记录下缺失时段的起止时间：

my @missing_periods;
my $prev_ts;

foreach my $ts (@timestamps) {
    if (defined $prev_ts) {
        my $diff = $ts - $prev_ts;
        # 间隔大于60秒，判定存在缺失
        if ($diff > 60) {
            # 缺失时段的起始是上一条记录的下一分钟，结束是当前记录的上一分钟
            my $start_missing = $prev_ts + 60;
            my $end_missing = $ts - 60;
            push @missing_periods, { start => $start_missing, end => $end_missing };
        }
    }
    $prev_ts = $ts;
}

# 可选：补充检测首尾时段的缺失（比如最早记录之前、当前时间到最后一条记录之间的缺失）
# 示例：检查从最后一条记录到当前时间的缺失
# my $current_ts = time();
# if ($prev_ts < $current_ts - 60) {
#     push @missing_periods, { start => $prev_ts + 60, end => $current_ts - 60 };
# }

3. 输出易读格式的缺失时段 #

用POSIX::strftime把Unix时间戳转换为YYYY-MM-DD HH:MM:SS的易读格式，打印缺失时段：

print "=== 数据库记录缺失检测结果 ===\n";
if (scalar @missing_periods > 0) {
    foreach my $period (@missing_periods) {
        my $start_str = strftime("%Y-%m-%d %H:%M:%S", localtime($period->{start}));
        my $end_str = strftime("%Y-%m-%d %H:%M:%S", localtime($period->{end}));
        print "- 缺失时段：$start_str 至 $end_str\n";
    }
} else {
    print "未检测到任何缺失的分钟级记录。\n";
}

4. 关闭数据库连接 #

最后记得释放数据库连接资源：

$dbh->disconnect();

完整脚本整合 #

把以上部分整合起来，就是一个完整的可运行脚本，记得替换数据库文件路径和时间字段名称为你的实际配置。

内容的提问来源于stack exchange，提问作者F. Grela