4 files changed, 23 insertions, 4 deletions
diff --git a/src/phorkie/Database/Adapter/Elasticsearch/Setup.php b/src/phorkie/Database/Adapter/Elasticsearch/Setup.php
index 066a21c..0df2874 100644
--- a/src/phorkie/Database/Adapter/Elasticsearch/Setup.php
+++ b/src/phorkie/Database/Adapter/Elasticsearch/Setup.php
@@ -10,12 +10,29 @@ class Database_Adapter_Elasticsearch_Setup implements Database_ISetup
 
     public function setup()
     {
-        $r = new Database_Adapter_Elasticsearch_HTTPRequest(
-            $this->searchInstance . 'repo/_mapping',
+        $r = new \HTTP_Request2(
+            $this->searchInstance . '/_mapping', \HTTP_Request2::METHOD_GET
+        );
+        $res = $r->send();
+        if ($res->getStatus() == 404) {
+            $this->reset();
+        }
+    }
+
+    public function reset()
+    {
+        $r = new \HTTP_Request2(
+            $this->searchInstance,
             \HTTP_Request2::METHOD_DELETE
         );
         $r->send();
 
+        $r = new Database_Adapter_Elasticsearch_HTTPRequest(
+            $this->searchInstance,
+            \HTTP_Request2::METHOD_PUT
+        );
+        $r->send();
+
         //create mapping
         //mapping for repositories
         $r = new Database_Adapter_Elasticsearch_HTTPRequest(
diff --git a/src/phorkie/Database/Adapter/Null/Setup.php b/src/phorkie/Database/Adapter/Null/Setup.php
index de23d0a..3850978 100644
--- a/src/phorkie/Database/Adapter/Null/Setup.php
+++ b/src/phorkie/Database/Adapter/Null/Setup.php
@@ -4,6 +4,7 @@ namespace phorkie;
 class Database_Adapter_Null_Setup
 {
     public function setup() {}
+    public function reset() {}
 }
 
 ?>
diff --git a/src/phorkie/Database/ISetup.php b/src/phorkie/Database/ISetup.php
index 1ac6b2f..bb7293e 100644
--- a/src/phorkie/Database/ISetup.php
+++ b/src/phorkie/Database/ISetup.php
@@ -4,6 +4,7 @@ namespace phorkie;
 interface Database_ISetup
 {
     public function setup();
+    public function reset();
 }
 
 ?>
diff --git a/src/phorkie/SetupCheck.php b/src/phorkie/SetupCheck.php
index 39c386e..8ead33f 100644
--- a/src/phorkie/SetupCheck.php
+++ b/src/phorkie/SetupCheck.php
@@ -72,8 +72,8 @@ class SetupCheck
 
     public function checkDatabase()
     {
-        $dbs = new Database_Setup_Elasticsearch();
-        $dbs->setup();
+        $dbs = new Database();
+        $dbs->getSetup()->setup();
     }
 
     public function fail($msg)