Merge pull request #11 from gaobinzhan/master

feat: testing
easy-swoole · Oct 19, 2020 · 09b7a0a · 09b7a0a
2 parents d7cdab7 + decf353
commit 09b7a0a
Show file tree

Hide file tree

Showing 10 changed files with 100 additions and 20 deletions.
diff --git a/tests/CreateTest.php b/tests/CreateTest.php
@@ -12,12 +12,13 @@ function test()
     {
         $bean = new Create();
         $time = time();
-        $bean->setIndex('my-index-'.$time);
+        $bean->setIndex('my-index-' . $time);
         $bean->setType('my-type');
-        $bean->setId('my-id-'.$time);
-        $bean->setBody(['test-field' => $time]);
+        $bean->setId('my-id-' . $time);
+        $bean->setBody(['test-field' => 'abd']);
         $response = $this->getElasticSearch()->client()->create($bean)->getBody();
-        $response = json_decode($response,true);
-        $this->assertEquals('created',$response['result']);
+        $response = json_decode($response, true);
+        var_dump('------------create', $response);
+        $this->assertEquals('created', $response['result']);
     }
 }
diff --git a/tests/ExistsSourceTest.php b/tests/ExistsSourceTest.php
@@ -9,12 +9,23 @@
 namespace EasySwoole\ElasticSearch\Tests;
 
 
+use EasySwoole\ElasticSearch\RequestBean\Create;
 use EasySwoole\ElasticSearch\RequestBean\ExistsSource;
 
 class ExistsSourceTest extends Base
 {
     public function test()
     {
+
+        $bean = new Create();
+        $time = time();
+        $bean->setIndex('my-index');
+        $bean->setType('my-type');
+        $bean->setId('my-id');
+        $bean->setBody(['test-field' => 'abd']);
+        $this->getElasticSearch()->client()->create($bean)->getBody();
+
+
         $bean = new ExistsSource();
         $bean->setIndex('my-index');
         $bean->setId('my-id');

diff --git a/tests/GetSourceTest.php b/tests/GetSourceTest.php
@@ -20,6 +20,7 @@ public function test()
         $bean->setId('my-id');
         $response = $this->getElasticSearch()->client()->getSource($bean)->getBody();
         $response = json_decode($response, true);
+        var_dump('--------get source', $response);
         $this->assertEquals('abd', $response['test-field']);
     }
 }
diff --git a/tests/IndexTest.php b/tests/IndexTest.php
@@ -23,6 +23,7 @@ public function test()
         $bean->setBody(['test-field' => '测试' . $time]);
         $response = $this->getElasticSearch()->client()->index($bean)->getBody();
         $response = json_decode($response, true);
+        var_dump('--------index', $response);
         $this->assertEquals('created', $response['result']);
     }
 }
diff --git a/tests/Indices/PutSettingsTest.php b/tests/Indices/PutSettingsTest.php
@@ -21,12 +21,12 @@ public function test()
         $bean->setBody([
             'settings' => [
                 'index.refresh_interval' => '2s',
-                //"index.blocks.write" => false
+//                "index.blocks.write" => true
             ]
         ]);
         $response = $this->getElasticSearch()->client()->indices()->putSettings($bean)->getBody();
         $response = json_decode($response, true);
-        //print_r($response);
+        var_dump('----------put settings', $response);
         $this->assertArrayNotHasKey('error', $response);
     }
 }
diff --git a/tests/Indices/ShrinkTest.php b/tests/Indices/ShrinkTest.php
@@ -9,26 +9,47 @@
 namespace EasySwoole\ElasticSearch\Tests\Indices;
 
 
+use EasySwoole\ElasticSearch\RequestBean\Indices\Delete;
+use EasySwoole\ElasticSearch\RequestBean\Indices\Create;
 use EasySwoole\ElasticSearch\RequestBean\Indices\Shrink;
 use EasySwoole\ElasticSearch\Tests\Base;
 
 class ShrinkTest extends Base
 {
     public function test()
     {
+
+        $bean = new Delete();
+        $bean->setIndex('my_source_index');
+        $this->getElasticSearch()->client()->indices()->delete($bean)->getBody();
+
+        $bean = new Create();
+        $bean->setIndex('my_source_index');
+        $bean->setBody([
+            'settings' => [
+                "index.number_of_shards" => 2,
+//                "index.number_of_replicas" => 1,
+//                "index.routing.allocation.require._name" => "shrink_node_name",
+                "index.blocks.write" => true
+            ]]);
+        $response = $this->getElasticSearch()->client()->indices()->create($bean)->getBody();
+        var_dump($response);
+        $this->assertArrayNotHasKey('error', json_decode($response, true));
+
         $bean = new Shrink();
-        $bean->setIndex('my-index');
-        $bean->setTarget('my_target_index');
+        $bean->setIndex('my_source_index');
+        $bean->setTarget('my_target_index' . time());
         $bean->setBody([
             'settings' => [
-                'index.number_of_replicas' => 1,
-                'index.number_of_shards' => 1,
-                'index.codec' => 'best_compression'
+                "index.number_of_replicas" => 1,
+                "index.number_of_shards" => 2,
+                "index.codec" => "best_compression"
             ]
         ]);
         $response = $this->getElasticSearch()->client()->indices()->shrink($bean)->getBody();
         $response = json_decode($response, true);
-        //print_r($response);
+        var_dump('------------------shrink test');
+        var_dump($response);
         $this->assertArrayNotHasKey('error', $response);
     }
 }
