Ticket #913: getAttribute.patch

db/jDbConnection.class.php

@@ -30 +30 @@
     const ATTR_CURSOR = 10;
     const CURSOR_FWDONLY = 0;
     const CURSOR_SCROLL = 1;
-
+    const ATTR_CLIENT_VERSION = null;
+    const ATTR_SERVER_INFO = null;
+    const ATTR_SERVER_VERSION = null;
+    
     /**
     * profile properties used by the connector
     * @var array
@@ -229 +232 @@
     abstract public function lastInsertId($fromSequence='');
 
     /**
-     * Not implemented
+     * return the value of the Attribute of the current Connection
      * @param integer $id the attribut id
      * @return string the attribute value
      */
-    public function getAttribute($id){ return '';}
+    abstract public function getAttribute($id);
 
     /**
-     * Not implemented
+     * set the value of the Attribute of the current Connection
      * @param integer $id the attribut id
      * @param string $value the attribute value
      */
-    public function setAttribute($id, $value){ }
+    public function setAttribute($id, $value) {        
+        define ("$id", $value);
+    }
 
     /**
      *

plugins/db/mysql/mysql.dbconnection.php

@@ -32 +32 @@
             throw new jException('jelix~db.error.nofunction','mysql');
         }
         parent::__construct($profile);
+        $this->_setAttributes();
     }
 
     /**
@@ -90 +91 @@
               && isset($this->_charsets[$GLOBALS['gJConfig']->charset])){
                 mysql_query("SET NAMES '".$this->_charsets[$GLOBALS['gJConfig']->charset]."'", $cnx);
             }
+            
+            
             return $cnx;
         }else{
             throw new jException('jelix~db.error.connection',$this->profile['host']);
@@ -156 +159 @@
         return mysql_real_escape_string($text,  $this->_connection );
     }
 
+    /**
+     * return the value of the given Attribute
+     * @param the Attribute to get
+     * @return string the value of the Attribute
+     */
+    public function getAttribute($id) {
+        return constant("ATTR_$id");
+    }
+    
+    protected function _setAttributes() {
+        $this->setAttribute("ATTR_CLIENT_VERSION",mysql_get_client_info());
+        $this->setAttribute("ATTR_SERVER_INFO",mysql_get_host_info($this->_connect()));
+        $this->setAttribute("ATTR_SERVER_VERSION",mysql_get_server_info($this->_connect()));
+    }
 }
 

plugins/db/pgsql/pgsql.dbconnection.php

@@ -39 +39 @@
                 {
                         $this->setAutoCommit(true);
         }
+        $this->_setAttributes();
     }
 
     /**
@@ -191 +192 @@
     protected function _quote($text){
         return pg_escape_string($text);
     }
+    
+
+    /**
+     * return the value of the given Attribute
+     * @param the Attribute to get
+     * @return string the value of the Attribute
+     */
+    public function getAttribute($id) {
+        return constant("ATTR_$id");
+    }
+    
+    protected function _setAttributes() {
+        $v = pg_version($this->_connect());
+        $this->setAttribute("ATTR_CLIENT_VERSION",array_key_exists('client') ? $v['client'] : null);
+        $this->setAttribute("ATTR_SERVER_INFO",null);
+        $this->setAttribute("ATTR_SERVER_VERSION", pg_parameter_status($this->_connect(),'server_info'));
+    }
+    
 }
 

plugins/db/sqlite/sqlite.dbconnection.php

@@ -21 +21 @@
             throw new jException('jelix~db.error.nofunction','sqlite');
         }
         parent::__construct($profile);
+        $this->_setAttributes();
     }
 
     /**
@@ -115 +116 @@
         return sqlite_escape_string($text);
     }
 
+
+    /**
+     * return the value of the given Attribute
+     * @param the Attribute to get
+     * @return string the value of the Attribute
+     */
+    public function getAttribute($id) {
+        return constant("ATTR_$id");
+    }
+    
+    protected function _setAttributes() {
+        $this->setAttribute("ATTR_CLIENT_VERSION",sqlite_libversion();
+        $this->setAttribute("ATTR_SERVER_INFO",null);
+        $this->setAttribute("ATTR_SERVER_VERSION", null);
+    }
+    
 }