Merge pull request #25 from bearth/master

add ability to use raw query for update function

Author: mavinoo

src/InterfaceBatch.php

@@ -6,7 +6,7 @@
 
 interface InterfaceBatch
 {
-    public function update(Model $table, array $values, string $index = null);
+    public function update(Model $table, array $values, string $index = null, bool $raw = false);
 
     public function insert(Model $table, array $columns, array $values, int $batchSize = 500);
 }

src/LaravelBatch.php

@@ -44,15 +44,15 @@ public function __construct(DatabaseManager $db)
      *
      * @return bool|int
      */
-    public function update(Model $table, array $values, string $index = null)
+    public function update(Model $table, array $values, string $index = null, bool $raw = false)
     {
         $final = [];
         $ids = [];
 
         if (!count($values)) {
             return false;
         }
-        
+
         if (!isset($index) || empty($index)) {
             $index = $table->getKeyName();
         }
@@ -61,7 +61,8 @@ public function update(Model $table, array $values, string $index = null)
             $ids[] = $val[$index];
             foreach (array_keys($val) as $field) {
                 if ($field !== $index) {
-                    $value = (is_null($val[$field]) ? 'NULL' : '"' . Common::mysql_escape($val[$field]) . '"');
+                    $finalField = $raw ? Common::mysql_escape($val[$field]) : '"' . Common::mysql_escape($val[$field]) . '"';
+                    $value = (is_null($val[$field]) ? 'NULL' : $finalField);
                     $final[$field][] = 'WHEN `' . $index . '` = "' . $val[$index] . '" THEN ' . $value . ' ';
                 }
             }
@@ -159,8 +160,7 @@ public function insert(Model $table, array $columns, array $values, int $batchSi
 
             $valueString = implode(', ', $valueArray);
 
-            $query [] = "INSERT INTO `" . $this->getFullTableName($table) . "` (" . implode(',', $columns) . ") VALUES $valueString;";
-
+            $query[] = "INSERT INTO `" . $this->getFullTableName($table) . "` (" . implode(',', $columns) . ") VALUES $valueString;";
         }
 
         if (count($query)) {