class.ilDBMySQL.php

Go to the documentation of this file.

<?php

/* Copyright (c) 1998-2012 ILIAS open source, Extended GPL, see docs/LICENSE */

include_once ("./Services/Database/classes/class.ilDB.php");

class ilDBMySQL extends ilDB
{
        var $max_allowed_packet_size;

        function getDSN()
        {
                $db_port_str = "";
                if (trim($this->getdbPort()) != "")
                {
                        $db_port_str = ":".$this->getdbPort();
                }
                
                $driver = $this->isMySQLi() ? "mysqli" : "mysql";      
                
                return $driver."://".$this->getDBUser().":".$this->getDBPassword().
                        "@".$this->getdbHost().$db_port_str."/".$this->getDBName();
        }
        
        protected function isMySQLi()
        {
                return ($this->getSubType() == "mysqli");
        }

        function getHostDSN()
        {               
                $driver = $this->isMySQLi() ? "mysqli" : "mysql"; 
                
                return $driver."://".$this->getDBUser().":".$this->getDBPassword().
                        "@".$this->getdbHost();
        }

        function getDBType()
        {
                return "mysql";
        }
        
        static function getReservedWords()
        {
                // version: 5.1
                // url: http://dev.mysql.com/doc/refman/5.1/en/reserved-words.html
                return array(
                "ACCESSIBLE", "ADD", "ALL", "ALTER", "ANALYZE", "AND",
                "AS", "ASC", "ASENSITIVE", "BEFORE", "BETWEEN", "BIGINT",
                "BINARY", "BLOB", "BOTH", "BY", "CALL", "CASCADE",
                "CASE", "CHANGE", "CHAR", "CHARACTER", "CHECK", "COLLATE",
                "COLUMN", "CONDITION", "CONSTRAINT", "CONTINUE", "CONVERT", "CREATE",
                "CROSS", "CURRENT_DATE", "CURRENT_TIME", "CURRENT_TIMESTAMP", "CURRENT_USER", "CURSOR",
                "DATABASE", "DATABASES", "DAY_HOUR", "DAY_MICROSECOND", "DAY_MINUTE", "DAY_SECOND",
                "DEC", "DECIMAL", "DECLARE", "DEFAULT", "DELAYED", "DELETE",
                "DESC", "DESCRIBE", "DETERMINISTIC", "DISTINCT", "DISTINCTROW", "DIV",
                "DOUBLE", "DROP", "DUAL", "EACH", "ELSE", "ELSEIF",
                "ENCLOSED", "ESCAPED", "EXISTS", "EXIT", "EXPLAIN", "FALSE",
                "FETCH", "FLOAT", "FLOAT4", "FLOAT8", "FOR", "FORCE",
                "FOREIGN", "FROM", "FULLTEXT", "GRANT", "GROUP", "HAVING",
                "HIGH_PRIORITY", "HOUR_MICROSECOND", "HOUR_MINUTE", "HOUR_SECOND", "IF", "IGNORE",
                "IN", "INDEX", "INFILE", "INNER", "INOUT", "INSENSITIVE",
                "INSERT", "INT", "INT1", "INT2", "INT3", "INT4",
                "INT8", "INTEGER", "INTERVAL", "INTO", "IS", "ITERATE",
                "JOIN", "KEY", "KEYS", "KILL", "LEADING", "LEAVE",
                "LEFT", "LIKE", "LIMIT", "LINEAR", "LINES", "LOAD",
                "LOCALTIME", "LOCALTIMESTAMP", "LOCK", "LONG", "LONGBLOB", "LONGTEXT",
                "LOOP", "LOW_PRIORITY", "MASTER_SSL_VERIFY_SERVER_CERT", "MATCH", "MEDIUMBLOB", "MEDIUMINT",
                "MEDIUMTEXT", "MIDDLEINT", "MINUTE_MICROSECOND", "MINUTE_SECOND", "MOD", "MODIFIES",
                "NATURAL", "NOT", "NO_WRITE_TO_BINLOG", "NULL", "NUMERIC", "ON",
                "OPTIMIZE", "OPTION", "OPTIONALLY", "OR", "ORDER", "OUT",
                "OUTER", "OUTFILE", "PRECISION", "PRIMARY", "PROCEDURE", "PURGE",
                "RANGE", "READ", "READS", "READ_WRITE", "REAL", "REFERENCES",
                "REGEXP", "RELEASE", "RENAME", "REPEAT", "REPLACE", "REQUIRE",
                "RESTRICT", "RETURN", "REVOKE", "RIGHT", "RLIKE", "SCHEMA",
                "SCHEMAS", "SECOND_MICROSECOND", "SELECT", "SENSITIVE", "SEPARATOR", "SET",
                "SHOW", "SMALLINT", "SPATIAL", "SPECIFIC", "SQL", "SQLEXCEPTION",
                "SQLSTATE", "SQLWARNING", "SQL_BIG_RESULT", "SQL_CALC_FOUND_ROWS", "SQL_SMALL_RESULT", "SSL",
                "STARTING", "STRAIGHT_JOIN", "TABLE", "TERMINATED", "THEN", "TINYBLOB",
                "TINYINT", "TINYTEXT", "TO", "TRAILING", "TRIGGER", "TRUE",
                "UNDO", "UNION", "UNIQUE", "UNLOCK", "UNSIGNED", "UPDATE",
                "USAGE", "USE", "USING", "UTC_DATE", "UTC_TIME", "UTC_TIMESTAMP",
                "VALUES", "VARBINARY", "VARCHAR", "VARCHARACTER", "VARYING", "WHEN",
                "WHERE", "WHILE", "WITH", "WRITE", "XOR", "YEAR_MONTH",
                "ZEROFILL"
                );
        }
        
