mirror of
https://github.com/FreshRSS/FreshRSS.git
synced 2026-03-17 05:46:26 -04:00
c76a318193
* CLI to export/import any database to/from SQLite
Require PHP 5.5+ https://github.com/FreshRSS/FreshRSS/pull/2495
* Travis
* Execution rights
* Fix wrong static fields
* Fix MySQL bad default buffering
https://stackoverflow.com/questions/6895098/pdo-mysql-memory-consumption-with-large-result-set/6935271#6935271
https://php.net/manual/ref.pdo-mysql
* Fix count on progression
* Avoid static DB information
To ease working with two DBs at the same time
* Less static, simplify
Needs some testing
* Small corrections
* Special case for SQLite to SQLite
* Modify special case for SQLite
* Remove special case for SQLite
More uniform logic for the 3 databases.
Fix wrong DROP TABLE for SQLite.
* Drop indexes
* Revert "Drop indexes"
This reverts commit f28d2bae09.
* Fix deletion
* Fix classic export
* Update cli/README.md
Co-Authored-By: Marien Fressinaud <dev@marienfressinaud.fr>
* Addressing part of review
* Remove goto 😢
* Travis
* Comment for SQLite case
* Fix missing fields when inserting
61 lines
1.8 KiB
PHP
61 lines
1.8 KiB
PHP
<?php
|
|
|
|
class FreshRSS_EntryDAOPGSQL extends FreshRSS_EntryDAOSQLite {
|
|
|
|
public function hasNativeHex() {
|
|
return true;
|
|
}
|
|
|
|
public function sqlHexDecode($x) {
|
|
return 'decode(' . $x . ", 'hex')";
|
|
}
|
|
|
|
public function sqlHexEncode($x) {
|
|
return 'encode(' . $x . ", 'hex')";
|
|
}
|
|
|
|
protected function autoUpdateDb($errorInfo) {
|
|
if (isset($errorInfo[0])) {
|
|
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;
|
|
}
|
|
|
|
protected function addColumn($name) {
|
|
return false;
|
|
}
|
|
|
|
public function commitNewEntries() {
|
|
$sql = 'DO $$
|
|
DECLARE
|
|
maxrank bigint := (SELECT MAX(id) FROM `' . $this->prefix . 'entrytmp`);
|
|
rank bigint := (SELECT maxrank - COUNT(*) FROM `' . $this->prefix . 'entrytmp`);
|
|
BEGIN
|
|
INSERT INTO `' . $this->prefix . 'entry` (id, guid, title, author, content, link, date, `lastSeen`, hash, is_read, is_favorite, id_feed, tags)
|
|
(SELECT rank + row_number() OVER(ORDER BY date) AS id, guid, title, author, content, link, date, `lastSeen`, hash, is_read, is_favorite, id_feed, tags
|
|
FROM `' . $this->prefix . 'entrytmp` AS etmp
|
|
WHERE NOT EXISTS (
|
|
SELECT 1 FROM `' . $this->prefix . 'entry` AS ereal
|
|
WHERE (etmp.id = ereal.id) OR (etmp.id_feed = ereal.id_feed AND etmp.guid = ereal.guid))
|
|
ORDER BY date);
|
|
DELETE FROM `' . $this->prefix . 'entrytmp` WHERE id <= maxrank;
|
|
END $$;';
|
|
$hadTransaction = $this->bd->inTransaction();
|
|
if (!$hadTransaction) {
|
|
$this->bd->beginTransaction();
|
|
}
|
|
$result = $this->bd->exec($sql) !== false;
|
|
if (!$hadTransaction) {
|
|
$this->bd->commit();
|
|
}
|
|
return $result;
|
|
}
|
|
}
|