diff --git a/tests/Indices/SplitTest.php b/tests/Indices/SplitTest.php
@@ -9,24 +9,48 @@
 namespace EasySwoole\ElasticSearch\Tests\Indices;
 
 
+use EasySwoole\ElasticSearch\RequestBean\Indices\Create;
+use EasySwoole\ElasticSearch\RequestBean\Indices\Delete;
 use EasySwoole\ElasticSearch\RequestBean\Indices\Split;
 use EasySwoole\ElasticSearch\Tests\Base;
 
 class SplitTest extends Base
 {
     public function test()
     {
+
+        $bean = new Delete();
+        $bean->setIndex('my_source_index');
+        $this->getElasticSearch()->client()->indices()->delete($bean)->getBody();
+
+        $bean = new Create();
+        $bean->setIndex('my_source_index');
+        $bean->setBody([
+            'settings' => [
+                "index.number_of_shards" => 1,
+//                "index.number_of_replicas" => 1,
+//                "index.routing.allocation.require._name" => "shrink_node_name",
+                "index.blocks.write" => true
+            ]]);
+        $response = $this->getElasticSearch()->client()->indices()->create($bean)->getBody();
+        var_dump($response);
+        $this->assertArrayNotHasKey('error', json_decode($response, true));
+
         $bean = new Split();
-        $bean->setIndex('my-index');
-        $bean->setTarget('my-target-index-1');
+        $bean->setIndex('my_source_index');
+        $bean->setTarget('my-target-index-' . time());
         $bean->setBody([
             "settings" => [
-                "index.number_of_shards" => 3
+                "index.number_of_shards" => 2,
+//                "index.blocks.write" => true
             ]
         ]);
+
+
         $response = $this->getElasticSearch()->client()->indices()->split($bean)->getBody();
         $response = json_decode($response, true);
-        //print_r($response);
+        var_dump('--------------split');
+        var_dump($response);
         $this->assertArrayNotHasKey('error', $response);
     }
 }
diff --git a/tests/Indices/UpdateAliasesTest.php b/tests/Indices/UpdateAliasesTest.php
@@ -9,13 +9,22 @@
 namespace EasySwoole\ElasticSearch\Tests\Indices;
 
 
+use EasySwoole\ElasticSearch\RequestBean\Create;
 use EasySwoole\ElasticSearch\RequestBean\Indices\UpdateAliases;
 use EasySwoole\ElasticSearch\Tests\Base;
 
 class UpdateAliasesTest extends Base
 {
     public function test()
     {
+
+        $bean = new Create();
+        $bean->setIndex('my-index-1');
+        $bean->setType('my-type');
+        $bean->setId('my-id-1');
+        $bean->setBody(['test-field' => 'abd']);
+        $this->getElasticSearch()->client()->create($bean)->getBody();
+
         $bean = new UpdateAliases();
         $bean->setBody(
             [
@@ -26,7 +35,7 @@ public function test()
         );
         $response = $this->getElasticSearch()->client()->indices()->updateAliases($bean)->getBody();
         $response = json_decode($response, true);
-        //print_r($response);
+        var_dump('-----------update alias', $response);
         $this->assertArrayNotHasKey('error', $response);
     }
 }
diff --git a/tests/Ingest/SimulateTest.php b/tests/Ingest/SimulateTest.php
@@ -18,8 +18,18 @@ public function test()
     {
         $bean = new Simulate();
         $bean->setId('my-pipeline-id');
-        $response=$this->getElasticSearch()->client()->ingest()->simulate($bean)->getBody();
-        print_r($response);
+        $bean->setBody([
+            'pipeline' => [
+                'description' => '_description'
+            ],
+            'docs' => [
+                ['_index' => 'my-index', '_id' => 'id', '_source' => ['foo' => 'bar']]
+            ]
+        ]);
+        $response = $this->getElasticSearch()->client()->ingest()->simulate($bean)->getBody();
+        $response = json_decode($response, true);
+        var_dump('-----------simulate');
+        var_dump($response);
         $this->assertArrayNotHasKey('error', $response);
     }
 }
diff --git a/tests/UpdateTest.php b/tests/UpdateTest.php
@@ -10,6 +10,7 @@
 
 
 use EasySwoole\ElasticSearch\RequestBean\Update;
+
 //参考文档
 //https://www.elastic.co/guide/cn/elasticsearch/guide/current/partial-updates.html
 class UpdateTest extends Base
@@ -27,6 +28,7 @@ public function test()
         ]);
         $response = $this->getElasticSearch()->client()->update($bean)->getBody();
         $response = json_decode($response, true);
+        var_dump('--------update', $response);
         $this->assertIsArray($response);
         $this->assertArrayHasKey('_shards', $response);
     }