Skip to content

Commit

Permalink
Migrate to use system tables
Browse files Browse the repository at this point in the history
  • Loading branch information
donhardman committed Jan 8, 2025
1 parent a273c25 commit 11ac01a
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 7 deletions.
8 changes: 4 additions & 4 deletions composer.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion src/Plugin/Sharding/Queue.php
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,7 @@ public function setup(): void {
'Trying to initialize while already initialized.'
);
}
$query = "CREATE TABLE `{$this->table}` (
$query = "CREATE TABLE {$this->table} (
`node` string,
`query` string,
`wait_for_id` bigint,
Expand Down
2 changes: 1 addition & 1 deletion src/Plugin/Sharding/State.php
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,7 @@ public function setup(): void {
'Trying to initialize while already initialized.'
);
}
$query = "CREATE TABLE `{$this->table}` (
$query = "CREATE TABLE {$this->table} (
`key` string,
`value` json,
`updated_at` timestamp
Expand Down
2 changes: 1 addition & 1 deletion src/Plugin/Sharding/Table.php
Original file line number Diff line number Diff line change
Expand Up @@ -710,7 +710,7 @@ public function setup(): void {
'Trying to initialize while already initialized.'
);
}
$query = "CREATE TABLE `{$this->table}` (
$query = "CREATE TABLE {$this->table} (
`cluster` string,
`node` string,
`table` string,
Expand Down

0 comments on commit 11ac01a

Please sign in to comment.