From 11ac01a0d8e1c235cbed9d90aaff3d7a354497fd Mon Sep 17 00:00:00 2001 From: Don Hardman Date: Wed, 25 Dec 2024 16:10:36 +0700 Subject: [PATCH] Migrate to use system tables --- composer.lock | 8 ++++---- src/Plugin/Sharding/Queue.php | 2 +- src/Plugin/Sharding/State.php | 2 +- src/Plugin/Sharding/Table.php | 2 +- 4 files changed, 7 insertions(+), 7 deletions(-) diff --git a/composer.lock b/composer.lock index 78ada78e..1a819ff4 100644 --- a/composer.lock +++ b/composer.lock @@ -715,12 +715,12 @@ "source": { "type": "git", "url": "https://github.com/manticoresoftware/buddy-core.git", - "reference": "a52c62cdc094eb03ce92d9795f04df381af87f31" + "reference": "6b0a5b94f50bbb52b5fd3552b7ebfe485dae0942" }, "dist": { "type": "zip", - "url": "https://api.github.com/repos/manticoresoftware/buddy-core/zipball/a52c62cdc094eb03ce92d9795f04df381af87f31", - "reference": "a52c62cdc094eb03ce92d9795f04df381af87f31", + "url": "https://api.github.com/repos/manticoresoftware/buddy-core/zipball/6b0a5b94f50bbb52b5fd3552b7ebfe485dae0942", + "reference": "6b0a5b94f50bbb52b5fd3552b7ebfe485dae0942", "shasum": "" }, "require": { @@ -759,7 +759,7 @@ "issues": "https://github.com/manticoresoftware/buddy-core/issues", "source": "https://github.com/manticoresoftware/buddy-core/tree/main" }, - "time": "2025-01-06T07:29:37+00:00" + "time": "2025-01-08T03:16:00+00:00" }, { "name": "manticoresoftware/manticoresearch-backup", diff --git a/src/Plugin/Sharding/Queue.php b/src/Plugin/Sharding/Queue.php index 3ba6cee9..7cdf1ef5 100644 --- a/src/Plugin/Sharding/Queue.php +++ b/src/Plugin/Sharding/Queue.php @@ -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, diff --git a/src/Plugin/Sharding/State.php b/src/Plugin/Sharding/State.php index 12ce293c..97b02c51 100644 --- a/src/Plugin/Sharding/State.php +++ b/src/Plugin/Sharding/State.php @@ -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 diff --git a/src/Plugin/Sharding/Table.php b/src/Plugin/Sharding/Table.php index 798bf4a7..a2f78782 100644 --- a/src/Plugin/Sharding/Table.php +++ b/src/Plugin/Sharding/Table.php @@ -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,