StatementExecuteCommand::stdDecodeBinaryValue() - Code Metrics - Inspection of "Split up cases into methods" - PlasmaPHP/driver-mysql - Measure and Improve Code Quality continuously with Scrutinizer

Failed Conditions

Push — master ( 7089e8...8ad259 )

by Charlotte

created 2018-11-24 12:25 UTC

StatementExecuteCommand::stdDecodeBinaryValue() D

↳ Parent: StatementExecuteCommand

Complexity

Conditions	26
Paths	27

Size

Total Lines	123
Code Lines	94

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	80
CRAP Score	26.2298

Importance

Changes

Metric	Value
cc	26
eloc	94
nc	27
nop	2
dl	0
loc	123
ccs	80
cts	86
cp	0.9302
crap	26.2298
rs	4.1666
c	0
b	0
f	0

How to fix Long Method Complexity

<?php
/**
 * Plasma Driver MySQL component
 * Copyright 2018 PlasmaPHP, All Rights Reserved
 *
 * Website: https://github.com/PlasmaPHP
 * License: https://github.com/PlasmaPHP/driver-mysql/blob/master/LICENSE
*/

namespace Plasma\Drivers\MySQL\Commands;

/**
 * Statement Execute command.
 * @internal
 */
class StatementExecuteCommand extends QueryCommand {
    /**
     * The identifier for this command.
     * @var int
     * @source
     */
    const COMMAND_ID = 0x17;
    
    /**
     * @var mixed
     */
    protected $id;
    
    /**
     * @var array
     */
    protected $params;
    
    /**
     * Constructor.
     * @param \Plasma\DriverInterface  $driver
     * @param mixed                    $id
     * @param string                   $query
     * @param array                    $params
     */
    function __construct(\Plasma\DriverInterface $driver, $id, string $query, array $params) {
        parent::__construct($driver, $query);
        
        $this->id = $id;
        $this->params = $params;
    }
    
    /**
     * Get the encoded message for writing to the database connection.
     * @return string
     */
    function getEncodedMessage(): string {
        $packet = \chr(static::COMMAND_ID);
        $packet .= \Plasma\BinaryBuffer::writeInt4($this->id);
        
        $packet .= "\x00"; // Cursor type flag
        $packet .= \Plasma\BinaryBuffer::writeInt4(1); // Iteration count is always 1
        
        $bitmapOffset = \strlen($packet);
        $packet .= \str_repeat("\x00", ((\count($this->params) + 7) >> 3));
        
        $bound = 0;
        
        $types = '';
        $values = '';
        
        foreach($this->params as $id => $param) {
            if($param === null) {
                $offset = $bitmapOffset + ($id >> 3);
                $packet[$offset] = $packet[$offset] | \chr((1 << ($id % 8)));
            } else {
                $bound = 1;
            }
            
            try {
                $manager = \Plasma\Types\TypeExtensionsManager::getManager('driver-mysql');
                $encode = $manager->encodeType($param);
                
                $unsigned = $encode->isUnsigned();
                $type = $encode->getSQLType();
                $value = $encode->getValue();
            } catch (\Plasma\Exception $e) {
                [ $unsigned, $type, $value ] = $this->stdEncodeValue($param);
            }
            
            $types .= \chr($type).($unsigned ? "\x80" : "\x00");
            $values .= $value;
        }
        
        $packet .= \chr($bound);
        
        if($bound) {
            $packet .= $types;
            $packet .= $values;
        }
        
        return $packet;
    }
    
    /**
     * Whether the sequence ID should be resetted.
     * @return bool
     */
    function resetSequence(): bool {
        return true;
    }
    
