Completed
Push — master ( 9d1314...5291f6 )
by kacper
02:05
created
src/MySQLReplication/BinLog/BinLogServerInfo.php 1 patch
Braces   +2 added lines, -4 removed lines patch added patch discarded remove patch
@@ -35,8 +35,7 @@  discard block
 block discarded – undo
35 35
             {
36 36
                 $i++;
37 37
                 break;
38
-            }
39
-            else
38
+            } else
40 39
             {
41 40
                 self::$serverInfo['server_version'] .= $pack[$i];
42 41
             }
@@ -116,8 +115,7 @@  discard block
 block discarded – undo
116 115
             if (false !== strpos($version, self::MYSQL_VERSION_MARIADB))
117 116
             {
118 117
                 self::$serverInfo['version_name'] = self::MYSQL_VERSION_MARIADB;
119
-            }
120
-            else if (false !== strpos($version, self::MYSQL_VERSION_PERCONA))
118
+            } else if (false !== strpos($version, self::MYSQL_VERSION_PERCONA))
121 119
             {
122 120
                 self::$serverInfo['version_name'] = self::MYSQL_VERSION_PERCONA;
123 121
             }
Please login to merge, or discard this patch.
src/MySQLReplication/Gtid/Gtid.php 1 patch
Braces   +1 added lines, -2 removed lines patch added patch discarded remove patch
@@ -53,8 +53,7 @@
 block discarded – undo
53 53
             {
54 54
                 $buffer .= BinaryDataReader::pack64bit($interval[0]);
55 55
                 $buffer .= BinaryDataReader::pack64bit($interval[1]);
56
-            }
57
-            else
56
+            } else
58 57
             {
59 58
                 $buffer .= BinaryDataReader::pack64bit($interval[0]);
60 59
                 $buffer .= BinaryDataReader::pack64bit($interval[0] + 1);
Please login to merge, or discard this patch.
src/MySQLReplication/BinaryDataReader/BinaryDataReader.php 1 patch
Braces   +14 added lines, -28 removed lines patch added patch discarded remove patch
@@ -109,17 +109,14 @@  discard block
 block discarded – undo
109 109
         if ($c < self::UNSIGNED_CHAR_COLUMN)
110 110
         {
111 111
             return $c;
112
-        }
113
-        elseif ($c == self::UNSIGNED_SHORT_COLUMN)
112
+        } elseif ($c == self::UNSIGNED_SHORT_COLUMN)
114 113
         {
115 114
             return $this->readUInt16();
116 115
 
117
-        }
118
-        elseif ($c == self::UNSIGNED_INT24_COLUMN)
116
+        } elseif ($c == self::UNSIGNED_INT24_COLUMN)
119 117
         {
120 118
             return $this->readUInt24();
121
-        }
122
-        elseif ($c == self::UNSIGNED_INT64_COLUMN)
119
+        } elseif ($c == self::UNSIGNED_INT64_COLUMN)
123 120
         {
124 121
             return $this->readUInt64();
125 122
         }
@@ -208,32 +205,25 @@  discard block
 block discarded – undo
208 205
         if ($size == self::UNSIGNED_CHAR_LENGTH)
209 206
         {
210 207
             return $this->readUInt8();
211
-        }
212
-        elseif ($size == self::UNSIGNED_SHORT_LENGTH)
208
+        } elseif ($size == self::UNSIGNED_SHORT_LENGTH)
213 209
         {
214 210
             return $this->readUInt16();
215
-        }
216
-        elseif ($size == self::UNSIGNED_INT24_LENGTH)
211
+        } elseif ($size == self::UNSIGNED_INT24_LENGTH)
217 212
         {
218 213
             return $this->readUInt24();
219
-        }
220
-        elseif ($size == self::UNSIGNED_INT32_LENGTH)
214
+        } elseif ($size == self::UNSIGNED_INT32_LENGTH)
221 215
         {
222 216
             return $this->readUInt32();
223
-        }
224
-        elseif ($size == self::UNSIGNED_INT40_LENGTH)
217
+        } elseif ($size == self::UNSIGNED_INT40_LENGTH)
225 218
         {
226 219
             return $this->readUInt40();
227
-        }
228
-        elseif ($size == self::UNSIGNED_INT48_LENGTH)
220
+        } elseif ($size == self::UNSIGNED_INT48_LENGTH)
229 221
         {
230 222
             return $this->readUInt48();
231
-        }
232
-        elseif ($size == self::UNSIGNED_INT56_LENGTH)
223
+        } elseif ($size == self::UNSIGNED_INT56_LENGTH)
233 224
         {
234 225
             return $this->readUInt56();
235
-        }
236
-        elseif ($size == self::UNSIGNED_INT64_LENGTH)
226
+        } elseif ($size == self::UNSIGNED_INT64_LENGTH)
237 227
         {
238 228
             return $this->readUInt64();
239 229
         }
