Integrity.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
namespace ILIAS\Database\Integrity;
 
use ilDBInterface;
 
class Integrity
{
    public function __construct(
        private ilDBInterface $database
    ) {
    }
 
    public function check(Definition $definition): Result
    {
        $on = [];
        $where = [];
        // $definition->associations() always returns a non empty array
        foreach ($definition->associations() as $association) {
            $on[] = sprintf('%s = %s', $association->field()->fieldName(), $association->referenceField()->fieldName());
            $where[] = sprintf('%s IS NULL', $association->referenceField()->fieldName());
            foreach ($definition->ignoreValues() as $value_to_ignore) {
                $where[] = sprintf('%s %s', $association->field()->fieldName(), $value_to_ignore);
            }
        }
 
        $result = $this->database->query(sprintf(
            'SELECT COUNT(1) as violations FROM %s LEFT JOIN %s ON %s WHERE %s',
            $definition->tableName(),
            $definition->referenceTableName(),
            implode(' AND ', $on),
            implode(' AND ', $where),
        ));
 
        $result = $this->database->fetchAssoc($result);
 
        return new Result((int) $result['violations']);
    }
}