Completed
Push — master ( 913952...f8c7e1 )
by Alexey
06:23
created
system/modules/Db/objects/Mysql/Mysql.php 3 patches
Indentation   +39 added lines, -39 removed lines patch added patch discarded remove patch
@@ -13,30 +13,30 @@  discard block
 block discarded – undo
13 13
 
14 14
 class Mysql extends \Object {
15 15
 
16
-  public $config = [];       // настройки подключения выбраной базы
17
-  public $connect = FALSE;        // ярлык соединения с MySQL
18
-  public $encoding = 'utf-8';        // установленная кодировка
19
-  public $db_name = 'test';         // выбраная в данный момент база
20
-  public $table_prefix = 'inji_';   // префикс названий таблиц
21
-  public $pdo = NULL;
22
-  public $lastQuery = '';
23
-  public $last_error = '';
24
-  public $noConnectAbort = false;
25
-  public $dbInstance = null;
16
+    public $config = [];       // настройки подключения выбраной базы
17
+    public $connect = FALSE;        // ярлык соединения с MySQL
18
+    public $encoding = 'utf-8';        // установленная кодировка
19
+    public $db_name = 'test';         // выбраная в данный момент база
20
+    public $table_prefix = 'inji_';   // префикс названий таблиц
21
+    public $pdo = NULL;
22
+    public $lastQuery = '';
23
+    public $last_error = '';
24
+    public $noConnectAbort = false;
25
+    public $dbInstance = null;
26 26
 
27
-  /**
28
-   * Подключение к MySQL
29
-   */
30
-  public function init($connect_options) {
27
+    /**
28
+     * Подключение к MySQL
29
+     */
30
+    public function init($connect_options) {
31 31
     extract($connect_options);
32 32
     if (isset($db_name))
33
-      $this->db_name = $db_name;
33
+        $this->db_name = $db_name;
34 34
     if (isset($encoding))
35
-      $this->encoding = $encoding;
35
+        $this->encoding = $encoding;
36 36
     if (isset($table_prefix))
37
-      $this->table_prefix = $table_prefix;
37
+        $this->table_prefix = $table_prefix;
38 38
     if (isset($noConnectAbort))
39
-      $this->noConnectAbort = $noConnectAbort;
39
+        $this->noConnectAbort = $noConnectAbort;
40 40
 
41 41
     $dsn = "mysql:host=$host;port=$port;dbname=$db_name;charset=$encoding";
42 42
     $dt = new \DateTime();
@@ -50,20 +50,20 @@  discard block
 block discarded – undo
50 50
     $this->pdo = new \PDO($dsn, $user, $pass, $opt);
51 51
     $error = $this->pdo->errorInfo();
52 52
     if ((int) $error[0]) {
53
-      if ($this->noConnectAbort) {
53
+        if ($this->noConnectAbort) {
54 54
         return false;
55
-      } else {
55
+        } else {
56 56
         INJI_SYSTEM_ERROR($error[2], true);
57
-      }
57
+        }
58 58
     } else {
59
-      $this->connect = true;
60
-      $query = new Mysql\Query($this);
61
-      $query->query("SET SQL_BIG_SELECTS=1");
62
-      return true;
59
+        $this->connect = true;
60
+        $query = new Mysql\Query($this);
61
+        $query->query("SET SQL_BIG_SELECTS=1");
62
+        return true;
63
+    }
63 64
     }
64
-  }
65 65
 
66
-  public function getTableCols($table_name) {
66
+    public function getTableCols($table_name) {
67 67
     $query = new Mysql\Query($this);
68 68
     $old_db = $this->db_name;
69 69
     $old_prefix = $this->table_prefix;
@@ -76,35 +76,35 @@  discard block
 block discarded – undo
76 76
     $this->db_name = $old_db;
77 77
     $this->table_prefix = $old_prefix;
78 78
     return $result->getArray('COLUMN_NAME');
79
-  }
79
+    }
80 80
 
81
-  public function tableExist($tableName) {
81
+    public function tableExist($tableName) {
82 82
     $query = new Mysql\Query($this);
83 83
     return (bool) $query->query("SHOW TABLES FROM `{$this->db_name}` LIKE '{$this->table_prefix}{$tableName}'")->getArray();
84
-  }
84
+    }
85 85
 
86
-  public function addCol($table = false, $name = false, $param = 'TEXT NOT NULL') {
86
+    public function addCol($table = false, $name = false, $param = 'TEXT NOT NULL') {
87 87
     if (!$table || !$name) {
88
-      return false;
88
+        return false;
89 89
     }
90 90
     if ($param == 'pk') {
91
-      $param = "int(11) NOT NULL AUTO_INCREMENT, PRIMARY KEY (`{$name}`)";
91
+        $param = "int(11) NOT NULL AUTO_INCREMENT, PRIMARY KEY (`{$name}`)";
92 92
     }
93 93
     $query = new Mysql\Query($this);
94 94
     return $query->query("ALTER TABLE `{$this->db_name}`.`{$this->table_prefix}{$table}` ADD `{$name}` {$param}");
95
-  }
95
+    }
96 96
 
97
-  public function delCol($table = false, $name = false) {
97
+    public function delCol($table = false, $name = false) {
98 98
     if (!$table || !$name) {
99
-      return false;
99
+        return false;
100 100
     }
101 101
     $query = new Mysql\Query($this);
102 102
     return $query->query("ALTER TABLE `{$this->db_name}`.`{$this->table_prefix}{$table}` DROP `{$name}`");
103
-  }
103
+    }
104 104
 
105
-  public function getTables() {
105
+    public function getTables() {
106 106
     $query = new Mysql\Query($this);
107 107
     return $query->query("SHOW TABLES")->getArray();
108
-  }
108
+    }
109 109
 
110 110
 }
