From 7435fbc94faeabe12c41e53da251d4b5ac0e42cb Mon Sep 17 00:00:00 2001
From: Falko Timme <ft@falkotimme.com>
Date: Tue, 15 Oct 2013 12:09:02 -0400
Subject: [PATCH] - Corrected errors in German language files from SVN commit 4172.

---
 interface/lib/classes/db_mysql.inc.php |   61 +++++++++++++++++++++---------
 1 files changed, 43 insertions(+), 18 deletions(-)

diff --git a/interface/lib/classes/db_mysql.inc.php b/interface/lib/classes/db_mysql.inc.php
index 02ad8d3..4672998 100644
--- a/interface/lib/classes/db_mysql.inc.php
+++ b/interface/lib/classes/db_mysql.inc.php
@@ -44,7 +44,8 @@
   private $errorNumber = 0;	// last error number
   public $errorMessage = '';	// last error message
   private $errorLocation = '';// last error location
-  public $show_error_messages = true; // false in server, true in interface
+  public $show_error_messages = false; // false in server, true in interface
+  private $isConnected = false; // needed to know if we have a valid mysqli object from the constructor
 
   // constructor
   public function __construct($prefix = '') {
@@ -58,12 +59,23 @@
     $this->dbNewLink = $conf[$prefix.'db_new_link'];
     $this->dbClientFlags = $conf[$prefix.'db_client_flags'];
     parent::__construct($conf[$prefix.'db_host'], $conf[$prefix.'db_user'],$conf[$prefix.'db_password'],$conf[$prefix.'db_database']);
-    if ($this->connect_error) {
+    $try = 0;
+    //while(!is_null($this->connect_error) && $try < 5) {
+	while(mysqli_connect_error() && $try < 5) {
+      if($try > 0) sleep(1);
+      
+      $try++;
       $this->updateError('DB::__construct');
-      return false;
-    } else {
-      $this->setCharacterEncoding();
+      
+      parent::__construct($conf[$prefix.'db_host'], $conf[$prefix.'db_user'],$conf[$prefix.'db_password'],$conf[$prefix.'db_database']);
     }
+    
+    //if(is_null($this->connect_error)) $this->isConnected = true;
+    //else return false;
+	if(!mysqli_connect_error()) $this->isConnected = true;
+    else return false;
+    
+    $this->setCharacterEncoding();
   }
 
   public function __destruct() {
@@ -72,41 +84,54 @@
 
   // error handler
   public function updateError($location) {
-    global $app;
+    global $app, $conf;
 
-    if($this->connect_error) {
+	/*
+    if(!is_null($this->connect_error)) {
       $this->errorNumber = $this->connect_errno;
       $this->errorMessage = $this->connect_error;
     } else {
       $this->errorNumber = $this->errno;
       $this->errorMessage = $this->error;
     }
+	*/
+	if(mysqli_connect_error()) {
+      $this->errorNumber = mysqli_connect_errno();
+      $this->errorMessage = mysqli_connect_error();
+    } else {
+      $this->errorNumber = mysqli_errno($this);
+      $this->errorMessage = mysqli_error($this);
+    }
+
 
     $this->errorLocation = $location;
     if($this->errorNumber) {
       $error_msg = $this->errorLocation .' '. $this->errorMessage;
-      // This right here will allow us to use the samefile for server & interface
-      if($this->show_error_messages) {
-	echo $error_msg;
+      // This right here will allow us to use the same file for server & interface
+      if($this->show_error_messages && $conf['demo_mode'] === false) {
+		echo $error_msg;
       } else if(is_object($app) && method_exists($app, 'log')) {
-	$app->log($error_msg, LOGLEVEL_WARN);
+		$app->log($error_msg, LOGLEVEL_WARN);
       }
     }
   }
   
   private function setCharacterEncoding() {
+    if($this->isConnected == false) return false;
     parent::query( 'SET NAMES '.$this->dbCharset); 
     parent::query( "SET character_set_results = '".$this->dbCharset."', character_set_client = '".$this->dbCharset."', character_set_connection = '".$this->dbCharset."', character_set_database = '".$this->dbCharset."', character_set_server = '".$this->dbCharset."'");
   }
 
   public function query($queryString) {
+    global $conf;
+	if($this->isConnected == false) return false;
     $try = 0;
     do {
         $try++;
-        $ok = parent::ping();
+        $ok = $this->ping();
         if(!$ok) {
-            if(!parent::real_connect($this->dbHost, $this->dbUser, $this->dbPass,$this->dbName)) {
-                if($try > 9) {
+            if(!$this->real_connect($this->dbHost, $this->dbUser, $this->dbPass, $this->dbName)) {
+                if($try > 4) {
                     $this->updateError('DB::query -> reconnect');
                     return false;
                 } else {
@@ -120,7 +145,7 @@
     } while($ok == false);
 	$this->queryId = parent::query($queryString);
     $this->updateError('DB::query('.$queryString.') -> mysqli_query');
-    if($this->errorNumber) debug_print_backtrace();
+    if($this->errorNumber && $conf['demo_mode'] === false) debug_print_backtrace();
     if(!$this->queryId) {
       return false;
     }
@@ -165,11 +190,11 @@
 
   // returns number of rows returned by the last select query
   public function numRows() {
-    return $this->queryId->num_rows;
+    return intval($this->queryId->num_rows);
   }
   
   public function affectedRows() {
-	return $this->queryId->affected_rows;
+	return intval($this->queryId->affected_rows);
   }
 
   // returns mySQL insert id
@@ -479,7 +504,7 @@
 
     // gibt Array mit Tabellennamen zur�ck
     public function getTables($database_name = '') {
-
+      if($this->isConnected == false) return false;
       if($database_name == '') $database_name = $this->dbName;
       $result = parent::query("SHOW TABLES FROM $database_name");
       for ($i = 0; $i < $result->num_rows; $i++) {

--
Gitblit v1.9.1