Final Class Yiisoft\Rbac\Db\AssignmentsStorage

                public function __construct(
    private readonly ConnectionInterface $database,
    private readonly string $tableName = 'yii_rbac_assignment',
) {
}

            

                public function add(Assignment $assignment): void
{
    $this
        ->database
        ->createCommand()
        ->insert(
            $this->tableName,
            [
                'item_name' => $assignment->getItemName(),
                'user_id' => $assignment->getUserId(),
                'created_at' => $assignment->getCreatedAt(),
            ],
        )
        ->execute();
}

            

                public function clear(): void
{
    $this
        ->database
        ->createCommand()
        ->delete($this->tableName)
        ->execute();
}

            

                public function exists(string $itemName, string $userId): bool
{
    return (new Query($this->database))
        ->from($this->tableName)
        ->where(['item_name' => $itemName, 'user_id' => $userId])
        ->exists();
}

            

                public function filterUserItemNames(string $userId, array $itemNames): array
{
    /** @var string[] */
    return (new Query($this->database))
        ->select('item_name')
        ->from($this->tableName)
        ->where(['user_id' => $userId, 'item_name' => $itemNames])
        ->column();
}

            

                public function get(string $itemName, string $userId): ?Assignment
{
    /**
     * @psalm-var RawAssignment|null $row
     * @infection-ignore-all
     * - ArrayItemRemoval, select.
     */
    $row = (new Query($this->database))
        ->select(['created_at'])
        ->from($this->tableName)
        ->where(['item_name' => $itemName, 'user_id' => $userId])
        ->one();
    return $row === null ? null : new Assignment($userId, $itemName, (int) $row['created_at']);
}

            

                public function getAll(): array
{
    /** @psalm-var RawAssignment[] $rows */
    $rows = (new Query($this->database))
        ->from($this->tableName)
        ->all();
    $assignments = [];
    foreach ($rows as $row) {
        $assignments[$row['user_id']][$row['item_name']] = new Assignment(
            $row['user_id'],
            $row['item_name'],
            (int) $row['created_at'],
        );
    }
    return $assignments;
}

            

                public function getByItemNames(array $itemNames): array
{
    if (empty($itemNames)) {
        /** @infection-ignore-all  */
        return [];
    }
    /** @psalm-var RawAssignment[] $rawAssignments */
    $rawAssignments = (new Query($this->database))
        ->from($this->tableName)
        ->where(['item_name' => $itemNames])
        ->all();
    $assignments = [];
    foreach ($rawAssignments as $rawAssignment) {
        $assignments[] = new Assignment(
            $rawAssignment['user_id'],
            $rawAssignment['item_name'],
            (int) $rawAssignment['created_at'],
        );
    }
    return $assignments;
}

            

                public function getByUserId(string $userId): array
{
    /** @psalm-var list<array{item_name: string, created_at: int|string}> $rawAssignments */
    $rawAssignments = (new Query($this->database))
        ->select(['item_name', 'created_at'])
        ->from($this->tableName)
        ->where(['user_id' => $userId])
        ->all();
    $assignments = [];
    foreach ($rawAssignments as $rawAssignment) {
        $assignments[$rawAssignment['item_name']] = new Assignment(
            $userId,
            $rawAssignment['item_name'],
            (int) $rawAssignment['created_at'],
        );
    }
    return $assignments;
}

            

                public function hasItem(string $name): bool
{
    return (new Query($this->database))
        ->from($this->tableName)
        ->where(['item_name' => $name])
        ->exists();
}

            

                public function remove(string $itemName, string $userId): void
{
    $this
        ->database
        ->createCommand()
        ->delete($this->tableName, ['item_name' => $itemName, 'user_id' => $userId])
        ->execute();
}

            

                public function removeByItemName(string $itemName): void
{
    $this
        ->database
        ->createCommand()
        ->delete($this->tableName, ['item_name' => $itemName])
        ->execute();
}

            

                public function removeByUserId(string $userId): void
{
    $this
        ->database
        ->createCommand()
        ->delete($this->tableName, ['user_id' => $userId])
        ->execute();
}

            

                public function renameItem(string $oldName, string $newName): void
{
    $this
        ->database
        ->createCommand()
        ->update($this->tableName, columns: ['item_name' => $newName], condition: ['item_name' => $oldName])
        ->execute();
}

            

                public function userHasItem(string $userId, array $itemNames): bool
{
    if (empty($itemNames)) {
        /** @infection-ignore-all  */
        return false;
    }
    return (new Query($this->database))
        ->from($this->tableName)
        ->where(['user_id' => $userId, 'item_name' => $itemNames])
        ->exists();
}