Merge pull request #30 from Smolevich/29-issue-add-put-method

29 issue add put method
Smolevich · Dec 23, 2022 · 90cc84d · 90cc84d
2 parents 0d53e5a + e839778
commit 90cc84d
Show file tree

Hide file tree

Showing 2 changed files with 40 additions and 1 deletion.
diff --git a/src/Reindexer/Services/Query.php b/src/Reindexer/Services/Query.php
@@ -5,7 +5,7 @@
 use Reindexer\BaseService;
 
 class Query extends BaseService {
-    public $database;
+    public string $database;
 
     public function getDatabase(): string {
         return $this->database ?? '';
@@ -26,6 +26,17 @@ public function createByHttpGet(string $query) {
         );
     }
 
+    public function createByHttpPut(mixed $query) {
+        $uri = sprintf('/api/%s/db/%s/query', $this->version, $this->getDatabase());
+
+        return $this->client->request(
+            'PUT',
+            $uri,
+            json_encode($query),
+            $this->defaultHeaders
+        );
+    }
+
     public function createSqlQueryByHttpPost(string $query) {
         $uri = sprintf('/api/%s/db/%s/sqlquery', $this->version, $this->getDatabase());
 

diff --git a/tests/Feature/Reindexer/ServiceTest.php b/tests/Feature/Reindexer/ServiceTest.php
@@ -144,5 +144,33 @@ public function testQuery() {
             ->getDecodedResponseBody(true);
 
         $this->assertEquals(3, count($response['items']));
+
+        $response = $this->queryService
+            ->createByHttpPut([
+                'namespace' => $this->namespaceName,
+                'type' => 'update',
+                'filters' => [
+                    [
+                        'field' => 'user_nickname',
+                        'cond' => 'EQ',
+                        'value' => 'LMonoceros',
+                    ]
+                ],
+                'update_fields' => [
+                    [
+                        'name' => 'user_nickname',
+                        'type' =>  'value',
+                        'values' => ['LMonoceros new']
+                    ]
+                ]
+            ])
+            ->getDecodedResponseBody(true);
+
+        $this->assertEquals(2, $response['updated']);
+
+        $response = $this->queryService
+            ->createByHttpGet("SELECT * FROM {$this->namespaceName} WHERE user_nickname = 'LMonoceros'")
+            ->getDecodedResponseBody(true);
+        $this->assertEquals(0, count($response['items']));
     }
 }