@@ -302,20 +292,16 @@  discard block
 block discarded – undo
302 292
         if ($size == self::UNSIGNED_CHAR_LENGTH)
303 293
         {
304 294
             return $this->readInt8();
305
-        }
306
-        elseif ($size == self::UNSIGNED_SHORT_LENGTH)
295
+        } elseif ($size == self::UNSIGNED_SHORT_LENGTH)
307 296
         {
308 297
             return $this->readInt16Be();
309
-        }
310
-        elseif ($size == self::UNSIGNED_INT24_LENGTH)
298
+        } elseif ($size == self::UNSIGNED_INT24_LENGTH)
311 299
         {
312 300
             return $this->readInt24Be();
313
-        }
314
-        elseif ($size == self::UNSIGNED_INT32_LENGTH)
301
+        } elseif ($size == self::UNSIGNED_INT32_LENGTH)
315 302
         {
316 303
             return $this->readInt32Be();
317
-        }
318
-        elseif ($size == self::UNSIGNED_INT40_LENGTH)
304
+        } elseif ($size == self::UNSIGNED_INT40_LENGTH)
319 305
         {
320 306
             return $this->readInt40Be();
321 307
         }
Please login to merge, or discard this patch.
src/MySQLReplication/Event/RowEvent/RowEvent.php 1 patch
Braces   +37 added lines, -74 removed lines patch added patch discarded remove patch
@@ -162,8 +162,7 @@  discard block
 block discarded – undo
162 162
                         'COLUMN_KEY' => '',
163 163
                     ];
164 164
                     $type = ConstFieldType::IGNORE;
165
-                }
166
-                else
165
+                } else
167 166
                 {
168 167
                     $type = ord($data['column_types'][$i]);
169 168
                 }
@@ -302,123 +301,98 @@  discard block
 block discarded – undo
302 301
             if ($this->checkNull($null_bitmap, $nullBitmapIndex))
303 302
             {
304 303
                 $values[$name] = null;
305
-            }
306
-            elseif ($column['type'] === ConstFieldType::IGNORE)
304
+            } elseif ($column['type'] === ConstFieldType::IGNORE)
307 305
             {
308 306
                 $values[$name] = null;
309
-            }
310
-            elseif ($column['type'] === ConstFieldType::TINY)
307
+            } elseif ($column['type'] === ConstFieldType::TINY)
311 308
             {
312 309
                 if (true === $column['unsigned'])
313 310
                 {
314 311
                     $values[$name] = $this->binaryDataReader->readUInt8();
315
-                }
316
-                else
312
+                } else
317 313
                 {
318 314
                     $values[$name] = $this->binaryDataReader->readInt8();
319 315
                 }
320
-            }
321
-            elseif ($column['type'] === ConstFieldType::SHORT)
316
+            } elseif ($column['type'] === ConstFieldType::SHORT)
322 317
             {
323 318
                 if (true === $column['unsigned'])
324 319
                 {
325 320
                     $values[$name] = $this->binaryDataReader->readUInt16();
326
-                }
327
-                else
321
+                } else
328 322
                 {
329 323
                     $values[$name] = $this->binaryDataReader->readInt16();
330 324
                 }
331
-            }
332
-            elseif ($column['type'] === ConstFieldType::LONG)
325
+            } elseif ($column['type'] === ConstFieldType::LONG)
333 326
             {
334 327
                 if (true === $column['unsigned'])
335 328
                 {
336 329
                     $values[$name] = $this->binaryDataReader->readUInt32();
337
-                }
338
-                else
330
+                } else
339 331
                 {
340 332
                     $values[$name] = $this->binaryDataReader->readInt32();
341 333
                 }
