Skip to content
Snippets Groups Projects
Commit 99101991 authored by Till Brehm's avatar Till Brehm
Browse files

Fixed error handling problem in mysql db library.

parent 6faf141a
No related branches found
No related tags found
No related merge requests found
...@@ -101,8 +101,8 @@ class db extends mysqli ...@@ -101,8 +101,8 @@ class db extends mysqli
} }
*/ */
if(mysqli_connect_error()) { if(mysqli_connect_error()) {
$this->errorNumber = mysqli_connect_errno(); $this->errorNumber = $this->connect_errno;
$this->errorMessage = mysqli_connect_error(); $this->errorMessage = $this->connect_error;
} else { } else {
$this->errorNumber = mysqli_errno($this); $this->errorNumber = mysqli_errno($this);
$this->errorMessage = mysqli_error($this); $this->errorMessage = mysqli_error($this);
...@@ -137,8 +137,8 @@ class db extends mysqli ...@@ -137,8 +137,8 @@ class db extends mysqli
$ok = $this->ping(); $ok = $this->ping();
if(!$ok) { if(!$ok) {
if(!$this->real_connect($this->dbHost, $this->dbUser, $this->dbPass, $this->dbName)) { if(!$this->real_connect($this->dbHost, $this->dbUser, $this->dbPass, $this->dbName)) {
$this->updateError('DB::query -> reconnect');
if($try > 9) { if($try > 9) {
$this->updateError('DB::query -> reconnect');
return false; return false;
} else { } else {
sleep(($try > 7 ? 5 : 1)); sleep(($try > 7 ? 5 : 1));
...@@ -150,7 +150,7 @@ class db extends mysqli ...@@ -150,7 +150,7 @@ class db extends mysqli
} }
} while($ok == false); } while($ok == false);
$this->queryId = parent::query($queryString); $this->queryId = parent::query($queryString);
$this->updateError('DB::query('.$queryString.') -> mysqli_query'); if(!$this->queryId) $this->updateError('DB::query('.$queryString.') -> mysqli_query');
if(!$this->queryId) { if(!$this->queryId) {
return false; return false;
} }
...@@ -184,9 +184,9 @@ class db extends mysqli ...@@ -184,9 +184,9 @@ class db extends mysqli
// returns the next record in an array // returns the next record in an array
public function nextRecord() { public function nextRecord() {
$this->record = $this->queryId->fetch_assoc(); $this->record = $this->queryId->fetch_assoc();
$this->updateError('DB::nextRecord()-> mysql_fetch_array');
if(!$this->record || !is_array($this->record)) if(!$this->record || !is_array($this->record))
{ {
$this->updateError('DB::nextRecord()-> mysql_fetch_array');
return false; return false;
} }
$this->currentRow++; $this->currentRow++;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment