Passed
Push — main ( 41e5bc...ca9ae3 )
by Miaad
01:45
created
src/database/mysql.php 1 patch
Spacing   +49 added lines, -49 removed lines patch added patch discarded remove patch
@@ -29,7 +29,7 @@  discard block
 block discarded – undo
29 29
     /**
30 30
      * If you want to use it in standalone mode , you MUST set `auto_process` to `false`
31 31
      */
32
-    public static function init (string $host = 'localhost', string $username = 'root', string $password = '', string $dbname = '', bool $auto_process = null, int $port = 3306): void {
32
+    public static function init(string $host = 'localhost', string $username = 'root', string $password = '', string $dbname = '', bool $auto_process = null, int $port = 3306): void {
33 33
         $host = settings::$db['host'] ?? $host;
34 34
         $port = settings::$db['port'] ?? $port;
35 35
         $user = settings::$db['user'] ?? settings::$db['username'] ?? $username;
@@ -39,7 +39,7 @@  discard block
 block discarded – undo
39 39
         self::$db_name = $dbname;
40 40
         self::$connection = new mysqli($host, $user, $pass, $dbname, $port);
41 41
         if (self::$connection->connect_errno) {
42
-            logger::write('SQL connection has problem : ' . self::$connection->connect_error, loggerTypes::ERROR);
42
+            logger::write('SQL connection has problem : '.self::$connection->connect_error, loggerTypes::ERROR);
43 43
             throw new bptException('SQL_CONNECTION_PROBLEM');
44 44
         }
45 45
         if (self::$auto_process && !lock::exist('BPT-MYSQL')) {
@@ -47,7 +47,7 @@  discard block
 block discarded – undo
47 47
         }
48 48
     }
49 49
 
50
-    private static function install (): void {
50
+    private static function install(): void {
51 51
         self::pureQuery("
52 52
 CREATE TABLE `users`
53 53
 (
@@ -68,7 +68,7 @@  discard block
 block discarded – undo
68 68
     /**
69 69
      * @internal Only for BPT self usage , Don't use it in your source!
70 70
      */
71
-    public static function process (): void {
71
+    public static function process(): void {
72 72
         if (self::$auto_process) {
73 73
             if (isset(BPT::$update->message)) {
74 74
                 self::processMessage(BPT::$update->message);
@@ -88,7 +88,7 @@  discard block
 block discarded – undo
88 88
         }
89 89
     }
90 90
 
91
-    private static function processMessage (message $update): void {
91
+    private static function processMessage(message $update): void {
92 92
         $type = $update->chat->type;
93 93
         if ($type === chatType::PRIVATE) {
94 94
             $user_id = $update->from->id;
@@ -114,7 +114,7 @@  discard block
 block discarded – undo
114 114
         }
115 115
     }
116 116
 
117
-    private static function processCallbackQuery (callbackQuery $update): void {
117
+    private static function processCallbackQuery(callbackQuery $update): void {
118 118
         $type = $update->message->chat->type;
119 119
         if ($type === chatType::PRIVATE) {
120 120
             $user_id = $update->from->id;
@@ -124,7 +124,7 @@  discard block
 block discarded – undo
124 124
         }
125 125
     }
126 126
 
127
-    private static function processInlineQuery (inlineQuery $update): void {
127
+    private static function processInlineQuery(inlineQuery $update): void {
128 128
         $type = $update->chat_type;
129 129
         if ($type === chatType::PRIVATE || $type === chatType::SENDER) {
130 130
             $user_id = $update->from->id;
@@ -134,7 +134,7 @@  discard block
 block discarded – undo
134 134
         }
135 135
     }
136 136
 
137
-    private static function processMyChatMember (chatMemberUpdated $update): void {
137
+    private static function processMyChatMember(chatMemberUpdated $update): void {
138 138
         $type = $update->chat->type;
139 139
         if ($type === chatType::PRIVATE) {
140 140
             if ($update->new_chat_member->status === chatMemberStatus::MEMBER) {
@@ -151,7 +151,7 @@  discard block
 block discarded – undo
151 151
      *
152 152
      * @return mysqli
153 153
      */
154
-    public static function getMysqli (): mysqli {
154
+    public static function getMysqli(): mysqli {
155 155
         return self::$connection;
156 156
     }
157 157
 
@@ -162,7 +162,7 @@  discard block
 block discarded – undo
162 162
      *
163 163
      * @return int|string
164 164
      */
165
-    public static function affected_rows (): int|string {
165
+    public static function affected_rows(): int | string {
166 166
         return self::$connection->affected_rows;
167 167
     }
168 168
 
@@ -173,7 +173,7 @@  discard block
 block discarded – undo
173 173
      *
174 174
      * @return int|string
175 175
      */
176
-    public static function affectedRows (): int|string {
176
+    public static function affectedRows(): int | string {
177 177
         return self::$connection->affected_rows;
178 178
     }
179 179
 
@@ -184,7 +184,7 @@  discard block
 block discarded – undo
184 184
      *
185 185
      * @return int|string
186 186
      */
187
-    public static function insert_id (): int|string {
187
+    public static function insert_id(): int | string {
188 188
         return self::$connection->insert_id;
189 189
     }
190 190
 
@@ -195,7 +195,7 @@  discard block
 block discarded – undo
195 195
      *
196 196
      * @return int|string
197 197
      */
198
-    public static function insertId (): int|string {
198
+    public static function insertId(): int | string {
199 199
         return self::$connection->insert_id;
200 200
     }
201 201
 
@@ -206,7 +206,7 @@  discard block
 block discarded – undo
206 206
      *
207 207
      * @return string
208 208
      */
209
-    public static function escapeString (string $text): string {
209
+    public static function escapeString(string $text): string {
210 210
         return self::$connection->real_escape_string($text);
211 211
     }
212 212
 
@@ -215,7 +215,7 @@  discard block
 block discarded – undo
215 215
      *
216 216
      * @return string
217 217
      */
218
-    public static function error (): string {
218
+    public static function error(): string {
219 219
         return self::$connection->error;
220 220
     }
221 221
 
@@ -224,7 +224,7 @@  discard block
 block discarded – undo
224 224
      *
225 225
      * @return int
226 226
      */
227
-    public static function errno (): int {
227
+    public static function errno(): int {
228 228
         return self::$connection->errno;
229 229
     }
230 230
 
@@ -235,7 +235,7 @@  discard block
 block discarded – undo
235 235
      *
236 236
      * @return bool
237 237
      */
238
-    public static function setCharset (string $charset): bool {
238
+    public static function setCharset(string $charset): bool {
239 239
         return self::$connection->set_charset($charset);
240 240
     }
241 241
 
@@ -250,7 +250,7 @@  discard block
 block discarded – undo
250 250
      *
251 251
      * @return mysqli_result|bool
252 252
      */
253
-    public static function pureQuery (string $query): mysqli_result|bool {
253
+    public static function pureQuery(string $query): mysqli_result | bool {
254 254
         return self::$connection->query($query);
255 255
     }
256 256
 
@@ -271,7 +271,7 @@  discard block
 block discarded – undo
271 271
      *
272 272
      * @return mysqli_result|bool
273 273
      */
274
-    public static function query (string $query, array $vars = [], bool $need_result = true): mysqli_result|bool {
274
+    public static function query(string $query, array $vars = [], bool $need_result = true): mysqli_result | bool {
275 275
         if (empty($vars)) {
276 276
             return self::pureQuery($query);
277 277
         }
@@ -288,7 +288,7 @@  discard block
 block discarded – undo
288 288
                 $types .= 's';
289 289
             }
290 290
         }
291
-        $prepare->bind_param($types,...$vars);
291
+        $prepare->bind_param($types, ...$vars);
292 292
         if (!$prepare->execute()) {
293 293
             logger::write(loggerTypes::WARNING, $prepare->error);
294 294
             return false;
@@ -319,8 +319,8 @@  discard block
 block discarded – undo
319 319
                 continue;
320 320
             }
321 321
 
322
-            $operator = substr($value,0,2);
323
-            $operator_value = substr($value,2);
322
+            $operator = substr($value, 0, 2);
323
+            $operator_value = substr($value, 2);
324 324
             switch ($operator) {
325 325
                 case '>=':
326 326
                     $query .= " `$name` >= ?";
@@ -357,17 +357,17 @@  discard block
 block discarded – undo
357 357
         return $values;
358 358
     }
359 359
 
360
-    private static function groupByBuilder(string &$query, string|array $group_by = []): void {
360
+    private static function groupByBuilder(string &$query, string | array $group_by = []): void {
361 361
         if (empty($group_by)) {
362 362
             return;
363 363
         }
364 364
         if (is_string($group_by)) {
365 365
             $group_by = [$group_by];
366 366
         }
367
-        $query .= ' GROUP BY `' . implode('`, `',$group_by) . '`';
367
+        $query .= ' GROUP BY `'.implode('`, `', $group_by).'`';
368 368
     }
369 369
 
370
-    private static function orderByBuilder(string &$query, string|array $order_by = []): void {
370
+    private static function orderByBuilder(string &$query, string | array $order_by = []): void {
371 371
         if (empty($order_by)) {
372 372
             return;
373 373
         }
@@ -420,8 +420,8 @@  discard block
 block discarded – undo
420 420
                 continue;
421 421
             }
422 422
 
423
-            $operator = substr($value,0,2);
424
-            $operator_value = substr($value,2);
423
+            $operator = substr($value, 0, 2);
424
+            $operator_value = substr($value, 2);
425 425
             switch ($operator) {
426 426
                 case '+=':
427 427
                     $query .= " `$name` = `$name` + ?";
@@ -454,19 +454,19 @@  discard block
 block discarded – undo
454 454
         return $values;
455 455
     }
456 456
 
457
-    private static function insertBuilder(string &$query, string|array $columns, array|string $values): array {
458
-        $query .= '(`' . (is_string($columns) ? $columns : implode('`,`', $columns)) . '`) VALUES (';
457
+    private static function insertBuilder(string &$query, string | array $columns, array | string $values): array {
458
+        $query .= '(`'.(is_string($columns) ? $columns : implode('`,`', $columns)).'`) VALUES (';
459 459
         if (is_string($values)) $values = [$values];
460
-        $query .= '?' . str_repeat(',?', count($values) - 1) . ')';
460
+        $query .= '?'.str_repeat(',?', count($values) - 1).')';
461 461
         return $values;
462 462
     }
463 463
 
464
-    private static function selectBuilder(string &$query, string|array $columns): void {
464
+    private static function selectBuilder(string &$query, string | array $columns): void {
465 465
         if ($columns == '*') {
466 466
             $query .= " * ";
467 467
         }
468 468
         else {
469
-            $query .= ' `' . (is_string($columns) ? $columns : implode('`,`', $columns)) . '` ';
469
+            $query .= ' `'.(is_string($columns) ? $columns : implode('`,`', $columns)).'` ';
470 470
         }
471 471
     }
472 472
 
@@ -482,7 +482,7 @@  discard block
 block discarded – undo
482 482
      *
483 483
      * @return bool
484 484
      */
485
-    public static function delete (string $table, array $where = null, int $count = null, int $offset = null): bool {
485
+    public static function delete(string $table, array $where = null, int $count = null, int $offset = null): bool {
486 486
         $query = "DELETE FROM `$table`";
487 487
         $vars = self::whereBuilder($query, $where);
488 488
         return self::query($query, $vars, false);
@@ -501,7 +501,7 @@  discard block
 block discarded – undo
501 501
      *
502 502
      * @return bool
503 503
      */
504
-    public static function update (string $table, array $modify, array $where = null, int $count = null, int $offset = null): bool {
504
+    public static function update(string $table, array $modify, array $where = null, int $count = null, int $offset = null): bool {
505 505
         $query = "UPDATE `$table` SET";
506 506
         $modify_vars = self::updateBuilder($query, $modify);
507 507
         $where_vars = self::whereBuilder($query, $where);
@@ -520,7 +520,7 @@  discard block
 block discarded – undo
520 520
      *
521 521
      * @return bool
522 522
      */
523
-    public static function insert (string $table, string|array $columns, array|string $values): bool {
523
+    public static function insert(string $table, string | array $columns, array | string $values): bool {
524 524
         $query = "INSERT INTO `$table`";
525 525
         $values = self::insertBuilder($query, $columns, $values);
526 526
         return self::query($query, $values, false);
@@ -543,14 +543,14 @@  discard block
 block discarded – undo
543 543
      *
544 544
      * @return mysqli_result|bool
545 545
      */
546
-    public static function select (string $table, array|string $columns = '*', array $where = null, int $count = null, int $offset = null, array|string $group_by = [], array|string $order_by = []): mysqli_result|bool {
546
+    public static function select(string $table, array | string $columns = '*', array $where = null, int $count = null, int $offset = null, array | string $group_by = [], array | string $order_by = []): mysqli_result | bool {
547 547
         $query = "SELECT";
548 548
         self::selectBuilder($query, $columns);
549 549
         $query .= "FROM `$table`";
550
-        $var = self::whereBuilder($query,$where);
550
+        $var = self::whereBuilder($query, $where);
551 551
         self::groupByBuilder($query, $group_by);
552 552
         self::orderByBuilder($query, $order_by);
553
-        self::countBuilder($query,$count,$offset);
553
+        self::countBuilder($query, $count, $offset);
554 554
         return self::query($query, $var);
555 555
     }
556 556
 
@@ -567,7 +567,7 @@  discard block
 block discarded – undo
567 567
      *
568 568
      * @return null|bool|array
569 569
      */
570
-    public static function selectArray (string $table, array|string $columns = '*', array $where = null, array|string $group_by = [], array|string $order_by = []): bool|array|null {
570
+    public static function selectArray(string $table, array | string $columns = '*', array $where = null, array | string $group_by = [], array | string $order_by = []): bool | array | null {
571 571
         $res = self::select($table, $columns, $where, 1, 0, $group_by, $order_by);
572 572
         if ($res) {
573 573
             return $res->fetch_assoc();
@@ -586,7 +586,7 @@  discard block
 block discarded – undo
586 586
      * @param array|string $group_by group result based on these columns
587 587
      * @param array|string $order_by order result based on these columns
588 588
      */
589
-    public static function selectObject (string $table, array|string $columns = '*', array $where = null, array|string $group_by = [], array|string $order_by = []) {
589
+    public static function selectObject(string $table, array | string $columns = '*', array $where = null, array | string $group_by = [], array | string $order_by = []) {
590 590
         $res = self::select($table, $columns, $where, 1, 0, $group_by, $order_by);
591 591
         if ($res) {
592 592
             return $res->fetch_object();
@@ -610,7 +610,7 @@  discard block
 block discarded – undo
610 610
      *
611 611
      * @return bool|Generator
612 612
      */
613
-    public static function selectEach (string $table, array|string $columns = '*', array $where = null, int $count = null, int $offset = null, array|string $group_by = [], array|string $order_by = []): bool|Generator {
613
+    public static function selectEach(string $table, array | string $columns = '*', array $where = null, int $count = null, int $offset = null, array | string $group_by = [], array | string $order_by = []): bool | Generator {
614 614
         $res = self::select($table, $columns, $where, $count, $offset, $group_by, $order_by);
615 615
         if ($res) {
616 616
             while ($row = $res->fetch_assoc()) yield $row;
@@ -628,10 +628,10 @@  discard block
 block discarded – undo
628 628
      *
629 629
      * @return string if save is true , return file name otherwise return sql data
630 630
      */
631
-    public static function backup (array $wanted_tables = null, bool $table_data = true, bool $save = true, string $file_name = ''): string {
631
+    public static function backup(array $wanted_tables = null, bool $table_data = true, bool $save = true, string $file_name = ''): string {
632 632
         self::setCharset('utf8mb4');
633 633
 
634
-        $tables = array_column(self::query('SHOW TABLES')->fetch_all(),0);
634
+        $tables = array_column(self::query('SHOW TABLES')->fetch_all(), 0);
635 635
         if (!empty($wanted_tables)) {
636 636
             $tables = array_intersect($tables, $wanted_tables);
637 637
         }
@@ -642,12 +642,12 @@  discard block
 block discarded – undo
642 642
             logger::write('No table founded for backup, if your database has table : check $wanted_tables argument', loggerTypes::WARNING);
643 643
         }
644 644
         foreach ($tables as $table) {
645
-            $sql .= self::query("SHOW CREATE TABLE `$table`")->fetch_row()[1] . ";\n\n";
645
+            $sql .= self::query("SHOW CREATE TABLE `$table`")->fetch_row()[1].";\n\n";
646 646
             if ($table_data) {
647 647
                 $total_rows = self::query("SELECT COUNT(*) as `cnt` FROM `$table`")->fetch_object()->cnt;
648 648
                 for ($i = 0; $i < $total_rows; $i = $i + 1000) {
649
-                    $sql .= "INSERT INTO " . $table . " VALUES";
650
-                    $result = self::select($table, '*' , null, 1000, $i);
649
+                    $sql .= "INSERT INTO ".$table." VALUES";
650
+                    $result = self::select($table, '*', null, 1000, $i);
651 651
                     $field_count = $result->field_count;
652 652
                     $affected_rows = self::affected_rows();
653 653
                     $counter = 1;
@@ -655,12 +655,12 @@  discard block
 block discarded – undo
655 655
                         $sql .= "\n(";
656 656
                         for ($column = 0; $column < $field_count; $column++) {
657 657
                             $row[$column] = str_replace("\n", "\\n", addslashes($row[$column]));
658
-                            $sql .= !empty($row[$column]) ? '"' . $row[$column] . '"' : '""';
658
+                            $sql .= !empty($row[$column]) ? '"'.$row[$column].'"' : '""';
659 659
                             if ($column < $field_count - 1) {
660 660
                                 $sql .= ',';
661 661
                             }
662 662
                         }
663
-                        $sql .= ')' . ($counter == $affected_rows ? ';' : ',');
663
+                        $sql .= ')'.($counter == $affected_rows ? ';' : ',');
664 664
                         $counter++;
665 665
                     }
666 666
                 }
@@ -676,7 +676,7 @@  discard block
 block discarded – undo
676 676
         }
677 677
 
678 678
         if (empty($file_name)) {
679
-            $file_name = self::$db_name . time() . '.sql';
679
+            $file_name = self::$db_name.time().'.sql';
680 680
         }
681 681
         file_put_contents($file_name, $sql);
682 682
         return $file_name;
Please login to merge, or discard this patch.