    /**
     * Parses the binary resultset row and returns the row.
     * @param \Plasma\BinaryBuffer  $buffer
     * @return array
     */
    protected function parseResultsetRow(\Plasma\BinaryBuffer $buffer): array {
        $buffer->read(1); // remove packet header
        
        $nullRow = array();
        $i = 0;
        
        /** @var \Plasma\ColumnDefinitionInterface  $column */
        foreach($this->fields as $column) { // Handle NULL-bitmap
            if((\ord($buffer[(($i + 2) >> 3)]) & (1 << (($i + 2) % 8))) !== 0) {
                $nullRow[$column->getName()] = null;
            }
            
            $i++;
        }
        
        $buffer->read(((\count($this->fields) + 9) >> 3)); // Remove NULL-bitmap
        $row = array();
        
        /** @var \Plasma\ColumnDefinitionInterface  $column */
        foreach($this->fields as $column) {
            if(\array_key_exists($column->getName(), $nullRow)) {
                $row[$column->getName()] = null;
                continue;
            }
            
            $value = $this->stdDecodeBinaryValue($column, $buffer);
            $parsedValue = $column->parseValue($value);
            
            if($value !== $parsedValue) {
                $value = $parsedValue;
            }
            
            $row[$column->getName()] = $value;
        }
        
        return $row;
    }
    
    /**
     * Standard encode value, if type extensions failed.
     * @param mixed  $param
     * @return array
     * @throws \Plasma\Exception
     */
    protected function stdEncodeValue($param): array {
        $unsigned = false;
        
        switch(\gettype($param)) {
            case 'boolean':
                $type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TINY;
                $value = ($param ? "\x01" : "\0");
            break;
            case 'integer':
                if($param >= 0) {
                    $unsigned = true;
                }
                
                if($param >= 0 && $param < (1 << 15)) {
                    $type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_SHORT;
                    $value = \Plasma\BinaryBuffer::writeInt2($param);
                } elseif(\PHP_INT_SIZE === 4) {
                    $type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONG;
                    $value = \Plasma\BinaryBuffer::writeInt4($param);
                } else {
                    $type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONGLONG;
                    $value = \Plasma\BinaryBuffer::writeInt8($param);
                }
            break;
            case 'double':
                $type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DOUBLE;
                $value = \Plasma\BinaryBuffer::writeDouble($param);
            break;
            case 'string':
                $type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONG_BLOB;
                $value = \Plasma\BinaryBuffer::writeStringLength($param);
            break;
            case 'NULL':
                $type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_NULL;
                $value = '';
            break;
            default:
                throw new \Plasma\Exception('Unexpected type for binding parameter: '.\gettype($param));
            break;
        }
        
        return array($unsigned, $type, $value);
    }
    
