git.dj3c1t.com Git - mtweb/blob - mw/app/data/impl/mw_mysql.php

   1 <?php
   2
   3   class mw_mysql{
   4
   5     var $link;
   6
   7     var $host;
   8     var $base;
   9     var $user;
  10     var $password;
  11
  12     var $EXTENTION_OK;
  13
  14     function extention_ok(&$env) { return $this->EXTENTION_OK; }
  15
  16     function authentication_required() { return true; }
  17
  18     function sgbd_name() { return "MySql"; }
  19
  20     function mw_mysql($params = array()){
  21       $this->host = isset($params["host"]) ? $params["host"] : "localhost";
  22       $this->base = isset($params["base"]) ? $params["base"] : "mtweb";
  23       $this->user = isset($params["user"]) ? $params["user"] : "";
  24       $this->password = isset($params["password"]) ? $params["password"] : "";
  25       $this->EXTENTION_OK = function_exists("mysql_connect");
  26     }
  27
  28     function connect($host, $base, $user, $password){
  29       $this->link = @mysql_connect($host, $user, $password);
  30       if(!$this->link) throw new Exception($this->exception_out("Impossible d'etablir une connection au serveur"));
  31       @mysql_query("SET NAMES 'utf8'");
  32       if($base){
  33         $connected = @mysql_select_db($base, $this->link);
  34         if(!$connected) throw new Exception($this->exception_out("Impossible de selectioner la base ".$base));
  35       }
  36       return true;
  37     }
  38
  39     function select_db($db_name){\r
  40       $this->base = $db_name;\r
  41       if(!$this->link) $this->connect($this->host, $this->base, $this->user, $this->password);\r
  42       return $this->query("USE ".$db_name);\r
  43     }
  44
  45     function desc_table($table_name){
  46       $sql = "SELECT * from information_schema.columns where table_name='".$table_name."'";
  47       $rst = $this->query($sql);
  48       $desc = array(
  49         "name" => $table_name,
  50         "attributs" => array()
  51       );
  52       try{
  53         while($v_rst = $this->fetch_assoc($rst)){\r
  54           $desc["attributs"][$v_rst["COLUMN_NAME"]] = array(
  55             "name" => $v_rst["COLUMN_NAME"],
  56             "prymary_key" => $v_rst["COLUMN_KEY"] == "PRI" ? true : false,
  57             "auto_increment" => $v_rst["EXTRA"] == "auto_increment" ? true : false
  58           );
  59         }\r
  60         $this->free_result($rst);
  61       }
  62       catch(Exception $e){
  63         throw new Exception($this->exception_out("Impossible de lire la description de la table"));
  64       }
  65       return $desc;
  66     }
  67
  68     function table_exists($table_name){\r
  69       if(!$this->link) $this->connect($this->host, $this->base, $this->user, $this->password);\r
  70       $EXISTS = false;
  71       try{
  72         $rst = $this->query("SHOW TABLES");
  73         while($v_rst = mysql_fetch_row($rst)){\r
  74           if($v_rst[0] == $table_name){
  75             $EXISTS = true;
  76             break;
  77           }\r
  78         }\r
  79         $this->free_result($rst);
  80       }
  81       catch(Exception $e){
  82         throw new Exception($this->exception_out("Impossible de savoir si la table existe"));
  83       }
  84       return $EXISTS;
  85     }
  86
  87     function field_exists($table_name, $field_name){
  88       if(!$this->link) $this->connect($this->host, $this->base, $this->user, $this->password);\r
  89       if(!($desc = $this->desc_table($table_name))){
  90         throw new Exception($this->exception_out("Impossible de lire la description de la table"));
  91       }
  92       $EXISTS = false;
  93       foreach($desc["attributs"] as $attribut_name => $attribut){
  94         if($field_name == $attribut_name){
  95           $EXISTS = true;
  96           break;
  97         }
  98       }
  99       return $EXISTS;
 100     }
 101
 102     function query($query_string){\r
 103       if(!$this->link) $this->connect($this->host, $this->base, $this->user, $this->password);\r
 104       $result = @mysql_query($query_string, $this->link);\r
 105       if(!$result) throw new Exception($this->exception_out("Syntaxe invalide dans une requete"));\r
 106       return $result;\r
 107     }
 108
 109     function fetch_assoc($rst){
 110       if($this->link){
 111         if($rst){
 112           return mysql_fetch_assoc($rst);
 113         }
 114         else throw new Exception($this->exception_out("fetch_assoc sans result handler"));
 115       }
 116       else throw new Exception($this->exception_out("fetch_assoc sans connexion"));
 117     }
 118
 119     function insert_id(){
 120       if($this->link){
 121         return mysql_insert_id($this->link);
 122       }
 123       else throw new Exception($this->exception_out("insert_id sans connexion"));
 124     }
 125
 126     function free_result($rst){
 127       if($this->link){
 128         if($rst){
 129           return mysql_free_result($rst);
 130         }
 131         else throw new Exception($this->exception_out("free_result sans result handler"));
 132       }
 133       else throw new Exception($this->exception_out("free_result sans connexion"));
 134     }
 135
 136     function close(){
 137       if($this->link) return mysql_close($this->link);
 138       return true;
 139     }
 140
 141     function exception_out($message){\r
 142       return "[erreur] mysql : ".$message;\r
 143     }
 144
 145   }
 146
 147 ?>