342
-            }
343
-            elseif ($column['type'] === ConstFieldType::LONGLONG)
334
+            } elseif ($column['type'] === ConstFieldType::LONGLONG)
344 335
             {
345 336
                 if (true === $column['unsigned'])
346 337
                 {
347 338
                     $values[$name] = $this->binaryDataReader->readUInt64();
348
-                }
349
-                else
339
+                } else
350 340
                 {
351 341
                     $values[$name] = $this->binaryDataReader->readInt64();
352 342
                 }
353
-            }
354
-            elseif ($column['type'] === ConstFieldType::INT24)
343
+            } elseif ($column['type'] === ConstFieldType::INT24)
355 344
             {
356 345
                 if (true === $column['unsigned'])
357 346
                 {
358 347
                     $values[$name] = $this->binaryDataReader->readUInt24();
359
-                }
360
-                else
348
+                } else
361 349
                 {
362 350
                     $values[$name] = $this->binaryDataReader->readInt24();
363 351
                 }
364
-            }
365
-            elseif ($column['type'] === ConstFieldType::FLOAT)
352
+            } elseif ($column['type'] === ConstFieldType::FLOAT)
366 353
             {
367 354
                 // http://dev.mysql.com/doc/refman/5.7/en/floating-point-types.html FLOAT(7,4)
368 355
                 $values[$name] = round($this->binaryDataReader->readFloat(), 4);
369
-            }
370
-            elseif ($column['type'] === ConstFieldType::DOUBLE)
356
+            } elseif ($column['type'] === ConstFieldType::DOUBLE)
371 357
             {
372 358
                 $values[$name] = $this->binaryDataReader->readDouble();
373
-            }
374
-            elseif ($column['type'] === ConstFieldType::VARCHAR || $column['type'] === ConstFieldType::STRING)
359
+            } elseif ($column['type'] === ConstFieldType::VARCHAR || $column['type'] === ConstFieldType::STRING)
375 360
             {
376 361
                 if ($column['max_length'] > 255)
377 362
                 {
378 363
                     $values[$name] = $this->getString(2, $column);
379
-                }
380
-                else
364
+                } else
381 365
                 {
382 366
                     $values[$name] = $this->getString(1, $column);
383 367
                 }
384
-            }
385
-            elseif ($column['type'] === ConstFieldType::NEWDECIMAL)
368
+            } elseif ($column['type'] === ConstFieldType::NEWDECIMAL)
386 369
             {
387 370
                 $values[$name] = $this->getDecimal($column);
388
-            }
389
-            elseif ($column['type'] === ConstFieldType::BLOB)
371
+            } elseif ($column['type'] === ConstFieldType::BLOB)
390 372
             {
391 373
                 $values[$name] = $this->getString($column['length_size'], $column);
392
-            }
393
-            elseif ($column['type'] === ConstFieldType::DATETIME)
374
+            } elseif ($column['type'] === ConstFieldType::DATETIME)
394 375
             {
395 376
                 $values[$name] = $this->getDatetime();
396
-            }
397
-            elseif ($column['type'] === ConstFieldType::DATETIME2)
377
+            } elseif ($column['type'] === ConstFieldType::DATETIME2)
398 378
             {
399 379
                 $values[$name] = $this->getDatetime2($column);
400
-            }
401
-            elseif ($column['type'] === ConstFieldType::TIMESTAMP)
380
+            } elseif ($column['type'] === ConstFieldType::TIMESTAMP)
402 381
 			{
403 382
 				$values[$name] = date('c', $this->binaryDataReader->readUInt32());
404
-			}
405
-            elseif ($column['type'] === ConstFieldType::TIME2)
383
+			} elseif ($column['type'] === ConstFieldType::TIME2)
406 384
             {
407 385
                 $values[$name] = $this->getTime2($column);
408
-            }
409
-            elseif ($column['type'] === ConstFieldType::TIMESTAMP2)
386
+            } elseif ($column['type'] === ConstFieldType::TIMESTAMP2)
410 387
             {
411 388
                 $values[$name] = $this->getTimestamp2($column);
412
-            }
413
-            elseif ($column['type'] === ConstFieldType::DATE)
389
+            } elseif ($column['type'] === ConstFieldType::DATE)
414 390
             {
415 391
                 $values[$name] = $this->getDate();
416
-            }
417
-            elseif ($column['type'] === ConstFieldType::YEAR)
392
+            } elseif ($column['type'] === ConstFieldType::YEAR)
418 393
             {
419 394
                 $values[$name] = $this->binaryDataReader->readUInt8() + 1900;
420
-            }
421
-            elseif ($column['type'] === ConstFieldType::ENUM)
395
+            } elseif ($column['type'] === ConstFieldType::ENUM)
422 396
             {
423 397
                 $value = $this->binaryDataReader->readUIntBySize($column['size']) - 1;
424 398
 
@@ -428,24 +402,19 @@  discard block
 block discarded – undo
428 402
                 {
429 403
                     $values[$name] = $column['enum_values'][$value];
430 404
                 }
431
-            }
432
-            elseif ($column['type'] === ConstFieldType::SET)
405
+            } elseif ($column['type'] === ConstFieldType::SET)
433 406
             {
434 407
                 $values[$name] = $this->getSet($column);
435
-            }
436
-            elseif ($column['type'] === ConstFieldType::BIT)
408
+            } elseif ($column['type'] === ConstFieldType::BIT)
437 409
             {
438 410
                 $values[$name] = $this->getBit($column);
439
-            }
440
-            elseif ($column['type'] === ConstFieldType::GEOMETRY)
411
+            } elseif ($column['type'] === ConstFieldType::GEOMETRY)
441 412
             {
442 413
                 $values[$name] = $this->binaryDataReader->readLengthCodedPascalString($column['length_size']);
443
-            }
444
-            elseif ($column['type'] === ConstFieldType::JSON)
414
+            } elseif ($column['type'] === ConstFieldType::JSON)
445 415
             {
446 416
                 $values[$name] = $this->jsonBinaryDecoderFactory->makeJsonBinaryDecoder($this->getString(BinaryDataReader::UNSIGNED_INT32_LENGTH, $column))->parseToString();
447
-            }
448
-            else
417
+            } else
449 418
             {
450 419
                 throw new MySQLReplicationException('Unknown row type: ' . $column['type']);
451 420
             }
