2012-11-22 03:25:06 +00:00
|
|
|
<?php defined('SYSPATH') OR die('No direct script access.');
|
2011-01-13 14:49:56 +00:00
|
|
|
/**
|
|
|
|
* Database query builder. See [Query Builder](/database/query/builder) for usage and examples.
|
|
|
|
*
|
|
|
|
* @package Kohana/Database
|
|
|
|
* @category Query
|
|
|
|
* @author Kohana Team
|
|
|
|
* @copyright (c) 2008-2009 Kohana Team
|
|
|
|
* @license http://kohanaphp.com/license
|
|
|
|
*/
|
|
|
|
abstract class Kohana_Database_Query_Builder extends Database_Query {
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Compiles an array of JOIN statements into an SQL partial.
|
|
|
|
*
|
2012-11-22 03:25:06 +00:00
|
|
|
* @param object $db Database instance
|
|
|
|
* @param array $joins join statements
|
2011-01-13 14:49:56 +00:00
|
|
|
* @return string
|
|
|
|
*/
|
|
|
|
protected function _compile_join(Database $db, array $joins)
|
|
|
|
{
|
|
|
|
$statements = array();
|
|
|
|
|
|
|
|
foreach ($joins as $join)
|
|
|
|
{
|
|
|
|
// Compile each of the join statements
|
|
|
|
$statements[] = $join->compile($db);
|
|
|
|
}
|
|
|
|
|
|
|
|
return implode(' ', $statements);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Compiles an array of conditions into an SQL partial. Used for WHERE
|
|
|
|
* and HAVING.
|
|
|
|
*
|
2012-11-22 03:25:06 +00:00
|
|
|
* @param object $db Database instance
|
|
|
|
* @param array $conditions condition statements
|
2011-01-13 14:49:56 +00:00
|
|
|
* @return string
|
|
|
|
*/
|
|
|
|
protected function _compile_conditions(Database $db, array $conditions)
|
|
|
|
{
|
|
|
|
$last_condition = NULL;
|
|
|
|
|
|
|
|
$sql = '';
|
|
|
|
foreach ($conditions as $group)
|
|
|
|
{
|
|
|
|
// Process groups of conditions
|
|
|
|
foreach ($group as $logic => $condition)
|
|
|
|
{
|
|
|
|
if ($condition === '(')
|
|
|
|
{
|
|
|
|
if ( ! empty($sql) AND $last_condition !== '(')
|
|
|
|
{
|
|
|
|
// Include logic operator
|
|
|
|
$sql .= ' '.$logic.' ';
|
|
|
|
}
|
|
|
|
|
|
|
|
$sql .= '(';
|
|
|
|
}
|
|
|
|
elseif ($condition === ')')
|
|
|
|
{
|
|
|
|
$sql .= ')';
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
if ( ! empty($sql) AND $last_condition !== '(')
|
|
|
|
{
|
|
|
|
// Add the logic operator
|
|
|
|
$sql .= ' '.$logic.' ';
|
|
|
|
}
|
|
|
|
|
|
|
|
// Split the condition
|
|
|
|
list($column, $op, $value) = $condition;
|
|
|
|
|
|
|
|
if ($value === NULL)
|
|
|
|
{
|
|
|
|
if ($op === '=')
|
|
|
|
{
|
|
|
|
// Convert "val = NULL" to "val IS NULL"
|
|
|
|
$op = 'IS';
|
|
|
|
}
|
|
|
|
elseif ($op === '!=')
|
|
|
|
{
|
|
|
|
// Convert "val != NULL" to "valu IS NOT NULL"
|
|
|
|
$op = 'IS NOT';
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// Database operators are always uppercase
|
|
|
|
$op = strtoupper($op);
|
|
|
|
|
|
|
|
if ($op === 'BETWEEN' AND is_array($value))
|
|
|
|
{
|
|
|
|
// BETWEEN always has exactly two arguments
|
|
|
|
list($min, $max) = $value;
|
|
|
|
|
2011-05-16 12:47:16 +00:00
|
|
|
if ((is_string($min) AND array_key_exists($min, $this->_parameters)) === FALSE)
|
2011-01-13 14:49:56 +00:00
|
|
|
{
|
2011-05-16 12:47:16 +00:00
|
|
|
// Quote the value, it is not a parameter
|
|
|
|
$min = $db->quote($min);
|
2011-01-13 14:49:56 +00:00
|
|
|
}
|
|
|
|
|
2011-05-16 12:47:16 +00:00
|
|
|
if ((is_string($max) AND array_key_exists($max, $this->_parameters)) === FALSE)
|
2011-01-13 14:49:56 +00:00
|
|
|
{
|
2011-05-16 12:47:16 +00:00
|
|
|
// Quote the value, it is not a parameter
|
|
|
|
$max = $db->quote($max);
|
2011-01-13 14:49:56 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// Quote the min and max value
|
2011-05-16 12:47:16 +00:00
|
|
|
$value = $min.' AND '.$max;
|
2011-01-13 14:49:56 +00:00
|
|
|
}
|
2011-05-16 12:47:16 +00:00
|
|
|
elseif ((is_string($value) AND array_key_exists($value, $this->_parameters)) === FALSE)
|
2011-01-13 14:49:56 +00:00
|
|
|
{
|
2011-05-16 12:47:16 +00:00
|
|
|
// Quote the value, it is not a parameter
|
2011-01-13 14:49:56 +00:00
|
|
|
$value = $db->quote($value);
|
|
|
|
}
|
|
|
|
|
|
|
|
if ($column)
|
|
|
|
{
|
2012-11-22 03:25:06 +00:00
|
|
|
if (is_array($column))
|
|
|
|
{
|
|
|
|
// Use the column name
|
|
|
|
$column = $db->quote_identifier(reset($column));
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
// Apply proper quoting to the column
|
|
|
|
$column = $db->quote_column($column);
|
|
|
|
}
|
2011-01-13 14:49:56 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// Append the statement to the query
|
|
|
|
$sql .= trim($column.' '.$op.' '.$value);
|
|
|
|
}
|
|
|
|
|
|
|
|
$last_condition = $condition;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return $sql;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Compiles an array of set values into an SQL partial. Used for UPDATE.
|
|
|
|
*
|
2012-11-22 03:25:06 +00:00
|
|
|
* @param object $db Database instance
|
|
|
|
* @param array $values updated values
|
2011-01-13 14:49:56 +00:00
|
|
|
* @return string
|
|
|
|
*/
|
|
|
|
protected function _compile_set(Database $db, array $values)
|
|
|
|
{
|
|
|
|
$set = array();
|
|
|
|
foreach ($values as $group)
|
|
|
|
{
|
|
|
|
// Split the set
|
|
|
|
list ($column, $value) = $group;
|
|
|
|
|
|
|
|
// Quote the column name
|
2011-05-16 12:47:16 +00:00
|
|
|
$column = $db->quote_column($column);
|
2011-01-13 14:49:56 +00:00
|
|
|
|
2011-05-16 12:47:16 +00:00
|
|
|
if ((is_string($value) AND array_key_exists($value, $this->_parameters)) === FALSE)
|
2011-01-13 14:49:56 +00:00
|
|
|
{
|
2011-05-16 12:47:16 +00:00
|
|
|
// Quote the value, it is not a parameter
|
|
|
|
$value = $db->quote($value);
|
2011-01-13 14:49:56 +00:00
|
|
|
}
|
|
|
|
|
2011-05-16 12:47:16 +00:00
|
|
|
$set[$column] = $column.' = '.$value;
|
2011-01-13 14:49:56 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return implode(', ', $set);
|
|
|
|
}
|
|
|
|
|
2012-11-22 03:25:06 +00:00
|
|
|
/**
|
|
|
|
* Compiles an array of GROUP BY columns into an SQL partial.
|
|
|
|
*
|
|
|
|
* @param object $db Database instance
|
|
|
|
* @param array $columns
|
|
|
|
* @return string
|
|
|
|
*/
|
|
|
|
protected function _compile_group_by(Database $db, array $columns)
|
|
|
|
{
|
|
|
|
$group = array();
|
|
|
|
|
|
|
|
foreach ($columns as $column)
|
|
|
|
{
|
|
|
|
if (is_array($column))
|
|
|
|
{
|
|
|
|
// Use the column alias
|
|
|
|
$column = $db->quote_identifier(end($column));
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
// Apply proper quoting to the column
|
|
|
|
$column = $db->quote_column($column);
|
|
|
|
}
|
|
|
|
|
|
|
|
$group[] = $column;
|
|
|
|
}
|
|
|
|
|
|
|
|
return 'GROUP BY '.implode(', ', $group);
|
|
|
|
}
|
|
|
|
|
2011-01-13 14:49:56 +00:00
|
|
|
/**
|
|
|
|
* Compiles an array of ORDER BY statements into an SQL partial.
|
|
|
|
*
|
2012-11-22 03:25:06 +00:00
|
|
|
* @param object $db Database instance
|
|
|
|
* @param array $columns sorting columns
|
2011-01-13 14:49:56 +00:00
|
|
|
* @return string
|
|
|
|
*/
|
|
|
|
protected function _compile_order_by(Database $db, array $columns)
|
|
|
|
{
|
|
|
|
$sort = array();
|
|
|
|
foreach ($columns as $group)
|
|
|
|
{
|
|
|
|
list ($column, $direction) = $group;
|
|
|
|
|
2012-11-22 03:25:06 +00:00
|
|
|
if (is_array($column))
|
2011-01-13 14:49:56 +00:00
|
|
|
{
|
2012-11-22 03:25:06 +00:00
|
|
|
// Use the column alias
|
|
|
|
$column = $db->quote_identifier(end($column));
|
2011-01-13 14:49:56 +00:00
|
|
|
}
|
2012-11-22 03:25:06 +00:00
|
|
|
else
|
2011-01-13 14:49:56 +00:00
|
|
|
{
|
2012-11-22 03:25:06 +00:00
|
|
|
// Apply proper quoting to the column
|
2011-05-16 12:47:16 +00:00
|
|
|
$column = $db->quote_column($column);
|
2011-01-13 14:49:56 +00:00
|
|
|
}
|
|
|
|
|
2012-11-22 03:25:06 +00:00
|
|
|
if ($direction)
|
|
|
|
{
|
|
|
|
// Make the direction uppercase
|
|
|
|
$direction = ' '.strtoupper($direction);
|
|
|
|
}
|
|
|
|
|
|
|
|
$sort[] = $column.$direction;
|
2011-01-13 14:49:56 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return 'ORDER BY '.implode(', ', $sort);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Reset the current builder status.
|
|
|
|
*
|
|
|
|
* @return $this
|
|
|
|
*/
|
|
|
|
abstract public function reset();
|
|
|
|
|
|
|
|
} // End Database_Query_Builder
|