DB2Statement::fetch() - Code Metrics - Inspection of "Merge pull request #3070 from morozov/stmt-fetch-m..." - doctrine/dbal - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 3.0.x ( 438bef...e6349b )

by Sergei

created 2020-04-13 15:56 UTC

DB2Statement::fetch() A

↳ Parent: DB2Statement

Complexity

Conditions	6
Paths	6

Size

Total Lines	24
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	6
eloc	14
nc	6
nop	1
dl	0
loc	24
rs	9.2222
c	0
b	0
f	0

<?php

namespace Doctrine\DBAL\Driver\IBMDB2;

use Doctrine\DBAL\Driver\Statement;
use Doctrine\DBAL\Driver\StatementIterator;
use Doctrine\DBAL\FetchMode;
use Doctrine\DBAL\ParameterType;
use IteratorAggregate;
use const DB2_BINARY;
use const DB2_CHAR;
use const DB2_LONG;
use const DB2_PARAM_FILE;
use const DB2_PARAM_IN;
use function assert;
use function db2_bind_param;
use function db2_execute;
use function db2_fetch_array;
use function db2_fetch_assoc;
use function db2_fetch_both;
use function db2_free_result;
use function db2_num_fields;
use function db2_num_rows;
use function db2_stmt_error;
use function db2_stmt_errormsg;
use function error_get_last;
use function fclose;
use function fwrite;
use function is_int;
use function is_resource;
use function ksort;
use function stream_copy_to_stream;
use function stream_get_meta_data;
use function tmpfile;

class DB2Statement implements IteratorAggregate, Statement
{
    /** @var resource */
    private $stmt;

    /** @var mixed[] */
    private $bindParam = [];

    /**
     * Map of LOB parameter positions to the tuples containing reference to the variable bound to the driver statement
     * and the temporary file handle bound to the underlying statement
     *
     * @var mixed[][]
     */
    private $lobs = [];

    /** @var int */
    private $defaultFetchMode = FetchMode::MIXED;

    /**
     * Indicates whether the statement is in the state when fetching results is possible
     *
     * @var bool
     */
    private $result = false;

    /**
     * @param resource $stmt
     */
    public function __construct($stmt)
    {
        $this->stmt = $stmt;
    }

    /**
     * {@inheritdoc}
     */
    public function bindValue($param, $value, $type = ParameterType::STRING)
    {
        return $this->bindParam($param, $value, $type);
    }

    /**
     * {@inheritdoc}
     */
    public function bindParam($column, &$variable, $type = ParameterType::STRING, $length = null)
    {
        assert(is_int($column));

        switch ($type) {
            case ParameterType::INTEGER:
                $this->bind($column, $variable, DB2_PARAM_IN, DB2_LONG);
                break;

            case ParameterType::LARGE_OBJECT:
                if (isset($this->lobs[$column])) {
                    [, $handle] = $this->lobs[$column];
                    fclose($handle);
                }

                $handle = $this->createTemporaryFile();
                $path   = stream_get_meta_data($handle)['uri'];

                $this->bind($column, $path, DB2_PARAM_FILE, DB2_BINARY);

                $this->lobs[$column] = [&$variable, $handle];
                break;

            default:
                $this->bind($column, $variable, DB2_PARAM_IN, DB2_CHAR);
                break;
        }

        return true;
    }

    /**
     * @param int   $position Parameter position
     * @param mixed $variable
     *
     * @throws DB2Exception
     */
    private function bind($position, &$variable, int $parameterType, int $dataType) : void
    {
        $this->bindParam[$position] =& $variable;

        if (! db2_bind_param($this->stmt, $position, 'variable', $parameterType, $dataType)) {
            throw new DB2Exception(db2_stmt_errormsg());
        }
    }

    /**
     * {@inheritdoc}
     */
    public function closeCursor()
    {
        $this->bindParam = [];

        if (! db2_free_result($this->stmt)) {
            return false;
        }

        $this->result = false;

        return true;
    }

    /**
     * {@inheritdoc}
     */
    public function columnCount()
    {
        $count = db2_num_fields($this->stmt);

        if ($count !== false) {
            return $count;
        }

        return 0;
    }

