|
|
@@ -146,13 +146,13 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
public function addEntry($valuesTmp) {
|
|
|
if ($this->addEntryPrepared == null) {
|
|
|
$sql = 'INSERT INTO `' . $this->prefix . 'entrytmp` (id, guid, title, author, '
|
|
|
- . ($this->isCompressed() ? 'content_bin' : 'content')
|
|
|
- . ', link, date, `lastSeen`, hash, is_read, is_favorite, id_feed, tags) '
|
|
|
- . 'VALUES(:id, :guid, :title, :author, '
|
|
|
- . ($this->isCompressed() ? 'COMPRESS(:content)' : ':content')
|
|
|
- . ', :link, :date, :last_seen, '
|
|
|
- . $this->sqlHexDecode(':hash')
|
|
|
- . ', :is_read, :is_favorite, :id_feed, :tags)';
|
|
|
+ . ($this->isCompressed() ? 'content_bin' : 'content')
|
|
|
+ . ', link, date, `lastSeen`, hash, is_read, is_favorite, id_feed, tags) '
|
|
|
+ . 'VALUES(:id, :guid, :title, :author, '
|
|
|
+ . ($this->isCompressed() ? 'COMPRESS(:content)' : ':content')
|
|
|
+ . ', :link, :date, :last_seen, '
|
|
|
+ . $this->sqlHexDecode(':hash')
|
|
|
+ . ', :is_read, :is_favorite, :id_feed, :tags)';
|
|
|
$this->addEntryPrepared = $this->bd->prepare($sql);
|
|
|
}
|
|
|
if ($this->addEntryPrepared) {
|
|
|
@@ -203,8 +203,13 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
|
|
|
public function commitNewEntries() {
|
|
|
$sql = 'SET @rank=(SELECT MAX(id) - COUNT(*) FROM `' . $this->prefix . 'entrytmp`); ' . //MySQL-specific
|
|
|
- 'INSERT IGNORE INTO `' . $this->prefix . 'entry` (id, guid, title, author, content_bin, link, date, `lastSeen`, hash, is_read, is_favorite, id_feed, tags) ' .
|
|
|
- 'SELECT @rank:=@rank+1 AS id, guid, title, author, content_bin, link, date, `lastSeen`, hash, is_read, is_favorite, id_feed, tags FROM `' . $this->prefix . 'entrytmp` ORDER BY date; ' .
|
|
|
+ 'INSERT IGNORE INTO `' . $this->prefix . 'entry`
|
|
|
+ (
|
|
|
+ id, guid, title, author, content_bin, link, date, `lastSeen`, hash, is_read, is_favorite, id_feed, tags
|
|
|
+ ) ' .
|
|
|
+ 'SELECT @rank:=@rank+1 AS id, guid, title, author, content_bin, link, date, `lastSeen`, hash, is_read, is_favorite, id_feed, tags
|
|
|
+ FROM `' . $this->prefix . 'entrytmp`
|
|
|
+ ORDER BY date; ' .
|
|
|
'DELETE FROM `' . $this->prefix . 'entrytmp` WHERE id <= @rank;';
|
|
|
$hadTransaction = $this->bd->inTransaction();
|
|
|
if (!$hadTransaction) {
|
|
|
@@ -226,13 +231,13 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
|
|
|
if ($this->updateEntryPrepared === null) {
|
|
|
$sql = 'UPDATE `' . $this->prefix . 'entry` '
|
|
|
- . 'SET title=:title, author=:author, '
|
|
|
- . ($this->isCompressed() ? 'content_bin=COMPRESS(:content)' : 'content=:content')
|
|
|
- . ', link=:link, date=:date, `lastSeen`=:last_seen, '
|
|
|
- . 'hash=' . $this->sqlHexDecode(':hash')
|
|
|
- . ', ' . ($valuesTmp['is_read'] === null ? '' : 'is_read=:is_read, ')
|
|
|
- . 'tags=:tags '
|
|
|
- . 'WHERE id_feed=:id_feed AND guid=:guid';
|
|
|
+ . 'SET title=:title, author=:author, '
|
|
|
+ . ($this->isCompressed() ? 'content_bin=COMPRESS(:content)' : 'content=:content')
|
|
|
+ . ', link=:link, date=:date, `lastSeen`=:last_seen, '
|
|
|
+ . 'hash=' . $this->sqlHexDecode(':hash')
|
|
|
+ . ', ' . ($valuesTmp['is_read'] === null ? '' : 'is_read=:is_read, ')
|
|
|
+ . 'tags=:tags '
|
|
|
+ . 'WHERE id_feed=:id_feed AND guid=:guid';
|
|
|
$this->updateEntryPrepared = $this->bd->prepare($sql);
|
|
|
}
|
|
|
|
|
|
@@ -295,8 +300,8 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
}
|
|
|
FreshRSS_UserDAO::touch();
|
|
|
$sql = 'UPDATE `' . $this->prefix . 'entry` '
|
|
|
- . 'SET is_favorite=? '
|
|
|
- . 'WHERE id IN (' . str_repeat('?,', count($ids) - 1). '?)';
|
|
|
+ . 'SET is_favorite=? '
|
|
|
+ . 'WHERE id IN (' . str_repeat('?,', count($ids) - 1). '?)';
|
|
|
$values = array($is_favorite ? 1 : 0);
|
|
|
$values = array_merge($values, $ids);
|
|
|
$stm = $this->bd->prepare($sql);
|
|
|
@@ -322,14 +327,14 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
*/
|
|
|
protected function updateCacheUnreads($catId = false, $feedId = false) {
|
|
|
$sql = 'UPDATE `' . $this->prefix . 'feed` f '
|
|
|
- . 'LEFT OUTER JOIN ('
|
|
|
- . 'SELECT e.id_feed, '
|
|
|
- . 'COUNT(*) AS nbUnreads '
|
|
|
- . 'FROM `' . $this->prefix . 'entry` e '
|
|
|
- . 'WHERE e.is_read=0 '
|
|
|
- . 'GROUP BY e.id_feed'
|
|
|
- . ') x ON x.id_feed=f.id '
|
|
|
- . 'SET f.`cache_nbUnreads`=COALESCE(x.nbUnreads, 0)';
|
|
|
+ . 'LEFT OUTER JOIN ('
|
|
|
+ . 'SELECT e.id_feed, '
|
|
|
+ . 'COUNT(*) AS nbUnreads '
|
|
|
+ . 'FROM `' . $this->prefix . 'entry` e '
|
|
|
+ . 'WHERE e.is_read=0 '
|
|
|
+ . 'GROUP BY e.id_feed'
|
|
|
+ . ') x ON x.id_feed=f.id '
|
|
|
+ . 'SET f.`cache_nbUnreads`=COALESCE(x.nbUnreads, 0)';
|
|
|
$hasWhere = false;
|
|
|
$values = array();
|
|
|
if ($feedId !== false) {
|
|
|
@@ -558,9 +563,9 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
public function searchByGuid($id_feed, $guid) {
|
|
|
// un guid est unique pour un flux donné
|
|
|
$sql = 'SELECT id, guid, title, author, '
|
|
|
- . ($this->isCompressed() ? 'UNCOMPRESS(content_bin) AS content' : 'content')
|
|
|
- . ', link, date, is_read, is_favorite, id_feed, tags '
|
|
|
- . 'FROM `' . $this->prefix . 'entry` WHERE id_feed=? AND guid=?';
|
|
|
+ . ($this->isCompressed() ? 'UNCOMPRESS(content_bin) AS content' : 'content')
|
|
|
+ . ', link, date, is_read, is_favorite, id_feed, tags '
|
|
|
+ . 'FROM `' . $this->prefix . 'entry` WHERE id_feed=? AND guid=?';
|
|
|
$stm = $this->bd->prepare($sql);
|
|
|
|
|
|
$values = array(
|
|
|
@@ -576,9 +581,9 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
|
|
|
public function searchById($id) {
|
|
|
$sql = 'SELECT id, guid, title, author, '
|
|
|
- . ($this->isCompressed() ? 'UNCOMPRESS(content_bin) AS content' : 'content')
|
|
|
- . ', link, date, is_read, is_favorite, id_feed, tags '
|
|
|
- . 'FROM `' . $this->prefix . 'entry` WHERE id=?';
|
|
|
+ . ($this->isCompressed() ? 'UNCOMPRESS(content_bin) AS content' : 'content')
|
|
|
+ . ', link, date, is_read, is_favorite, id_feed, tags '
|
|
|
+ . 'FROM `' . $this->prefix . 'entry` WHERE id=?';
|
|
|
$stm = $this->bd->prepare($sql);
|
|
|
|
|
|
$values = array($id);
|
|
|
@@ -600,16 +605,14 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
if (!($state & FreshRSS_Entry::STATE_READ)) {
|
|
|
$search .= 'AND ' . $alias . 'is_read=0 ';
|
|
|
}
|
|
|
- }
|
|
|
- elseif ($state & FreshRSS_Entry::STATE_READ) {
|
|
|
+ } elseif ($state & FreshRSS_Entry::STATE_READ) {
|
|
|
$search .= 'AND ' . $alias . 'is_read=1 ';
|
|
|
}
|
|
|
if ($state & FreshRSS_Entry::STATE_FAVORITE) {
|
|
|
if (!($state & FreshRSS_Entry::STATE_NOT_FAVORITE)) {
|
|
|
$search .= 'AND ' . $alias . 'is_favorite=1 ';
|
|
|
}
|
|
|
- }
|
|
|
- elseif ($state & FreshRSS_Entry::STATE_NOT_FAVORITE) {
|
|
|
+ } elseif ($state & FreshRSS_Entry::STATE_NOT_FAVORITE) {
|
|
|
$search .= 'AND ' . $alias . 'is_favorite=0 ';
|
|
|
}
|
|
|
|
|
|
@@ -621,7 +624,8 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
throw new FreshRSS_EntriesGetter_Exception('Bad order in Entry->listByType: [' . $order . ']!');
|
|
|
}
|
|
|
/*if ($firstId === '' && parent::$sharedDbType === 'mysql') {
|
|
|
- $firstId = $order === 'DESC' ? '9000000000'. '000000' : '0'; //MySQL optimization. TODO: check if this is needed again, after the filtering for old articles has been removed in 0.9-dev
|
|
|
+ //MySQL optimization. TODO: check if this is needed again, after the filtering for old articles has been removed in 0.9-dev
|
|
|
+ $firstId = $order === 'DESC' ? '9000000000'. '000000' : '0';
|
|
|
}*/
|
|
|
if ($firstId !== '') {
|
|
|
$search .= 'AND ' . $alias . 'id ' . ($order === 'DESC' ? '<=' : '>=') . $firstId . ' ';
|
|
|
@@ -759,13 +763,13 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
list($values, $sql) = $this->sqlListWhere($type, $id, $state, $order, $limit, $firstId, $filter, $date_min);
|
|
|
|
|
|
$sql = 'SELECT e0.id, e0.guid, e0.title, e0.author, '
|
|
|
- . ($this->isCompressed() ? 'UNCOMPRESS(content_bin) AS content' : 'content')
|
|
|
- . ', e0.link, e0.date, e0.is_read, e0.is_favorite, e0.id_feed, e0.tags '
|
|
|
- . 'FROM `' . $this->prefix . 'entry` e0 '
|
|
|
- . 'INNER JOIN ('
|
|
|
- . $sql
|
|
|
- . ') e2 ON e2.id=e0.id '
|
|
|
- . 'ORDER BY e0.id ' . $order;
|
|
|
+ . ($this->isCompressed() ? 'UNCOMPRESS(content_bin) AS content' : 'content')
|
|
|
+ . ', e0.link, e0.date, e0.is_read, e0.is_favorite, e0.id_feed, e0.tags '
|
|
|
+ . 'FROM `' . $this->prefix . 'entry` e0 '
|
|
|
+ . 'INNER JOIN ('
|
|
|
+ . $sql
|
|
|
+ . ') e2 ON e2.id=e0.id '
|
|
|
+ . 'ORDER BY e0.id ' . $order;
|
|
|
|
|
|
$stm = $this->bd->prepare($sql);
|
|
|
$stm->execute($values);
|
|
|
@@ -839,7 +843,7 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
|
|
|
public function countUnreadRead() {
|
|
|
$sql = 'SELECT COUNT(e.id) AS count FROM `' . $this->prefix . 'entry` e INNER JOIN `' . $this->prefix . 'feed` f ON e.id_feed=f.id WHERE priority > 0'
|
|
|
- . ' UNION SELECT COUNT(e.id) AS count FROM `' . $this->prefix . 'entry` e INNER JOIN `' . $this->prefix . 'feed` f ON e.id_feed=f.id WHERE priority > 0 AND is_read=0';
|
|
|
+ . ' UNION SELECT COUNT(e.id) AS count FROM `' . $this->prefix . 'entry` e INNER JOIN `' . $this->prefix . 'feed` f ON e.id_feed=f.id WHERE priority > 0 AND is_read=0';
|
|
|
$stm = $this->bd->prepare($sql);
|
|
|
$stm->execute();
|
|
|
$res = $stm->fetchAll(PDO::FETCH_COLUMN, 0);
|
|
|
@@ -870,9 +874,9 @@ class FreshRSS_EntryDAO extends Minz_ModelPdo implements FreshRSS_Searchable {
|
|
|
|
|
|
public function countUnreadReadFavorites() {
|
|
|
$sql = 'SELECT c FROM ('
|
|
|
- . 'SELECT COUNT(id) AS c, 1 as o FROM `' . $this->prefix . 'entry` WHERE is_favorite=1 '
|
|
|
- . 'UNION SELECT COUNT(id) AS c, 2 AS o FROM `' . $this->prefix . 'entry` WHERE is_favorite=1 AND is_read=0'
|
|
|
- . ') u ORDER BY o';
|
|
|
+ . 'SELECT COUNT(id) AS c, 1 as o FROM `' . $this->prefix . 'entry` WHERE is_favorite=1 '
|
|
|
+ . 'UNION SELECT COUNT(id) AS c, 2 AS o FROM `' . $this->prefix . 'entry` WHERE is_favorite=1 AND is_read=0'
|
|
|
+ . ') u ORDER BY o';
|
|
|
$stm = $this->bd->prepare($sql);
|
|
|
$stm->execute();
|
|
|
$res = $stm->fetchAll(PDO::FETCH_COLUMN, 0);
|