Yiisoft\ActiveRecord\Trait\TransactionalTrait

Complexity

Total Complexity

13

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	isTransactional()	0	3	1
A	transactions()	0	6	1
A	insert()	0	20	4
A	delete()	0	16	3
A	update()	0	20	4

<?php

declare(strict_types=1);

namespace Yiisoft\ActiveRecord\Trait;

use Throwable;
use Yiisoft\ActiveRecord\ActiveRecordInterface;
use Yiisoft\ActiveRecord\TransactionalInterface;

use function in_array;

/**
 * Trait to implement transactional operations and {@see TransactionalInterface} for ActiveRecord.
 *
 * @see ActiveRecordInterface::insert()
 * @see ActiveRecordInterface::update()
 * @see ActiveRecordInterface::delete()
 */
trait TransactionalTrait
{
    public function delete(): int
    {
        if (!$this->isTransactional(TransactionalInterface::OP_DELETE)) {
            return $this->deleteInternal();

The method deleteInternal() does not exist on Yiisoft\ActiveRecord\Trait\TransactionalTrait. Did you maybe mean delete()?

        }

        $transaction = $this->db->beginTransaction();

        try {
            $result = $this->deleteInternal();
            $transaction->commit();

            return $result;
        } catch (Throwable $e) {
            $transaction->rollBack();
            throw $e;
        }
    }

    public function insert(array $attributes = null): bool
    {
        if (!$this->isTransactional(TransactionalInterface::OP_INSERT)) {
            return $this->insertInternal($attributes);

The method insertInternal() does not exist on Yiisoft\ActiveRecord\Trait\TransactionalTrait. Did you maybe mean insert()?

        }

        $transaction = $this->db->beginTransaction();

        try {
            $result = $this->insertInternal($attributes);
            if ($result === false) {
                $transaction->rollBack();
            } else {
                $transaction->commit();
            }

            return $result;
        } catch (Throwable $e) {
            $transaction->rollBack();
            throw $e;
        }
    }

    public function isTransactional(int $operation): bool
    {
        return in_array($operation, $this->transactions(), true);
    }

    public function transactions(): array
    {
        return [
            TransactionalInterface::OP_INSERT,
            TransactionalInterface::OP_UPDATE,
            TransactionalInterface::OP_DELETE,
        ];
    }

    public function update(array $attributeNames = null): int
    {
        if (!$this->isTransactional(TransactionalInterface::OP_UPDATE)) {
            return $this->updateInternal($attributeNames);

The method updateInternal() does not exist on Yiisoft\ActiveRecord\Trait\TransactionalTrait. Did you maybe mean update()?

        }

        $transaction = $this->db->beginTransaction();

        try {
            $result = $this->updateInternal($attributeNames);
            if ($result === 0) {
                $transaction->rollBack();
            } else {
                $transaction->commit();
            }

            return $result;
        } catch (Throwable $e) {
            $transaction->rollBack();
            throw $e;
        }
    }
}