mirrors/rss-bridge
1
0
Fork 0
mirror of https://github.com/RSS-Bridge/rss-bridge.git synced 2024-11-22 09:35:28 +03:00
Code Issues Projects Releases Packages Wiki Activity

perf(SqliteCache): add index to updated (#3515)

Browse source 
* refactor(SqliteCache)

* perf(SqliteCache): add index to updated
This commit is contained in:
Dag 2023-07-15 22:12:16 +02:00 committed by GitHub
parent eaea8e6640
commit ef8181478d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
caches/SQLiteCache.php
View file

@ -1,8 +1,5 @@
<?php <?php
/**
* Cache based on SQLite 3 <https://www.sqlite.org>
*/
class SQLiteCache implements CacheInterface class SQLiteCache implements CacheInterface
{ {
private \SQLite3 $db; private \SQLite3 $db;
@ -32,6 +29,7 @@ class SQLiteCache implements CacheInterface
$this->db = new \SQLite3($config['file']); $this->db = new \SQLite3($config['file']);
$this->db->enableExceptions(true); $this->db->enableExceptions(true);
$this->db->exec("CREATE TABLE storage ('key' BLOB PRIMARY KEY, 'value' BLOB, 'updated' INTEGER)"); $this->db->exec("CREATE TABLE storage ('key' BLOB PRIMARY KEY, 'value' BLOB, 'updated' INTEGER)");
$this->db->exec('CREATE INDEX idx_storage_updated ON storage (updated)');
} }
$this->db->busyTimeout($config['timeout']); $this->db->busyTimeout($config['timeout']);
} }
@ -42,20 +40,22 @@ class SQLiteCache implements CacheInterface
$stmt->bindValue(':key', $this->getCacheKey()); $stmt->bindValue(':key', $this->getCacheKey());
$result = $stmt->execute(); $result = $stmt->execute();
if ($result) { if ($result) {
$data = $result->fetchArray(\SQLITE3_ASSOC); $row = $result->fetchArray(\SQLITE3_ASSOC);
if (isset($data['value'])) { $data = unserialize($row['value']);
return unserialize($data['value']); if ($data !== false) {
return $data;
} }
} }
return null; return null;
} }
public function saveData($data): void public function saveData($data): void
{ {
$blob = serialize($data);
$stmt = $this->db->prepare('INSERT OR REPLACE INTO storage (key, value, updated) VALUES (:key, :value, :updated)'); $stmt = $this->db->prepare('INSERT OR REPLACE INTO storage (key, value, updated) VALUES (:key, :value, :updated)');
$stmt->bindValue(':key', $this->getCacheKey()); $stmt->bindValue(':key', $this->getCacheKey());
$stmt->bindValue(':value', serialize($data)); $stmt->bindValue(':value', $blob);
$stmt->bindValue(':updated', time()); $stmt->bindValue(':updated', time());
$stmt->execute(); $stmt->execute();
} }
@ -66,12 +66,9 @@ class SQLiteCache implements CacheInterface
$stmt->bindValue(':key', $this->getCacheKey()); $stmt->bindValue(':key', $this->getCacheKey());
$result = $stmt->execute(); $result = $stmt->execute();
if ($result) { if ($result) {
$data = $result->fetchArray(\SQLITE3_ASSOC); $row = $result->fetchArray(\SQLITE3_ASSOC);
if (isset($data['updated'])) { return $row['updated'];
return $data['updated'];
} }
}
return null; return null;
} }