Issues in StatementExecuteCommand.php - Failed Issues - Inspection of "Current state (prepared statements works for the m..." - PlasmaPHP/driver-mysql - Measure and Improve Code Quality continuously with Scrutinizer

Failed Conditions

Push — master ( 888a68...c84b74 )

by Charlotte

created 2018-11-18 00:03 UTC

src/Commands/StatementExecuteCommand.php (1 issue)

Labels

Severity

Critical 1

<?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;
            var_dump($param, unpack('C*', $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\ColumnDefinitionInterface  $column
     * @param \Plasma\BinaryBuffer               $buffer
     * @return array
     */
    protected function parseResultsetRow(\Plasma\BinaryBuffer $buffer): array {
        $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()] = $nullRow[$column->getName()];
                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();
        
        switch(true) {
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TINY) !== 0):
                $value = $buffer->readInt1();
                $value = $this->zeroFillInts($column, $value);
            break;
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_SHORT) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_YEAR) !== 0):
                $value = $buffer->readInt2();
                $value = $this->zeroFillInts($column, $value);
            break;
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_INT24) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONG) !== 0):
                $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 (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONGLONG) !== 0):
                $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 (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_FLOAT) !== 0):
                $value = $buffer->readFloat();
            break;
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DOUBLE) !== 0):
                $value = $buffer->readDouble();
            break;
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DATE) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_NEWDATE) !== 0):
                $length = $buffer->readIntLength();
                if($length > 0) {
                    $year = $buffer->readInt2();
                    $month = $buffer->readInt1();
                    $day = $buffer->readInt1();
                    
                    $value = \sprintf('%d-%d-%d', $year, $month, $day);
                } else {
                    $value = '0000-00-00';
                }
            break;
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DATETIME) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TIMESTAMP) !== 0):
                $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) {
                        $micro = $buffer->readInt4();
                    } else {
                        $micro = 0;
                    }
                    
                    $timestamp = (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TIMESTAMP) !== 0);
                    
                    $micro = \str_pad($micro, 6, '0', \STR_PAD_LEFT);
                    $micro = ($timestamp ? $micro : \number_format($micro, 0, '', ' '));
                    
                    $value = \sprintf('%d-%d-%d %d:%d:%d'.($micro > 0 ? '.%s' : ''), $year, $month, $day, $hour, $min, $sec, $micro);
                    
                    if($timestamp) {
                        $value = \DateTime::createFromFormat('Y-m-d H:i:s'.($micro > 0 ? '.u' : ''), $value)->getTimestamp();
                    }
                } else {
                    $value = '0000-00-00 00:00:00.000 000';
                }
            break;
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TIME) !== 0):
                $length = $buffer->readIntLength();
                if($length > 0) {
                    $sign = $buffer->readInt1();
                    $days = $buffer->readInt4();
                    
                    if($sign === 1) {
                        $days *= -1;
                    }
                    
                    $hour = $buffer->readInt1();
                    $min = $buffer->readInt1();
                    $sec = $buffer->readInt1();
                    
                    if($length > 8) {
                        $micro = $buffer->readInt4();
                    } else {
                        $micro = 0;
                    }
                    
                    $micro = \str_pad($micro, 6, '0', \STR_PAD_LEFT);
                    $micro = \number_format($micro, 0, '', ' ');
                    
                    $value = \sprintf('%dd %d:%d:%d'.($micro > 0 ? '.%s' : ''), $days, $hour, $min, $sec, $micro);
                } else {
                    $value = '0d 00:00:00';
                }
            break;
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_NULL) !== 0):
                $value = null;
            break;
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_STRING) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_VARCHAR) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_VAR_STRING) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_ENUM) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_SET) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONG_BLOB) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_MEDIUM_BLOB) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_BLOB) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TINY_BLOB) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_GEOMETRY) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_BIT) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DECIMAL) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_NEWDECIMAL) !== 0):
            case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_JSON) !== 0):
            case ($column->getType() === 'VARSTRING'): // WTF is going on ?! flags = 0, type = VARSTRING
                $value = $buffer->readStringLength();
            break;
            default:
                throw new \InvalidArgumentException('Unknown column type (flags: '.$flags.', type: '.$column->getType().')');
            break;
        }
        
        return $value;
    }
    
    /**
     * @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;
    }
}


GitHub Access Token became invalid

Push — master ( 888a68...c84b74 )

src/Commands/StatementExecuteCommand.php (1 issue)

Labels

Severity

Introduced By

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			function __construct(\Plasma\DriverInterface $driver, $id, string $query, array $params) {
42			parent::__construct($driver, $query);
43
44			$this->id = $id;
45			$this->params = $params;
46			}
47
48			/**
49			* Get the encoded message for writing to the database connection.
50			* @return string
51			*/
52			function getEncodedMessage(): string {
53			$packet = \chr(static::COMMAND_ID);
54			$packet .= \Plasma\BinaryBuffer::writeInt4($this->id);
55
56			$packet .= "\x00"; // Cursor type flag
57			$packet .= \Plasma\BinaryBuffer::writeInt4(1); // Iteration count is always 1
58
59			$bitmapOffset = \strlen($packet);
60			$packet .= \str_repeat("\x00", ((\count($this->params) + 7) >> 3));
61
62			$bound = 0;
63
64			$types = '';
65			$values = '';
66
67			foreach($this->params as $id => $param) {
68			if($param === null) {
69			$offset = $bitmapOffset + ($id >> 3);
70			$packet[$offset] = $packet[$offset] \| \chr((1 << ($id % 8)));
71			} else {
72			$bound = 1;
73			}
74
75			try {
76			$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			} catch (\Plasma\Exception $e) {
83			[ $unsigned, $type, $value ] = $this->stdEncodeValue($param);
84			}
85
86			$types .= \chr($type).($unsigned ? "\x80" : "\x00");
87			$values .= $value;
88			var_dump($param, unpack('C*', $value));
			0 ignored issues – show Security Debugging Code introduced 2018-11-18 00:09 UTC by Report Bug Copy Issue Report Show Similar Issues like this `var_dump($param, unpack('C*', $value))` looks like debug code. Are you sure you do not want to remove it? Loading history...
89			}
90
91			$packet .= \chr($bound);
92
93			if($bound) {
94			$packet .= $types;
95			$packet .= $values;
96			}
97
98			return $packet;
99			}
100
101			/**
102			* Whether the sequence ID should be resetted.
103			* @return bool
104			*/
105			function resetSequence(): bool {
106			return true;
107			}
108
109			/**
110			* Parses the binary resultset row and returns the row.
111			* @param \Plasma\ColumnDefinitionInterface $column
112			* @param \Plasma\BinaryBuffer $buffer
113			* @return array
114			*/
115			protected function parseResultsetRow(\Plasma\BinaryBuffer $buffer): array {
116			$nullRow = array();
117			$i = 0;
118
119			/** @var \Plasma\ColumnDefinitionInterface $column */
120			foreach($this->fields as $column) { // Handle NULL-bitmap
121			if((\ord($buffer[(($i + 2) >> 3)]) & (1 << (($i + 2) % 8))) !== 0) {
122			$nullRow[$column->getName()] = null;
123			}
124
125			$i++;
126			}
127
128			$buffer->read(((\count($this->fields) + 9) >> 3)); // Remove NULL-bitmap
129			$row = array();
130
131			/** @var \Plasma\ColumnDefinitionInterface $column */
132			foreach($this->fields as $column) {
133			if(\array_key_exists($column->getName(), $nullRow)) {
134			$row[$column->getName()] = $nullRow[$column->getName()];
135			continue;
136			}
137
138			$value = $this->stdDecodeBinaryValue($column, $buffer);
139			$parsedValue = $column->parseValue($value);
140
141			if($value !== $parsedValue) {
142			$value = $parsedValue;
143			}
144
145			$row[$column->getName()] = $value;
146			}
147
148			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			protected function stdEncodeValue($param): array {
158			$unsigned = false;
159
160			switch(\gettype($param)) {
161			case 'boolean':
162			$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TINY;
163			$value = ($param ? "\x01" : "\0");
164			break;
165			case 'integer':
166			if($param >= 0) {
167			$unsigned = true;
168			}
169
170			if($param >= 0 && $param < (1 << 15)) {
171			$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_SHORT;
172			$value = \Plasma\BinaryBuffer::writeInt2($param);
173			} elseif(\PHP_INT_SIZE === 4) {
174			$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONG;
175			$value = \Plasma\BinaryBuffer::writeInt4($param);
176			} else {
177			$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONGLONG;
178			$value = \Plasma\BinaryBuffer::writeInt8($param);
179			}
180			break;
181			case 'double':
182			$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DOUBLE;
183			$value = \Plasma\BinaryBuffer::writeDouble($param);
184			break;
185			case 'string':
186			$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONG_BLOB;
187			$value = \Plasma\BinaryBuffer::writeStringLength($param);
188			break;
189			case 'NULL':
190			$type = \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_NULL;
191			$value = '';
192			break;
193			default:
194			throw new \Plasma\Exception('Unexpected type for binding parameter: '.\gettype($param));
195			break;
196			}
197
198			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			protected function stdDecodeBinaryValue(\Plasma\ColumnDefinitionInterface $column, \Plasma\BinaryBuffer $buffer) {
209			$flags = $column->getFlags();
210
211			switch(true) {
212			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TINY) !== 0):
213			$value = $buffer->readInt1();
214			$value = $this->zeroFillInts($column, $value);
215			break;
216			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_SHORT) !== 0):
217			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_YEAR) !== 0):
218			$value = $buffer->readInt2();
219			$value = $this->zeroFillInts($column, $value);
220			break;
221			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_INT24) !== 0):
222			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONG) !== 0):
223			$value = $buffer->readInt4();
224
225			if(($flags & \Plasma\Drivers\MySQL\FieldFlags::UNSIGNED_FLAG) !== 0 && \PHP_INT_SIZE <= 4) {
226			$value = \bcadd($value, '18446744073709551616');
227			}
228
229			$value = $this->zeroFillInts($column, $value);
230			break;
231			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONGLONG) !== 0):
232			$value = $buffer->readInt8();
233
234			if(($flags & \Plasma\Drivers\MySQL\FieldFlags::UNSIGNED_FLAG) !== 0) {
235			$value = \bcadd($value, '18446744073709551616');
236			} elseif(\PHP_INT_SIZE > 4) {
237			$value = (int) $value;
238			}
239
240			$value = $this->zeroFillInts($column, $value);
241			break;
242			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_FLOAT) !== 0):
243			$value = $buffer->readFloat();
244			break;
245			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DOUBLE) !== 0):
246			$value = $buffer->readDouble();
247			break;
248			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DATE) !== 0):
249			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_NEWDATE) !== 0):
250			$length = $buffer->readIntLength();
251			if($length > 0) {
252			$year = $buffer->readInt2();
253			$month = $buffer->readInt1();
254			$day = $buffer->readInt1();
255
256			$value = \sprintf('%d-%d-%d', $year, $month, $day);
257			} else {
258			$value = '0000-00-00';
259			}
260			break;
261			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DATETIME) !== 0):
262			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TIMESTAMP) !== 0):
263			$length = $buffer->readIntLength();
264			if($length > 0) {
265			$year = $buffer->readInt2();
266			$month = $buffer->readInt1();
267			$day = $buffer->readInt1();
268
269			if($length > 4) {
270			$hour = $buffer->readInt1();
271			$min = $buffer->readInt1();
272			$sec = $buffer->readInt1();
273			} else {
274			$hour = 0;
275			$min = 0;
276			$sec = 0;
277			}
278
279			if($length > 7) {
280			$micro = $buffer->readInt4();
281			} else {
282			$micro = 0;
283			}
284
285			$timestamp = (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TIMESTAMP) !== 0);
286
287			$micro = \str_pad($micro, 6, '0', \STR_PAD_LEFT);
288			$micro = ($timestamp ? $micro : \number_format($micro, 0, '', ' '));
289
290			$value = \sprintf('%d-%d-%d %d:%d:%d'.($micro > 0 ? '.%s' : ''), $year, $month, $day, $hour, $min, $sec, $micro);
291
292			if($timestamp) {
293			$value = \DateTime::createFromFormat('Y-m-d H:i:s'.($micro > 0 ? '.u' : ''), $value)->getTimestamp();
294			}
295			} else {
296			$value = '0000-00-00 00:00:00.000 000';
297			}
298			break;
299			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TIME) !== 0):
300			$length = $buffer->readIntLength();
301			if($length > 0) {
302			$sign = $buffer->readInt1();
303			$days = $buffer->readInt4();
304
305			if($sign === 1) {
306			$days *= -1;
307			}
308
309			$hour = $buffer->readInt1();
310			$min = $buffer->readInt1();
311			$sec = $buffer->readInt1();
312
313			if($length > 8) {
314			$micro = $buffer->readInt4();
315			} else {
316			$micro = 0;
317			}
318
319			$micro = \str_pad($micro, 6, '0', \STR_PAD_LEFT);
320			$micro = \number_format($micro, 0, '', ' ');
321
322			$value = \sprintf('%dd %d:%d:%d'.($micro > 0 ? '.%s' : ''), $days, $hour, $min, $sec, $micro);
323			} else {
324			$value = '0d 00:00:00';
325			}
326			break;
327			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_NULL) !== 0):
328			$value = null;
329			break;
330			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_STRING) !== 0):
331			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_VARCHAR) !== 0):
332			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_VAR_STRING) !== 0):
333			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_ENUM) !== 0):
334			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_SET) !== 0):
335			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_LONG_BLOB) !== 0):
336			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_MEDIUM_BLOB) !== 0):
337			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_BLOB) !== 0):
338			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_TINY_BLOB) !== 0):
339			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_GEOMETRY) !== 0):
340			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_BIT) !== 0):
341			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_DECIMAL) !== 0):
342			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_NEWDECIMAL) !== 0):
343			case (($flags & \Plasma\Drivers\MySQL\FieldFlags::FIELD_TYPE_JSON) !== 0):
344			case ($column->getType() === 'VARSTRING'): // WTF is going on ?! flags = 0, type = VARSTRING
345			$value = $buffer->readStringLength();
346			break;
347			default:
348			throw new \InvalidArgumentException('Unknown column type (flags: '.$flags.', type: '.$column->getType().')');
349			break;
350			}
351
352			return $value;
353			}
354
355			/**
356			* @param \Plasma\ColumnDefinitionInterface $column
357			* @param string\|int $value
358			* @return string\|int
359			*/
360			protected function zeroFillInts(\Plasma\ColumnDefinitionInterface $column, $value) {
361			$flags = $column->getFlags();
362
363			if(($flags & \Plasma\Drivers\MySQL\FieldFlags::ZEROFILL_FLAG) !== 0) {
364			$value = \str_pad(((string) $value), $column->getLength(), '0', \STR_PAD_LEFT);
365			}
366
367			return $value;
368			}
369			}
370

PlasmaPHP / driver-mysql

GitHub Access Token became invalid

Push — master ( 888a68...c84b74 )

src/Commands/StatementExecuteCommand.php (1 issue)

Labels

Severity

Introduced By

Duplication Side-by-Side

Filter issues like