OpenTimeTracker/library/Staple/Query/DataSet.class.php

<?php

/** 
 * @author Ironpilot
 * 
 * 
 */
class Staple_Query_DataSet implements ArrayAccess, Iterator, Countable
{
	private $data = array();
	private $literal = array();
	
	public function __construct(array $data = NULL)
	{
		if(isset($data))
		{
			$this->setData($data);
		}
	}
	
	/* (non-PHPdoc)
	 * @see ArrayAccess::offsetExists()
	 */
	public function offsetExists($offset)
	{
		return array_key_exists($offset, $this->data);
	}

	/* (non-PHPdoc)
	 * @see ArrayAccess::offsetGet()
	 */
	public function offsetGet($offset)
	{
		if(array_key_exists($offset, $this->data))
		{
			return $this->data[$offset];
		}
		else
		{
			return NULL;
		}
	}

	/* (non-PHPdoc)
	 * @see ArrayAccess::offsetSet()
	 */
	public function offsetSet($offset, $value)
	{
		$this->data[$offset] = $value;
		$this->literal[$offset] = false;
	}

	/* (non-PHPdoc)
	 * @see ArrayAccess::offsetUnset()
	 */
	public function offsetUnset($offset)
	{
		unset($this->data[$offset]);
		unset($this->literal[$offset]);
	}
	/* (non-PHPdoc)
	 * @see Iterator::current()
	 */
	public function current()
	{
		return current($this->data);
	}

	/* (non-PHPdoc)
	 * @see Iterator::key()
	 */
	public function key()
	{
		return key($this->data);
	}

	/* (non-PHPdoc)
	 * @see Iterator::next()
	 */
	public function next()
	{
		return next($this->data);
	}

	/* (non-PHPdoc)
	 * @see Iterator::rewind()
	 */
	public function rewind()
	{
		return reset($this->data);
	}

	/* (non-PHPdoc)
	 * @see Iterator::valid()
	 */
	public function valid()
	{
		if(key($this->data) === NULL)
		{
			return false;
		}
		else
		{
			return true;
		}
	}

	/* (non-PHPdoc)
	 * @see Countable::count()
	 */
	public function count()
	{
		return count($this->data);
	}

	/**
	 * Adds a data pair (key and value) to the dataset. Will overwrite the value of any existing duplicate key.
	 * @param string $key
	 * @param mixed $value
	 */
	public function addDataPair($key,$value)
	{
		$this->data[$key] = $value;
		return $this;
	}

	/**
	 * Appends the contents of the submitted array to the dataset.
	 * Note: numeric keys will be renumbered if duplicated, and string keys will be overwritten
	 * if duplicated.
	 *  
	 * @param array $data
	 */
	public function addData(array $data)
	{
		foreach ($data as $key=>$value)
		{
			$this->literal[$key] = false;
		}
		$this->data = array_merge($this->data, $data);
		return $this;
	}
	
	/**
	 * Clears any current data and uses the supplied data array.
	 * 
	 * @param array $data
	 */
	public function setData(array $data)
	{
		foreach ($data as $key=>$value)
		{
			$this->literal[$key] = false;
		}
		$this->data = $data;
		return $this;
	}
	
	public function getData()
	{
		return $this->data;
	}
	
	public function getColumns()
	{
		return array_keys($this->data);
	}
	
	public function getLiteralFor($column)
	{
		if(array_key_exists($column, $this->literal))
		{
			return $this->literal[$column];
		}
		else
		{
			return NULL;
		}
	}
	
	public function addLiteralColumn($column, $data)
	{
		$this->data[$column] = $data;
		$this->literal[$column] = true;
		return $this;
	}
	
	public function addLiteralData(array $data)
	{
		foreach ($data as $key=>$value)
		{
			$this->literal[$key] = true;
		}
		$this->data = array_merge($this->data, $data);
		return $this;
	}
	
	public function getInsertString()
	{
		$stmt = '('.implode(',',$this->getColumns()).') ';
		$stmt .= "\nVALUES (";
		$colcount = 0;
		foreach ($this->data as $name=>$col)
		{
			if($colcount > 0)
			{
				$stmt .= ',';
			}
			if($this->literal[$name] === true)
			{
				$stmt .= $col;
			}
			else
			{
				$stmt .= Staple_Query::convertTypes($col);
			}
			$colcount++;
		}
		$stmt .= ") ";
		return $stmt;
	}
	
	public function getInsertMultipleString()
	{
		$stmt = '(';
		$colcount = 0;
		foreach ($this->data as $name=>$col)
		{
			if($colcount > 0)
			{
				$stmt .= ',';
			}
			if($this->literal[$name] === true)
			{
				$stmt .= $col;
			}
			else
			{
				$stmt .= Staple_Query::convertTypes($col);
			}
			$colcount++;
		}
		$stmt .= ")";
		return $stmt;
	}
	
	public function getUpdateString()
	{
		$stmt = '';
		$colcount = 0;
		foreach ($this->data as $name=>$col)
		{
			if($colcount > 0)
			{
				$stmt .= ',';
			}
			$stmt .= ' '.$name.'=';
			if($this->literal[$name] === true)
			{
				$stmt .= $col;
			}
			else
			{
				$stmt .= Staple_Query::convertTypes($col);
			}
			$colcount++;
		}
		return $stmt;
	}
}

?>