    /**
     * Standard decode value, if type extensions failed.
     * @param \Plasma\ColumnDefinitionInterface  $column
     * @param \Plasma\BinaryBuffer               $buffer
     * @return mixed
     * @throws \Plasma\Exception
     */
    protected function stdDecodeBinaryValue(\Plasma\ColumnDefinitionInterface $column, \Plasma\BinaryBuffer $buffer) {
        $flags = $column->getFlags();
        $type = $column->getType();
        
        switch(true) {
            case $this->isTypeString($type):

                $value = $buffer->readStringLength();
            break;
            case ($type === 'TINY'):
                $value = $buffer->readInt1();
                $value = $this->zeroFillInts($column, $value);
            break;

            case $this->isTypeShortOrYear($type):

                $value = $buffer->readInt2();
                $value = $this->zeroFillInts($column, $value);
            break;

            case $this->isTypeInt24orLong($type):

                $value = $buffer->readInt4();
                
                if(($flags & \Plasma\Drivers\MySQL\FieldFlags::UNSIGNED_FLAG) !== 0 && \PHP_INT_SIZE <= 4) {
                    $value = \bcadd($value, '18446744073709551616');
                }
                
                $value = $this->zeroFillInts($column, $value);
            break;
            case ($type === 'LONGLONG'):
                $value = $buffer->readInt8();
                
                if(($flags & \Plasma\Drivers\MySQL\FieldFlags::UNSIGNED_FLAG) !== 0) {
                    $value = \bcadd($value, '18446744073709551616');
                } elseif(\PHP_INT_SIZE > 4) {
                    $value = (int) $value;
                }
                
                $value = $this->zeroFillInts($column, $value);
            break;
            case ($type === 'FLOAT'):
                $value = $buffer->readFloat();
            break;
            case ($type === 'DOUBLE'):
                $value = $buffer->readDouble();
            break;
            case $this->isTypeDate($type):

                $length = $buffer->readIntLength();
                if($length > 0) {
                    $year = $buffer->readInt2();
                    $month = $buffer->readInt1();
                    $day = $buffer->readInt1();
                    
                    $value = \sprintf('%04d-%02d-%02d', $year, $month, $day);
                } else {
                    $value = '0000-00-00';
                }

            break;

            case $this->isTypeDateTime($type):

                $length = $buffer->readIntLength();
                if($length > 0) {
                    $year = $buffer->readInt2();
                    $month = $buffer->readInt1();
                    $day = $buffer->readInt1();
                    
                    if($length > 4) {
                        $hour = $buffer->readInt1();
                        $min = $buffer->readInt1();
                        $sec = $buffer->readInt1();
                    } else {
                        $hour = 0;
                        $min = 0;
                        $sec = 0;
                    }
                    
                    if($length > 7) {
                        $microI = $buffer->readInt4();
                    } else {
                        $microI = 0;
                    }
                    
                    $micro = \str_pad($microI, 6, '0', \STR_PAD_LEFT);
                    $micro = \substr($micro, 0, 3).' '.\substr($micro, 3);
                    
                    $value = \sprintf('%04d-%02d-%02d %02d:%02d:%02d'.($microI > 0 ? '.%s' : ''), $year, $month, $day, $hour, $min, $sec, $micro);
                    
                    if($type === 'TIMESTAMP') {
                        $value = \DateTime::createFromFormat('Y-m-d H:i:s'.($microI > 0 ? '.u' : ''), $value)->getTimestamp();
                    }
                } else {
                    $value = '0000-00-00 00:00:00.000 000';
                }
            break;
            case ($type === 'TIME'):
                $length = $buffer->readIntLength();
                if($length > 1) {
                    $sign = $buffer->readInt1();
                    $days = $buffer->readInt4();
                    
                    if($sign === 1) {
                        $days *= -1;
                    }
                    
                    $hour = $buffer->readInt1();
                    $min = $buffer->readInt1();
                    $sec = $buffer->readInt1();
                    
                    if($length > 8) {
                        $microI = $buffer->readInt4();
                    } else {
                        $microI = 0;
                    }
                    
                    $micro = \str_pad($microI, 6, '0', \STR_PAD_LEFT);
                    $micro = \substr($micro, 0, 3).' '.\substr($micro, 3);
                    
                    $value = \sprintf('%dd %02d:%02d:%02d'.($microI > 0 ? '.%s' : ''), $days, $hour, $min, $sec, $micro);
                } else {
                    $value = '0d 00:00:00';
                }
            break;
            default:
                throw new \InvalidArgumentException('Unknown column type (flags: '.$flags.', type: '.$column->getType().')');
            break;
        }
        
        return $value;
    }
    
    /**
     * @param string  $type
     * @return bool
     */
    protected function isTypeString(string $type): bool {
        $types = array(
            'STRING', 'VARCHAR', 'VARSTRING', 'ENUM', 'SET', 'LONGBLOB',
            'MEDIUMBLOB', 'BLOB', 'TINYBLOB', 'GEMOTERY', 'BIT', 'DECIMAL',
            'NEWDECIMAL', 'JSON'
        );
        
        return \in_array($type, $types, true);
    }
    
    /**
     * @param string  $type
     * @return bool
     */
    protected function isTypeShortOrYear(string $type): bool {
        $types = array('SHORT', 'YEAR');
        return \in_array($type, $types, true);
    }
    
    /**
     * @param string  $type
     * @return bool
     */
    protected function isTypeInt24orLong(string $type): bool {
        $types = array('INT24', 'LONG');
        return \in_array($type, $types, true);
    }
    
    /**
     * @param string  $type
     * @return bool
     */
    protected function isTypeDate(string $type): bool {
        $types = array('DATE', 'NEWDATE');
        return \in_array($type, $types, true);
    }
    
