Updated index create command

Client/Connection.php

@@ -245,14 +245,17 @@ public function scroll($scrollId, $scrollDuration)
      * Creates fresh elasticsearch index.
      *
      * @param bool $putWarmers Determines if warmers should be loaded.
+     * @param bool $noMapping  Determines if mapping should be included.
      */
-    public function createIndex($putWarmers = false)
+    public function createIndex($putWarmers = false, $noMapping = false)
     {
         $this->isReadOnly('Create index');
 
         $settings = $this->settings;
-        unset($settings['body']['mappings']);
 
+        if ($noMapping) {
+            unset($settings['body']['mappings']);
+        }
         $this->client->indices()->create($settings);
 
         if ($putWarmers) {
@@ -361,16 +364,17 @@ public function updateTypes(array $types = [])
      * Tries to drop and create fresh elasticsearch index.
      *
      * @param bool $putWarmers Determines if warmers should be loaded.
+     * @param bool $noMapping  Determines if mapping should be included.
      */
-    public function dropAndCreateIndex($putWarmers = false)
+    public function dropAndCreateIndex($putWarmers = false, $noMapping = false)
     {
         try {
             $this->dropIndex();
         } catch (\Exception $e) {
             // Do nothing because I'm only trying.
         }
 
-        $this->createIndex($putWarmers);
+        $this->createIndex($putWarmers, $noMapping);
     }
 
     /**

Command/IndexCreateCommand.php

@@ -32,7 +32,8 @@ protected function configure()
             ->setName('ongr:es:index:create')
             ->setDescription('Creates elasticsearch index.')
             ->addOption('time', 't', InputOption::VALUE_NONE, 'Adds date suffix to new index name')
-            ->addOption('with-warmers', 'w', InputOption::VALUE_NONE, 'Puts warmers into index');
+            ->addOption('with-warmers', 'w', InputOption::VALUE_NONE, 'Puts warmers into index')
+            ->addOption('no-mapping', 'm', InputOption::VALUE_NONE, 'Do not include mapping');
     }
 
     /**
@@ -47,9 +48,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
             $finder = $this->getContainer()->get('es.client.index_suffix_finder');
             $finder->setNextFreeIndex($connection);
         }
-
-        $connection->createIndex($input->getOption('with-warmers'));
-
+        $connection->createIndex($input->getOption('with-warmers'), $input->getOption('no-mapping') ? true : false);
         $output->writeln(
             sprintf(
                 '<info>Created index for manager named `</info><comment>%s</comment><info>`</info>',

Test/AbstractElasticsearchTestCase.php

@@ -244,7 +244,6 @@ protected function getManager($name = 'default', $createIndex = true, array $cus
         // Drops and creates index.
         if ($createIndex) {
             $connection->dropAndCreateIndex();
-            $connection->createTypes();
         }
 
         // Populates elasticsearch index with data.

Tests/Functional/Client/ConnectionTest.php

@@ -204,7 +204,7 @@ public function testWarmers()
     {
         $manager = $this->getManager('default', false);
         $connection = $manager->getConnection();
-        $connection->dropAndCreateIndex(true);
+        $connection->dropAndCreateIndex(true, false);
 
         $warmers = $connection->getClient()->indices()->getWarmer(
             [

Tests/Functional/Command/CreateIndexCommandTest.php

@@ -30,13 +30,23 @@ public function getTestExecuteData()
                 [
                     'timestamp' => false,
                     'warm' => false,
+                    'noMapping' => true,
                 ],
             ],
             [
                 'default',
                 [
                     'timestamp' => false,
                     'warm' => true,
+                    'noMapping' => false,
+                ],
+            ],
+            [
+                'default',
+                [
+                    'timestamp' => false,
+                    'warm' => true,
+                    'noMapping' => true,
                 ],
             ],
         ];
@@ -75,9 +85,12 @@ public function testExecute($argument, $options)
         if ($options['warm']) {
             $arguments['--with-warmers'] = null;
         }
-
+        if ($options['noMapping']) {
+            $arguments['--no-mapping'] = null;
+        }
         $commandTester->execute($arguments);
-
+        $mapping = $connection->getMappingFromIndex();
+        $this->assertEquals($options['noMapping'], empty($mapping));
         $this->assertTrue($connection->indexExists(), 'Index should exist.');
         $connection->dropIndex();
     }

Tests/Functional/Command/TypeCreateCommandTest.php

@@ -74,7 +74,7 @@ public function testExecute($arguments, $message, $checkMapping = true)
             ->getContainer()
             ->get('es.manager.' . $manager)
             ->getConnection();
-        $connection->dropAndCreateIndex();
+        $connection->dropAndCreateIndex(false, true);
 
         $this->assertEquals($message, $this->runCreateCommand($arguments));
 
@@ -134,7 +134,7 @@ public function testExecuteOnExistingTypes($arguments, $message, $createTypes =
             ->getContainer()
             ->get('es.manager.' . $manager)
             ->getConnection();
-        $connection->dropAndCreateIndex();
+        $connection->dropAndCreateIndex(false, true);
         $connection->createTypes($createTypes);
 
         $this->assertEquals($message, $this->runCreateCommand($arguments));