@@ -547,8 +516,7 @@  discard block
 block discarded – undo
547 516
         {
548 517
             $mask = 0;
549 518
             $res = '';
550
-        }
551
-        else
519
+        } else
552 520
         {
553 521
             $mask = -1;
554 522
             $res = '-';
@@ -683,12 +651,10 @@  discard block
 block discarded – undo
683 651
         if ($column['fsp'] === 1 || $column['fsp'] === 2)
684 652
         {
685 653
             $read = 1;
686
-        }
687
-        elseif ($column['fsp'] === 3 || $column['fsp'] === 4)
654
+        } elseif ($column['fsp'] === 3 || $column['fsp'] === 4)
688 655
         {
689 656
             $read = 2;
690
-        }
691
-        elseif ($column ['fsp'] === 5 || $column['fsp'] === 6)
657
+        } elseif ($column ['fsp'] === 5 || $column['fsp'] === 6)
692 658
         {
693 659
             $read = 3;
694 660
         }
@@ -809,8 +775,7 @@  discard block
 block discarded – undo
809 775
                 if (1 === $column['bytes'])
810 776
                 {
811 777
                     $end = $column['bits'];
812
-                }
813
-                else
778
+                } else
814 779
                 {
815 780
                     $end = $column['bits'] % 8;
816 781
                     if (0 === $end)
@@ -818,8 +783,7 @@  discard block
 block discarded – undo
818 783
                         $end = 8;
819 784
                     }
820 785
                 }
821
-            }
822
-            else
786
+            } else
823 787
             {
824 788
                 $end = 8;
825 789
             }
@@ -829,8 +793,7 @@  discard block
 block discarded – undo
829 793
                 if ($data & (1 << $bit))
830 794
                 {
831 795
                     $current_byte .= '1';
832
-                }
833
-                else
796
+                } else
834 797
                 {
835 798
                     $current_byte .= '0';
836 799
                 }
Please login to merge, or discard this patch.
src/MySQLReplication/JsonBinaryDecoder/JsonBinaryDecoderService.php 1 patch
Braces   +22 added lines, -44 removed lines patch added patch discarded remove patch
@@ -94,20 +94,16 @@  discard block
 block discarded – undo
94 94
         if (self::SMALL_OBJECT === $type)
