Checks database connection on insert method

Eduardo Haddad · Eduardo Haddad · commit 0f9b4fb5d764 · 2019-11-01T16:36:36.000-03:00
diff --git a/src/LaravelBatch.php b/src/LaravelBatch.php
@@ -164,11 +164,11 @@ public function insert(Model $table, array $columns, array $values, int $batchSi
         }
 
         if (count($query)) {
-            return $this->db->transaction(function () use ($totalValues, $totalChunk, $query) {
+            return $this->db->transaction(function () use ($totalValues, $totalChunk, $query, $table) {
 
                 $totalQuery = 0;
                 foreach ($query as $value) {
-                    $totalQuery += $this->db->statement($value) ? 1 : 0;
+                    $totalQuery += $this->db->connection($this->getConnectionName($table))->statement($value) ? 1 : 0;
                 }
 
                 return [

Original file line number	Diff line number	Diff line change
`@@ -164,11 +164,11 @@ public function insert(Model $table, array $columns, array $values, int $batchSi`
`164`	`164`	`}`
`165`	`165`
`166`	`166`	`if (count($query)) {`
`167`		`- return $this->db->transaction(function () use ($totalValues, $totalChunk, $query) {`
	`167`	`+ return $this->db->transaction(function () use ($totalValues, $totalChunk, $query, $table) {`
`168`	`168`
`169`	`169`	`$totalQuery = 0;`
`170`	`170`	`foreach ($query as $value) {`
`171`		`- $totalQuery += $this->db->statement($value) ? 1 : 0;`
	`171`	`+ $totalQuery += $this->db->connection($this->getConnectionName($table))->statement($value) ? 1 : 0;`
`172`	`172`	`}`
`173`	`173`
`174`	`174`	`return [`