        function initConnection()
        {
                // SET 'max_allowed_packet' (only possible for mysql version 4)
                $this->setMaxAllowedPacket();
                
                // NOTE: Two sourcecodes use this or a similar handling:
                // - classes/class.ilDB.php
                // - setup/classes/class.ilClient.php

                $this->query("SET NAMES utf8");
                if (DEVMODE == 1)
                {
                        $this->query("SET SESSION SQL_MODE = 'ONLY_FULL_GROUP_BY'");
                }

                $this->query("SET SESSION STORAGE_ENGINE = 'MYISAM'");
        }

        function now()
        {
                return "now()";
        }

        function optimizeTable($a_table)
        {
                $this->query("OPTIMIZE TABLE ".$a_table);
        }

        function getDBVersion()
        {
                if(!$this->isMySQLi())
                {
                        $vers = @mysql_get_server_info();
                }
                else
                {
                    $vers = @mysqli_get_server_info($this->db->connection);
                }               
                if (trim($vers) == "")
                {
                        $vers = "Unknown";
                }
                return $vers;
        }
        

        function isMysql4_0OrHigher()
        {
                $version = explode(".", $this->getDBVersion());
                if((int) $version[0] < 4)
                {
                        return false;
                }
                return true;
        }

        function isMysql4_1()
        {
                $version = explode(".", $this->getDBVersion());
                if ($version[0] == "4" && $version[1] == "1")
                {
                        return true;
                }
                
                return false;
        }

        function isMysql4_1OrHigher()
        {
                $version = explode(".", $this->getDBVersion());
                if ((int)$version[0] >= 5 ||
                        ((int)$version[0] == 4 && (int)$version[1] >= 1))
                {
                        return true;
                }
                
                return false;
        }

        function checkQuerySize($a_query)
        {
                global $lang;

                if(strlen($a_query) >= $this->max_allowed_packet_size)
                {
                        return false;
                }
                else
                {
                        return true;
                }
        }

        protected function setMaxAllowedPacket()
        {
                $version = $this->getDBVersion();

                // CHANG VALUE IF MYSQL VERSION > 4.0
                // Switched back to "SET GLOBAL ..."
                // @see http://bugs.mysql.com/bug.php?id=22891
                // smeyer 2009 07 30
                if (substr($version,0,1) == "4")
                {
                        ini_get("post_max_size");
                        $query = "SET GLOBAL max_allowed_packet = ".(int) ini_get("post_max_size") * 1024 * 1024;
//echo "-".$query."-";
                        $this->query($query);
                }
                // STORE NEW max_size in member variable
                $query = "SHOW VARIABLES LIKE 'max_allowed_packet'";
                $res = $this->db->query($query);

                while($row = $res->fetchRow(DB_FETCHMODE_OBJECT))
                {
                        $this->max_allowed_packet_size = $row->value;
                }
//echo "-".$this->max_allowed_packet_size."-";
                return true;
        }

        function supportsFulltext()
        {
                return true;
        }

        function addFulltextIndex($a_table, $a_fields, $a_name = "in")
        {
                $i_name = $this->constraintName($a_table, $a_name)."_idx";
                $f_str = implode($a_fields, ",");
                $q = "ALTER TABLE $a_table ADD FULLTEXT $i_name ($f_str)";
                $this->query($q);
        }

        function dropFulltextIndex($a_table, $a_name)
        {
                $i_name = $this->constraintName($a_table, $a_name)."_idx";
                $this->query("ALTER TABLE $a_table DROP FULLTEXT $i_name");
        }

        function isFulltextIndex($a_table, $a_name)
        {
                $set = $this->query("SHOW INDEX FROM ".$a_table);
                while ($rec = $this->fetchAssoc($set))
                {
                        if ($rec["Key_name"] == $a_name && $rec["Index_type"] == "FULLTEXT")
                        {
                                return true;
                        }
                }
        }
        
        public function lockTables($a_tables)
        {
                global $ilLog;
                
                $lock = 'LOCK TABLES ';

                $counter = 0;
                foreach($a_tables as $table)
                {
                        if($counter++)
                        {
                                $lock .= ', ';
                        }
                        $lock .= ($table['name'].' ');
                        
                        if($table['alias'])
                        {
                                $lock .= ($table['alias'].' ');
                        }

                        switch($table['type'])
                        {
                                case ilDB::LOCK_READ:
                                        $lock .= ' READ ';
                                        break;
                                
                                case ilDB::LOCK_WRITE:
                                        $lock .= ' WRITE ';
                                        break;
                        }
                }
                $ilLog->write(__METHOD__.': '.$lock);
                $this->query($lock);
        }
        
        public function unlockTables()
        {
                $this->query('UNLOCK TABLES');
        }
        
        protected function getCreateTableOptions()
        {
                // InnoDB is default engine for MySQL >= 5.5
                return array('type' => 'MyISAM');
        }
        
        public function getErrorNo()
        {
                if(!$this->isMySQLi())
                {
                        return mysql_errno();
                }
                else
                {
                        return mysqli_errno($this->db->connection);
                }
        }
        
        public function getLastError()
        {
                if(!$this->isMySQLi())
                {
                        return mysql_error();
                }
                else
                {
                        return mysqli_error($this->db->connection);
                }
        }
}
?>