perl - 在数据库中发送多个请求

Question

我在 perl 中有这个脚本，这个程序解析一个日志文件并将结果发送到数据库中，我的问题是我的脚本只插入一个请求，我需要插入多个请求：

#Connect to the database.
my $dbh = DBI->connect("DBI:mysql:database=database;host=IP",
"hostname", 'password',
{'RaiseError' => 1});



while (my ($user, $ref) = each %counts) {
  while (my ($program, $count) = each %$ref) {
    #print "$count OSUSER with session $user and with program $program\n";
    print "time = $time, count = $count, user = $user, program = $program, last_line = $last_line\n";

    $request ="'$time', '$count', '$user', '$program', $last_line";

    my $sth = $dbh->prepare("REPLACE `test` (time, nb, os_name, program, last_line) VALUES($request);")
    or die "prepare statement failed: $dbh->errstr()";

    $sth->execute() or die "execution failed: $dbh->errstr()";
    print $sth->rows . " rows found.\n";
    $sth->finish;
  }
}

我的日志：

       ID USER                    TERMINAL        SERVICE                    
---------- ------------------------- --------------- -------------------------  
         1 toto                    titi     roro          
         2 toto                    titi     roro          
         4 gigi                    gege        fefe      

我的数据库：

+----+---------------------+-----------+-------------+----------------+-----------+
| ID | time                | nb        | os_name     | program        | last_line |
+----+---------------------+-----------+-------------+----------------+-----------+
| 15  | 2019-01-04 14:00:00|        33 | titi        | roro           | 109       |

我想要：

+----+---------------------+-----------+-------------+----------------+-----------+
| ID | time                | nb        | os_name     | program        | last_line |
+----+---------------------+-----------+-------------+----------------+-----------+
| 15  | 2019-01-04 14:00:00|        33 | titi        | roro           | 109       |
| 16  | 2019-01-04 14:00:00|        9  | gege        | fefe           | 109       |      

（由 Dave Cross 添加 - 从评论中复制。这是表定义。）

CREATE TABLE test (
  ID INT UNSIGNED NOT NULL AUTO_INCREMENT,
  time datetime NOT NULL,
  nb int NOT NULL,
  os_name nvarchar(100) NOT NULL,
  program nvarchar(100) NOT NULL,
  last_line nvarchar(100)NOT NULL,
  PRIMARY KEY (ID),
  UNIQUE KEY (time)
) ENGINE=InnoDB;

Answer 1

您的表定义（来自评论）包括：

UNIQUE KEY (time)

因此，您的表只能包含任何 time 值的单行。

此外，您在 SQL 中使用 REPLACE。因此，当您第二次运行语句时，您的数据库会看到存在具有相同唯一键的现有行，因此它会更新该行而不是插入新行。

在我看来，您的代码完全按预期工作。如果要添加更多行，则需要更改$time中的值。

更新：

来自您对另一个答案的评论。

我使用 INSERT 进行了测试，但不起作用：DBD::mysql::st 执行失败：重复条目 '2019-01-04 17:45:00' for key 'time'

是的！这正是应该发生的事情。通过将time 列声明为UNIQUE，您是在告诉您的数据库每个时间值只能在您的表中出现一次。因此，如果您尝试在同一时间插入另一行（这就是您正在做的），您会收到该错误。

因此，您从 INSERT 切换到 REPLACE 并没有收到任何错误，但只插入了一行 - 因为这是 REPLACE 所做的。

您在表中给出的示例在时间列中有两个相同的值。当您在该列上有 UNIQUE 定义时，这不会发生。这正是 UNIQUE 键可以防止的。

您需要退后一步，仔细考虑您想要的表格。如果要在表中重复时间值，则需要删除表中的 UNIQUE 键定义（然后将 REPLACE 更改为 INSERT）。

Answer 2

来自manual for REPLACE：

REPLACE 的工作方式与INSERT 完全相同，只是如果表中的旧行与PRIMARY KEY 或UNIQUE 索引的新行具有相同的值，则删除旧行在插入新行之前。

（重点：我）

你有它。你有相同的时间2019-01-04 14:00:00 两次。当REPLACE第二个时，第一个被删除

尝试删除time 上的唯一索引。