95 95
         {
96 96
             $this->parseObject(BinaryDataReader::UNSIGNED_SHORT_LENGTH);
97
-        }
98
-        else if (self::LARGE_OBJECT === $type)
97
+        } else if (self::LARGE_OBJECT === $type)
99 98
         {
100 99
             $this->parseObject(BinaryDataReader::UNSIGNED_INT32_LENGTH);
101
-        }
102
-        else if (self::SMALL_ARRAY === $type)
100
+        } else if (self::SMALL_ARRAY === $type)
103 101
         {
104 102
             $this->parseArray(BinaryDataReader::UNSIGNED_SHORT_LENGTH);
105
-        }
106
-        else if (self::LARGE_ARRAY === $type)
103
+        } else if (self::LARGE_ARRAY === $type)
107 104
         {
108 105
             $this->parseObject(BinaryDataReader::UNSIGNED_INT32_LENGTH);
109
-        }
110
-        else
106
+        } else
111 107
         {
112 108
             $this->parseScalar($type);
113 109
         }
@@ -175,24 +171,21 @@  discard block
 block discarded – undo
175 171
                 $this->readLiteral(),
176 172
                 $type
177 173
             );
178
-        }
179
-        else if (self::INT16 === $type)
174
+        } else if (self::INT16 === $type)
180 175
         {
181 176
             return new JsonBinaryDecoderValue(
182 177
                 true,
183 178
                 $this->binaryDataReader->readInt16(),
184 179
                 $type
185 180
             );
186
-        }
187
-        else if (self::UINT16 === $type)
181
+        } else if (self::UINT16 === $type)
188 182
         {
189 183
             return new JsonBinaryDecoderValue(
190 184
                 true,
191 185
                 $this->binaryDataReader->readUInt16(),
192 186
                 $type
193 187
             );
194
-        }
195
-        else if (BinaryDataReader::UNSIGNED_INT32_LENGTH === $intSize)
188
+        } else if (BinaryDataReader::UNSIGNED_INT32_LENGTH === $intSize)
196 189
         {
197 190
             if (self::INT32 === $type)
198 191
             {
@@ -201,8 +194,7 @@  discard block
 block discarded – undo
201 194
                     $this->binaryDataReader->readInt32(),
202 195
                     $type
203 196
                 );
204
-            }
205
-            else if (self::UINT32 === $type)
197
+            } else if (self::UINT32 === $type)
206 198
             {
207 199
                 return new JsonBinaryDecoderValue(
208 200
                     true,
@@ -210,8 +202,7 @@  discard block
 block discarded – undo
210 202
                     $type
211 203
                 );
212 204
             }
213
-        }
214
-        else
205
+        } else
215 206
         {
216 207
             $offset = $this->binaryDataReader->readUIntBySize($intSize);
217 208
             if ($offset > $numBytes)
@@ -242,12 +233,10 @@  discard block
 block discarded – undo
242 233
         if (0 === $literal)
243 234
         {
244 235
             return null;
245
-        }
246
-        else if (1 === $literal)
236
+        } else if (1 === $literal)
247 237
         {
248 238
             return true;
249
-        }
250
-        else if (2 === $literal)
239
+        } else if (2 === $literal)
251 240
         {
252 241
             return false;
253 242
         }
@@ -263,18 +252,15 @@  discard block
 block discarded – undo
263 252
         if (false === $jsonBinaryDecoderValue->isIsResolved())
264 253
         {
265 254
             $this->parseJson($jsonBinaryDecoderValue->getType());
266
-        }
267
-        else
255
+        } else
268 256
         {
269 257
             if (null === $jsonBinaryDecoderValue->getValue())
270 258
             {
271 259
                 $this->jsonBinaryDecoderFormatter->formatValueNull();
272
-            }
273
-            elseif (is_bool($jsonBinaryDecoderValue->getValue()))
260
+            } elseif (is_bool($jsonBinaryDecoderValue->getValue()))
274 261
             {
275 262
                 $this->jsonBinaryDecoderFormatter->formatValueBool($jsonBinaryDecoderValue->getValue());
276
-            }
277
-            elseif (is_numeric($jsonBinaryDecoderValue->getValue()))
263
+            } elseif (is_numeric($jsonBinaryDecoderValue->getValue()))
278 264
             {
279 265
                 $this->jsonBinaryDecoderFormatter->formatValueNumeric($jsonBinaryDecoderValue->getValue());
280 266
             }
@@ -314,8 +300,7 @@  discard block
 block discarded – undo
