SqlSession::executeAtomically() - Code Metrics - BenGorUser/CarlosBuenosvinosDddBridge - Measure and Improve Code Quality continuously with Scrutinizer

SqlSession::executeAtomically() A
last analyzed 2017-02-02 18:49 UTC

↳ Parent: SqlSession

Complexity

Conditions	3
Paths	4

Size

Total Lines	15
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	15
rs	9.4285
c	0
b	0
f	0
cc	3
eloc	10
nc	4
nop	1

<?php

/*
 * This file is part of the BenGorUser package.
 *
 * (c) Beñat Espiña <[email protected]>
 * (c) Gorka Laucirica <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace BenGorUser\CarlosBuenosvinosDddBridge\Infrastructure\Application\Service;

use Ddd\Application\Service\TransactionalSession;

/**
 * Class SqlSession.
 *
 * @author Beñat Espiña <[email protected]>
 */
class SqlSession implements TransactionalSession
{
    /**
     * The database abstraction layer.
     *
     * @var \PDO
     */
    private $pdo;

    /**
     * Constructor.
     *
     * @param \PDO $pdo The database abstraction layer
     */
    public function __construct(\PDO $pdo)
    {
        $this->pdo = $pdo;
    }

    /**
     * {@inheritdoc}
     */
    public function executeAtomically(callable $operation)
    {
        $this->pdo->beginTransaction();
        $this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);

        try {
            $return = call_user_func($operation, $this);
            $this->pdo->commit();

            return $return ?: true;
        } catch (\Exception $exception) {
            $this->pdo->rollback();
            throw $exception;
        }
    }
}


1			<?php
2
3			/*
4			* This file is part of the BenGorUser package.
5			*
6			* (c) Beñat Espiña <[email protected]>
7			* (c) Gorka Laucirica <[email protected]>
8			*
9			* For the full copyright and license information, please view the LICENSE
10			* file that was distributed with this source code.
11			*/
12
13			namespace BenGorUser\CarlosBuenosvinosDddBridge\Infrastructure\Application\Service;
14
15			use Ddd\Application\Service\TransactionalSession;
16
17			/**
18			* Class SqlSession.
19			*
20			* @author Beñat Espiña <[email protected]>
21			*/
22			class SqlSession implements TransactionalSession
23			{
24			/**
25			* The database abstraction layer.
26			*
27			* @var \PDO
28			*/
29			private $pdo;
30
31			/**
32			* Constructor.
33			*
34			* @param \PDO $pdo The database abstraction layer
35			*/
36			public function __construct(\PDO $pdo)
37			{
38			$this->pdo = $pdo;
39			}
40
41			/**
42			* {@inheritdoc}
43			*/
44			public function executeAtomically(callable $operation)
45			{
46			$this->pdo->beginTransaction();
47			$this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
48
49			try {
50			$return = call_user_func($operation, $this);
51			$this->pdo->commit();
52
53			return $return ?: true;
54			} catch (\Exception $exception) {
55			$this->pdo->rollback();
56			throw $exception;
57			}
58			}
59			}
60

BenGorUser / CarlosBuenosvinosDddBridge

SqlSession::executeAtomically() A last analyzed 2017-02-02 18:49 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

SqlSession::executeAtomically() A
last analyzed 2017-02-02 18:49 UTC