PHP Classes
elePHPant
Icontem

File: Plugins/database.php

Recommend this page to a friend!
Stumble It! Stumble It! Bookmark in del.icio.us Bookmark in del.icio.us
  Classes of Aziz S. Hussain  >  Aziz MVC  >  Plugins/database.php  >  Download  
File: Plugins/database.php
Role: Class source
Content type: text/plain
Description: Database Plugins
Class: Aziz MVC
Framework that uses MVC design pattern
Author: By
Last change: Fixed Minor Bugs
Date: 4 years ago
Size: 9,699 bytes
 

Contents

Class file image Download
<?php
/*
Written by Aziz S. Hussain
@
www.AzizSaleh.com
Produced under LGPL license
@
http://www.gnu.org/licenses/lgpl.html


# Class structure
class database ()
{
    protected databaseName, databaseHost, databaseUser, databasePassword
    protected connectionLink, mysqlError
    protected lastInsertID
   
    resource query(sql as string, arrayReplace as array)
                                    # Executes mysql_query and stores lastInsertID, if any
                                    # If arrayReplace is set, it will search sql for any question marks
                                    # and replace them with matching index of arrayReplace
                                   
    array result(query as (string|object),isObject as boolean = false)
                                    # Querys the (query string|query object) and returns array or object result
                                   
    (array|string) cleanInput(array as (array|string)
                                    # Executes mysql_real_escape_string on the (array|string)
                                    # (array|string) also is escaped for inserting/adding using the ''

    (number|string) escape(fieldValue as (number|string), isNumber as boolean = false)
                                    # Execute mysql_real_escape_string if isNumber is true
                                    # Runs preg_replace instead
                                   
    void showError(string theError) # Outputs MySQL Error along with an end of line
   
    string getPrimaryField(string tableName)
                                    # Returns the primary field name of the specified table
                                   
    resource delete(string tableName,(string|array) keyDelete,string keyField = NULL)
                                    # This function is overloaded in three ways as:
    resource delete(string tableName,string keyDelete)
                                    # Will delete record value keyDelete using primary field
    resource delete(string tableName,string keyDelete,string keyField)
                                    # Will delete record value keyDelete using keyField field
    resource delete(string tableName,array keyDelete)
                                    # Will delete record based on multiple fieldname with associated fieldvalues
                                   
    resource insert(string tableName,array ARRAY_VARS)
                                    # This function will insert or update values of tableName from an array
                                    # Like POST, GET, SESSION,...
                                    # The way this works, is that it retrieves a lits of fields for that table and checks
                                    # Them against the ARRAY_VARS. If the primary key exist in ARRAY_VARS, then it updates,
                                    # Otherwise it does an insert to the table
   
    string (mysql query) findMatches(string tableName,array ARRAY_VARS)
                                    # Find relationship between tablename and ARRAY_VARS, create MySQL statement
                                   
    array (resource,string tablename) createTable(array ARRAY_VARS, string tableName = NULL)
                                    # Create a database table based on ARRAY_VARS, if tableName is NULL a random string is
                                    # Generated to use for the table name
                                   
    void close() # Closes the database connection
   
    string generateRandom(integer strLen)
                                    # Generate a random string of strLen length
}
*/

// Check if class already called
if(class_exists('database')){ return;}
                            
