4
0

DatabaseDAOSQLite.php 2.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394
  1. <?php
  2. declare(strict_types=1);
  3. /**
  4. * This class is used to test database is well-constructed (SQLite).
  5. */
  6. class FreshRSS_DatabaseDAOSQLite extends FreshRSS_DatabaseDAO {
  7. #[\Override]
  8. public function tablesAreCorrect(): bool {
  9. $sql = "SELECT name FROM sqlite_master WHERE type='table'";
  10. $res = $this->fetchAssoc($sql);
  11. if ($res === null) {
  12. return false;
  13. }
  14. $tables = [
  15. $this->pdo->prefix() . 'category' => false,
  16. $this->pdo->prefix() . 'feed' => false,
  17. $this->pdo->prefix() . 'entry' => false,
  18. $this->pdo->prefix() . 'entrytmp' => false,
  19. $this->pdo->prefix() . 'tag' => false,
  20. $this->pdo->prefix() . 'entrytag' => false,
  21. ];
  22. foreach ($res as $value) {
  23. if (is_array($value) && is_string($value['name'] ?? null)) {
  24. $tables[$value['name']] = true;
  25. }
  26. }
  27. return count(array_keys($tables, true, true)) == count($tables);
  28. }
  29. /** @return list<array{name:string,type:string,notnull:bool,default:mixed}> */
  30. #[\Override]
  31. public function getSchema(string $table): array {
  32. $sql = <<<SQL
  33. PRAGMA table_info('{$table}')
  34. SQL;
  35. $res = $this->fetchAssoc($sql);
  36. if ($res !== null) {
  37. /** @var list<array{name:string,type:string,notnull:bool|int,dflt_value:string|int|bool|null}> $res */
  38. return $this->listDaoToSchema($res);
  39. }
  40. return [];
  41. }
  42. /**
  43. * @param array<string,string|int|bool|null> $dao
  44. * @return array{'name':string,'type':string,'notnull':bool,'default':mixed}
  45. */
  46. #[\Override]
  47. public function daoToSchema(array $dao): array {
  48. return [
  49. 'name' => is_string($dao['name'] ?? null) ? $dao['name'] : '',
  50. 'type' => is_string($dao['type'] ?? null) ? strtolower($dao['type']) : '',
  51. 'notnull' => empty($dao['notnull']),
  52. 'default' => is_scalar($dao['dflt_value'] ?? null) ? $dao['dflt_value'] : null,
  53. ];
  54. }
  55. #[\Override]
  56. protected function selectVersion(): string {
  57. return $this->fetchString('SELECT sqlite_version()') ?? '';
  58. }
  59. #[\Override]
  60. public function size(bool $all = false): int {
  61. $sum = 0;
  62. if ($all) {
  63. foreach (glob(DATA_PATH . '/users/*/db.sqlite') ?: [] as $filename) {
  64. $sum += (@filesize($filename) ?: 0);
  65. }
  66. } else {
  67. $sum = (@filesize(DATA_PATH . '/users/' . $this->current_user . '/db.sqlite') ?: 0);
  68. }
  69. return $sum;
  70. }
  71. #[\Override]
  72. public function optimize(): bool {
  73. $ok = $this->pdo->exec('VACUUM') !== false;
  74. if (!$ok) {
  75. $info = $this->pdo->errorInfo();
  76. Minz_Log::warning(__METHOD__ . ' error : ' . json_encode($info));
  77. }
  78. return $ok;
  79. }
  80. #[\Override]
  81. public static function strilike(string $haystack, string $needle, bool $contains = false): bool {
  82. return $contains ? (stripos($haystack, $needle) !== false) : (strcasecmp($haystack, $needle) === 0);
  83. }
  84. }