    /**
     * {@inheritdoc}
     */
    public function errorCode()
    {
        return db2_stmt_error();
    }

    /**
     * {@inheritdoc}
     */
    public function errorInfo()
    {
        return [
            db2_stmt_errormsg(),
            db2_stmt_error(),
        ];
    }

    /**
     * {@inheritdoc}
     */
    public function execute($params = null)
    {
        if ($params === null) {
            ksort($this->bindParam);

            $params = [];

            foreach ($this->bindParam as $column => $value) {
                $params[] = $value;
            }
        }

        foreach ($this->lobs as [$source, $target]) {
            if (is_resource($source)) {
                $this->copyStreamToStream($source, $target);

                continue;
            }

            $this->writeStringToStream($source, $target);
        }

        $retval = db2_execute($this->stmt, $params);

        foreach ($this->lobs as [, $handle]) {
            fclose($handle);
        }

        $this->lobs = [];

        if ($retval === false) {
            throw new DB2Exception(db2_stmt_errormsg());
        }

        $this->result = true;

        return $retval;
    }

    /**
     * {@inheritdoc}
     */
    public function setFetchMode($fetchMode)
    {
        $this->defaultFetchMode = $fetchMode;

        return true;
    }

    /**
     * {@inheritdoc}
     */
    public function getIterator()
    {
        return new StatementIterator($this);
    }

    /**
     * {@inheritdoc}
     */
    public function fetch($fetchMode = null)
    {
        // do not try fetching from the statement if it's not expected to contain result
        // in order to prevent exceptional situation
        if (! $this->result) {
            return false;
        }

        $fetchMode = $fetchMode ?? $this->defaultFetchMode;
        switch ($fetchMode) {
            case FetchMode::COLUMN:
                return $this->fetchColumn();

            case FetchMode::MIXED:
                return db2_fetch_both($this->stmt);

            case FetchMode::ASSOCIATIVE:
                return db2_fetch_assoc($this->stmt);

            case FetchMode::NUMERIC:
                return db2_fetch_array($this->stmt);

            default:
                throw new DB2Exception('Given Fetch-Style ' . $fetchMode . ' is not supported.');
        }
    }

    /**
     * {@inheritdoc}
     */
    public function fetchAll($fetchMode = null)
    {
        $rows = [];

        switch ($fetchMode) {
            case FetchMode::COLUMN:
                while (($row = $this->fetchColumn()) !== false) {
                    $rows[] = $row;
                }
                break;
            default:
                while (($row = $this->fetch($fetchMode)) !== false) {
                    $rows[] = $row;
                }
        }

        return $rows;
    }

    /**
     * {@inheritdoc}
     */
    public function fetchColumn()
    {
        $row = $this->fetch(FetchMode::NUMERIC);

        if ($row === false) {
            return false;
        }

        return $row[0] ?? null;
    }

    /**
     * {@inheritdoc}
     */
    public function rowCount() : int
    {
        return @db2_num_rows($this->stmt);
    }

    /**
     * @return resource
     *
     * @throws DB2Exception
     */
    private function createTemporaryFile()
    {
        $handle = @tmpfile();

        if ($handle === false) {
            throw new DB2Exception('Could not create temporary file: ' . error_get_last()['message']);
        }

        return $handle;
    }

    /**
     * @param resource $source
     * @param resource $target
     *
     * @throws DB2Exception
     */
    private function copyStreamToStream($source, $target) : void
    {
        if (@stream_copy_to_stream($source, $target) === false) {
            throw new DB2Exception('Could not copy source stream to temporary file: ' . error_get_last()['message']);
        }
    }

    /**
     * @param resource $target
     *
     * @throws DB2Exception
     */
    private function writeStringToStream(string $string, $target) : void
    {
        if (@fwrite($target, $string) === false) {
            throw new DB2Exception('Could not write string to temporary file: ' . error_get_last()['message']);
        }
    }
}


