| 560 | | my @prefix = (""); |
| 561 | | if ($LJ::USE_RECENT_TABLES) { push @prefix, "recent_"; } |
| 562 | | foreach my $pfx (@prefix) |
| 563 | | { |
| 564 | | if ($clustered) { |
| 565 | | # clustered recents have times now (for purger process.. can't use itemid key prefix) |
| 566 | | my ($ec, $ev); |
| 567 | | if ($pfx) { ($ec, $ev) = (", logtime", ", NOW()"); } |
| 568 | | $dbcm->do("REPLACE INTO ${pfx}logtext2 (journalid, jitemid, subject, event $ec) ". |
| 569 | | "VALUES ($ownerid, $itemid, $qsubject, $qevent $ev)"); |
| 570 | | if ($dbcm->err) { |
| 571 | | my $msg = $dbcm->errstr; |
| 572 | | LJ::delete_item2($dbh, $dbcm, $ownerid, $itemid); # roll-back |
| 573 | | return fail($err,501,"logtext:$msg"); |
| 574 | | } |
| 575 | | } else { |
| | 560 | if ($clustered) { |
| | 561 | $dbcm->do("REPLACE INTO logtext2 (journalid, jitemid, subject, event) ". |
| | 562 | "VALUES ($ownerid, $itemid, $qsubject, $qevent)"); |
| | 563 | if ($dbcm->err) { |
| | 564 | my $msg = $dbcm->errstr; |
| | 565 | LJ::delete_item2($dbh, $dbcm, $ownerid, $itemid); # roll-back |
| | 566 | return fail($err,501,"logtext:$msg"); |
| | 567 | } |
| | 568 | } else { |
| | 569 | my @prefix = (""); |
| | 570 | if ($LJ::USE_RECENT_TABLES) { push @prefix, "recent_"; } |
| | 571 | foreach my $pfx (@prefix) |
| | 572 | { |
| 907 | | my @prefix = (""); |
| 908 | | if ($LJ::USE_RECENT_TABLES) { push @prefix, "recent_"; } |
| 909 | | foreach my $pfx (@prefix) { |
| 910 | | if ($clustered) { |
| 911 | | $dbcm->do("UPDATE ${pfx}logtext2 SET event=$qevent, subject=$qsubject ". |
| 912 | | "WHERE journalid=$ownerid AND jitemid=$qitemid"); |
| 913 | | } else { |
| | 904 | if ($clustered) { |
| | 905 | $dbcm->do("UPDATE logtext2 SET event=$qevent, subject=$qsubject ". |
| | 906 | "WHERE journalid=$ownerid AND jitemid=$qitemid"); |
| | 907 | } else { |
| | 908 | my @prefix = (""); |
| | 909 | if ($LJ::USE_RECENT_TABLES) { push @prefix, "recent_"; } |
| | 910 | foreach my $pfx (@prefix) { |