BPTproto / BPT-Multi

src/database/mysql.php

Spacing +49 added lines, -49 removed lines

@@ -29,7 +29,7 @@ 
     /**
      * If you want to use it in standalone mode , you MUST set `auto_process` to `false`
      */
-    public static function init (string $host = 'localhost', string $username = 'root', string $password = '', string $dbname = '', bool $auto_process = null, int $port = 3306): void {
+    public static function init(string $host = 'localhost', string $username = 'root', string $password = '', string $dbname = '', bool $auto_process = null, int $port = 3306): void {
         $host = settings::$db['host'] ?? $host;
         $port = settings::$db['port'] ?? $port;
         $user = settings::$db['user'] ?? settings::$db['username'] ?? $username;
@@ -39,7 +39,7 @@ 
         self::$db_name = $dbname;
         self::$connection = new mysqli($host, $user, $pass, $dbname, $port);
         if (self::$connection->connect_errno) {
-            logger::write('SQL connection has problem : ' . self::$connection->connect_error, loggerTypes::ERROR);
+            logger::write('SQL connection has problem : '.self::$connection->connect_error, loggerTypes::ERROR);
             throw new bptException('SQL_CONNECTION_PROBLEM');
         }
         if (self::$auto_process && !lock::exist('BPT-MYSQL')) {
@@ -47,7 +47,7 @@ 
         }
     }
 
-    private static function install (): void {
+    private static function install(): void {
         self::pureQuery("
 CREATE TABLE `users`
 (
@@ -68,7 +68,7 @@ 
     /**
      * @internal Only for BPT self usage , Don't use it in your source!
      */
-    public static function process (): void {
+    public static function process(): void {
         if (self::$auto_process) {
             if (isset(BPT::$update->message)) {
                 self::processMessage(BPT::$update->message);
@@ -88,7 +88,7 @@ 
         }
     }
 
-    private static function processMessage (message $update): void {
+    private static function processMessage(message $update): void {
         $type = $update->chat->type;
         if ($type === chatType::PRIVATE) {
             $user_id = $update->from->id;
@@ -114,7 +114,7 @@ 
         }
     }
 
-    private static function processCallbackQuery (callbackQuery $update): void {
+    private static function processCallbackQuery(callbackQuery $update): void {
         $type = $update->message->chat->type;
         if ($type === chatType::PRIVATE) {
             $user_id = $update->from->id;
@@ -124,7 +124,7 @@ 
         }
     }
 
-    private static function processInlineQuery (inlineQuery $update): void {
+    private static function processInlineQuery(inlineQuery $update): void {
         $type = $update->chat_type;
         if ($type === chatType::PRIVATE || $type === chatType::SENDER) {
             $user_id = $update->from->id;
@@ -134,7 +134,7 @@ 
         }
     }
 
-    private static function processMyChatMember (chatMemberUpdated $update): void {
+    private static function processMyChatMember(chatMemberUpdated $update): void {
         $type = $update->chat->type;
         if ($type === chatType::PRIVATE) {
             if ($update->new_chat_member->status === chatMemberStatus::MEMBER) {
@@ -151,7 +151,7 @@ 
      *
      * @return mysqli
      */
-    public static function getMysqli (): mysqli {
+    public static function getMysqli(): mysqli {
         return self::$connection;
     }
 
@@ -162,7 +162,7 @@ 
      *
      * @return int|string
      */
-    public static function affected_rows (): int|string {
+    public static function affected_rows(): int | string {
         return self::$connection->affected_rows;
     }
 
@@ -173,7 +173,7 @@ 
      *
      * @return int|string
      */
-    public static function affectedRows (): int|string {
+    public static function affectedRows(): int | string {
         return self::$connection->affected_rows;
     }
 
@@ -184,7 +184,7 @@ 
      *
      * @return int|string
      */
-    public static function insert_id (): int|string {
+    public static function insert_id(): int | string {
         return self::$connection->insert_id;
     }
 
@@ -195,7 +195,7 @@ 
      *
      * @return int|string
      */
-    public static function insertId (): int|string {
+    public static function insertId(): int | string {
         return self::$connection->insert_id;
     }
 
@@ -206,7 +206,7 @@ 
      *
      * @return string
      */
-    public static function escapeString (string $text): string {
+    public static function escapeString(string $text): string {
         return self::$connection->real_escape_string($text);
     }
 
@@ -215,7 +215,7 @@ 
      *
      * @return string
      */
-    public static function error (): string {
+    public static function error(): string {
         return self::$connection->error;
     }
 
@@ -224,7 +224,7 @@ 
      *
      * @return int
      */
-    public static function errno (): int {
+    public static function errno(): int {
         return self::$connection->errno;
     }
 
@@ -235,7 +235,7 @@ 
      *
      * @return bool
      */
-    public static function setCharset (string $charset): bool {
+    public static function setCharset(string $charset): bool {
         return self::$connection->set_charset($charset);
     }
 
@@ -250,7 +250,7 @@ 
      *
      * @return mysqli_result|bool
      */
-    public static function pureQuery (string $query): mysqli_result|bool {
+    public static function pureQuery(string $query): mysqli_result | bool {
         return self::$connection->query($query);
     }
 
@@ -271,7 +271,7 @@ 
      *
      * @return mysqli_result|bool
      */
-    public static function query (string $query, array $vars = [], bool $need_result = true): mysqli_result|bool {
+    public static function query(string $query, array $vars = [], bool $need_result = true): mysqli_result | bool {
         if (empty($vars)) {
             return self::pureQuery($query);
         }
@@ -288,7 +288,7 @@ 
                 $types .= 's';
             }
         }
-        $prepare->bind_param($types,...$vars);
+        $prepare->bind_param($types, ...$vars);
         if (!$prepare->execute()) {
             logger::write(loggerTypes::WARNING, $prepare->error);
             return false;
@@ -319,8 +319,8 @@ 
                 continue;
             }
 
-            $operator = substr($value,0,2);
-            $operator_value = substr($value,2);
+            $operator = substr($value, 0, 2);
+            $operator_value = substr($value, 2);
             switch ($operator) {
                 case '>=':
                     $query .= " `$name` >= ?";
@@ -357,17 +357,17 @@ 
         return $values;
     }
 
-    private static function groupByBuilder(string &$query, string|array $group_by = []): void {
+    private static function groupByBuilder(string &$query, string | array $group_by = []): void {
         if (empty($group_by)) {
             return;
         }
         if (is_string($group_by)) {
             $group_by = [$group_by];
         }
-        $query .= ' GROUP BY `' . implode('`, `',$group_by) . '`';
+        $query .= ' GROUP BY `'.implode('`, `', $group_by).'`';
     }
 
-    private static function orderByBuilder(string &$query, string|array $order_by = []): void {
+    private static function orderByBuilder(string &$query, string | array $order_by = []): void {
         if (empty($order_by)) {
             return;
         }
@@ -420,8 +420,8 @@ 
                 continue;
             }
 
-            $operator = substr($value,0,2);
-            $operator_value = substr($value,2);
+            $operator = substr($value, 0, 2);
+            $operator_value = substr($value, 2);
             switch ($operator) {
                 case '+=':
                     $query .= " `$name` = `$name` + ?";
@@ -454,19 +454,19 @@ 
         return $values;
     }
 
-    private static function insertBuilder(string &$query, string|array $columns, array|string $values): array {
-        $query .= '(`' . (is_string($columns) ? $columns : implode('`,`', $columns)) . '`) VALUES (';
+    private static function insertBuilder(string &$query, string | array $columns, array | string $values): array {
+        $query .= '(`'.(is_string($columns) ? $columns : implode('`,`', $columns)).'`) VALUES (';
         if (is_string($values)) $values = [$values];
-        $query .= '?' . str_repeat(',?', count($values) - 1) . ')';
+        $query .= '?'.str_repeat(',?', count($values) - 1).')';
         return $values;
     }
 
-    private static function selectBuilder(string &$query, string|array $columns): void {
+    private static function selectBuilder(string &$query, string | array $columns): void {
         if ($columns == '*') {
             $query .= " * ";
         }
         else {
-            $query .= ' `' . (is_string($columns) ? $columns : implode('`,`', $columns)) . '` ';
+            $query .= ' `'.(is_string($columns) ? $columns : implode('`,`', $columns)).'` ';
         }
     }
 
@@ -482,7 +482,7 @@ 
      *
      * @return bool
      */
-    public static function delete (string $table, array $where = null, int $count = null, int $offset = null): bool {
+    public static function delete(string $table, array $where = null, int $count = null, int $offset = null): bool {
         $query = "DELETE FROM `$table`";
         $vars = self::whereBuilder($query, $where);
         return self::query($query, $vars, false);
@@ -501,7 +501,7 @@ 
      *
      * @return bool
      */
-    public static function update (string $table, array $modify, array $where = null, int $count = null, int $offset = null): bool {
+    public static function update(string $table, array $modify, array $where = null, int $count = null, int $offset = null): bool {
         $query = "UPDATE `$table` SET";
         $modify_vars = self::updateBuilder($query, $modify);
         $where_vars = self::whereBuilder($query, $where);
@@ -520,7 +520,7 @@ 
      *
      * @return bool
      */
-    public static function insert (string $table, string|array $columns, array|string $values): bool {
+    public static function insert(string $table, string | array $columns, array | string $values): bool {
         $query = "INSERT INTO `$table`";
         $values = self::insertBuilder($query, $columns, $values);
         return self::query($query, $values, false);
@@ -543,14 +543,14 @@ 
      *
      * @return mysqli_result|bool
      */
-    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 {
+    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 {
         $query = "SELECT";
         self::selectBuilder($query, $columns);
         $query .= "FROM `$table`";
-        $var = self::whereBuilder($query,$where);
+        $var = self::whereBuilder($query, $where);
         self::groupByBuilder($query, $group_by);
         self::orderByBuilder($query, $order_by);
-        self::countBuilder($query,$count,$offset);
+        self::countBuilder($query, $count, $offset);
         return self::query($query, $var);
     }
 
@@ -567,7 +567,7 @@ 
      *
      * @return null|bool|array
      */
-    public static function selectArray (string $table, array|string $columns = '*', array $where = null, array|string $group_by = [], array|string $order_by = []): bool|array|null {
+    public static function selectArray(string $table, array | string $columns = '*', array $where = null, array | string $group_by = [], array | string $order_by = []): bool | array | null {
         $res = self::select($table, $columns, $where, 1, 0, $group_by, $order_by);
         if ($res) {
             return $res->fetch_assoc();
@@ -586,7 +586,7 @@ 
      * @param array|string $group_by group result based on these columns
      * @param array|string $order_by order result based on these columns
      */
-    public static function selectObject (string $table, array|string $columns = '*', array $where = null, array|string $group_by = [], array|string $order_by = []) {
+    public static function selectObject(string $table, array | string $columns = '*', array $where = null, array | string $group_by = [], array | string $order_by = []) {
         $res = self::select($table, $columns, $where, 1, 0, $group_by, $order_by);
         if ($res) {
             return $res->fetch_object();
@@ -610,7 +610,7 @@ 
      *
      * @return bool|Generator
      */
-    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 {
+    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 {
         $res = self::select($table, $columns, $where, $count, $offset, $group_by, $order_by);
         if ($res) {
             while ($row = $res->fetch_assoc()) yield $row;
@@ -628,10 +628,10 @@ 
      *
      * @return string if save is true , return file name otherwise return sql data
      */
-    public static function backup (array $wanted_tables = null, bool $table_data = true, bool $save = true, string $file_name = ''): string {
+    public static function backup(array $wanted_tables = null, bool $table_data = true, bool $save = true, string $file_name = ''): string {
         self::setCharset('utf8mb4');
 
-        $tables = array_column(self::query('SHOW TABLES')->fetch_all(),0);
+        $tables = array_column(self::query('SHOW TABLES')->fetch_all(), 0);
         if (!empty($wanted_tables)) {
             $tables = array_intersect($tables, $wanted_tables);
         }
@@ -642,12 +642,12 @@ 
             logger::write('No table founded for backup, if your database has table : check $wanted_tables argument', loggerTypes::WARNING);
         }
         foreach ($tables as $table) {
-            $sql .= self::query("SHOW CREATE TABLE `$table`")->fetch_row()[1] . ";\n\n";
+            $sql .= self::query("SHOW CREATE TABLE `$table`")->fetch_row()[1].";\n\n";
             if ($table_data) {
                 $total_rows = self::query("SELECT COUNT(*) as `cnt` FROM `$table`")->fetch_object()->cnt;
                 for ($i = 0; $i < $total_rows; $i = $i + 1000) {
-                    $sql .= "INSERT INTO " . $table . " VALUES";
-                    $result = self::select($table, '*' , null, 1000, $i);
+                    $sql .= "INSERT INTO ".$table." VALUES";
+                    $result = self::select($table, '*', null, 1000, $i);
                     $field_count = $result->field_count;
                     $affected_rows = self::affected_rows();
                     $counter = 1;
@@ -655,12 +655,12 @@ 
                         $sql .= "\n(";
                         for ($column = 0; $column < $field_count; $column++) {
                             $row[$column] = str_replace("\n", "\\n", addslashes($row[$column]));
-                            $sql .= !empty($row[$column]) ? '"' . $row[$column] . '"' : '""';
+                            $sql .= !empty($row[$column]) ? '"'.$row[$column].'"' : '""';
                             if ($column < $field_count - 1) {
                                 $sql .= ',';
                             }
                         }
-                        $sql .= ')' . ($counter == $affected_rows ? ';' : ',');
+                        $sql .= ')'.($counter == $affected_rows ? ';' : ',');
                         $counter++;
                     }
                 }
@@ -676,7 +676,7 @@ 
         }
 
         if (empty($file_name)) {
-            $file_name = self::$db_name . time() . '.sql';
+            $file_name = self::$db_name.time().'.sql';
         }
         file_put_contents($file_name, $sql);
         return $file_name;