Added support for non-default connection

yadakhov · Aug 28, 2016 · a17dc01 · a17dc01
1 parent 8abcc88
commit a17dc01
Showing 1 changed file with 14 additions and 3 deletions.
diff --git a/src/InsertOnDuplicateKey.php b/src/InsertOnDuplicateKey.php
@@ -35,7 +35,7 @@ public static function insertOnDuplicateKey(array $data, array $updateColumns =
 
         $data = static::inLineArray($data);
 
-        return DB::statement($sql, $data);
+        return DB::connection(static::getModelConnectionName())->statement($sql, $data);
     }
 
     /**
@@ -60,7 +60,7 @@ public static function insertIgnore(array $data)
 
         $data = static::inLineArray($data);
 
-        return DB::statement($sql, $data);
+        return DB::connection(static::getModelConnectionName())->statement($sql, $data);
     }
 
     /**
@@ -85,7 +85,7 @@ public static function replace(array $data)
 
         $data = static::inLineArray($data);
 
-        return DB::statement($sql, $data);
+        return DB::connection(static::getModelConnectionName())->statement($sql, $data);
     }
 
     /**
@@ -100,6 +100,17 @@ public static function getTableName()
         return (new $class())->getTable();
     }
 
+    /**
+    * Static function for getting connection name
+    *
+    * @return string
+    */
+    public static function getModelConnectionName()
+    {
+        $class = get_called_class();
+        return (new $class())->getConnectionName();
+    }
+
     /**
      * Static function for getting the primary key.
      *