Update class.MySQL.php

Set attributes to private
Added commit and rollback methods;
Added charset management (experimental);
Removed useless setting.
Forces commit before closing.

Author: cfilippe

class.MySQL.php

@@ -23,34 +23,34 @@
 class MySQL {
 
 	// Base variables
-    var $lastError;         // Holds the last error
-	var $lastQuery;         // Holds the last query
-	var $result;            // Holds the MySQL query result
-	var $records;           // Holds the total number of records returned
-	var $affected;          // Holds the total number of records affected
-	var $rawResults;        // Holds raw 'arrayed' results
-	var $arrayedResult;     // Holds an array of the result
+    	private $lastError;         // Holds the last error
+	private $lastQuery;         // Holds the last query
+	private $result;            // Holds the MySQL query result
+	private $records;           // Holds the total number of records returned
+	private $affected;          // Holds the total number of records affected
+	private $rawResults;        // Holds raw 'arrayed' results
+	private $arrayedResult;     // Holds an array of the result
 
-	var $hostname;          // MySQL Hostname
-	var $username;          // MySQL Username
-	var $password;          // MySQL Password
-	var $database;          // MySQL Database
+	private $hostname;          // MySQL Hostname
+	private $username;          // MySQL Username
+	private $password;          // MySQL Password
+	private $database;          // MySQL Database
 
-	var $databaseLink;      // Database Connection Link
+	private $databaseLink;      // Database Connection Link
 
 
 
 	/* *******************
 	 * Class Constructor *
 	 * *******************/
 
-	function __construct($database, $username, $password, $hostname='localhost', $port=3306){
+	function __construct($database, $username, $password, $hostname='localhost', $port=3306, $persistant = false){
 		$this->database = $database;
 		$this->username = $username;
 		$this->password = $password;
 		$this->hostname = $hostname.':'.$port;
 
-		$this->Connect();
+		$this->Connect($persistant);
 	}
 
 	/* *******************
@@ -85,6 +85,8 @@ private function Connect($persistant = false){
 			$this->lastError = 'Could not connect to database: ' . mysql_error($this->databaseLink);
 			return false;
 		}
+		
+		$this->setCharset(); // TODO: remove forced charset find out a specific management
 		return true;
 	}
 
@@ -124,7 +126,8 @@ private function SecureData($data, $types){
     private function CleanData($data, $type = ''){
         switch($type) {
             case 'none':
-                $data = $data;
+				// useless do not reaffect just do nothing
+                //$data = $data;
                 break;
             case 'str':
                 $data = settype( $data, 'string');
@@ -197,7 +200,18 @@ public function executeSQL($query){
         }
     }
 
+	public function commit(){
+		return mysql_query("COMMIT", $this->databaseLink);
+	}
+  
+	public function rollback(){
+		return mysql_query("ROLLBACK", $this->databaseLink);
+	}
 
+	public function setCharset( $charset = 'UTF8' ) {
+		return mysql_set_charset ( $this->SecureData($charset,'string'), $this->databaseLink);
+	}
+	
     // Adds a record to the database based on the array key names
     public function insert($table, $vars, $exclude = '', $datatypes){
 
@@ -378,6 +392,8 @@ public function countRows($from, $where=''){
     // Closes the connections
     public function closeConnection(){
         if($this->databaseLink){
+			// Commit before closing just in case :)
+			$this->commit();
             mysql_close($this->databaseLink);
         }
     }