Source for file mysql.dbconnection.php

Documentation is available at mysql.dbconnection.php

  1. <?php
  2. /**
  3. @package    jelix
  4. @subpackage db_driver
  5. @author     Gérald Croes, Laurent Jouanneau
  6. @contributor Laurent Jouanneau
  7. @contributor Sylvain de Vathaire, Julien Issler
  8. @copyright  2001-2005 CopixTeam, 2005-2010 Laurent Jouanneau
  9. @copyright  2009 Julien Issler
  10. *  This class was get originally from the Copix project (CopixDbConnectionMysql, Copix 2.3dev20050901, http://www.copix.org)
  11. *  Few lines of code are still copyrighted 2001-2005 CopixTeam (LGPL licence).
  12. *  Initial authors of this Copix class are Gerald Croes and Laurent Jouanneau,
  13. *  and this class was adapted for Jelix by Laurent Jouanneau
  14. *
  15. @link      http://www.jelix.org
  16. @licence  http://www.gnu.org/licenses/lgpl.html GNU Lesser General Public Licence, see LICENCE file
  17. */
  18.  
  19. /**
  20.  *
  21.  * @package    jelix
  22.  * @subpackage db_driver
  23.  */
  24. class mysqlDbConnection extends jDbConnection {
  25.  
  26.     protected $_charsets =array'UTF-8'=>'utf8''ISO-8859-1'=>'latin1');
  27.  
  28.     function __construct($profile){
  29.         // à cause du @, on est obligé de tester l'existence de mysql, sinon en cas d'absence
  30.         // on a droit à un arret sans erreur
  31.         if(!function_exists('mysql_connect')){
  32.             throw new jException('jelix~db.error.nofunction','mysql');
  33.         }
  34.         parent::__construct($profile);
  35.     }
  36.  
  37.     /**
  38.      * enclose the field name
  39.      * @param string $fieldName the field name
  40.      * @return string the enclosed field name
  41.      * @since 1.1.1
  42.      */
  43.     public function encloseName($fieldName){
  44.         return '`'.$fieldName.'`';
  45.     }
  46.  
  47.     /**
  48.     * begin a transaction
  49.     */
  50.     public function beginTransaction (){
  51.         $this->_doExec ('SET AUTOCOMMIT=0');
  52.         $this->_doExec ('BEGIN');
  53.     }
  54.  
  55.     /**
  56.     * Commit since the last begin
  57.     */
  58.     public function commit (){
  59.         $this->_doExec ('COMMIT');
  60.         $this->_doExec ('SET AUTOCOMMIT=1');
  61.     }
  62.  
  63.     /**
  64.     * Rollback since the last BEGIN
  65.     */
  66.     public function rollback (){
  67.         $this->_doExec ('ROLLBACK');
  68.         $this->_doExec ('SET AUTOCOMMIT=1');
  69.     }
  70.  
  71.     /**
  72.     *
  73.     */
  74.     public function prepare ($query){
  75.         throw new jException('jelix~db.error.feature.unsupported'array('mysql','prepare'));
  76.     }
  77.  
  78.     public function errorInfo(){
  79.         return array'HY000' ,mysql_errno($this->_connection)mysql_error($this->_connection));
  80.     }
  81.  
  82.     public function errorCode(){
  83.        return mysql_errno($this->_connection);
  84.     }
  85.  
  86.     protected function _connect (){
  87.         $funcconnect($this->profile['persistent']'mysql_pconnect':'mysql_connect');
  88.         if($cnx @$funcconnect ($this->profile['host']$this->profile['user']$this->profile['password'])){
  89.             if(isset($this->profile['force_encoding']&& $this->profile['force_encoding'== true
  90.               && isset($this->_charsets[$GLOBALS['gJConfig']->charset])){
  91.                 mysql_query("SET NAMES '".$this->_charsets[$GLOBALS['gJConfig']->charset]."'"$cnx);
  92.             }
  93.             return $cnx;
  94.         }else{
  95.             throw new jException('jelix~db.error.connection',$this->profile['host']);
  96.         }
  97.     }
  98.  
  99.     protected function _disconnect (){
  100.         return mysql_close ($this->_connection);
  101.     }
  102.  
  103.  
  104.     protected function _doQuery ($query){
  105.         // ici et non lors du connect, pour le cas où il y a plusieurs connexion active
  106.         if(!mysql_select_db ($this->profile['database']$this->_connection)){
  107.             if(mysql_errno($this->_connection))
  108.                 throw new jException('jelix~db.error.database.unknown',$this->profile['database']);
  109.             else
  110.                 throw new jException('jelix~db.error.connection.closed',$this->profile['name']);
  111.         }
  112.  
  113.         if ($qI mysql_query ($query$this->_connection)){
  114.             return new mysqlDbResultSet ($qI);
  115.         }else{
  116.             throw new jException('jelix~db.error.query.bad',  mysql_error($this->_connection).'('.$query.')');
  117.         }
  118.     }
  119.  
  120.     protected function _doExec($query){
  121.         if(!mysql_select_db ($this->profile['database']$this->_connection))
  122.             throw new jException('jelix~db.error.database.unknown',$this->profile['database']);
  123.  
  124.         if ($qI mysql_query ($query$this->_connection)){
  125.             return mysql_affected_rows($this->_connection);
  126.         }else{
  127.             throw new jException('jelix~db.error.query.bad',  mysql_error($this->_connection).'('.$query.')');
  128.         }
  129.     }
  130.  
  131.     protected function _doLimitQuery ($queryString$offset$number){
  132.         $queryString.= ' LIMIT '.$offset.','.$number;
  133.         $result $this->_doQuery($queryString);
  134.         return $result;
  135.     }
  136.  
  137.  
  138.     public function lastInsertId($fromSequence=''){// on n'a pas besoin de l'argument pour mysql
  139.         return mysql_insert_id ($this->_connection);
  140.     }
  141.  
  142.     /**
  143.     * tell mysql to be autocommit or not
  144.     * @param boolean $state the state of the autocommit value
  145.     * @return void 
  146.     */
  147.     protected function _autoCommitNotify ($state){
  148.         $this->query ('SET AUTOCOMMIT='.($state '1' '0'));
  149.     }
  150.  
  151.     /**
  152.      * @return string escaped text or binary string
  153.      */
  154.     protected function _quote($text$binary{
  155.         return mysql_real_escape_string($text$this->_connection);
  156.     }
  157.  
  158. }

Documentation generated on Thu, 19 Sep 2013 00:08:44 +0200 by phpDocumentor 1.4.3