mysqli class fix

pihel · May 24, 2015 · 401f822 · 401f822
1 parent a9be2e9
commit 401f822
Showing 1 changed file with 104 additions and 96 deletions.
diff --git a/lib/db/mysqli.php b/lib/db/mysqli.php
@@ -1,97 +1,105 @@
-<?
-class MySQLi_DB extends FileCacheDB {
-
-  public function try_connect($srv, $login, $pasw, $db) {
-    return new mysqli($srv, $login, $pasw, $db);
-  }
-
-  public function after_connect() {
-    $this->_con->set_charset($this->encode);
-    $this->_con->autocommit($this->autocommit);
-  }
-
-  public function raiseError() {
-    if(!$this->_con) return;
-    if(intval($this->_con->errno) < 1) return;
-
-    $error_msg = "[".$this->_con->errno."] ".$this->_con->error;
-    //$this->_con->close();
-    throw new Error($error_msg);
-  }
-
-  public function commit() {
-    $this->_con->commit();
-  }
-
-  public function rollback() {
-    $this->_con->rollback();
-  }
-
-  public function last_id() {
-    return $this->_con->insert_id;
-  }
-
-  public function affect() {
-    return $this->_con->affected_rows;
-  }
-
-  protected function _exec($sql, $args) {
-
-    $this->_stmt = $this->_con->prepare($sql);
-    if(!$this->_stmt) $this->raiseError();
-    //биндим параменты
-    //tnx http://www.php.net/manual/en/mysqli-stmt.bind-param.php#100879
-    $params = $args;
-    $refs = array();
-    array_unshift($params, str_repeat('s', count($args)));
-    if (strnatcmp(phpversion(),'5.3') >= 0) {
-      foreach($params as $key => $value) {
-          $refs[$key] = &$params[$key];
-      }
-    } else {
-      $refs = $params;
-    }
-    call_user_func_array(array($this->_stmt, 'bind_param'), $refs);
-
-    if(!$this->_stmt->execute()) $this->raiseError();
-
-    //получаем результаты
-    $meta = $this->_stmt->result_metadata();
-    $ret = NULL;
-    if($meta !== false) {
-      $ret = array();
-      $cols = array();
-      //tnx http://www.php.net/manual/en/mysqli-stmt.fetch.php#72720
-      $fields = $meta->fetch_fields();
-      $cnt_fields = count($fields);
-      foreach($fields as $field) {
-        $cols[] = &$this->_con->results[$field->name];
-      }
-      call_user_func_array(array($this->_stmt, 'bind_result'), $cols);
-      $key = 0;
-      while($this->_stmt->fetch() != NULL) {
-        $num_col = 0;
-        foreach ($this->_con->results as $result) {
-            $ret[$key][$fields[$num_col]->name] = $result;
-            $num_col++;
-        }
-        $key++;
-      }
-    }
-
-    $this->_stmt->close();
-
-    return $ret;
-  }
-
-  public function getRealSql($sql, $args) {
-    $sql = str_replace("?", "%s", $sql);
-    $sql = vsprintf($sql, $args);
-    return $sql;
-  }
-
-  function __destruct() {
-    if(is_resource($this->_con)) $this->_con->close;
-  }
-}
+<?
+class MySQLi_DB extends FileCacheDB {
+
+  public function try_connect($srv, $login, $pasw, $db) {
+    return new mysqli($srv, $login, $pasw, $db);
+  }
+
+  public function after_connect() {
+    $this->raiseError();
+    $this->_con->set_charset($this->encode);
+    $this->_con->autocommit($this->autocommit);
+  }
+
+  public function raiseError() {
+    if(!$this->_con) return;
+    if(intval($this->_con->errno) < 1 && intval($this->_con->connect_errno) < 1 ) return;
+
+    if(empty($this->_con->errno)) {
+      $error_msg = "[".$this->_con->connect_errno."] ".$this->_con->connect_error;
+    } else {
+      $error_msg = "[".$this->_con->errno."] ".$this->_con->error;
+    }
+    //$this->_con->close();
+    throw new Error($error_msg);
+  }
+
+  public function commit() {
+    $this->_con->commit();
+  }
+
+  public function rollback() {
+    $this->_con->rollback();
+  }
+
+  public function last_id() {
+    return $this->_con->insert_id;
+  }
+
+  public function affect() {
+    return $this->_con->affected_rows;
+  }
+
+  protected function _exec($sql, $args) {
+    unset($this->_stmt);
+    unset($this->_con->results);
+    if(!$this->_con) $this->raiseError();
+    $this->_stmt = $this->_con->prepare($sql);
+    if(!$this->_stmt) $this->raiseError();
+    //биндим параменты
+    //tnx http://www.php.net/manual/en/mysqli-stmt.bind-param.php#100879
+    $params = $args;
+    $refs = array();
+    array_unshift($params, str_repeat('s', count($args)));
+    if (strnatcmp(phpversion(),'5.3') >= 0) {
+      foreach($params as $key => $value) {
+          $refs[$key] = &$params[$key];
+      }
+    } else {
+      $refs = $params;
+    }
+    call_user_func_array(array($this->_stmt, 'bind_param'), $refs);
+
+    if(!$this->_stmt->execute()) $this->raiseError();
+
+
+
+    //получаем результаты
+    $meta = $this->_stmt->result_metadata();
+    $ret = NULL;
+    if($meta !== false) {
+      $ret = array();
+      $cols = array();
+      //tnx http://www.php.net/manual/en/mysqli-stmt.fetch.php#72720
+      $fields = $meta->fetch_fields();
+      foreach($fields as $field) {
+        $cols[] = &$this->_con->results[$field->name];
+      }
+      call_user_func_array(array($this->_stmt, 'bind_result'), $cols);
+      $key = 0;
+      while($this->_stmt->fetch() != NULL) {
+        $num_col = 0;
+        foreach ($this->_con->results as $result) {
+            $ret[$key][$fields[$num_col]->name] = $result;
+            $num_col++;
+        }
+        $key++;
+      }
+    }
+
+    $this->_stmt->close();
+
+    return $ret;
+  }
+
+  public function getRealSql($sql, $args) {
+    $sql = str_replace("?", "%s", $sql);
+    $sql = vsprintf($sql, $args);
+    return $sql;
+  }
+
+  function __destruct() {
+    if(is_resource($this->_con)) $this->_con->close;
+  }
+}
 ?>