Added: FS#1691 - Add support for mysql flags like MYSQL_CLIENT_SSL in ISPCo...

tbrehm

2011-09-12 c84a6d596f48e03a9b258027cc2d7eea0049d12a

 server/lib/classes/db_mysql.inc.php

@@ -29,44 +29,52 @@

   class db
   {
      var $dbHost = "";      // hostname of the MySQL server
      var $dbName = "";      // logical database name on that server
      var $dbUser = "";      // database authorized user
      var $dbPass = "";      // user's password
      var $dbHost = '';      // hostname of the MySQL server
      var $dbName = '';      // logical database name on that server
      var $dbUser = '';      // database authorized user
      var $dbPass = '';      // user's password
      var $dbCharset = 'utf8';// Database charset
      var $dbNewLink = false; // Return a new linkID when connect is called again
      var $dbClientFlags = 0; // MySQL Client falgs
      var $linkId = 0;      // last result of mysql_connect()
      var $queryId = 0;      // last result of mysql_query()
      var $record   = array();   // last record fetched
        var $autoCommit = 1;    // Autocommit Transactions
      var $autoCommit = 1;    // Autocommit Transactions
      var $currentRow;      // current row number
      var $errorNumber = 0;   // last error number
      var $errorMessage = "";   // last error message
      var $errorLocation = "";// last error location
      var $errorMessage = '';   // last error message
      var $errorLocation = '';// last error location
      var $show_error_messages = true;

      // constructor
      function db()
      {
      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"];
         $this->dbHost = $conf['db_host'];
         $this->dbName = $conf['db_database'];
         $this->dbUser = $conf['db_user'];
         $this->dbPass = $conf['db_password'];
         $this->dbCharset = $conf['db_charset'];
         $this->dbNewLink = $conf['db_new_link'];
         $this->dbClientFlags = $conf['db_client_flags'];
         //$this->connect();
      }
		
      public function __destruct() {
         $this->closeConn();
      }

      // error handler
      function updateError($location)
      {
         global $app;
         $this->errorNumber = mysql_errno($this->linkId);
         $this->errorMessage = mysql_error($this->linkId);
         $this->errorNumber = @mysql_errno($this->linkId);
         $this->errorMessage = @mysql_error($this->linkId);
         $this->errorLocation = $location;
         if($this->errorNumber && $this->show_error_messages && method_exists($app,'log'))
         {
            // echo('<br /><b>'.$this->errorLocation.'</b><br />'.$this->errorMessage);
            $app->log($this->errorLocation." ".$this->errorMessage,LOGLEVEL_WARN);
            $app->log($this->errorLocation.' '.$this->errorMessage,LOGLEVEL_WARN);
            //flush();
         }
      }
@@ -75,7 +83,7 @@
      {
         if($this->linkId == 0)
         {
            $this->linkId = mysql_connect($this->dbHost, $this->dbUser, $this->dbPass);
            $this->linkId = @mysql_connect($this->dbHost, $this->dbUser, $this->dbPass, $this->dbNewLink, $this->dbClientFlags);
            if(!$this->linkId)
            {
               $this->updateError('DB::connect()-> mysql_connect');
@@ -282,16 +290,16 @@
      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"];
      $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;
         $username = $app->db->quote($_SESSION['s']['user']['username']);
         $dbidx = $primary_field.':'.$primary_id;
                  
         if($action == 'INSERT') $action = 'i';
         if($action == 'UPDATE') $action = 'u';
@@ -339,7 +347,8 @@
      
      return true;
   }
       

 
       public function closeConn()
       {
          if($this->linkId)
@@ -383,31 +392,30 @@
       */
       
       function createTable($table_name,$columns) {
       $index = "";
       $index = '';
       $sql = "CREATE TABLE $table_name (";
       foreach($columns as $col){
            $sql .= $col["name"]." ".$this->mapType($col["type"],$col["typeValue"])." ";
            $sql .= $col['name'].' '.$this->mapType($col['type'],$col['typeValue']).' ';
       
            if($col["defaultValue"] != "") $sql .= "DEFAULT '".$col["defaultValue"]."' ";
            if($col["notNull"] == true) {
                $sql .= "NOT NULL ";
            if($col['defaultValue'] != '') $sql .= "DEFAULT '".$col['defaultValue']."' ";
            if($col['notNull'] == true) {
                $sql .= 'NOT NULL ';
            } else {
                $sql .= "NULL ";
                $sql .= 'NULL ';
            }
            if($col["autoInc"] == true) $sql .= "auto_increment ";
            $sql.= ",";
            if($col['autoInc'] == true) $sql .= 'auto_increment ';
            $sql.= ',';
            // key Definitionen
            if($col["option"] == "primary") $index .= "PRIMARY KEY (".$col["name"]."),";
            if($col["option"] == "index") $index .= "INDEX (".$col["name"]."),";
            if($col["option"] == "unique") $index .= "UNIQUE (".$col["name"]."),";
            if($col['option'] == 'primary') $index .= 'PRIMARY KEY ('.$col['name'].'),';
            if($col['option'] == 'index') $index .= 'INDEX ('.$col['name'].'),';
            if($col['option'] == 'unique') $index .= 'UNIQUE ('.$col['name'].'),';
       }
       $sql .= $index;
       $sql = substr($sql,0,-1);
       $sql .= ")";
       
       $sql .= ')';
       $this->query($sql);
       return true;
       }
    }
       
       /*
       $columns = array(action =>   add | alter | drop
@@ -423,29 +431,29 @@
       
       */
       function alterTable($table_name,$columns) {
       $index = "";
       $index = '';
       $sql = "ALTER TABLE $table_name ";
       foreach($columns as $col){
            if($col["action"] == 'add') {
                $sql .= "ADD ".$col["name"]." ".$this->mapType($col["type"],$col["typeValue"])." ";
            } elseif ($col["action"] == 'alter') {
                $sql .= "CHANGE ".$col["name"]." ".$col["name_new"]." ".$this->mapType($col["type"],$col["typeValue"])." ";
            } elseif ($col["action"] == 'drop') {
                $sql .= "DROP ".$col["name"]." ";
            if($col['action'] == 'add') {
                $sql .= 'ADD '.$col['name'].' '.$this->mapType($col['type'],$col['typeValue']).' ';
            } elseif ($col['action'] == 'alter') {
                $sql .= 'CHANGE '.$col['name'].' '.$col['name_new'].' '.$this->mapType($col['type'],$col['typeValue']).' ';
            } elseif ($col['action'] == 'drop') {
                $sql .= 'DROP '.$col['name'].' ';
            }
            if($col["action"] != 'drop') {  
            if($col["defaultValue"] != "") $sql .= "DEFAULT '".$col["defaultValue"]."' ";
            if($col["notNull"] == true) {
                $sql .= "NOT NULL ";
            if($col['action'] != 'drop') {  
            if($col['defaultValue'] != '') $sql .= "DEFAULT '".$col['defaultValue']."' ";
            if($col['notNull'] == true) {
                $sql .= 'NOT NULL ';
            } else {
                $sql .= "NULL ";
                $sql .= 'NULL ';
            }
            if($col["autoInc"] == true) $sql .= "auto_increment ";
            $sql.= ",";
            // key Definitionen
            if($col["option"] == "primary") $index .= "PRIMARY KEY (".$col["name"]."),";
            if($col["option"] == "index") $index .= "INDEX (".$col["name"]."),";
            if($col["option"] == "unique") $index .= "UNIQUE (".$col["name"]."),";
            if($col['autoInc'] == true) $sql .= 'auto_increment ';
            $sql.= ',';
            // Index definitions
            if($col['option'] == 'primary') $index .= 'PRIMARY KEY ('.$col['name'].'),';
            if($col['option'] == 'index') $index .= 'INDEX ('.$col['name'].'),';
            if($col['option'] == 'unique') $index .= 'UNIQUE ('.$col['name'].'),';
            }
       }
       $sql .= $index;
@@ -462,7 +470,7 @@
       return $this->query($sql);
       }
       
       // gibt Array mit Tabellennamen zurück
       // gibt Array mit Tabellennamen zur�ck
       function getTables($database_name = '') {
         
         if($database_name == '') $database_name = $this->dbName;
@@ -473,7 +481,7 @@
            return $tb_names;       
       }
       
       // gibt Feldinformationen zur Tabelle zurück
       // gibt Feldinformationen zur Tabelle zur�ck
       /*
       $columns = array(action =>   add | alter | drop
                        name =>     Spaltenname
@@ -493,7 +501,7 @@
       global $go_api,$go_info;
       // Tabellenfelder einlesen
        
        if($rows = $go_api->db->queryAllRecords("SHOW FIELDS FROM ".$table_name)){
        if($rows = $go_api->db->queryAllRecords('SHOW FIELDS FROM '.$table_name)){
        foreach($rows as $row) {
            $name = $row[0];
            $default = $row[4];
@@ -505,38 +513,38 @@
            
            $column = array();
        
            $column["name"] = $name;
            //$column["type"] = $type;
            $column["defaultValue"] = $default;
            if(stristr($key,"PRI")) $column["option"] = "primary";
            if(stristr($isnull,"YES")) {
                $column["notNull"] = false;
            $column['name'] = $name;
            //$column['type'] = $type;
            $column['defaultValue'] = $default;
            if(stristr($key,'PRI')) $column['option'] = 'primary';
            if(stristr($isnull,'YES')) {
                $column['notNull'] = false;
            } else {
               $column["notNull"] = true; 
               $column['notNull'] = true; 
            }
            if($extra == 'auto_increment') $column["autoInc"] = true;
            if($extra == 'auto_increment') $column['autoInc'] = true;
            
            
            // Type in Metatype umsetzen
            
            if(stristr($type,"int(")) $metaType = 'int32';
            if(stristr($type,"bigint")) $metaType = 'int64';
            if(stristr($type,"char")) {
            if(stristr($type,'int(')) $metaType = 'int32';
            if(stristr($type,'bigint')) $metaType = 'int64';
            if(stristr($type,'char')) {
                $metaType = 'char';
                $tmp_typeValue = explode('(',$type);
                $column["typeValue"] = substr($tmp_typeValue[1],0,-1);  
                $column['typeValue'] = substr($tmp_typeValue[1],0,-1);  
            }
            if(stristr($type,"varchar")) {
            if(stristr($type,'varchar')) {
                $metaType = 'varchar';
                $tmp_typeValue = explode('(',$type);
                $column["typeValue"] = substr($tmp_typeValue[1],0,-1);  
                $column['typeValue'] = substr($tmp_typeValue[1],0,-1);  
            }
            if(stristr($type,"text")) $metaType = 'text';
            if(stristr($type,"double")) $metaType = 'double';
            if(stristr($type,"blob")) $metaType = 'blob';
            if(stristr($type,'text')) $metaType = 'text';
            if(stristr($type,'double')) $metaType = 'double';
            if(stristr($type,'blob')) $metaType = 'blob';
            
            
            $column["type"] = $metaType;
            $column['type'] = $metaType;
            
        $columns[] = $column;
        }
@@ -595,7 +603,7 @@
            return 'char';
       break;
       case 'varchar':
            if($typeValue < 1) die("Datenbank Fehler: Für diesen Datentyp ist eine Längenangabe notwendig.");
            if($typeValue < 1) die('Database failure: Lenght required for these data types.');
            return 'varchar('.$typeValue.')';
       break;
       case 'text':
@@ -609,4 +617,4 @@
      
   }

?>
?>