aviat/OpenSQLManager
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Initial implementation of the rest of the query builder methods

Browse Source
This commit is contained in:
Timothy Warren 2012-03-14 14:17:15 -04:00
parent 79ca1ee071
commit 4683311f61
1 changed files with 100 additions and 95 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

191
sys/db/query_builder.php
View File

@ -162,6 +162,8 @@ class Query_Builder {
return $this; return $this;
} }
// --------------------------------------------------------------------------
// ! 'Like' methods
// -------------------------------------------------------------------------- // --------------------------------------------------------------------------
/** /**
@ -330,6 +332,8 @@ class Query_Builder {
return $this; return $this;
} }
// --------------------------------------------------------------------------
// ! 'Where' methods
// -------------------------------------------------------------------------- // --------------------------------------------------------------------------
/** /**
@ -562,6 +566,8 @@ class Query_Builder {
} }
// -------------------------------------------------------------------------- // --------------------------------------------------------------------------
// ! Other Query Modifier methods
// --------------------------------------------------------------------------ß
/** /**
* Creates a join phrase in a compiled query * Creates a join phrase in a compiled query
@ -571,9 +577,23 @@ class Query_Builder {
* @param string $type * @param string $type
* @return $this * @return $this
*/ */
public function join($table, $condition, $type='inner') public function join($table, $condition, $type='')
{ {
// @todo Implement join method $table = $this->db->quote_ident($table);
$matches = array();
if (preg_match('/([\[\w\.]+)([\W\s]+)(.+)/', $condition, $matches))
{
$condition = $this->db->quote_ident($matches[0]).' '.$matches[1].' '.$this->db->quote_ident($matches[2]);
}
$this->query_map[] = array(
'type' => 'join',
'conjunction' => strtoupper($type).' JOIN ',
'string' => $condition,
);
return $this; return $this;
} }
@ -655,6 +675,8 @@ class Query_Builder {
return $this; return $this;
} }
// --------------------------------------------------------------------------
// ! Query execution methods
// -------------------------------------------------------------------------- // --------------------------------------------------------------------------
/** /**
@ -680,7 +702,7 @@ class Query_Builder {
$this->limit($limit, $offset); $this->limit($limit, $offset);
} }
$sql = $this->_compile_select(); $sql = $this->_compile();
// Do prepared statements for anything involving a "where" clause // Do prepared statements for anything involving a "where" clause
if ( ! empty($this->query_map)) if ( ! empty($this->query_map))
@ -699,46 +721,6 @@ class Query_Builder {
return $result; return $result;
} }
// --------------------------------------------------------------------------
// ! Insert/Update/Delete Queries
// --------------------------------------------------------------------------
/**
* Sets values for inserts / updates / deletes
*
* @param mixed $key
* @param mixed $val
* @return $this
*/
public function set($key, $val)
{
// Plain key, value pair
if (is_scalar($key) && is_scalar($val))
{
$this->set_array[$key] = $val;
$this->values[] = $val;
}
// Object or array
elseif ( ! is_scalar($key))
{
foreach($key as $k => $v)
{
$this->set_array[$k] = $v;
$this->values[] = $val;
}
}
// Use the keys of the array to make the insert/update string
// Escape the field names
$this->set_array_keys = array_map(array($this->db, 'quote_ident'), array_keys($this->set_array));
// Generate the "set" string
$this->set_string = implode('=?, ', $this->set_array_keys);
$this->set_string .= '=?';
return $this;
}
// -------------------------------------------------------------------------- // --------------------------------------------------------------------------
/** /**
@ -900,6 +882,44 @@ class Query_Builder {
// ! Miscellaneous Methods // ! Miscellaneous Methods
// -------------------------------------------------------------------------- // --------------------------------------------------------------------------
/**
* Sets values for inserts / updates / deletes
*
* @param mixed $key
* @param mixed $val
* @return $this
*/
public function set($key, $val)
{
// Plain key, value pair
if (is_scalar($key) && is_scalar($val))
{
$this->set_array[$key] = $val;
$this->values[] = $val;
}
// Object or array
elseif ( ! is_scalar($key))
{
foreach($key as $k => $v)
{
$this->set_array[$k] = $v;
$this->values[] = $val;
}
}
// Use the keys of the array to make the insert/update string
// Escape the field names
$this->set_array_keys = array_map(array($this->db, 'quote_ident'), array_keys($this->set_array));
// Generate the "set" string
$this->set_string = implode('=?, ', $this->set_array_keys);
$this->set_string .= '=?';
return $this;
}
// --------------------------------------------------------------------------
/** /**
* Clear out the class variables, so the next query can be run * Clear out the class variables, so the next query can be run
*/ */
@ -945,6 +965,41 @@ class Query_Builder {
switch($type) switch($type)
{ {
default: default:
$sql = 'SELECT * FROM '.$this->from_string;
// Set the select string
if ( ! empty($this->select_string))
{
// Replace the star with the selected fields
$sql = str_replace('*', $this->select_string, $sql);
}
// Set the where string
if ( ! empty($this->query_map))
{
foreach($this->query_map as $q)
{
$sql .= $q['conjunction'] . $q['string'];
}
}
// Set the group_by string
if ( ! empty($this->group_string))
{
$sql .= $this->group_string;
}
// Set the order_by string
if ( ! empty($this->order_string))
{
$sql .= $this->order_string;
}
// Set the limit via the class variables
if (isset($this->limit) && is_numeric($this->limit))
{
$sql = $this->sql->limit($sql, $this->limit, $this->offset);
}
break; break;
case "insert": case "insert":
@ -987,55 +1042,5 @@ class Query_Builder {
return $sql; return $sql;
} }
// --------------------------------------------------------------------------
/**
* Compiles a "select" type query
*
* @return string
*/
private function _compile_select()
{
$sql = 'SELECT * FROM '.$this->from_string;
// Set the select string
if ( ! empty($this->select_string))
{
// Replace the star with the selected fields
$sql = str_replace('*', $this->select_string, $sql);
}
// Set the where string
if ( ! empty($this->query_map))
{
foreach($this->query_map as $q)
{
$sql .= $q['conjunction'] . $q['string'];
}
}
// Set the group_by string
if ( ! empty($this->group_string))
{
$sql .= $this->group_string;
}
// Set the order_by string
if ( ! empty($this->order_string))
{
$sql .= $this->order_string;
}
// Set the limit via the class variables
if (isset($this->limit) && is_numeric($this->limit))
{
$sql = $this->sql->limit($sql, $this->limit, $this->offset);
}
echo $sql."<br />";
return $sql;
}
} }
// End of query_builder.php // End of query_builder.php