314 300
         if (null === $r)
315 301
         {
316 302
             $this->jsonBinaryDecoderFormatter->formatValueNull();
317
-        }
318
-        else
303
+        } else
319 304
         {
320 305
             $this->jsonBinaryDecoderFormatter->formatValueBool($r);
321 306
         }
@@ -326,32 +311,25 @@  discard block
 block discarded – undo
326 311
         if (self::LITERAL === $type)
327 312
         {
328 313
             $this->parseBoolean();
329
-        }
330
-        else if (self::INT16 === $type)
314
+        } else if (self::INT16 === $type)
331 315
         {
332 316
             $this->jsonBinaryDecoderFormatter->formatValue($this->binaryDataReader->readInt16());
333
-        }
334
-        else if (self::INT32 === $type)
317
+        } else if (self::INT32 === $type)
335 318
         {
336 319
             $this->jsonBinaryDecoderFormatter->formatValue($this->binaryDataReader->readInt32());
337
-        }
338
-        else if (self::INT64 === $type)
320
+        } else if (self::INT64 === $type)
339 321
         {
340 322
             $this->jsonBinaryDecoderFormatter->formatValue($this->binaryDataReader->readInt64());
341
-        }
342
-        else if (self::UINT16 === $type)
323
+        } else if (self::UINT16 === $type)
343 324
         {
344 325
             $this->jsonBinaryDecoderFormatter->formatValue($this->binaryDataReader->readUInt16());
345
-        }
346
-        else if (self::UINT64 === $type)
326
+        } else if (self::UINT64 === $type)
347 327
         {
348 328
             $this->jsonBinaryDecoderFormatter->formatValue($this->binaryDataReader->readUInt64());
349
-        }
350
-        else if (self::DOUBLE === $type)
329
+        } else if (self::DOUBLE === $type)
351 330
         {
352 331
             $this->jsonBinaryDecoderFormatter->formatValue($this->binaryDataReader->readDouble());
353
-        }
354
-        else if (self::STRING === $type)
332
+        } else if (self::STRING === $type)
355 333
         {
356 334
             $this->jsonBinaryDecoderFormatter->formatValue(
357 335
                 $this->binaryDataReader->read($this->readVariableInt())
Please login to merge, or discard this patch.
src/MySQLReplication/BinLog/BinLogSocketConnect.php 1 patch
Braces   +2 added lines, -4 removed lines patch added patch discarded remove patch
@@ -171,8 +171,7 @@  discard block
 block discarded – undo
171 171
         if (in_array($head, $this->packageOkHeader, true))
172 172
         {
173 173
             return ['status' => true, 'code' => 0, 'msg' => ''];
174
-        }
175
-        else
174
+        } else
176 175
         {
177 176
             $error_code = unpack('v', $packet[1] . $packet[2])[1];
178 177
             $error_msg = '';
@@ -230,8 +229,7 @@  discard block
 block discarded – undo
230 229
         if ('' !== $this->config->getGtid())
231 230
         {
232 231
             $this->setBinLogDumpGtid();
233
-        }
234
-        else
232
+        } else
235 233
         {
236 234
             $this->setBinLogDump();
237 235
         }
Please login to merge, or discard this patch.
src/MySQLReplication/Event/Event.php 1 patch
Braces   +8 added lines, -16 removed lines patch added patch discarded remove patch
@@ -100,8 +100,7 @@  discard block
 block discarded – undo
100 100
             {
101 101
                 $this->eventDispatcher->dispatch(ConstEventsNames::TABLE_MAP, $event);
102 102
             }
103
-        }
104
-        else
103
+        } else
105 104
         {
106 105
             if ([] !== $this->config->getEventsOnly() && !in_array($eventInfo->getType(), $this->config->getEventsOnly(), true))
107 106
             {
@@ -120,40 +119,33 @@  discard block
 block discarded – undo
120 119
                 {
121 120
                     $this->eventDispatcher->dispatch(ConstEventsNames::UPDATE, $event);
122 121
                 }
123
-            }
124
-            elseif (in_array($eventInfo->getType(), [ConstEventType::WRITE_ROWS_EVENT_V1, ConstEventType::WRITE_ROWS_EVENT_V2], true))
122
+            } elseif (in_array($eventInfo->getType(), [ConstEventType::WRITE_ROWS_EVENT_V1, ConstEventType::WRITE_ROWS_EVENT_V2], true))
125 123
             {
126 124
                 $event = $this->rowEventService->makeRowEvent($binaryDataReader, $eventInfo)->makeWriteRowsDTO();
127 125
                 if ($event !== null)
128 126
                 {
129 127
                     $this->eventDispatcher->dispatch(ConstEventsNames::WRITE, $event);
130 128
                 }
131
-            }
132
-            elseif (in_array($eventInfo->getType(), [ConstEventType::DELETE_ROWS_EVENT_V1, ConstEventType::DELETE_ROWS_EVENT_V2], true))
129
+            } elseif (in_array($eventInfo->getType(), [ConstEventType::DELETE_ROWS_EVENT_V1, ConstEventType::DELETE_ROWS_EVENT_V2], true))
133 130
             {
134 131
                 $event = $this->rowEventService->makeRowEvent($binaryDataReader, $eventInfo)->makeDeleteRowsDTO();
135 132
                 if ($event !== null)
136 133
                 {
137 134
                     $this->eventDispatcher->dispatch(ConstEventsNames::DELETE, $event);
138 135
                 }
139
-            }
140
-            elseif (ConstEventType::XID_EVENT === $eventInfo->getType())
136
+            } elseif (ConstEventType::XID_EVENT === $eventInfo->getType())
141 137
             {
142 138
                 $this->eventDispatcher->dispatch(ConstEventsNames::XID, (new XidEvent($eventInfo, $binaryDataReader))->makeXidDTO());
143
-            }
144
-            elseif (ConstEventType::ROTATE_EVENT === $eventInfo->getType())
139
+            } elseif (ConstEventType::ROTATE_EVENT === $eventInfo->getType())
145 140
             {
146 141
                 $this->eventDispatcher->dispatch(ConstEventsNames::ROTATE, (new RotateEvent($eventInfo, $binaryDataReader))->makeRotateEventDTO());
147
-            }
148
-            elseif (ConstEventType::GTID_LOG_EVENT === $eventInfo->getType())
142
+            } elseif (ConstEventType::GTID_LOG_EVENT === $eventInfo->getType())
149 143
             {
150 144
                 $this->eventDispatcher->dispatch(ConstEventsNames::GTID, (new GtidEvent($eventInfo, $binaryDataReader))->makeGTIDLogDTO());
151
-            }
152
-            elseif (ConstEventType::QUERY_EVENT === $eventInfo->getType())
145
+            } elseif (ConstEventType::QUERY_EVENT === $eventInfo->getType())
153 146
             {
154 147
                 $this->eventDispatcher->dispatch(ConstEventsNames::QUERY, (new QueryEvent($eventInfo, $binaryDataReader))->makeQueryDTO());
155
-            }
156
-            elseif (ConstEventType::MARIA_GTID_EVENT === $eventInfo->getType())
148
+            } elseif (ConstEventType::MARIA_GTID_EVENT === $eventInfo->getType())
157 149
             {
158 150
                 $this->eventDispatcher->dispatch(ConstEventsNames::MARIADB_GTID, (new MariaDbGtidEvent($eventInfo, $binaryDataReader))->makeMariaDbGTIDLogDTO());
159 151
             }
