Add support pgsql for updateWithTwoIndex

Author: goszowski

src/Batch.php

@@ -169,6 +169,8 @@ public function updateWithTwoIndex(Model $table, array $values, string $index =
  {
  $final = [];
  $ids = [];
+ $connection = config('database.default');
+ $driver = config("database.connections.{$connection}.driver");
 
  if (!count($values)) {
  return false;
@@ -183,19 +185,38 @@ public function updateWithTwoIndex(Model $table, array $values, string $index =
  $ids2[] = $val[$index2];
  foreach (array_keys($val) as $field) {
  if ($field !== $index || $field !== $index2) {
- $finalField = $raw ? Common::mysql_escape($val[$field]) : '"' . 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 . '` = "' . Common::mysql_escape($val[$index]) . '" AND `' . $index2 . '` = "' . $val[$index2] . '") THEN ' . $value . ' ';
+
+ if ($driver == 'pgsql') {
+ $final[$field][] = 'WHEN (' . $index . ' = \'' . Common::mysql_escape($val[$index]) . '\' AND ' . $index2 . ' = \'' . $val[$index2] . '\') THEN ' . $value . ' ';
+ }
+ else {
+ $final[$field][] = 'WHEN (`' . $index . '` = "' . Common::mysql_escape($val[$index]) . '" AND `' . $index2 . '` = "' . $val[$index2] . '") THEN ' . $value . ' ';
+ }
  }
  }
  }
 
- $cases = '';
- foreach ($final as $k => $v) {
- $cases .= '`' . $k . '` = (CASE ' . implode("\n", $v) . "\n"
- . 'ELSE `' . $k . '` END), ';
+
+ if ($driver == 'pgsql') {
+ $cases = '';
+ foreach ($final as $k => $v) {
+ $cases .= '"' . $k . '" = (CASE ' . implode("\n", $v) . "\n"
+ . 'ELSE "' . $k . '" END), ';
+ }
+
+ $query = "UPDATE \"" . $this->getFullTableName($table) . '" SET ' . substr($cases, 0, -2) . " WHERE \"$index\" IN('" . implode("','", $ids) . "') AND \"$index2\" IN('" . implode("','", $ids2) . "');";
+ //$query = "UPDATE \"" . $this->getFullTableName($table) . "\" SET " . substr($cases, 0, -2) . " WHERE \"$index\" IN(" . '"' . implode('","', $ids) . '")' . " AND \"$index2\" IN(" . '"' . implode('","', $ids2) . '"' . " );";
+ }
+ else {
+ $cases = '';
+ foreach ($final as $k => $v) {
+ $cases .= '`' . $k . '` = (CASE ' . implode("\n", $v) . "\n"
+ . 'ELSE `' . $k . '` END), ';
+ }
+ $query = "UPDATE `" . $this->getFullTableName($table) . "` SET " . substr($cases, 0, -2) . " WHERE `$index` IN(" . '"' . implode('","', $ids) . '")' . " AND `$index2` IN(" . '"' . implode('","', $ids2) . '"' . " );";
  }
- $query = "UPDATE `" . $this->getFullTableName($table) . "` SET " . substr($cases, 0, -2) . " WHERE `$index` IN(" . '"' . implode('","', $ids) . '")' . " AND `$index2` IN(" . '"' . implode('","', $ids2) . '"' . " );";
 
  return $this->db->connection($this->getConnectionName($table))->update($query);
  }