Please login to merge, or discard this patch.
Spacing   +6 added lines, -6 removed lines patch added patch discarded remove patch
@@ -13,11 +13,11 @@  discard block
 block discarded – undo
13 13
 
14 14
 class Mysql extends \Object {
15 15
 
16
-  public $config = [];       // настройки подключения выбраной базы
17
-  public $connect = FALSE;        // ярлык соединения с MySQL
18
-  public $encoding = 'utf-8';        // установленная кодировка
19
-  public $db_name = 'test';         // выбраная в данный момент база
20
-  public $table_prefix = 'inji_';   // префикс названий таблиц
16
+  public $config = []; // настройки подключения выбраной базы
17
+  public $connect = FALSE; // ярлык соединения с MySQL
18
+  public $encoding = 'utf-8'; // установленная кодировка
19
+  public $db_name = 'test'; // выбраная в данный момент база
20
+  public $table_prefix = 'inji_'; // префикс названий таблиц
21 21
   public $pdo = NULL;
22 22
   public $lastQuery = '';
23 23
   public $last_error = '';
@@ -71,7 +71,7 @@  discard block
 block discarded – undo
71 71
     $this->table_prefix = '';
72 72
 
73 73
     $query->where('TABLE_SCHEMA', $old_db);
74
-    $query->where('TABLE_NAME', $old_prefix . $table_name);
74
+    $query->where('TABLE_NAME', $old_prefix.$table_name);
75 75
     $result = $query->select('COLUMNS');
76 76
     $this->db_name = $old_db;
77 77
     $this->table_prefix = $old_prefix;
Please login to merge, or discard this patch.
Braces   +12 added lines, -8 removed lines patch added patch discarded remove patch
@@ -29,14 +29,18 @@
 block discarded – undo
29 29
    */
30 30
   public function init($connect_options) {
31 31
     extract($connect_options);
32
-    if (isset($db_name))
33
-      $this->db_name = $db_name;
34
-    if (isset($encoding))
35
-      $this->encoding = $encoding;
36
-    if (isset($table_prefix))
37
-      $this->table_prefix = $table_prefix;
38
-    if (isset($noConnectAbort))
39
-      $this->noConnectAbort = $noConnectAbort;
32
+    if (isset($db_name)) {
33
+          $this->db_name = $db_name;
34
+    }
35
+    if (isset($encoding)) {
36
+          $this->encoding = $encoding;
37
+    }
38
+    if (isset($table_prefix)) {
39
+          $this->table_prefix = $table_prefix;
40
+    }
41
+    if (isset($noConnectAbort)) {
42
+          $this->noConnectAbort = $noConnectAbort;
43
+    }
40 44
 
41 45
     $dsn = "mysql:host=$host;port=$port;dbname=$db_name;charset=$encoding";
42 46
     $dt = new \DateTime();
Please login to merge, or discard this patch.