Integrity.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

namespace ILIAS\components\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']);
    }
}