-
Notifications
You must be signed in to change notification settings - Fork 49
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Inject database dependency into constructor of Index
Add new IndexRepository class to handle all database access. Inject IndexRepository as a dependency into the constructor of Index and use that instead of directly accessing the database. Add basic indexing test. Fix existing test that uses indexing to use IndexRepository.
- Loading branch information
haszi
committed
Mar 28, 2024
1 parent
e89427b
commit 9052457
Showing
6 changed files
with
368 additions
and
112 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,119 @@ | ||
| <?php | ||
| namespace phpdotnet\phd; | ||
|
|
||
| class IndexRepository | ||
| { | ||
| public function __construct( | ||
| private \SQLite3 $db | ||
| ) {} | ||
|
|
||
| public function init(): void { | ||
| $create = <<<SQL | ||
| CREATE TABLE ids ( | ||
| docbook_id TEXT, | ||
| filename TEXT, | ||
| parent_id TEXT, | ||
| sdesc TEXT, | ||
| ldesc TEXT, | ||
| element TEXT, | ||
| previous TEXT, | ||
| next TEXT, | ||
| chunk INTEGER | ||
| ); | ||
| CREATE TABLE changelogs ( | ||
| membership TEXT, -- How the extension in distributed (pecl, core, bundled with/out external dependencies..) | ||
| docbook_id TEXT, | ||
| parent_id TEXT, | ||
| version TEXT, | ||
| description TEXT | ||
| ); | ||
| CREATE TABLE indexing ( | ||
| time INTEGER PRIMARY KEY | ||
| ); | ||
| SQL; | ||
| $this->db->exec('DROP TABLE IF EXISTS ids'); | ||
| $this->db->exec('DROP TABLE IF EXISTS indexing'); | ||
| $this->db->exec('DROP TABLE IF EXISTS changelogs'); | ||
| $this->db->exec('PRAGMA default_synchronous=OFF'); | ||
| $this->db->exec('PRAGMA count_changes=OFF'); | ||
| $this->db->exec('PRAGMA cache_size=100000'); | ||
| $this->db->exec($create); | ||
| } | ||
|
|
||
| public function saveIndexingTime(int $time): void { | ||
| $this->db->exec("BEGIN TRANSACTION; INSERT INTO indexing (time) VALUES ('" . $time . "'); COMMIT"); | ||
| } | ||
|
|
||
| public function commit( | ||
| array $commitList, | ||
| array $postReplacementIndexes, | ||
| array $postReplacementValues, | ||
| array $changelog, | ||
| ): bool { | ||
| if (!$commitList) { | ||
| return false; | ||
| } | ||
|
|
||
| foreach ($postReplacementValues as $key => $postReplacementValue) { | ||
| $postReplacementValues[$key] = $this->db->escapeString($postReplacementValue); | ||
| } | ||
|
|
||
| foreach ($commitList as $key => $commit) { | ||
| $commitList[$key] = sprintf( | ||
| "INSERT INTO ids (docbook_id, filename, parent_id, sdesc, ldesc, element, previous, next, chunk) VALUES('%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d);\n", | ||
| $this->db->escapeString($commit["docbook_id"]), | ||
| $this->db->escapeString($commit["filename"]), | ||
| $this->db->escapeString($commit["parent_id"]), | ||
| $this->db->escapeString($commit["sdesc"]), | ||
| $this->db->escapeString($commit["ldesc"]), | ||
| $this->db->escapeString($commit["element"]), | ||
| $this->db->escapeString($commit["previous"]), | ||
| $this->db->escapeString($commit["next"]), | ||
| $this->db->escapeString($commit["chunk"]) | ||
| ); | ||
| } | ||
|
|
||
| $search = $this->db->escapeString("POST-REPLACEMENT"); | ||
| $none = $this->db->escapeString(""); | ||
|
|
||
| foreach($postReplacementIndexes as $a) { | ||
| if (isset($postReplacementValues[$a["docbook_id"]])) { | ||
| $replacement = $postReplacementValues[$a["docbook_id"]]; | ||
| $commitList[$a["idx"]] = str_replace($search, $replacement, $commitList[$a["idx"]]); | ||
| } else { | ||
| // If there are still post replacement, then they don't have | ||
| // any 'next' page | ||
| $commitList[$a["idx"]] = str_replace($search, $none, $commitList[$a["idx"]]); | ||
| } | ||
| } | ||
|
|
||
| $this->db->exec('BEGIN TRANSACTION; '.implode("", $commitList).' COMMIT'); | ||
| $this->saveChangelogs($changelog); | ||
| return true; | ||
| } | ||
|
|
||
| private function saveChangelogs(array $changelog): void { | ||
| $log = ""; | ||
| foreach($changelog as $id => $arr) { | ||
| foreach($arr as $entry) { | ||
| $log .= sprintf( | ||
| "INSERT INTO changelogs (membership, docbook_id, parent_id, version, description) VALUES('%s', '%s', '%s', '%s', '%s');\n", | ||
| $this->db->escapeString($entry[0] ?? ''), | ||
| $this->db->escapeString($id), | ||
| $this->db->escapeString($entry[1]), | ||
| $this->db->escapeString($entry[2]), | ||
| $this->db->escapeString($entry[3]) | ||
| ); | ||
| } | ||
| } | ||
| $this->db->exec('BEGIN TRANSACTION; ' . $log. ' COMMIT'); | ||
| } | ||
|
|
||
| public function lastErrorCode(): int { | ||
| return $this->db->lastErrorCode(); | ||
| } | ||
|
|
||
| public function lastErrorMsg(): string { | ||
| return $this->db->lastErrorMsg(); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.