1			<?php
2
3			namespace Doctrine\DBAL\Driver\IBMDB2;
4
5			use Doctrine\DBAL\Driver\Statement;
6			use Doctrine\DBAL\Driver\StatementIterator;
7			use Doctrine\DBAL\FetchMode;
8			use Doctrine\DBAL\ParameterType;
9			use IteratorAggregate;
10			use const DB2_BINARY;
11			use const DB2_CHAR;
12			use const DB2_LONG;
13			use const DB2_PARAM_FILE;
14			use const DB2_PARAM_IN;
15			use function assert;
16			use function db2_bind_param;
17			use function db2_execute;
18			use function db2_fetch_array;
19			use function db2_fetch_assoc;
20			use function db2_fetch_both;
21			use function db2_free_result;
22			use function db2_num_fields;
23			use function db2_num_rows;
24			use function db2_stmt_error;
25			use function db2_stmt_errormsg;
26			use function error_get_last;
27			use function fclose;
28			use function fwrite;
29			use function is_int;
30			use function is_resource;
31			use function ksort;
32			use function stream_copy_to_stream;
33			use function stream_get_meta_data;
34			use function tmpfile;
35
36			class DB2Statement implements IteratorAggregate, Statement
37			{
38			/** @var resource */
39			private $stmt;
40
41			/** @var mixed[] */
42			private $bindParam = [];
43
44			/**
45			* Map of LOB parameter positions to the tuples containing reference to the variable bound to the driver statement
46			* and the temporary file handle bound to the underlying statement
47			*
48			* @var mixed[][]
49			*/
50			private $lobs = [];
51
52			/** @var int */
53			private $defaultFetchMode = FetchMode::MIXED;
54
55			/**
56			* Indicates whether the statement is in the state when fetching results is possible
57			*
58			* @var bool
59			*/
60			private $result = false;
61
62			/**
63			* @param resource $stmt
64			*/
65			public function __construct($stmt)
66			{
67			$this->stmt = $stmt;
68			}
69
70			/**
71			* {@inheritdoc}
72			*/
73			public function bindValue($param, $value, $type = ParameterType::STRING)
74			{
75			return $this->bindParam($param, $value, $type);
76			}
77
78			/**
79			* {@inheritdoc}
80			*/
81			public function bindParam($column, &$variable, $type = ParameterType::STRING, $length = null)
82			{
83			assert(is_int($column));
84
85			switch ($type) {
86			case ParameterType::INTEGER:
87			$this->bind($column, $variable, DB2_PARAM_IN, DB2_LONG);
88			break;
89
90			case ParameterType::LARGE_OBJECT:
91			if (isset($this->lobs[$column])) {
92			[, $handle] = $this->lobs[$column];
93			fclose($handle);
94			}
95
96			$handle = $this->createTemporaryFile();
97			$path = stream_get_meta_data($handle)['uri'];
98
99			$this->bind($column, $path, DB2_PARAM_FILE, DB2_BINARY);
100
101			$this->lobs[$column] = [&$variable, $handle];
102			break;
103
104			default:
105			$this->bind($column, $variable, DB2_PARAM_IN, DB2_CHAR);
106			break;
107			}
108
109			return true;
110			}
111
112			/**
113			* @param int $position Parameter position
114			* @param mixed $variable
115			*
116			* @throws DB2Exception
117			*/
118			private function bind($position, &$variable, int $parameterType, int $dataType) : void
119			{
120			$this->bindParam[$position] =& $variable;
121
122			if (! db2_bind_param($this->stmt, $position, 'variable', $parameterType, $dataType)) {
123			throw new DB2Exception(db2_stmt_errormsg());
124			}
125			}
126
127			/**
128			* {@inheritdoc}
129			*/
130			public function closeCursor()
131			{
132			$this->bindParam = [];
133
134			if (! db2_free_result($this->stmt)) {
135			return false;
136			}
137
138			$this->result = false;
139
140			return true;
141			}
142
143			/**
144			* {@inheritdoc}
145			*/
146			public function columnCount()
147			{
148			$count = db2_num_fields($this->stmt);
149
150			if ($count !== false) {
151			return $count;
152			}
153
154			return 0;
155			}
156
157			/**
158			* {@inheritdoc}
159			*/
160			public function errorCode()
161			{
162			return db2_stmt_error();
163			}
164
165			/**
166			* {@inheritdoc}
167			*/
168			public function errorInfo()
169			{
170			return [
171			db2_stmt_errormsg(),
172			db2_stmt_error(),
173			];
174			}
175
176			/**
177			* {@inheritdoc}
178			*/
179			public function execute($params = null)
180			{
181			if ($params === null) {
182			ksort($this->bindParam);
183
184			$params = [];
185
186			foreach ($this->bindParam as $column => $value) {
187			$params[] = $value;
188			}
189			}
190
191			foreach ($this->lobs as [$source, $target]) {
192			if (is_resource($source)) {
193			$this->copyStreamToStream($source, $target);
194
195			continue;
196			}
197
198			$this->writeStringToStream($source, $target);
199			}
200
201			$retval = db2_execute($this->stmt, $params);
202
203			foreach ($this->lobs as [, $handle]) {
204			fclose($handle);
205			}
206
207			$this->lobs = [];
208
209			if ($retval === false) {
210			throw new DB2Exception(db2_stmt_errormsg());
211			}
212
213			$this->result = true;
214
215			return $retval;
216			}
217
218			/**
219			* {@inheritdoc}
220			*/
221			public function setFetchMode($fetchMode)
222			{
223			$this->defaultFetchMode = $fetchMode;
224
225			return true;
226			}
227
228			/**
229			* {@inheritdoc}
230			*/
231			public function getIterator()
232			{
233			return new StatementIterator($this);
234			}
235
236			/**
237			* {@inheritdoc}
238			*/
239			public function fetch($fetchMode = null)
240			{
241			// do not try fetching from the statement if it's not expected to contain result
242			// in order to prevent exceptional situation
243			if (! $this->result) {
244			return false;
245			}
246
247			$fetchMode = $fetchMode ?? $this->defaultFetchMode;
248			switch ($fetchMode) {
249			case FetchMode::COLUMN:
250			return $this->fetchColumn();
251
252			case FetchMode::MIXED:
253			return db2_fetch_both($this->stmt);
254
255			case FetchMode::ASSOCIATIVE:
256			return db2_fetch_assoc($this->stmt);
257
258			case FetchMode::NUMERIC:
259			return db2_fetch_array($this->stmt);
260
261			default:
262			throw new DB2Exception('Given Fetch-Style ' . $fetchMode . ' is not supported.');
263			}
264			}
265
266			/**
267			* {@inheritdoc}
268			*/
269			public function fetchAll($fetchMode = null)
270			{
271			$rows = [];
272
273			switch ($fetchMode) {
274			case FetchMode::COLUMN:
275			while (($row = $this->fetchColumn()) !== false) {
276			$rows[] = $row;
277			}
278			break;
279			default:
280			while (($row = $this->fetch($fetchMode)) !== false) {
281			$rows[] = $row;
282			}
283			}
284
285			return $rows;
286			}
287
288			/**
289			* {@inheritdoc}
290			*/
291			public function fetchColumn()
292			{
293			$row = $this->fetch(FetchMode::NUMERIC);
294
295			if ($row === false) {
296			return false;
297			}
298
299			return $row[0] ?? null;
300			}
301
302			/**
303			* {@inheritdoc}
304			*/
305			public function rowCount() : int
306			{
307			return @db2_num_rows($this->stmt);
308			}
309
310			/**
311			* @return resource
312			*
313			* @throws DB2Exception
314			*/
315			private function createTemporaryFile()
316			{
317			$handle = @tmpfile();
318
319			if ($handle === false) {
320			throw new DB2Exception('Could not create temporary file: ' . error_get_last()['message']);
321			}
322
323			return $handle;
324			}
325
326			/**
327			* @param resource $source
328			* @param resource $target
329			*
330			* @throws DB2Exception
331			*/
332			private function copyStreamToStream($source, $target) : void
333			{
334			if (@stream_copy_to_stream($source, $target) === false) {
335			throw new DB2Exception('Could not copy source stream to temporary file: ' . error_get_last()['message']);
336			}
337			}
338
339			/**
340			* @param resource $target
341			*
342			* @throws DB2Exception
343			*/
344			private function writeStringToStream(string $string, $target) : void
345			{
346			if (@fwrite($target, $string) === false) {
347			throw new DB2Exception('Could not write string to temporary file: ' . error_get_last()['message']);
348			}
349			}
350			}
351

doctrine / dbal

Push — 3.0.x ( 438bef...e6349b )

DB2Statement::fetch() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like