| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394 |
- <?php
- declare(strict_types=1);
- /**
- * This class is used to test database is well-constructed (SQLite).
- */
- class FreshRSS_DatabaseDAOSQLite extends FreshRSS_DatabaseDAO {
- #[\Override]
- public function tablesAreCorrect(): bool {
- $sql = "SELECT name FROM sqlite_master WHERE type='table'";
- $res = $this->fetchAssoc($sql);
- if ($res === null) {
- return false;
- }
- $tables = [
- $this->pdo->prefix() . 'category' => false,
- $this->pdo->prefix() . 'feed' => false,
- $this->pdo->prefix() . 'entry' => false,
- $this->pdo->prefix() . 'entrytmp' => false,
- $this->pdo->prefix() . 'tag' => false,
- $this->pdo->prefix() . 'entrytag' => false,
- ];
- foreach ($res as $value) {
- if (is_array($value) && is_string($value['name'] ?? null)) {
- $tables[$value['name']] = true;
- }
- }
- return count(array_keys($tables, true, true)) == count($tables);
- }
- /** @return list<array{name:string,type:string,notnull:bool,default:mixed}> */
- #[\Override]
- public function getSchema(string $table): array {
- $sql = <<<SQL
- PRAGMA table_info('{$table}')
- SQL;
- $res = $this->fetchAssoc($sql);
- if ($res !== null) {
- /** @var list<array{name:string,type:string,notnull:bool|int,dflt_value:string|int|bool|null}> $res */
- return $this->listDaoToSchema($res);
- }
- return [];
- }
- /**
- * @param array<string,string|int|bool|null> $dao
- * @return array{'name':string,'type':string,'notnull':bool,'default':mixed}
- */
- #[\Override]
- public function daoToSchema(array $dao): array {
- return [
- 'name' => is_string($dao['name'] ?? null) ? $dao['name'] : '',
- 'type' => is_string($dao['type'] ?? null) ? strtolower($dao['type']) : '',
- 'notnull' => empty($dao['notnull']),
- 'default' => is_scalar($dao['dflt_value'] ?? null) ? $dao['dflt_value'] : null,
- ];
- }
- #[\Override]
- protected function selectVersion(): string {
- return $this->fetchString('SELECT sqlite_version()') ?? '';
- }
- #[\Override]
- public function size(bool $all = false): int {
- $sum = 0;
- if ($all) {
- foreach (glob(DATA_PATH . '/users/*/db.sqlite') ?: [] as $filename) {
- $sum += (@filesize($filename) ?: 0);
- }
- } else {
- $sum = (@filesize(DATA_PATH . '/users/' . $this->current_user . '/db.sqlite') ?: 0);
- }
- return $sum;
- }
- #[\Override]
- public function optimize(): bool {
- $ok = $this->pdo->exec('VACUUM') !== false;
- if (!$ok) {
- $info = $this->pdo->errorInfo();
- Minz_Log::warning(__METHOD__ . ' error : ' . json_encode($info));
- }
- return $ok;
- }
- #[\Override]
- public static function strilike(string $haystack, string $needle, bool $contains = false): bool {
- return $contains ? (stripos($haystack, $needle) !== false) : (strcasecmp($haystack, $needle) === 0);
- }
- }
|