DB2Connection::lastInsertId() - Code Metrics - Inspection of "Extract getSequenceNumber() from lastInsertId()" - doctrine/dbal - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#3759)

by Benjamin

created 2019-12-01 13:27 UTC

DB2Connection::lastInsertId() A

↳ Parent: DB2Connection

Complexity

Conditions	2
Paths	2

Size

Total Lines	9
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	2.0932

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	4
c	1
b	0
f	0
dl	0
loc	9
ccs	5
cts	7
cp	0.7143
rs	10
cc	2
nc	2
nop	0
crap	2.0932

<?php

declare(strict_types=0);

namespace Doctrine\DBAL\Driver\IBMDB2;

use Doctrine\DBAL\Driver\ResultStatement;
use Doctrine\DBAL\Driver\ServerInfoAwareConnection;
use Doctrine\DBAL\Driver\Statement as DriverStatement;
use stdClass;
use const DB2_AUTOCOMMIT_OFF;
use const DB2_AUTOCOMMIT_ON;
use function db2_autocommit;
use function db2_commit;
use function db2_connect;
use function db2_escape_string;
use function db2_exec;
use function db2_last_insert_id;
use function db2_num_rows;
use function db2_pconnect;
use function db2_prepare;
use function db2_rollback;
use function db2_server_info;

class DB2Connection implements ServerInfoAwareConnection
{
    /** @var resource */
    private $conn = null;

    /**
     * @param array<string, mixed> $params
     * @param array<string, mixed> $driverOptions
     *
     * @throws DB2Exception
     */
    public function __construct(array $params, string $username, string $password, array $driverOptions = [])
    {
        if (isset($params['persistent']) && $params['persistent'] === true) {
            $conn = db2_pconnect($params['dbname'], $username, $password, $driverOptions);
        } else {
            $conn = db2_connect($params['dbname'], $username, $password, $driverOptions);
        }

        if ($conn === false) {
            throw DB2Exception::fromConnectionError();
        }

        $this->conn = $conn;
    }

    /**
     * {@inheritdoc}
     */
    public function getServerVersion() : string
    {
        /** @var stdClass $serverInfo */
        $serverInfo = db2_server_info($this->conn);

        return $serverInfo->DBMS_VER;
    }

    /**
     * {@inheritdoc}
     */
    public function requiresQueryForServerVersion() : bool
    {
        return false;
    }

    /**
     * {@inheritdoc}
     */
    public function prepare(string $sql) : DriverStatement
    {
        $stmt = @db2_prepare($this->conn, $sql);
        if (! $stmt) {

            throw DB2Exception::fromStatementError();
        }

        return new DB2Statement($stmt);
    }

    /**
     * {@inheritdoc}
     */
    public function query(string $sql) : ResultStatement
    {
        $stmt = $this->prepare($sql);
        $stmt->execute();

        return $stmt;
    }

    /**
     * {@inheritdoc}
     */
    public function quote(string $input) : string
    {
        return "'" . db2_escape_string($input) . "'";
    }

    /**
     * {@inheritdoc}
     */
    public function exec(string $statement) : int
    {
        $stmt = @db2_exec($this->conn, $statement);

        if ($stmt === false) {
            throw DB2Exception::fromStatementError();
        }

        return db2_num_rows($stmt);
    }

    /**
     * {@inheritdoc}
     */
    public function lastInsertId() : string
    {
        $lastInsertId = db2_last_insert_id($this->conn);

        if ($lastInsertId === '') {
            throw new DB2Exception('No identity value was generated by the last statement.');
        }

        return $lastInsertId;
    }

    /**
     * {@inheritdoc}
     */
    public function getSequenceNumber(string $name) : string
    {
        throw new DB2Exception('Sequences on IBM DB2 are not currently supported.');
    }

    /**
     * {@inheritdoc}
     */
    public function beginTransaction() : void
    {
        if (! db2_autocommit($this->conn, DB2_AUTOCOMMIT_OFF)) {
            throw DB2Exception::fromConnectionError($this->conn);
        }
    }

    /**
     * {@inheritdoc}
     */
    public function commit() : void
    {
        if (! db2_commit($this->conn)) {
            throw DB2Exception::fromConnectionError($this->conn);
        }

        if (! db2_autocommit($this->conn, DB2_AUTOCOMMIT_ON)) {
            throw DB2Exception::fromConnectionError($this->conn);
        }
    }

    /**
     * {@inheritdoc}
     */
    public function rollBack() : void
    {
        if (! db2_rollback($this->conn)) {
            throw DB2Exception::fromConnectionError($this->conn);
        }

        if (! db2_autocommit($this->conn, DB2_AUTOCOMMIT_ON)) {
            throw DB2Exception::fromConnectionError($this->conn);
        }
    }
}


