Как использовать транзакции в cakephp? - PullRequest
Новая
       22

Как использовать транзакции в cakephp?

0 голосов
/ 19 июня 2019

Я пытаюсь использовать commit с setConnection () но это не работает ... Я понятия не имею, как заставить транзакцию работать в cakephp

Я нашел в документации это: https://book.cakephp.org/3.0/en/orm/database-basics.html#using-transactions

но я не смог реализовать ... Проблема в том, что я хочу гарантировать сохранение двух объектов: 

$this->Users->save($user) and $clientTable->save($client)

это мой код: 

public function register()
    {
        $locator = TableRegistry::getTableLocator();
        $clientTable = $locator->get("Clients");

        $user = $this->Users->newEntity();
        $client = $clientTable->newEntity();

        if ($this->request->is('post')) {

            $request = $this->request->getData();

            $user = $this->Users->patchEntity($user, $request);

            $result = false;
            // begin()
            if ($this->Users->save($user)) {
                $request['user_id'] = $user->id;
                $client = $clientTable->patchEntity($client, $request);
                if ($clientTable->save($client)) {
                    $result = true;
                }
            }
            if ($result) {
                // commit()
                $this->Flash->success(__('The user has been registered.'));

                return $this->redirect([
                    'action' => 'login'
                ]);
            } else {
                // rollback()
            }

        $this->Flash->error(__('The user could not be registered. Please, try again.'));
        }
        $this->set(compact('$user'));
    }

Ответы [ 2 ]

1 голос
/ 19 июня 2019

Вы можете попробовать следующий код: 

try {
    $this->Users->getConnection()->begin();
    $this->Users->saveOrFail($userEntity, ['atomic' => false]);
    $this->Users->getConnection()->commit();

} catch(\Cake\ORM\Exception\PersistenceFailedException $e) {
    $this->Users->getConnection()->rollback();
}
0 голосов
/ 20 июня 2019

Я думаю, что смог выполнить транзакцию с помощью «транзакции».

В моих тестах, если в сущности «Клиенты» есть ошибка, сущность «Пользователи» не сохраняется.

Я не знаю, если это лучший способ сделать, но это сработало 

public function register()
    {
        $locator = TableRegistry::getTableLocator();
        $userTable = $locator->get("Users");
        $clientTable = $locator->get("Clients");

        $user = $userTable->newEntity();
        $client = $clientTable->newEntity();
        if ($this->request->is('post')) {
            $request = $this->request->getData();

            $user = $userTable->patchEntity($user, $request);

            $conn = ConnectionManager::get('default');

            try {
                $conn->transactional(function ($conn) use ($userTable, $clientTable, $user, $client, $request) {

                    $userTable->saveOrFail($user, [
                        'atomic' => false
                    ]);
                    $request['user_id'] = $user->id;
                    $client = $clientTable->patchEntity($client, $request);

                    $clientTable->saveOrFail($client, [
                        'atomic' => false
                    ]);
                });
                $this->Flash->success(__('The user has been registered.'));

                return $this->redirect([
                    'action' => 'login'
                ]);
            } catch (\Cake\ORM\Exception\PersistenceFailedException $e) {
                $this->Flash->error(__('Error on save: {0}', $e->getMessage()));

                return $this->redirect([
                    'action' => 'register'
                ]);
            }

            $this->Flash->error(__('The user could not be registered. Please, try again.'));
        }
        $this->set(compact('$user'));
    }
...