class
database
{
   
# Variables needed to connect
   
protected $databaseName, $databaseHost, $databaseUser, $databasePassword;
   
# Connection link and error holder
   
protected $connectionLink, $mysqlError;
   
# Last insert ID (primary keys)
   
protected $lastInsertID;
   
# Holds the current ? replace
   
protected $curReplace, $arrayReplace;
   
   
# Construct database with information
   
function __construct(&$theLink)
    {
       
$this->connectionLink = $theLink;
    }
   
   
# Regular query with ? replace style
   
function query($sql,$arrayReplace = NULL)
    {
       
$this->curReplace = -1;
       
       
$arrayReplace = $this->cleanInput($arrayReplace);
       
$this->arrayReplace = $arrayReplace;
       
        if(isset(
$arrayReplace))
        {
            if(
is_array($arrayReplace))
            {
               
$arrayReplaces = array_fill(0,count($arrayReplace),'?');
               
$query = preg_replace_callback('/\?/Uism','database::doSwitch',$sql);
            } else {
               
$query = str_replace('?',$arrayReplace,$sql);
            }
        } else {
           
$query = $sql;
        }

       
$queryLink = @mysql_query($query,$this->connectionLink) or $this->showError(mysql_error($this->connectionLink));
        return
$queryLink;
    }
   
   
# This is a helper function to preg_replace all question marks
   
protected function doSwitch($result)
    {
       
$this->curReplace++;
        return
$this->arrayReplace[$this->curReplace];
    }
   
   
# Returns array or object result set assoc of an object or string query
   
function result($query,$isObject = false)
    {
        if(!
is_resource($query)){ $query = $this->query($query);}

       
$records = array();
        while(
$eachRecord = @mysql_fetch_assoc($query)){ $records[] = $eachRecord;}

        if(
$isObject == true)
        {
           
$records = (object) $records;
        }
        return
$records;
    }
   
   
# Sanitize an array & organize into mysql style ''
   
function cleanInput($array)
    {
        if(!isset(
$array)){ return;}
        if(!
is_array($array)){ return "'".$this->escape($array)."'";}
       
       
$newArray = array();
        foreach(
$array as $item)
        {
           
$newArray[] = "'".$this->escape($item)."'";
        }
        return
$newArray;
    }
   
   
# Sanitize input for Query
   
function escape($fieldValue,$isNumber = false)
    {
        if(
$isNumber == true)
        {
            return
preg_replace('/[^0-9\.]/iUsm','',$fieldValue);
        } else {
            return
mysql_real_escape_string($fieldValue,$this->connectionLink);
        }
    }
   
   
# Show error sent
   
function showError($theError)
    {
        echo
$this->mysqlError = $theError;
        echo
PHP_EOL;
    }
   
   
# Return the primary key of the specified table
   
function getPrimaryField($tableName)
    {
       
$result = $this->query("SELECT k.column_name
            FROM information_schema.key_column_usage as k
            WHERE table_schema = schema()
            AND constraint_name = 'PRIMARY'
            AND table_name = '"
.$tableName."'");
        list(
$theKeyField) = $this->result($result);
        return
$theKeyField['column_name'];
    }
   
   
# Delete a record based on one keyfield (leave empty to do primary) that matches keyDelete
    # To delete a record based on a number of fields, pass the array to keyDelete
   
function delete($tableName,$keyDelete,$keyField = NULL)
    {
       
# if keyDelete in form of array = array('fieldname' => 'fieldvalue','fieldname' => 'fieldvalue'...)
       
if(is_array($keyDelete))
        {
           
$queryAdd = 'WHERE ';
            foreach(
$keyDelete as $field => $value)
            {
               
$queryAdd .= "`$field` = '$value' AND";
            }
           
$queryAdd = substr($queryAdd,0,strlen($queryAdd)-4);
           
$query = "DELETE FROM `$tableName` $queryAdd";
            return
$this->query($query);
        }
        if(
$keyField == NULL){ $keyField = $this->getPrimaryField($tableName);}
       
$query = "DELETE FROM `$tableName` WHERE `$keyField`='$keyDelete'";
        return
$this->query($query);
    }
   
   
# Insert/update into table values from ARRAY
    # variable names must match those found on table
    # Primary must exist for an update
   
function insert($tableName,$ARRAY_VARS)
    {
       
# Check if we are sending anything?
       
if($ARRAY_VARS == NULL){ return;}
       
# Return fields matches between array and table structure
       
$queryDo = $this->findMatches($tableName,$ARRAY_VARS,'INSERT');
       
# Do query
       
return $this->query($queryDo);
    }

   
# Find matches
   
function findMatches($tableName,$ARRAY_VARS)
    {
       
# We need two arrays to store fields/values
       
$arrayFields = array();
       
$arrayFieldValue = array();
       
$arrayUpdates = array();
       
       
# Primary field (will update if found, otherwise insert)
       
$primaryField = $this->getPrimaryField($tableName);
       
$primaryFound = false;
       
       
# Get list of fields for the table
       
$tableFields = $this->result("SHOW COLUMNS FROM `$tableName`",'assoc');

        foreach(
$tableFields as $fieldInfo)
        {
           
# Check if the field exist in ARRAY_VARS
           
if(array_key_exists($fieldInfo['Field'],$ARRAY_VARS))
            {
               
$fieldNameFormatted = "`".$fieldInfo['Field']."`";
               
$fieldValueFormatted = "'".$this->escape($ARRAY_VARS[$fieldInfo['Field']])."'";
               
$arrayFields[] = $fieldNameFormatted;
               
$arrayFieldValue[] = $fieldValueFormatted;
                if(
$fieldInfo['Field'] == $primaryField && $ARRAY_VARS[$primaryField] > 0){
                   
# Insure parimary field is a number
                   
settype($ARRAY_VARS[$primaryField],"integer");
                   
$primaryFound = true;
                }
               
$arrayUpdates[] = $fieldNameFormatted.' = '.$fieldValueFormatted;
            }
        }
       
       
# Are we doing insert or update
       
if($primaryFound == TRUE)
        {
           
$finalQuery = "UPDATE `$tableName` SET ".implode(',',$arrayUpdates);
           
$finalQuery .= " WHERE `$primaryField`='".$ARRAY_VARS[$primaryField]."'";
        } else {
           
$finalQuery = "INSERT INTO `$tableName` (".implode(',',$arrayFields).") VALUES (".implode(',',$arrayFieldValue).")";
        }
        return
$finalQuery;
    }
   
   
# Create table based on Array Schema
   
function createTable($ARRAY_VARS,$tableName = NULL)
    {
       
# If no table name sent, generate one
       
if($tableName == NULL){ $tableName = $this->generateRandom(4);}

       
# Setup query
       
$createQuery = "CREATE TABLE `$tableName` (
        `primaryKey` BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY ,"
;
       
       
# Get fieldnames to add to creation query
       
foreach(array_keys($ARRAY_VARS) as $fieldName)
        {
           
$createQuery .= "
            `
$fieldName` VARCHAR( 255 ) NOT NULL ,";
        }
       
$createQuery = substr($createQuery,0,strlen($createQuery)-1);
       
$createQuery .= "
        );"
;

       
$result = $this->query($createQuery);
        return array(
$result,$tableName);
    }
   
   
# Close database connection
   
function close()
    {
        @
mysql_close($this->connectionLink) or $this->showError(mysql_error($this->connectionLink));
    }
   
   
# Generate a random number at x length
   
function generateRandom($strLen)
    {
          return
substr(md5(uniqid(rand(),1)),1,$strLen);
    }
}

// End of file /AzizMVC/Plugins/Database.php