Please login to merge, or discard this patch.
src/MySQLReplication/Event/RowEvent/Columns.php 1 patch
Braces   +15 added lines, -30 removed lines patch added patch discarded remove patch
@@ -46,53 +46,41 @@  discard block
 block discarded – undo
46 46
         if (self::$field['type'] === ConstFieldType::VARCHAR)
47 47
         {
48 48
             self::$field['max_length'] = $binaryDataReader->readInt16();
49
-        }
50
-        elseif (self::$field['type'] === ConstFieldType::DOUBLE)
49
+        } elseif (self::$field['type'] === ConstFieldType::DOUBLE)
51 50
         {
52 51
             self::$field['size'] = $binaryDataReader->readUInt8();
53
-        }
54
-        elseif (self::$field['type'] === ConstFieldType::FLOAT)
52
+        } elseif (self::$field['type'] === ConstFieldType::FLOAT)
55 53
         {
56 54
             self::$field['size'] = $binaryDataReader->readUInt8();
57
-        }
58
-        elseif (self::$field['type'] === ConstFieldType::TIMESTAMP2)
55
+        } elseif (self::$field['type'] === ConstFieldType::TIMESTAMP2)
59 56
         {
60 57
             self::$field['fsp'] = $binaryDataReader->readUInt8();
61
-        }
62
-        elseif (self::$field['type'] === ConstFieldType::DATETIME2)
58
+        } elseif (self::$field['type'] === ConstFieldType::DATETIME2)
63 59
         {
64 60
             self::$field['fsp'] = $binaryDataReader->readUInt8();
65
-        }
66
-        elseif (self::$field['type'] === ConstFieldType::TIME2)
61
+        } elseif (self::$field['type'] === ConstFieldType::TIME2)
67 62
         {
68 63
             self::$field['fsp'] = $binaryDataReader->readUInt8();
69
-        }
70
-        elseif (self::$field['type'] === ConstFieldType::TINY && $columnSchema['COLUMN_TYPE'] === 'tinyint(1)')
64
+        } elseif (self::$field['type'] === ConstFieldType::TINY && $columnSchema['COLUMN_TYPE'] === 'tinyint(1)')
71 65
         {
72 66
             self::$field['type_is_bool'] = true;
73
-        }
74
-        elseif (self::$field['type'] === ConstFieldType::VAR_STRING || self::$field['type'] === ConstFieldType::STRING)
67
+        } elseif (self::$field['type'] === ConstFieldType::VAR_STRING || self::$field['type'] === ConstFieldType::STRING)
75 68
         {
76 69
             self::getFieldSpecial($binaryDataReader, $columnSchema);
77
-        }
78
-        elseif (self::$field['type'] === ConstFieldType::BLOB)
70
+        } elseif (self::$field['type'] === ConstFieldType::BLOB)
79 71
         {
80 72
             self::$field['length_size'] = $binaryDataReader->readUInt8();
81
-        }
82
-        elseif (self::$field['type'] === ConstFieldType::GEOMETRY)
73
+        } elseif (self::$field['type'] === ConstFieldType::GEOMETRY)
83 74
         {
84 75
             self::$field['length_size'] = $binaryDataReader->readUInt8();
85
-        }
86
-        elseif (self::$field['type'] === ConstFieldType::JSON)
76
+        } elseif (self::$field['type'] === ConstFieldType::JSON)
87 77
         {
88 78
             self::$field['length_size'] = $binaryDataReader->readUInt8();
89
-        }
90
-        elseif (self::$field['type'] === ConstFieldType::NEWDECIMAL)
79
+        } elseif (self::$field['type'] === ConstFieldType::NEWDECIMAL)
91 80
         {
92 81
             self::$field['precision'] = $binaryDataReader->readUInt8();
93 82
             self::$field['decimals'] = $binaryDataReader->readUInt8();
94
-        }
95
-        elseif (self::$field['type'] === ConstFieldType::BIT)
83
+        } elseif (self::$field['type'] === ConstFieldType::BIT)
96 84
         {
97 85
             $bits = $binaryDataReader->readUInt8();
98 86
             $bytes = $binaryDataReader->readUInt8();
@@ -117,8 +105,7 @@  discard block
 block discarded – undo
117 105
             self::$field['type'] = $real_type;
118 106
             self::$field['size'] = $metadata & 0x00ff;
119 107
             self::getFieldSpecialValues($columnSchema);
120
-        }
121
-        else
108
+        } else
122 109
         {
123 110
             self::$field['max_length'] = ((($metadata >> 4) & 0x300) ^ 0x300) + ($metadata & 0x00ff);
124 111
         }
@@ -133,12 +120,10 @@  discard block
 block discarded – undo
133 120
         if (self::$field['type'] === ConstFieldType::ENUM)
134 121
         {
135 122
             self::$field['enum_values'] = explode(',', str_replace(['enum(', ')', '\''], '', $columnSchema['COLUMN_TYPE']));
136
-        }
137
-        else if (self::$field['type'] === ConstFieldType::SET)
123
+        } else if (self::$field['type'] === ConstFieldType::SET)
138 124
         {
139 125
             self::$field['set_values'] = explode(',', str_replace(['set(', ')', '\''], '', $columnSchema['COLUMN_TYPE']));
140
-        }
141
-        else
126
+        } else
142 127
         {
143 128
             throw new ConfigException('Type not handled! - ' . self::$field['type']);
144 129
         }
Please login to merge, or discard this patch.