FOGController
Contents
Overview
FOGController is a new Chainable PHP Class developed for use in FOG web applications. This Class acts as an abstraction layer between PHP's data and its database entry.
The Class is an abstract Class, providing a base for FOG Classes to build from. All you need to do is describe to the Class the relationship between your Database fields and common names used when accessing the data.
- Please note all of this is developmental and could change at any moment
Variables & Methods
Variables and their defaults
abstract class FOGController
{
// Table
protected $databaseTable = '';
// Name -> Database field name
protected $databaseFields = array();
// Do not update these database fields
protected $databaseFieldsToIgnore = array(
'createdBy',
'createdTime'
);
// Allow setting / getting of these additional fields
protected $additionalFields = array();
// Required database fields
protected $databaseFieldsRequired = array(
'id',
'name'
);
// Store data array
protected $data = array();
// Auto save class data on __destruct
protected $autoSave = false;
// DEBUG mode - print all Errors & SQL queries
protected $debug = false;
}
Methods
$this public function __construct($data) $this public function __destruct() $this public function set($key, $value) $this public function get($key) $this public function add($key, $value) $this public function remove($key, $object) boolean public function save() boolean public function load($field = 'id') boolean public function destroy($field = 'id') void public function error($txt, $data = array()) void public function info($txt, $data = array()) boolean public function isValid() boolean private function isTableDefined() string public function __toString()
Example
This is an example of FOG's up coming OS Class in v0.33
OS.class.php
class OS extends FOGController
{
// Table
protected $databaseTable = 'os';
// Name -> Database field name
protected $databaseFields = array(
'id' => 'osID',
'name' => 'osName',
'description' => 'osDescription'
);
}
Only $databaseFields is required.
Providing $databaseTable gives access to FOGControllers save() and load() functions.
Example: Add new OS
// New OS Object
$OS = new OS();
// Set name -> Set description -> Save to database (returns true on success)
if ($OS->set('name', 'Windows 8')->set('description', 'more junk')->save())
{
// id property is added after a successful save
$FOGCore->setMessage(sprintf('OS Added: ID: %s, Name: %s', $OS->get('id'), $OS->get('name')));
}
else
{
$FOGCore->setMessage(sprintf('Failed to add: %s', $OS->get('name')));
}
// Redirect back to self
$FOGCore->redirect();
Example: Update an Existing OS
// OS ID Variable
$id = '1';
// Load OS - auto loads from database when ID is passed
$OS = new OS($id);
// Is OS valid? (was it loaded from the database correctly)
if ($OS->isValid())
{
print_r($OS);
}
Class
FOGController.class.php
<?php
// Blackout - 1:28 PM 23/09/2011
abstract class FOGController
{
// Table
protected $databaseTable = '';
// Name -> Database field name
protected $databaseFields = array();
// Do not update these database fields
protected $databaseFieldsToIgnore = array(
'createdBy',
'createdTime'
);
// Allow setting / getting of these additional fields
protected $additionalFields = array();
// Required database fields
protected $databaseFieldsRequired = array(
'id',
'name'
);
// Store data array
protected $data = array();
// Auto save class data on __destruct
protected $autoSave = false;
// DEBUG mode - print all Errors & SQL queries
protected $debug = true;
// Database Class
protected $db;
// Construct
public function __construct($data)
{
try
{
// Error checking
if (!count($this->databaseFields))
{
throw new Exception('No database fields defined for this class!');
}
// Database
$this->db = $GLOBALS['db'];
// Add incoming data
if (is_array($data))
{
// Iterate data -> Set data
foreach ($data AS $key => $value)
{
$this->set($key, $value);
}
}
// If incoming data is an INT -> Set as ID -> Load from database
elseif (is_numeric($data))
{
if ($data <= 0)
{
throw new Exception(sprintf('ID less than or equal to 0: Data: %s', $data));
//return false;
}
$this->set('id', $data)->load();
}
// Unknown data format
else
{
throw new Exception('No data array or ID passed!');
}
}
catch (Exception $e)
{
$this->error('Create Class Failed: Class: %s, Error: %s', array(get_class($this), $e->getMessage()));
}
return $this;
}
// Destruct
public function __destruct()
{
// Auto save
if ($this->autoSave)
{
$this->save();
}
}
// Set
public function set($key, $value)
{
try
{
$databaseFieldsRev = array_flip($this->databaseFields);
if (!array_key_exists($key, $this->databaseFields) && !in_array($key, $this->additionalFields) && !array_key_exists($key, $databaseFieldsRev))
{
throw new Exception('Invalid data being set');
}
if (array_key_exists($key, $databaseFieldsRev))
{
$key = $databaseFieldsRev[$key];
}
$this->data[$key] = $value;
}
catch (Exception $e)
{
$this->error('Set Failed: Class: %s, Key: %s, Value: %s, Error: %s', array(get_class($this), $key, $value, $e->getMessage()));
}
return $this;
}
// Get
public function get($key)
{
return (isset($this->data[$key]) ? $this->data[$key] : '');
}
/*
public function __set($key, $value)
{
return $this->set($key, $value);
}
public function __get($key)
{
return $this->get($key);
}
*/
// Add
public function add($key, $value)
{
try
{
$databaseFieldsRev = array_flip($this->databaseFields);
if (!array_key_exists($key, $this->databaseFields) && !in_array($key, $this->additionalFields) && !array_key_exists($key, $databaseFieldsRev))
{
throw new Exception('Invalid data being set');
}
if (array_key_exists($key, $databaseFieldsRev))
{
$key = $databaseFieldsRev[$key];
}
$this->data[$key][] = $value;
}
catch (Exception $e)
{
$this->error('Add Failed: Class: %s, Key: %s, Value: %s, Error: %s', array(get_class($this), $key, $value, $e->getMessage()));
}
return $this;
}
// Remove
public function remove($key, $object)
{
try
{
$databaseFieldsRev = array_flip($this->databaseFields);
if (!array_key_exists($key, $this->databaseFields) && !in_array($key, $this->additionalFields) && !array_key_exists($key, $databaseFieldsRev))
{
throw new Exception('Invalid data being set');
}
if (array_key_exists($key, $databaseFieldsRev))
{
$key = $databaseFieldsRev[$key];
}
foreach ((array)$this->data[$key] AS $i => $data)
{
if ($data->get('id') != $object->get('id'))
{
$newDataArray[] = $data;
}
}
$this->data[$key] = (array)$newDataArray;
}
catch (Exception $e)
{
$this->error('Remove Failed: Class: %s, Key: %s, Object: %s, Error: %s', array(get_class($this), $key, $object, $e->getMessage()));
}
return $this;
}
// Save
public function save()
{
try
{
// Error checking
if (!$this->isTableDefined())
{
throw new Exception('No Table defined for this class');
}
// Variables
$fieldData = array();
$fieldsToUpdate = $this->databaseFields;
$fieldToName = array_flip($this->databaseFields);
// Remove unwanted fields for update query
foreach ($this->databaseFields AS $name => $fieldName)
{
if (in_array($name, $this->databaseFieldsToIgnore))
{
unset($fieldsToUpdate[$name]);
}
}
// Build insert key and value arrays
foreach ($this->databaseFields AS $name => $fieldName)
{
$insertKeys[] = $this->db->sanitize($fieldName);
$insertValues[] = $this->db->sanitize($this->get($name));
}
// Build update field array using filtered data
foreach ($fieldsToUpdate AS $name => $fieldName)
{
$updateData[] = sprintf("`%s`='%s'", $this->db->sanitize($fieldName), $this->db->sanitize($this->get($name)));
}
// Insert & Update query all-in-one
$query = sprintf("INSERT INTO `%s` (`%s`) VALUES ('%s') ON DUPLICATE KEY UPDATE %s",
$this->db->sanitize($this->databaseTable),
implode("`, `", $insertKeys),
implode("', '", $insertValues),
implode(', ', $updateData)
);
// INFO
$this->info($query);
if (!$this->db->query($query))
{
// Query failed
throw new Exception($this->db->error());
}
// Database query was successful - set ID if ID was not set
if (!$this->get('id'))
{
$this->set('id', $this->db->insert_id());
}
// Success
return true;
}
catch (Exception $e)
{
$this->error('Database Save Failed: Class: %s, ID: %s, Error: %s', array(get_class($this), $this->get('id'), $e->getMessage()));
}
// Fail
return false;
}
// Load
public function load($field = 'id')
{
try
{
// Error checking
if (!$this->isTableDefined())
{
throw new Exception('No Table defined for this class');
}
if (!$this->get($field))
{
throw new Exception(sprintf('Operation field not set: %s', strtoupper($field)));
}
// Variables
$fieldToName = array_flip($this->databaseFields);
// Build query
if (is_array($this->get($field)))
{
// Multiple values
foreach ($this->get($field) AS $fieldValue)
{
$fieldData[] = sprintf("`%s`='%s'", $this->db->sanitize($this->databaseFields[$field]), $this->db->sanitize($fieldValue));
}
$query = sprintf("SELECT * FROM `%s` WHERE %s",
$this->db->sanitize($this->databaseTable),
implode(' OR ', $fieldData)
);
}
else
{
// Single value
$query = sprintf("SELECT * FROM `%s` WHERE `%s`='%s'",
$this->db->sanitize($this->databaseTable),
$this->db->sanitize($this->databaseFields[$field]),
$this->db->sanitize($this->get($field))
);
}
// INFO
$this->info($query);
// Did we find a row in the database?
if (!$queryData = $this->db->query($query)->fetch()->get())
{
throw new Exception($this->db->error());
}
// Loop returned rows -> Set new data
foreach ($queryData AS $key => $value)
{
$this->set($fieldToName[$key], (string)$value);
}
// Success
return true;
}
catch (Exception $e)
{
$this->error('Database Load Failed: Class: %s, ID: %s, Error: %s', array(get_class($this), $this->get('id'), $e->getMessage()));
}
// Fail
return false;
}
// Destroy
public function destroy($field = 'id')
{
try
{
// Error checking
if (!$this->isTableDefined())
{
throw new Exception('No Table defined for this class');
}
if (!$this->get($field))
{
throw new Exception(sprintf('Operation field not set: %s', strtoupper($field)));
}
// Variables
$fieldToName = array_flip($this->databaseFields);
// Query row data
$query = sprintf("DELETE FROM `%s` WHERE `%s`='%s'",
$this->db->sanitize($this->databaseTable),
$this->db->sanitize($this->databaseFields[$field]),
$this->db->sanitize($this->get($field))
);
// INFO
$this->info($query);
// Did we find a row in the database?
if (!$queryData = $this->db->query($query)->fetch()->get())
{
throw new Exception('Failed to delete');
}
// Success
return true;
}
catch (Exception $e)
{
$this->error('Database Destroy Failed: Class: %s, ID: %s, Error: %s', array(get_class($this), $this->get('id'), $e->getMessage()));
}
// Fail
return false;
}
// Error
public function error($txt, $data = array())
{
if ($this->debug)
{
$txt = (is_array($data) && count($data) ? vsprintf($txt, $data) : $txt);
$GLOBALS['FOGCore']->error(sprintf('Class: %s, Error: %s', get_class($this), $txt));
}
}
// Info
public function info($txt, $data = array())
{
if ($this->debug)
{
$txt = (is_array($data) && count($data) ? vsprintf($txt, $data) : $txt);
$GLOBALS['FOGCore']->info(sprintf('Class: %s, Info: %s', get_class($this), $txt));
}
}
// isValid
public function isValid()
{
// TODO: Add $this->databaseFieldsRequired checks
if ($this->get('id') || $this->get('name'))
{
return true;
}
return false;
}
// isTableDefined
private function isTableDefined()
{
return (!empty($this->databaseTable) ? true : false);
}
// Name is returned if class is printed
public function __toString()
{
return $this->get('name');
}
}
