CaseUpdate.php

Go to the documentation of this file.

<?php

 
namespace Depage\XmlDb\Helpers;

class CaseUpdate
{
    use IdentifierChecker;

    public const DEFAULT_SIZE = 200;
 
    protected $pdo;

    protected $values = [];

    public function __construct($pdo, protected string $table, protected int $size = self::DEFAULT_SIZE)
    {
        $this->pdo = $pdo;
 
        $this->checkIdentifier($table, 'table');
    }
 
    public function isEmpty(): bool
    {
        return count($this->values) == 0;
    }

    public function isFull(): bool
    {
        return count($this->values) >= $this->size;
    }

    public function add($id, $value): void
    {
        $this->values[(int) $id] = $value;
    }

    public function write(string $column, array $conditions = []): void
    {
        if ($this->isEmpty()) {
            return;
        }
 
        $column = $this->checkIdentifier($column);
 
        $where = '';
        $whereParams = [];
        foreach ($conditions as $name => $value) {
            $where .= ' AND ' . $this->checkIdentifier((string) $name) . ' = ?';
            $whereParams[] = $value;
        }
 
        $chunks = array_chunk($this->values, $this->size, true);
        $this->values = [];
 
        foreach ($chunks as $chunk) {
            $this->update($column, $where, $chunk, $whereParams);
        }
    }

    protected function update(string $column, string $where, array $chunk, array $whereParams): void
    {
        $case = '';
        $ids = [];
        $params = [];
 
        foreach ($chunk as $id => $value) {
            $case .= ' WHEN ? THEN ?';
            $params[] = $id;
            $params[] = $value;
            $ids[] = $id;
        }
 
        $query = $this->pdo->prepare(
            "UPDATE {$this->table}
            SET {$column} = CASE id{$case} END
            WHERE id IN (" . implode(", ", array_fill(0, count($ids), '?')) . ")" . $where
        );
        $query->execute(array_merge(
            $params,
            $ids,
            $whereParams
        ));
    }
}
 
/* vim:set ft=php sw=4 sts=4 fdm=marker et : */