mirrors/tt-rss
1
0
Fork 0
mirror of https://git.tt-rss.org/fox/tt-rss.git synced 2025-10-12 19:41:04 +02:00
Code Issues Projects Releases Wiki Activity

ccache: PDO

Browse Source
This commit is contained in:
Andrew Dolgov 2017-12-01 18:03:33 +03:00
parent a25ac0d7c8
commit 933ff559e6
1 changed files with 65 additions and 101 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

166
classes/ccache.php
View File

@ -1,17 +1,15 @@
<?php <?php
class CCache { class CCache {
/* function ccache_zero($feed_id, $owner_uid) {
db_query("UPDATE ttrss_counters_cache SET
value = 0, updated = NOW() WHERE
feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
} */
static function zero_all($owner_uid) { static function zero_all($owner_uid) {
db_query("UPDATE ttrss_counters_cache SET $pdo = Db::pdo();
value = 0 WHERE owner_uid = '$owner_uid'");
db_query("UPDATE ttrss_cat_counters_cache SET $sth = $pdo->prepare("UPDATE ttrss_counters_cache SET
value = 0 WHERE owner_uid = '$owner_uid'"); value = 0 WHERE owner_uid = ?");
$sth->execute([$owner_uid]);
$sth = $pdo->prepare("UPDATE ttrss_cat_counters_cache SET
value = 0 WHERE owner_uid = ?");
$sth->execute([$owner_uid]);
} }
static function remove($feed_id, $owner_uid, $is_cat = false) { static function remove($feed_id, $owner_uid, $is_cat = false) {
@ -22,19 +20,25 @@ class CCache {
$table = "ttrss_cat_counters_cache"; $table = "ttrss_cat_counters_cache";
} }
db_query("DELETE FROM $table WHERE $pdo = Db::pdo();
feed_id = '$feed_id' AND owner_uid = '$owner_uid'");
$sth = $pdo->prepare("DELETE FROM $table WHERE
feed_id = ? AND owner_uid = ?");
$sth->execute([$feed_id, $owner_uid]);
} }
static function update_all($owner_uid) { static function update_all($owner_uid) {
$pdo = Db::pdo();
if (get_pref('ENABLE_FEED_CATS', $owner_uid)) { if (get_pref('ENABLE_FEED_CATS', $owner_uid)) {
$result = db_query("SELECT feed_id FROM ttrss_cat_counters_cache $sth = $pdo->prepare("SELECT feed_id FROM ttrss_cat_counters_cache
WHERE feed_id > 0 AND owner_uid = '$owner_uid'"); WHERE feed_id > 0 AND owner_uid = ?");
$sth->execute([$owner_uid]);
while ($line = db_fetch_assoc($result)) { while ($line = $sth->fetch()) {
CCache::update($line["feed_id"], $owner_uid, true); CCache::update($line["feed_id"], $owner_uid, true);
} }
@ -43,10 +47,11 @@ class CCache {
CCache::update(0, $owner_uid, true); CCache::update(0, $owner_uid, true);
} else { } else {
$result = db_query("SELECT feed_id FROM ttrss_counters_cache $sth = $pdo->prepare("SELECT feed_id FROM ttrss_counters_cache
WHERE feed_id > 0 AND owner_uid = '$owner_uid'"); WHERE feed_id > 0 AND owner_uid = ?");
$sth->execute([$owner_uid]);
while ($line = db_fetch_assoc($result)) { while ($line = $sth->fetch()) {
print CCache::update($line["feed_id"], $owner_uid); print CCache::update($line["feed_id"], $owner_uid);
} }
@ -61,27 +66,20 @@ class CCache {
if (!$is_cat) { if (!$is_cat) {
$table = "ttrss_counters_cache"; $table = "ttrss_counters_cache";
/* if ($feed_id > 0) {
$tmp_result = db_query("SELECT owner_uid FROM ttrss_feeds
WHERE id = '$feed_id'");
$owner_uid = db_fetch_result($tmp_result, 0, "owner_uid");
} */
} else { } else {
$table = "ttrss_cat_counters_cache"; $table = "ttrss_cat_counters_cache";
} }
if (DB_TYPE == "pgsql") { $pdo = Db::pdo();
$date_qpart = "updated > NOW() - INTERVAL '15 minutes'";
} else if (DB_TYPE == "mysql") {
$date_qpart = "updated > DATE_SUB(NOW(), INTERVAL 15 MINUTE)";
}
$result = db_query("SELECT value FROM $table $sth = $pdo->prepare("SELECT value FROM $table
WHERE owner_uid = '$owner_uid' AND feed_id = '$feed_id' WHERE owner_uid = ? AND feed_id = ?
LIMIT 1"); LIMIT 1");
if (db_num_rows($result) == 1) { $sth->execute([$owner_uid, $feed_id]);
return db_fetch_result($result, 0, "value");
if ($row = $sth->fetch()) {
return $row["value"];
} else { } else {
if ($no_update) { if ($no_update) {
return -1; return -1;
@ -97,12 +95,6 @@ class CCache {
if (!is_numeric($feed_id)) return; if (!is_numeric($feed_id)) return;
/* if (!$is_cat && $feed_id > 0) {
$tmp_result = db_query("SELECT owner_uid FROM ttrss_feeds
WHERE id = '$feed_id'");
$owner_uid = db_fetch_result($tmp_result, 0, "owner_uid");
} */
$prev_unread = CCache::find($feed_id, $owner_uid, $is_cat, true); $prev_unread = CCache::find($feed_id, $owner_uid, $is_cat, true);
/* When updating a label, all we need to do is recalculate feed counters /* When updating a label, all we need to do is recalculate feed counters
@ -119,54 +111,59 @@ class CCache {
$table = "ttrss_cat_counters_cache"; $table = "ttrss_cat_counters_cache";
} }
if ($is_cat && $feed_id >= 0) { $pdo = Db::pdo();
if ($feed_id != 0) {
$cat_qpart = "cat_id = '$feed_id'";
} else {
$cat_qpart = "cat_id IS NULL";
}
if ($is_cat && $feed_id >= 0) {
/* Recalculate counters for child feeds */ /* Recalculate counters for child feeds */
if (!$pcat_fast) { if (!$pcat_fast) {
$result = db_query("SELECT id FROM ttrss_feeds $sth = $pdo->prepare("SELECT id FROM ttrss_feeds
WHERE owner_uid = '$owner_uid' AND $cat_qpart"); WHERE owner_uid = :uid AND cat_id = :cat OR (:cat = 0 AND cat_id IS NULL)");
$sth->execute([":uid" => $owner_uid, ":cat" => $feed_id]);
while ($line = db_fetch_assoc($result)) { while ($line = $sth->fetch()) {
CCache::update($line["id"], $owner_uid, false, false); CCache::update($line["id"], $owner_uid, false, false);
} }
} }
$result = db_query("SELECT SUM(value) AS sv $sth = $pdo->prepare("SELECT SUM(value) AS sv
FROM ttrss_counters_cache, ttrss_feeds FROM ttrss_counters_cache, ttrss_feeds
WHERE id = feed_id AND $cat_qpart AND WHERE id = feed_id AND
ttrss_counters_cache.owner_uid = $owner_uid AND cat_id = :cat OR (:cat IS NULL AND cat_id IS NULL) AND
ttrss_feeds.owner_uid = '$owner_uid'"); ttrss_counters_cache.owner_uid = :uid AND
ttrss_feeds.owner_uid = :uid");
$sth->execute([":uid" => $owner_uid, ":cat" => $feed_id]);
$row = $sth->fetch();
$unread = (int) db_fetch_result($result, 0, "sv"); $unread = (int) $row["sv"];
} else { } else {
$unread = (int) Feeds::getFeedArticles($feed_id, $is_cat, true, $owner_uid); $unread = (int) Feeds::getFeedArticles($feed_id, $is_cat, true, $owner_uid);
} }
db_query("BEGIN"); $pdo->beginTransaction();
$result = db_query("SELECT feed_id FROM $table $sth = $pdo->prepare("SELECT feed_id FROM $table
WHERE owner_uid = '$owner_uid' AND feed_id = '$feed_id' LIMIT 1"); WHERE owner_uid = ? AND feed_id = ? LIMIT 1");
$sth->execute([$owner_uid, $feed_id]);
if (db_num_rows($result) == 1) { if ($sth->fetch()) {
db_query("UPDATE $table SET
value = '$unread', updated = NOW() WHERE $sth = $pdo->prepare("UPDATE $table SET
feed_id = '$feed_id' AND owner_uid = '$owner_uid'"); value = ?, updated = NOW() WHERE
feed_id = ? AND owner_uid = ?");
$sth->execute([$unread, $feed_id, $owner_uid]);
} else { } else {
db_query("INSERT INTO $table $sth = $pdo->prepare("INSERT INTO $table
(feed_id, value, owner_uid, updated) (feed_id, value, owner_uid, updated)
VALUES VALUES
($feed_id, $unread, $owner_uid, NOW())"); (?, ?, ?, NOW())");
$sth->execute([$feed_id, $unread, $owner_uid]);
} }
db_query("COMMIT"); $pdo->commit();
if ($feed_id > 0 && $prev_unread != $unread) { if ($feed_id > 0 && $prev_unread != $unread) {
@ -176,13 +173,13 @@ class CCache {
if ($update_pcat) { if ($update_pcat) {
$result = db_query("SELECT cat_id FROM ttrss_feeds $sth = $pdo->prepare("SELECT cat_id FROM ttrss_feeds
WHERE owner_uid = '$owner_uid' AND id = '$feed_id'"); WHERE owner_uid = ? AND id = ?");
$sth->execute([$owner_uid, $feed_id]);
$cat_id = (int) db_fetch_result($result, 0, "cat_id");
CCache::update($cat_id, $owner_uid, true, true, true);
if ($row = $sth->fetch()) {
CCache::update($row["cat_id"], $owner_uid, true, true, true);
}
} }
} }
} else if ($feed_id < 0) { } else if ($feed_id < 0) {
@ -192,37 +189,4 @@ class CCache {
return $unread; return $unread;
} }
/* function ccache_cleanup($owner_uid) {
if (DB_TYPE == "pgsql") {
db_query("DELETE FROM ttrss_counters_cache AS c1 WHERE
(SELECT count(*) FROM ttrss_counters_cache AS c2
WHERE c1.feed_id = c2.feed_id AND c2.owner_uid = c1.owner_uid) > 1
AND owner_uid = '$owner_uid'");
db_query("DELETE FROM ttrss_cat_counters_cache AS c1 WHERE
(SELECT count(*) FROM ttrss_cat_counters_cache AS c2
WHERE c1.feed_id = c2.feed_id AND c2.owner_uid = c1.owner_uid) > 1
AND owner_uid = '$owner_uid'");
} else {
db_query("DELETE c1 FROM
ttrss_counters_cache AS c1,
ttrss_counters_cache AS c2
WHERE
c1.owner_uid = '$owner_uid' AND
c1.owner_uid = c2.owner_uid AND
c1.feed_id = c2.feed_id");
db_query("DELETE c1 FROM
ttrss_cat_counters_cache AS c1,
ttrss_cat_counters_cache AS c2
WHERE
c1.owner_uid = '$owner_uid' AND
c1.owner_uid = c2.owner_uid AND
c1.feed_id = c2.feed_id");
}
} */
} }