@@ -29,7 +29,7 @@ discard block |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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; |