    /**
     * @param string  $type
     * @return bool
     */
    protected function isTypeDateTime(string $type): bool {
        $types = array('DATETIME', 'TIMESTAMP');
        return \in_array($type, $types, true);
    }
    
    /**
     * @param \Plasma\ColumnDefinitionInterface  $column
     * @param string|int                         $value
     * @return string|int
     */
    protected function zeroFillInts(\Plasma\ColumnDefinitionInterface $column, $value) {
        $flags = $column->getFlags();
        
        if(($flags & \Plasma\Drivers\MySQL\FieldFlags::ZEROFILL_FLAG) !== 0) {
            $value = \str_pad(((string) $value), $column->getLength(), '0', \STR_PAD_LEFT);
        }
        
        return $value;
    }
}


1		<?php
2		/**
3		* Plasma Driver MySQL component
4		* Copyright 2018 PlasmaPHP, All Rights Reserved
5		*
6		* Website: https://github.com/PlasmaPHP
7		* License: https://github.com/PlasmaPHP/driver-mysql/blob/master/LICENSE
8		*/
9
10		namespace Plasma\Drivers\MySQL\Commands;
11
12		/**
13		* Statement Execute command.
14		* @internal
15		*/
16		class StatementExecuteCommand extends QueryCommand {
17		/**
18		* The identifier for this command.
19		* @var int
20		* @source
21		*/
22		const COMMAND_ID = 0x17;
23
24		/**
25		* @var mixed
26		*/
27		protected $id;
28
29		/**
30		* @var array
31		*/
32		protected $params;
33
34		/**
35		* Constructor.
36		* @param \Plasma\DriverInterface $driver
37		* @param mixed $id
38		* @param string $query
39		* @param array $params
40		*/
41	37	function __construct(\Plasma\DriverInterface $driver, $id, string $query, array $params) {
42	37	parent::__construct($driver, $query);
43
44	37	$this->id = $id;
45	37	$this->params = $params;
46	37	}
47
48		/**
49		* Get the encoded message for writing to the database connection.
50		* @return string
51		*/
52	36	function getEncodedMessage(): string {
53	36	$packet = \chr(static::COMMAND_ID);
54	36	$packet .= \Plasma\BinaryBuffer::writeInt4($this->id);
55
56	36	$packet .= "\x00"; // Cursor type flag
57	36	$packet .= \Plasma\BinaryBuffer::writeInt4(1); // Iteration count is always 1
58
59	36	$bitmapOffset = \strlen($packet);
60	36	$packet .= \str_repeat("\x00", ((\count($this->params) + 7) >> 3));
61
62	36	$bound = 0;
63
64	36	$types = '';
65	36	$values = '';
66
67	36	foreach($this->params as $id => $param) {
68	36	if($param === null) {
69	1	$offset = $bitmapOffset + ($id >> 3);
70	1	$packet[$offset] = $packet[$offset] \| \chr((1 << ($id % 8)));
71		} else {
72	36	$bound = 1;
73		}
74
75		try {
76	36	$manager = \Plasma\Types\TypeExtensionsManager::getManager('driver-mysql');
77		$encode = $manager->encodeType($param);
78
79		$unsigned = $encode->isUnsigned();
80		$type = $encode->getSQLType();
81		$value = $encode->getValue();
82	36	} catch (\Plasma\Exception $e) {
83	36	[ $unsigned, $type, $value ] = $this->stdEncodeValue($param);
84		}
85
86	35	$types .= \chr($type).($unsigned ? "\x80" : "\x00");
87	35	$values .= $value;
88		}
89
90	35	$packet .= \chr($bound);
91
92	35	if($bound) {
93	35	$packet .= $types;
94	35	$packet .= $values;
95		}
96
97	35	return $packet;
98		}
99
100		/**
101		* Whether the sequence ID should be resetted.
102		* @return bool
103		*/
104	36	function resetSequence(): bool {
105	36	return true;
106		}
107
108		/**
109		* Parses the binary resultset row and returns the row.
110		* @param \Plasma\BinaryBuffer $buffer
111		* @return array
112		*/
113	35	protected function parseResultsetRow(\Plasma\BinaryBuffer $buffer): array {
114	35	$buffer->read(1); // remove packet header
115
116	35	$nullRow = array();
117	35	$i = 0;
118
119		/** @var \Plasma\ColumnDefinitionInterface $column */
120	35	foreach($this->fields as $column) { // Handle NULL-bitmap
121	35	if((\ord($buffer[(($i + 2) >> 3)]) & (1 << (($i + 2) % 8))) !== 0) {
122	2	$nullRow[$column->getName()] = null;
123		}
124
125	35	$i++;
126		}
127
128	35	$buffer->read(((\count($this->fields) + 9) >> 3)); // Remove NULL-bitmap
129	35	$row = array();
130
131		/** @var \Plasma\ColumnDefinitionInterface $column */
132	35	foreach($this->fields as $column) {
133	35	if(\array_key_exists($column->getName(), $nullRow)) {
134	2	$row[$column->getName()] = null;
135	2	continue;
136		}
137
138	35	$value = $this->stdDecodeBinaryValue($column, $buffer);
139	35	$parsedValue = $column->parseValue($value);
140
141	35	if($value !== $parsedValue) {
142		$value = $parsedValue;
143		}
144
145	35	$row[$column->getName()] = $value;
146		}
147
148	35	return $row;
149		}
150
151		/**
152		* Standard encode value, if type extensions failed.
153		* @param mixed $param
154		* @return array
155		* @throws \Plasma\Exception
156		*/
157	36	protected function stdEncodeValue($param): array {
158	36	$unsigned = false;
159
160	36	switch(\gettype($param)) {
161		case 'boolean':
162	1	$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TINY;
163	1	$value = ($param ? "\x01" : "\0");
164	1	break;
165		case 'integer':
166	7	if($param >= 0) {
167	7	$unsigned = true;
168		}
169
170	7	if($param >= 0 && $param < (1 << 15)) {
171	7	$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_SHORT;
172	7	$value = \Plasma\BinaryBuffer::writeInt2($param);
173	3	} elseif(\PHP_INT_SIZE === 4) {
174		$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONG;
175		$value = \Plasma\BinaryBuffer::writeInt4($param);
176		} else {
177	3	$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONGLONG;
178	3	$value = \Plasma\BinaryBuffer::writeInt8($param);
179		}
180	7	break;
181		case 'double':
182	2	$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DOUBLE;
183	2	$value = \Plasma\BinaryBuffer::writeDouble($param);
184	2	break;
185		case 'string':
186	26	$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONG_BLOB;
187	26	$value = \Plasma\BinaryBuffer::writeStringLength($param);
188	26	break;
189		case 'NULL':
190	1	$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_NULL;
191	1	$value = '';
192	1	break;
193		default:
194	1	throw new \Plasma\Exception('Unexpected type for binding parameter: '.\gettype($param));
195		break;
196		}
197
198	35	return array($unsigned, $type, $value);
199		}
200
201		/**
202		* Standard decode value, if type extensions failed.
203		* @param \Plasma\ColumnDefinitionInterface $column
204		* @param \Plasma\BinaryBuffer $buffer
205		* @return mixed
206		* @throws \Plasma\Exception
207		*/
208	35	protected function stdDecodeBinaryValue(\Plasma\ColumnDefinitionInterface $column, \Plasma\BinaryBuffer $buffer) {
209	35	$flags = $column->getFlags();
210	35	$type = $column->getType();
211
212		switch(true) {
213	35	case $this->isTypeString($type):
		1 ignored issue – show Coding Style introduced 2018-11-24 12:27 UTC by Report Bug Copy Issue Report Line indented incorrectly; expected 8 spaces, found 12 Loading history...
214	18	$value = $buffer->readStringLength();
215	18	break;
216	17	case ($type === 'TINY'):
217	7	$value = $buffer->readInt1();
218	7	$value = $this->zeroFillInts($column, $value);
219	7	break;
		1 ignored issue – show Coding Style introduced 2018-11-24 12:27 UTC by Report Bug Copy Issue Report Case breaking statement indented incorrectly; expected 16 spaces, found 12 Loading history...
220	17	case $this->isTypeShortOrYear($type):
		1 ignored issue – show Coding Style introduced 2018-11-24 12:27 UTC by Report Bug Copy Issue Report Line indented incorrectly; expected 8 spaces, found 12 Loading history...
221	7	$value = $buffer->readInt2();
222	7	$value = $this->zeroFillInts($column, $value);
223	7	break;
		1 ignored issue – show Coding Style introduced 2018-11-24 12:27 UTC by Report Bug Copy Issue Report Case breaking statement indented incorrectly; expected 16 spaces, found 12 Loading history...
224	17	case $this->isTypeInt24orLong($type):
		1 ignored issue – show Coding Style introduced 2018-11-24 12:27 UTC by Report Bug Copy Issue Report Line indented incorrectly; expected 8 spaces, found 12 Loading history...
225	7	$value = $buffer->readInt4();
226
227	7	if(($flags & \Plasma\Drivers\MySQL\FieldFlags::UNSIGNED_FLAG) !== 0 && \PHP_INT_SIZE <= 4) {
228		$value = \bcadd($value, '18446744073709551616');
229		}
230
231	7	$value = $this->zeroFillInts($column, $value);
232	7	break;
233	17	case ($type === 'LONGLONG'):
234	7	$value = $buffer->readInt8();
235
236	7	if(($flags & \Plasma\Drivers\MySQL\FieldFlags::UNSIGNED_FLAG) !== 0) {
237		$value = \bcadd($value, '18446744073709551616');
238	7	} elseif(\PHP_INT_SIZE > 4) {
239	7	$value = (int) $value;
240		}
241
242	7	$value = $this->zeroFillInts($column, $value);
243	7	break;
244	10	case ($type === 'FLOAT'):
245	2	$value = $buffer->readFloat();
246	2	break;
247	10	case ($type === 'DOUBLE'):
248	2	$value = $buffer->readDouble();
249	2	break;
250	8	case $this->isTypeDate($type):
		1 ignored issue – show Coding Style introduced 2018-11-24 12:27 UTC by Report Bug Copy Issue Report Line indented incorrectly; expected 8 spaces, found 12 Loading history...
251	8	$length = $buffer->readIntLength();
252	8	if($length > 0) {
253	1	$year = $buffer->readInt2();
254	1	$month = $buffer->readInt1();
255	1	$day = $buffer->readInt1();
256
257	1	$value = \sprintf('%04d-%02d-%02d', $year, $month, $day);
258		} else {
259	7	$value = '0000-00-00';
260		}
		1 ignored issue – show Coding Style introduced 2018-11-24 12:27 UTC by Report Bug Copy Issue Report Line indented incorrectly; expected 12 spaces, found 16 Loading history...
261	8	break;
		1 ignored issue – show Coding Style introduced 2018-11-24 12:27 UTC by Report Bug Copy Issue Report Case breaking statement indented incorrectly; expected 16 spaces, found 12 Loading history...
262	8	case $this->isTypeDateTime($type):
		1 ignored issue – show Coding Style introduced 2018-11-24 12:27 UTC by Report Bug Copy Issue Report Line indented incorrectly; expected 8 spaces, found 12 Loading history...
263	8	$length = $buffer->readIntLength();
264	8	if($length > 0) {
265	2	$year = $buffer->readInt2();
266	2	$month = $buffer->readInt1();
267	2	$day = $buffer->readInt1();
268
269	2	if($length > 4) {
270	1	$hour = $buffer->readInt1();
271	1	$min = $buffer->readInt1();
272	1	$sec = $buffer->readInt1();
273		} else {
274	1	$hour = 0;
275	1	$min = 0;
276	1	$sec = 0;
277		}
278
279	2	if($length > 7) {
280		$microI = $buffer->readInt4();
281		} else {
282	2	$microI = 0;
283		}
284
285	2	$micro = \str_pad($microI, 6, '0', \STR_PAD_LEFT);
286	2	$micro = \substr($micro, 0, 3).' '.\substr($micro, 3);
287
288	2	$value = \sprintf('%04d-%02d-%02d %02d:%02d:%02d'.($microI > 0 ? '.%s' : ''), $year, $month, $day, $hour, $min, $sec, $micro);
289
290	2	if($type === 'TIMESTAMP') {
291	2	$value = \DateTime::createFromFormat('Y-m-d H:i:s'.($microI > 0 ? '.u' : ''), $value)->getTimestamp();
292		}
293		} else {
294	8	$value = '0000-00-00 00:00:00.000 000';
295		}
296	8	break;
297	8	case ($type === 'TIME'):
298	8	$length = $buffer->readIntLength();
299	8	if($length > 1) {
300	1	$sign = $buffer->readInt1();
301	1	$days = $buffer->readInt4();
302
303	1	if($sign === 1) {
304		$days *= -1;
305		}
306
307	1	$hour = $buffer->readInt1();
308	1	$min = $buffer->readInt1();
309	1	$sec = $buffer->readInt1();
310
311	1	if($length > 8) {
312		$microI = $buffer->readInt4();
313		} else {
314	1	$microI = 0;
315		}
316
317	1	$micro = \str_pad($microI, 6, '0', \STR_PAD_LEFT);
318	1	$micro = \substr($micro, 0, 3).' '.\substr($micro, 3);
319
320	1	$value = \sprintf('%dd %02d:%02d:%02d'.($microI > 0 ? '.%s' : ''), $days, $hour, $min, $sec, $micro);
321		} else {
322	7	$value = '0d 00:00:00';
323		}
324	8	break;
325		default:
326		throw new \InvalidArgumentException('Unknown column type (flags: '.$flags.', type: '.$column->getType().')');
327		break;
328		}
329
330	35	return $value;
331		}
332
333		/**
334		* @param string $type
335		* @return bool
336		*/
337	35	protected function isTypeString(string $type): bool {
338		$types = array(
339	35	'STRING', 'VARCHAR', 'VARSTRING', 'ENUM', 'SET', 'LONGBLOB',
340		'MEDIUMBLOB', 'BLOB', 'TINYBLOB', 'GEMOTERY', 'BIT', 'DECIMAL',
341		'NEWDECIMAL', 'JSON'
342		);
343
344	35	return \in_array($type, $types, true);
345		}
346
347		/**
348		* @param string $type
349		* @return bool
350		*/
351	17	protected function isTypeShortOrYear(string $type): bool {
352	17	$types = array('SHORT', 'YEAR');
353	17	return \in_array($type, $types, true);
354		}
355
356		/**
357		* @param string $type
358		* @return bool
359		*/
360	17	protected function isTypeInt24orLong(string $type): bool {
361	17	$types = array('INT24', 'LONG');
362	17	return \in_array($type, $types, true);
363		}
364
365		/**
366		* @param string $type
367		* @return bool
368		*/
369	8	protected function isTypeDate(string $type): bool {
370	8	$types = array('DATE', 'NEWDATE');
371	8	return \in_array($type, $types, true);
372		}
373
374		/**
375		* @param string $type
376		* @return bool
377		*/
378	8	protected function isTypeDateTime(string $type): bool {
379	8	$types = array('DATETIME', 'TIMESTAMP');
380	8	return \in_array($type, $types, true);
381		}
382
383		/**
384		* @param \Plasma\ColumnDefinitionInterface $column
385		* @param string\|int $value
386		* @return string\|int
387		*/
388	7	protected function zeroFillInts(\Plasma\ColumnDefinitionInterface $column, $value) {
389	7	$flags = $column->getFlags();
390
391	7	if(($flags & \Plasma\Drivers\MySQL\FieldFlags::ZEROFILL_FLAG) !== 0) {
392	7	$value = \str_pad(((string) $value), $column->getLength(), '0', \STR_PAD_LEFT);
393		}
394
395	7	return $value;
396		}
397		}
398

PlasmaPHP / driver-mysql

GitHub Access Token became invalid

Push — master ( 7089e8...8ad259 )

StatementExecuteCommand::stdDecodeBinaryValue() D

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like