225 lines
		
	
	
		
			5.6 KiB
		
	
	
	
		
			PHP
		
	
	
		
			Executable File
		
	
	
	
	
			
		
		
	
	
			225 lines
		
	
	
		
			5.6 KiB
		
	
	
	
		
			PHP
		
	
	
		
			Executable File
		
	
	
	
	
| <?php namespace Illuminate\Database\Query\Grammars;
 | |
| 
 | |
| use Illuminate\Database\Query\Builder;
 | |
| 
 | |
| class SqlServerGrammar extends Grammar {
 | |
| 
 | |
| 	/**
 | |
| 	 * All of the available clause operators.
 | |
| 	 *
 | |
| 	 * @var array
 | |
| 	 */
 | |
| 	protected $operators = array(
 | |
| 		'=', '<', '>', '<=', '>=', '!<', '!>', '<>', '!=',
 | |
| 		'like', 'not like', 'between', 'ilike',
 | |
| 		'&', '&=', '|', '|=', '^', '^=',
 | |
| 	);
 | |
| 
 | |
| 	/**
 | |
| 	 * Compile a select query into SQL.
 | |
| 	 *
 | |
| 	 * @param  \Illuminate\Database\Query\Builder
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	public function compileSelect(Builder $query)
 | |
| 	{
 | |
| 		$components = $this->compileComponents($query);
 | |
| 
 | |
| 		// If an offset is present on the query, we will need to wrap the query in
 | |
| 		// a big "ANSI" offset syntax block. This is very nasty compared to the
 | |
| 		// other database systems but is necessary for implementing features.
 | |
| 		if ($query->offset > 0)
 | |
| 		{
 | |
| 			return $this->compileAnsiOffset($query, $components);
 | |
| 		}
 | |
| 
 | |
| 		return $this->concatenate($components);
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Compile the "select *" portion of the query.
 | |
| 	 *
 | |
| 	 * @param  \Illuminate\Database\Query\Builder  $query
 | |
| 	 * @param  array  $columns
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	protected function compileColumns(Builder $query, $columns)
 | |
| 	{
 | |
| 		if ( ! is_null($query->aggregate)) return;
 | |
| 
 | |
| 		$select = $query->distinct ? 'select distinct ' : 'select ';
 | |
| 
 | |
| 		// If there is a limit on the query, but not an offset, we will add the top
 | |
| 		// clause to the query, which serves as a "limit" type clause within the
 | |
| 		// SQL Server system similar to the limit keywords available in MySQL.
 | |
| 		if ($query->limit > 0 && $query->offset <= 0)
 | |
| 		{
 | |
| 			$select .= 'top '.$query->limit.' ';
 | |
| 		}
 | |
| 
 | |
| 		return $select.$this->columnize($columns);
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Compile the "from" portion of the query.
 | |
| 	 *
 | |
| 	 * @param  \Illuminate\Database\Query\Builder  $query
 | |
| 	 * @param  string  $table
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	protected function compileFrom(Builder $query, $table)
 | |
| 	{
 | |
| 		$from = parent::compileFrom($query, $table);
 | |
| 
 | |
| 		if (is_string($query->lock)) return $from.' '.$query->lock;
 | |
| 
 | |
| 		if ( ! is_null($query->lock))
 | |
| 		{
 | |
| 			return $from.' with(rowlock,'.($query->lock ? 'updlock,' : '').'holdlock)';
 | |
| 		}
 | |
| 
 | |
| 		return $from;
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Create a full ANSI offset clause for the query.
 | |
| 	 *
 | |
| 	 * @param  \Illuminate\Database\Query\Builder  $query
 | |
| 	 * @param  array  $components
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	protected function compileAnsiOffset(Builder $query, $components)
 | |
| 	{
 | |
| 		// An ORDER BY clause is required to make this offset query work, so if one does
 | |
| 		// not exist we'll just create a dummy clause to trick the database and so it
 | |
| 		// does not complain about the queries for not having an "order by" clause.
 | |
| 		if ( ! isset($components['orders']))
 | |
| 		{
 | |
| 			$components['orders'] = 'order by (select 0)';
 | |
| 		}
 | |
| 
 | |
| 		// We need to add the row number to the query so we can compare it to the offset
 | |
| 		// and limit values given for the statements. So we will add an expression to
 | |
| 		// the "select" that will give back the row numbers on each of the records.
 | |
| 		$orderings = $components['orders'];
 | |
| 
 | |
| 		$components['columns'] .= $this->compileOver($orderings);
 | |
| 
 | |
| 		unset($components['orders']);
 | |
| 
 | |
| 		// Next we need to calculate the constraints that should be placed on the query
 | |
| 		// to get the right offset and limit from our query but if there is no limit
 | |
| 		// set we will just handle the offset only since that is all that matters.
 | |
| 		$constraint = $this->compileRowConstraint($query);
 | |
| 
 | |
| 		$sql = $this->concatenate($components);
 | |
| 
 | |
| 		// We are now ready to build the final SQL query so we'll create a common table
 | |
| 		// expression from the query and get the records with row numbers within our
 | |
| 		// given limit and offset value that we just put on as a query constraint.
 | |
| 		return $this->compileTableExpression($sql, $constraint);
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Compile the over statement for a table expression.
 | |
| 	 *
 | |
| 	 * @param  string  $orderings
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	protected function compileOver($orderings)
 | |
| 	{
 | |
| 		return ", row_number() over ({$orderings}) as row_num";
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Compile the limit / offset row constraint for a query.
 | |
| 	 *
 | |
| 	 * @param  \Illuminate\Database\Query\Builder  $query
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	protected function compileRowConstraint($query)
 | |
| 	{
 | |
| 		$start = $query->offset + 1;
 | |
| 
 | |
| 		if ($query->limit > 0)
 | |
| 		{
 | |
| 			$finish = $query->offset + $query->limit;
 | |
| 
 | |
| 			return "between {$start} and {$finish}";
 | |
| 		}
 | |
| 
 | |
| 		return ">= {$start}";
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Compile a common table expression for a query.
 | |
| 	 *
 | |
| 	 * @param  string  $sql
 | |
| 	 * @param  string  $constraint
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	protected function compileTableExpression($sql, $constraint)
 | |
| 	{
 | |
| 		return "select * from ({$sql}) as temp_table where row_num {$constraint}";
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Compile the "limit" portions of the query.
 | |
| 	 *
 | |
| 	 * @param  \Illuminate\Database\Query\Builder  $query
 | |
| 	 * @param  int  $limit
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	protected function compileLimit(Builder $query, $limit)
 | |
| 	{
 | |
| 		return '';
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Compile the "offset" portions of the query.
 | |
| 	 *
 | |
| 	 * @param  \Illuminate\Database\Query\Builder  $query
 | |
| 	 * @param  int  $offset
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	protected function compileOffset(Builder $query, $offset)
 | |
| 	{
 | |
| 		return '';
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Compile a truncate table statement into SQL.
 | |
| 	 *
 | |
| 	 * @param  \Illuminate\Database\Query\Builder  $query
 | |
| 	 * @return array
 | |
| 	 */
 | |
| 	public function compileTruncate(Builder $query)
 | |
| 	{
 | |
| 		return array('truncate table '.$this->wrapTable($query->from) => array());
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Get the format for database stored dates.
 | |
| 	 *
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	public function getDateFormat()
 | |
| 	{
 | |
| 		return 'Y-m-d H:i:s.000';
 | |
| 	}
 | |
| 
 | |
| 	/**
 | |
| 	 * Wrap a single string in keyword identifiers.
 | |
| 	 *
 | |
| 	 * @param  string  $value
 | |
| 	 * @return string
 | |
| 	 */
 | |
| 	protected function wrapValue($value)
 | |
| 	{
 | |
| 		if ($value === '*') return $value;
 | |
| 
 | |
| 		return '['.str_replace(']', ']]', $value).']';
 | |
| 	}
 | |
| 
 | |
| }
 |