1		<?php
2
3		declare(strict_types=0);
4
5		namespace Doctrine\DBAL\Driver\IBMDB2;
6
7		use Doctrine\DBAL\Driver\ResultStatement;
8		use Doctrine\DBAL\Driver\ServerInfoAwareConnection;
9		use Doctrine\DBAL\Driver\Statement as DriverStatement;
10		use stdClass;
11		use const DB2_AUTOCOMMIT_OFF;
12		use const DB2_AUTOCOMMIT_ON;
13		use function db2_autocommit;
14		use function db2_commit;
15		use function db2_connect;
16		use function db2_escape_string;
17		use function db2_exec;
18		use function db2_last_insert_id;
19		use function db2_num_rows;
20		use function db2_pconnect;
21		use function db2_prepare;
22		use function db2_rollback;
23		use function db2_server_info;
24
25		class DB2Connection implements ServerInfoAwareConnection
26		{
27		/** @var resource */
28		private $conn = null;
29
30		/**
31		* @param array<string, mixed> $params
32		* @param array<string, mixed> $driverOptions
33		*
34		* @throws DB2Exception
35		*/
36		public function __construct(array $params, string $username, string $password, array $driverOptions = [])
37		{
38		if (isset($params['persistent']) && $params['persistent'] === true) {
39		$conn = db2_pconnect($params['dbname'], $username, $password, $driverOptions);
40	227	} else {
41		$conn = db2_connect($params['dbname'], $username, $password, $driverOptions);
42	227	}
43
44	227	if ($conn === false) {
45		throw DB2Exception::fromConnectionError();
46		}
47	227
48		$this->conn = $conn;
49		}
50	227
51		/**
52		* {@inheritdoc}
53		*/
54	227	public function getServerVersion() : string
55	227	{
56		/** @var stdClass $serverInfo */
57		$serverInfo = db2_server_info($this->conn);
58
59		return $serverInfo->DBMS_VER;
60		}
61
62		/**
63		* {@inheritdoc}
64		*/
65		public function requiresQueryForServerVersion() : bool
66		{
67		return false;
68		}
69
70		/**
71	228	* {@inheritdoc}
72		*/
73	228	public function prepare(string $sql) : DriverStatement
74		{
75		$stmt = @db2_prepare($this->conn, $sql);
76		if (! $stmt) {
		0 ignored issues – show introduced 2019-03-27 04:59 UTC by Report Bug Copy Issue Report `$stmt` is of type `false\|resource`, thus it always evaluated to `false`. Loading history...
77		throw DB2Exception::fromStatementError();
78		}
79	227
80		return new DB2Statement($stmt);
81	227	}
82	227
83		/**
84		* {@inheritdoc}
85		*/
86	227	public function query(string $sql) : ResultStatement
87		{
88		$stmt = $this->prepare($sql);
89		$stmt->execute();
90
91		return $stmt;
92	227	}
93
94	227	/**
95	227	* {@inheritdoc}
96	227	*/
97	227	public function quote(string $input) : string
98		{
99	227	return "'" . db2_escape_string($input) . "'";
100		}
101
102		/**
103		* {@inheritdoc}
104		*/
105	227	public function exec(string $statement) : int
106		{
107	227	$stmt = @db2_exec($this->conn, $statement);
108
109	227	if ($stmt === false) {
110		throw DB2Exception::fromStatementError();
111		}
112
113	227	return db2_num_rows($stmt);
114		}
115
116		/**
117		* {@inheritdoc}
118		*/
119	227	public function lastInsertId() : string
120		{
121	227	$lastInsertId = db2_last_insert_id($this->conn);
122
123	227	if ($lastInsertId === '') {
124	227	throw new DB2Exception('No identity value was generated by the last statement.');
125		}
126
127	227	return $lastInsertId;
128		}
129
130		/**
131		* {@inheritdoc}
132		*/
133	7	public function getSequenceNumber(string $name) : string
134		{
135	7	throw new DB2Exception('Sequences on IBM DB2 are not currently supported.');
136		}
137
138		/**
139		* {@inheritdoc}
140		*/
141	220	public function beginTransaction() : void
142		{
143	220	if (! db2_autocommit($this->conn, DB2_AUTOCOMMIT_OFF)) {
144	220	throw DB2Exception::fromConnectionError($this->conn);
145		}
146		}
147
148		/**
149	216	* {@inheritdoc}
150		*/
151	216	public function commit() : void
152		{
153		if (! db2_commit($this->conn)) {
154	216	throw DB2Exception::fromConnectionError($this->conn);
155	216	}
156
157		if (! db2_autocommit($this->conn, DB2_AUTOCOMMIT_ON)) {
158		throw DB2Exception::fromConnectionError($this->conn);
159		}
160	220	}
161
162	220	/**
163		* {@inheritdoc}
164		*/
165	220	public function rollBack() : void
166	220	{
167		if (! db2_rollback($this->conn)) {
168		throw DB2Exception::fromConnectionError($this->conn);
169		}
170
171		if (! db2_autocommit($this->conn, DB2_AUTOCOMMIT_ON)) {
172		throw DB2Exception::fromConnectionError($this->conn);
173		}
174		}
175		}
176

doctrine / dbal

Pull Request — master (#3759)

DB2Connection::lastInsertId() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like