Merged Revisions 3771-3801 from stable branch.

tbrehm

2013-02-12 72695f0356210b5ca68d33d09e91c00ed9d6c2b6

 server/lib/classes/db_mysql.inc.php

@@ -1,4 +1,3 @@

<?php
/*
   Copyright (c) 2005, Till Brehm, projektfarm Gmbh
@@ -30,7 +29,7 @@

class db extends mysqli
{
  private $dbHost = '';      // hostname of the MySQL server
  protected $dbHost = '';      // hostname of the MySQL server
  private $dbName = '';      // logical database name on that server
  private $dbUser = '';      // database authorized user
  private $dbPass = '';      // user's password
@@ -42,40 +41,55 @@
  private $record   = array();   // last record fetched
  private $autoCommit = 1;    // Autocommit Transactions
  private $currentRow;      // current row number
  private $errorNumber = 0;   // last error number
  public $errorNumber = 0;   // last error number
  public $errorMessage = '';   // last error message
  private $errorLocation = '';// last error location
  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() {
    global $conf;
    $this->dbHost = $conf['db_host'];
    $this->dbName = $conf['db_database'];
    $this->dbUser = $conf['db_user'];
    $this->dbPass = $conf['db_password'];
  public function __construct($host = NULL , $user = NULL, $pass = NULL, $database = NULL) {
    global $app, $conf;

    $this->dbHost = $host ? $host  : $conf['db_host'];
    $this->dbName = $database ? $database : $conf['db_database'];
    $this->dbUser = $user ? $user : $conf['db_user'];
    $this->dbPass = $pass ? $pass : $conf['db_password'];
    $this->dbCharset = $conf['db_charset'];
    $this->dbNewLink = $conf['db_new_link'];
    $this->dbClientFlags = $conf['db_client_flags'];
    parent::__construct($conf['db_host'], $conf['db_user'],$conf['db_password'],$conf['db_database']);
    if ($this->connect_error) {
      $this->updateError('DB::__construct');
      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."'");

    parent::__construct($this->dbHost, $this->dbUser, $this->dbPass,$this->dbName);
    $try = 0;
    while(!is_null($this->connect_error) && $try < 10) {
      if($try > 8) sleep(5);
      elseif($try > 0) sleep(1);
      
      $try++;
      $this->updateError('DB::__construct');
      
      parent::__construct($this->dbHost, $this->dbUser, $this->dbPass,$this->dbName);
    }
    
    if(is_null($this->connect_error)) $this->isConnected = true;
    
    $this->setCharacterEncoding();
  }

  public function __destruct() {
    $this->close(); // helps avoid memory leaks, and persitent connections that don't go away.
  }

  /* This allows our private variables to be "read" out side of the class */
   public function __get($var) {
      return isset($this->$var) ? $this->$var : NULL;
   }

  // error handler
  public function updateError($location) {
    global $app;

    if($this->connect_error) {
    if(!is_null($this->connect_error)) {
      $this->errorNumber = $this->connect_errno;
      $this->errorMessage = $this->connect_error;
    } else {
@@ -89,14 +103,42 @@
      // This right here will allow us to use the samefile for server & interface
      if($this->show_error_messages) {
   echo $error_msg;
      } else if(method_exists($app, 'log')) {
      } else if(is_object($app) && method_exists($app, 'log')) {
   $app->log($error_msg, LOGLEVEL_WARN);
      } else {
         /* This could be called before $app is ever declared..  In that case we should just spit out to error_log() */
      error_log($error_msg);
      }
    }
  }
  
  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) {
    $this->queryId = parent::query($queryString);
    if($this->isConnected == false) return false;
    $try = 0;
    do {
        $try++;
        $ok = $this->ping();
        if(!$ok) {
            if(!$this->real_connect($this->dbHost, $this->dbUser, $this->dbPass, $this->dbName)) {
                if($try > 9) {
                    $this->updateError('DB::query -> reconnect');
                    return false;
                } else {
                    sleep(($try > 7 ? 5 : 1));
                }
            } else {
                $this->setCharacterEncoding();
                $ok = true;
            }
        }
    } while($ok == false);
   $this->queryId = parent::query($queryString);
    $this->updateError('DB::query('.$queryString.') -> mysqli_query');
    if(!$this->queryId) {
      return false;
@@ -144,6 +186,10 @@
  public function numRows() {
    return $this->queryId->num_rows;
  }
  
  public function affectedRows() {
   return $this->queryId->affected_rows;
  }

  // returns mySQL insert id
  public function insertID() {
@@ -173,44 +219,6 @@
    return $out;
  }

  /*
  //* These functions are deprecated and will be removed.
  function insert($tablename,$form,$debug = 0)
  {
  if(is_array($form)){
  foreach($form as $key => $value) 
  {
  $sql_key .= "$key, ";
  $sql_value .= "'".$this->check($value)."', ";
  }
  $sql_key = substr($sql_key,0,strlen($sql_key) - 2);
  $sql_value = substr($sql_value,0,strlen($sql_value) - 2);

  $sql = "INSERT INTO $tablename (" . $sql_key . ") VALUES (" . $sql_value .")";

  if($debug == 1) echo "SQL-Statement: ".$sql."<br><br>";
  $this->query($sql);
  if($debug == 1) echo "mySQL Error Message: ".$this->errorMessage;
  }
  }

  function update($tablename,$form,$bedingung,$debug = 0)
  {

  if(is_array($form)){
  foreach($form as $key => $value) 
  {
  $insql .= "$key = '".$this->check($value)."', ";
  }
  $insql = substr($insql,0,strlen($insql) - 2);
  $sql = "UPDATE $tablename SET " . $insql . " WHERE $bedingung";
  if($debug == 1) echo "SQL-Statement: ".$sql."<br><br>";
  $this->query($sql);
  if($debug == 1) echo "mySQL Error Message: ".$this->errorMessage;
  }
  }
   */

  public function diffrec($record_old, $record_new) {
    $diffrec_full = array();
    $diff_num = 0;
@@ -218,10 +226,10 @@
    if(is_array($record_old) && count($record_old) > 0) {
      foreach($record_old as $key => $val) {
   // if(!isset($record_new[$key]) || $record_new[$key] != $val) {
   if($record_new[$key] != $val) {
   if(@$record_new[$key] != $val) {
     // Record has changed
     $diffrec_full['old'][$key] = $val;
     $diffrec_full['new'][$key] = $record_new[$key];
     $diffrec_full['new'][$key] = @$record_new[$key];
     $diff_num++;
   } else {
     $diffrec_full['old'][$key] = $val;
@@ -247,7 +255,7 @@
    }

    //** Function to fill the datalog with a full differential record.
    public function datalogSave($db_table, $action, $primary_field, $primary_id, $record_old, $record_new) {
    public function datalogSave($db_table, $action, $primary_field, $primary_id, $record_old, $record_new, $force_update = false) {
      global $app,$conf;

      // Insert backticks only for incomplete table names.
@@ -257,29 +265,38 @@
   $escape = '`';
      }

      $tmp = $this->diffrec($record_old, $record_new);
      $diffrec_full = $tmp['diff_rec'];
      $diff_num = $tmp['diff_num'];
      unset($tmp);
      if($force_update == true) {
         //* We force a update even if no record has changed
         $diffrec_full = array('new' => $record_new,'old' => $record_old);
         $diff_num = count($record_new);
      } else {
         //* get the difference record between old and new record
         $tmp = $this->diffrec($record_old, $record_new);
         $diffrec_full = $tmp['diff_rec'];
         $diff_num = $tmp['diff_num'];
         unset($tmp);
      }

      // Insert the server_id, if the record has a server_id
      $server_id = (isset($record_old['server_id']) && $record_old['server_id'] > 0)?$record_old['server_id']:0;
      if(isset($record_new['server_id'])) $server_id = $record_new['server_id'];


      if($diff_num > 0) {
   //print_r($diff_num);
   //print_r($diffrec_full);
   $diffstr = $app->db->quote(serialize($diffrec_full));
   $username = $app->db->quote($_SESSION['s']['user']['username']);
   $dbidx = $primary_field.':'.$primary_id;
   if($diff_num > 0) {
      $diffstr = $this->quote(serialize($diffrec_full));
      if(isset($_SESSION)) {
         $username = $this->quote($_SESSION['s']['user']['username']);
      } else {
         $username = 'admin';
      }
      $dbidx = $primary_field.':'.$primary_id;

   if($action == 'INSERT') $action = 'i';
   if($action == 'UPDATE') $action = 'u';
   if($action == 'DELETE') $action = 'd';
   $sql = "INSERT INTO sys_datalog (dbtable,dbidx,server_id,action,tstamp,user,data) VALUES ('".$db_table."','$dbidx','$server_id','$action','".time()."','$username','$diffstr')";
   $app->db->query($sql);
      }
      if($action == 'INSERT') $action = 'i';
      if($action == 'UPDATE') $action = 'u';
      if($action == 'DELETE') $action = 'd';
      $sql = "INSERT INTO sys_datalog (dbtable,dbidx,server_id,action,tstamp,user,data) VALUES ('".$db_table."','$dbidx','$server_id','$action','".time()."','$username','$diffstr')";
      $this->query($sql);
   }

      return true;
    }
@@ -287,9 +304,23 @@
    //** Inserts a record and saves the changes into the datalog
    public function datalogInsert($tablename, $insert_data, $index_field) {
      global $app;
	  
     if(is_array($insert_data)) {
         $key_str = '';
         $val_str = '';
         foreach($insert_data as $key => $val) {
            $key_str .= "`".$key ."`,";
            $val_str .= "'".$this->quote($val)."',";
         }
         $key_str = substr($key_str,0,-1);
         $val_str = substr($val_str,0,-1);
         $insert_data_str = '('.$key_str.') VALUES ('.$val_str.')';
      } else {
         $insert_data_str = $insert_data;
      }

      $old_rec = array();
      $this->query("INSERT INTO $tablename $insert_data");
      $this->query("INSERT INTO $tablename $insert_data_str");
      $index_value = $this->insertID();
      $new_rec = $this->queryOneRecord("SELECT * FROM $tablename WHERE $index_field = '$index_value'");
      $this->datalogSave($tablename, 'INSERT', $index_field, $index_value, $old_rec, $new_rec);
@@ -298,13 +329,24 @@
    }

    //** Updates a record and saves the changes into the datalog
    public function datalogUpdate($tablename, $update_data, $index_field, $index_value) {
      global $app;

      $old_rec = $this->queryOneRecord("SELECT * FROM $tablename WHERE $index_field = '$index_value'");
      $this->query("UPDATE $tablename SET $update_data WHERE $index_field = '$index_value'");
    public function datalogUpdate($tablename, $update_data, $index_field, $index_value, $force_update = false) {
      global $app;
      
     $old_rec = $this->queryOneRecord("SELECT * FROM $tablename WHERE $index_field = '$index_value'");
	  
     if(is_array($update_data)) {
         $update_data_str = '';
         foreach($update_data as $key => $val) {
            $update_data_str .= "`".$key ."` = '".$this->quote($val)."',";
         }
         $update_data_str = substr($update_data_str,0,-1);
      } else {
         $update_data_str = $update_data;
      }
		
      $this->query("UPDATE $tablename SET $update_data_str WHERE $index_field = '$index_value'");
      $new_rec = $this->queryOneRecord("SELECT * FROM $tablename WHERE $index_field = '$index_value'");
      $this->datalogSave($tablename, 'UPDATE', $index_field, $index_value, $old_rec, $new_rec);
      $this->datalogSave($tablename, 'UPDATE', $index_field, $index_value, $old_rec, $new_rec, $force_update);

      return true;
    }
@@ -438,7 +480,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++) {
@@ -583,4 +625,4 @@

         }

         ?>
         ?>