[Lambda-cvs] lambda/classes lambdaMySQLi.class.php,1.5,1.6

[Ariejan de V. <ar...@us...>]

Update of /cvsroot/lambda/lambda/classes
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv2323/classes

Modified Files:
	lambdaMySQLi.class.php 
Log Message:
Added basic MySQL functions for PHP4/MySQL


Index: lambdaMySQLi.class.php
===================================================================
RCS file: /cvsroot/lambda/lambda/classes/lambdaMySQLi.class.php,v
retrieving revision 1.5
retrieving revision 1.6
diff -C2 -d -r1.5 -r1.6
*** lambdaMySQLi.class.php	7 Jul 2004 10:13:16 -0000	1.5
--- lambdaMySQLi.class.php	7 Jul 2004 10:37:50 -0000	1.6
***************
*** 14,18 ****
--- 14,121 ----
   **/ 
  class lambdaMySQLi {
+     /**
+      * @var array Configuration settings
+      **/
+     var $config;
+     
+     /**
+      * @var object MySQL Database link
+      **/
+     var $link;
+     
+     /**
+      * @var object Local reference to error handler
+      **/
+     var $handler;
+     
+     /**
+      * @var int Number of performed queries
+      **/
+     var $query_count;
+     
+     /**
+      * @var array Query history
+      **/
+     var $query_history;
+     
+     /**
+      * Initialise the lambdaMySQLi class
+      **/
+     function lambdaMySQLi() {
+ 	global $handler, $config;
+ 	
+ 	// Create local reference
+ 	$this->handler = $handler;
+ 	
+ 	// Copy configuration settings
+ 	$this->config = $config['mysql'];
+ 	
+ 	// Set default zero-values
+ 	$this->link = null;
+ 	$this->query_count = 0;
+ 	$this->query_history = array();
+     }
      
+     /**
+      * Create a connection to the MySQL database
+      *
+      * @return bool true on successful connection, otherwise false
+      **/
+     function connect() {
+ 	// Build the right hostname to use a non-default socket or port
+ 	$host = $this->config['hostname'];
+ 	
+ 	if(!empty($this->config['port'])) {
+ 	    $host .= ":" . $this->config['port'];
+ 	}
+ 	elseif (!empty($this->config['socket'])) {
+ 	    $host .= ":" . $this->config['socket'];
+ 	}
+ 	
+ 	// Try to establish a connection
+ 	// Assume the connection is successful.
+ 	$mylink = @mysql_connect($host, $this->config['username'],
+ 	                                $this->config['password'], true);
+ 					
+ 	// Select the proper database and check for errors
+ 	if(!@mysql_select_db($this->config['dbname'], $mylink)) {
+ 	    $this->handler->error("Connection to MySQL failed", true);
+ 	    return false;
+ 	} else {
+ 	    $this->link = $mylink;
+ 	    return true;
+ 	}
+     }
+     
+     /**
+      * Perform a query
+      *
+      * Perform a query and return the result or false
+      *
+      * @param string valid SQL query
+      * @return object MySQL Result or boolean
+      **/
+     function query($sql) {
+ 	// Make sure we have a valid connection
+ 	if(!$this->link || !@$this->connect()) {
+ 	    return false;
+ 	}
+     
+ 	// Increase query count
+ 	$this->query_count++;
+ 	
+ 	// Add to query history
+ 	$this->query_history[] = $sql;
+     
+ 	// Perform the query and return the result
+ 	$result = @mysql_query($sql, $this->link);
+ 	
+ 	if(!$result) {
+ 	    $this->handler->warning("Error performing query");
+ 	    $this->handler->debug("Error performing query: $sql", 2);
+ 	}
+ 	
+ 	return $result;
+     }
  
  }
\ No newline at end of file