mirror of
https://github.com/FreshRSS/FreshRSS.git
synced 2026-01-24 13:17:59 -05:00
e750448f5b
* Remove FreshRSS_Searchable for better types The interface was not used, and it was preventing more precise types for the different `searchById()` methods, as they each have different input and output types. * Consistent entry ID Entry IDs (which are 64-bit integers) must be processed as string to be compatible with 32-bit platforms * Fix type * A few more related types * PHPStan level 6 * Some more casts needed * String cast for htmlspecialchars
73 lines
2.4 KiB
PHP
73 lines
2.4 KiB
PHP
<?php
|
|
|
|
class FreshRSS_EntryDAOPGSQL extends FreshRSS_EntryDAOSQLite {
|
|
|
|
public static function hasNativeHex(): bool {
|
|
return true;
|
|
}
|
|
|
|
public static function sqlHexDecode(string $x): string {
|
|
return 'decode(' . $x . ", 'hex')";
|
|
}
|
|
|
|
public static function sqlHexEncode(string $x): string {
|
|
return 'encode(' . $x . ", 'hex')";
|
|
}
|
|
|
|
public static function sqlIgnoreConflict(string $sql): string {
|
|
return rtrim($sql, ' ;') . ' ON CONFLICT DO NOTHING';
|
|
}
|
|
|
|
/** @param array<string> $errorInfo */
|
|
protected function autoUpdateDb(array $errorInfo): bool {
|
|
if (isset($errorInfo[0])) {
|
|
if ($errorInfo[0] === FreshRSS_DatabaseDAO::ER_BAD_FIELD_ERROR || $errorInfo[0] === FreshRSS_DatabaseDAOPGSQL::UNDEFINED_COLUMN) {
|
|
$errorLines = explode("\n", $errorInfo[2], 2); // The relevant column name is on the first line, other lines are noise
|
|
foreach (['attributes'] as $column) {
|
|
if (stripos($errorLines[0], $column) !== false) {
|
|
return $this->addColumn($column);
|
|
}
|
|
}
|
|
}
|
|
if ($errorInfo[0] === FreshRSS_DatabaseDAOPGSQL::UNDEFINED_TABLE) {
|
|
if (stripos($errorInfo[2], 'tag') !== false) {
|
|
$tagDAO = FreshRSS_Factory::createTagDao();
|
|
return $tagDAO->createTagTable(); //v1.12.0
|
|
} elseif (stripos($errorInfo[2], 'entrytmp') !== false) {
|
|
return $this->createEntryTempTable(); //v1.7.0
|
|
}
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
public function commitNewEntries(): bool {
|
|
//TODO: Update to PostgreSQL 9.5+ syntax with ON CONFLICT DO NOTHING
|
|
$sql = 'DO $$
|
|
DECLARE
|
|
maxrank bigint := (SELECT MAX(id) FROM `_entrytmp`);
|
|
rank bigint := (SELECT maxrank - COUNT(*) FROM `_entrytmp`);
|
|
BEGIN
|
|
INSERT INTO `_entry`
|
|
(id, guid, title, author, content, link, date, `lastSeen`, hash, is_read, is_favorite, id_feed, tags, attributes)
|
|
(SELECT rank + row_number() OVER(ORDER BY date, id) AS id, guid, title, author, content,
|
|
link, date, `lastSeen`, hash, is_read, is_favorite, id_feed, tags, attributes
|
|
FROM `_entrytmp` AS etmp
|
|
WHERE NOT EXISTS (
|
|
SELECT 1 FROM `_entry` AS ereal
|
|
WHERE (etmp.id = ereal.id) OR (etmp.id_feed = ereal.id_feed AND etmp.guid = ereal.guid))
|
|
ORDER BY date, id);
|
|
DELETE FROM `_entrytmp` WHERE id <= maxrank;
|
|
END $$;';
|
|
$hadTransaction = $this->pdo->inTransaction();
|
|
if (!$hadTransaction) {
|
|
$this->pdo->beginTransaction();
|
|
}
|
|
$result = $this->pdo->exec($sql) !== false;
|
|
if (!$hadTransaction) {
|
|
$this->pdo->commit();
|
|
}
|
|
return $result;
|
|
}
|
|
}
|