Merge pull request #56 from tomlankhorst/master

Use table prefixes only for raw SQL

Author: msonowal

src/Services/IndexService.php

@@ -67,7 +67,7 @@ public function createOrUpdateIndex()
     protected function createIndex()
     {
         $indexName = $this->modelService->indexName;
-        $tableName = $this->modelService->tableName;
+        $tableName = $this->modelService->tablePrefixedName;
         $indexFields = implode(',', array_map(function($indexField) {
             return "`$indexField`";
         }, $this->modelService->getFullTextIndexFields()));
@@ -84,7 +84,7 @@ protected function createIndex()
 
     protected function indexAlreadyExists()
     {
-        $tableName = $this->modelService->tableName;
+        $tableName = $this->modelService->tablePrefixedName;
         $indexName = $this->modelService->indexName;
 
         return !empty(DB::connection($this->modelService->connectionName)->
@@ -102,7 +102,7 @@ protected function indexNeedsUpdate()
     protected function getIndexFields()
     {
         $indexName = $this->modelService->indexName;
-        $tableName = $this->modelService->tableName;
+        $tableName = $this->modelService->tablePrefixedName;
 
         $index = DB::connection($this->modelService->connectionName)->
         select("SHOW INDEX FROM $tableName WHERE Key_name = ?", [$indexName]);
@@ -131,7 +131,7 @@ protected function updateIndex()
     public function dropIndex()
     {
         $indexName = $this->modelService->indexName;
-        $tableName = $this->modelService->tableName;
+        $tableName = $this->modelService->tablePrefixedName;
 
         if ($this->indexAlreadyExists()) {
             DB::connection($this->modelService->connectionName)

src/Services/ModelService.php

@@ -10,8 +10,12 @@ class ModelService
 
     public $connectionName;
 
+    public $tablePrefix;
+
     public $tableName;
 
+    public $tablePrefixedName;
+
     public $indexName;
 
     protected $fullTextIndexTypes = ['VARCHAR', 'TEXT', 'CHAR'];
@@ -25,7 +29,11 @@ public function setModel($model)
         $this->connectionName = $modelInstance->getConnectionName() !== null ?
             $modelInstance->getConnectionName() : config('database.default');
 
-        $this->tableName = config("database.connections.$this->connectionName.prefix", '').$modelInstance->getTable();
+        $this->tablePrefix = config("database.connections.$this->connectionName.prefix", '');
+
+        $this->tableName = $modelInstance->getTable();
+
+        $this->tablePrefixedName = $this->tablePrefix.$this->tableName;
 
         $this->indexName = $modelInstance->searchableAs();
 
@@ -40,7 +48,7 @@ public function getFullTextIndexFields()
         foreach ($searchableFields as $searchableField) {
 
             //@TODO cache this.
-            $sql = "SHOW FIELDS FROM $this->tableName where Field = ?";
+            $sql = "SHOW FIELDS FROM $this->tablePrefixedName where Field = ?";
             $column = DB::connection($this->connectionName)->select($sql, [$searchableField]);
 
             if (!isset($column[0])) {