CI_DB_pdo_sqlsrv_driver - Code Metrics - ci-bonfire/Sprint - Measure and Improve Code Quality continuously with Scrutinizer

CI_DB_pdo_sqlsrv_driver B
last analyzed 2016-08-09 21:23 UTC

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	317
Duplicated Lines	33.12 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

Metric	Value
dl	105
loc	317
rs	8.439
c	0
b	0
f	0
wmc	47
lcom	1
cbo	1

9 Methods

Rating	Name	Duplication	Size	Complexity
F	__construct()	0	51	17
C	db_connect()	0	22	7
A	_list_tables()	14	14	3
A	_list_columns()	0	6	1
B	field_data()	24	24	4
A	_update()	0	6	1
A	_delete()	9	9	2
C	_limit()	48	48	9
A	_insert_batch()	10	10	3

How to fix Duplicated Code Complexity

Duplicated Code

Duplicate code is one of the most pungent code smells. A rule that is often used is to re-structure code once it is duplicated in three or more places.

Common duplication problems, and corresponding solutions are:

If you have the same expression in different places: Extract expression to a method
If you have the same method in different sub-classes: Extract method, and pull up field to the parent class
If you have the same code in unrelated classes: Consider extracting the code to a new class, and injecting that class

Complex Class

Tip: Before tackling complexity, make sure that you eliminate any duplication first. This often can reduce the size of classes significantly.

Complex classes like CI_DB_pdo_sqlsrv_driver often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes. You can also have a look at the cohesion graph to spot any un-connected, or weakly-connected components.

Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.

While breaking up the class, it is a good idea to analyze how other classes use CI_DB_pdo_sqlsrv_driver, and based on these observations, apply Extract Interface, too.

<?php

/**
 * CodeIgniter
 *
 * An open source application development framework for PHP
 *
 * This content is released under the MIT License (MIT)
 *
 * Copyright (c) 2014 - 2015, British Columbia Institute of Technology
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 *
 * @package	CodeIgniter
 * @author	EllisLab Dev Team
 * @copyright	Copyright (c) 2008 - 2014, EllisLab, Inc. (http://ellislab.com/)
 * @copyright	Copyright (c) 2014 - 2015, British Columbia Institute of Technology (http://bcit.ca/)
 * @license	http://opensource.org/licenses/MIT	MIT License
 * @link	http://codeigniter.com
 * @since	Version 3.0.0
 * @filesource
 */
defined('BASEPATH') OR exit('No direct script access allowed');

/**
 * PDO SQLSRV Database Adapter Class
 *
 * Note: _DB is an extender class that the app controller
 * creates dynamically based on whether the query builder
 * class is being used or not.
 *
 * @package		CodeIgniter
 * @subpackage	Drivers
 * @category	Database
 * @author		EllisLab Dev Team
 * @link		http://codeigniter.com/user_guide/database/
 */
class CI_DB_pdo_sqlsrv_driver extends CI_DB_pdo_driver {

	/**
	 * Sub-driver
	 *
	 * @var	string
	 */
	public $subdriver = 'sqlsrv';

	// --------------------------------------------------------------------

	/**
	 * ORDER BY random keyword
	 *
	 * @var	array
	 */
	protected $_random_keyword = array('NEWID()', 'RAND(%d)');

	/**
	 * Quoted identifier flag
	 *
	 * Whether to use SQL-92 standard quoted identifier
	 * (double quotes) or brackets for identifier escaping.
	 *
	 * @var	bool
	 */
	protected $_quoted_identifier;

	// --------------------------------------------------------------------

	/**
	 * Class constructor
	 *
	 * Builds the DSN if not already set.
	 *
	 * @param	array	$params
	 * @return	void
	 */
	public function __construct($params)
	{
		parent::__construct($params);

		if (empty($this->dsn))
		{
			$this->dsn = 'sqlsrv:Server='.(empty($this->hostname) ? '127.0.0.1' : $this->hostname);

			empty($this->port) OR $this->dsn .= ','.$this->port;
			empty($this->database) OR $this->dsn .= ';Database='.$this->database;

			// Some custom options

			if (isset($this->QuotedId))
			{
				$this->dsn .= ';QuotedId='.$this->QuotedId;
				$this->_quoted_identifier = (bool) $this->QuotedId;
			}

			if (isset($this->ConnectionPooling))
			{
				$this->dsn .= ';ConnectionPooling='.$this->ConnectionPooling;
			}

			if ($this->encrypt === TRUE)
			{
				$this->dsn .= ';Encrypt=1';
			}

			if (isset($this->TraceOn))
			{
				$this->dsn .= ';TraceOn='.$this->TraceOn;
			}

			if (isset($this->TrustServerCertificate))
			{
				$this->dsn .= ';TrustServerCertificate='.$this->TrustServerCertificate;
			}

			empty($this->APP) OR $this->dsn .= ';APP='.$this->APP;
			empty($this->Failover_Partner) OR $this->dsn .= ';Failover_Partner='.$this->Failover_Partner;
			empty($this->LoginTimeout) OR $this->dsn .= ';LoginTimeout='.$this->LoginTimeout;
			empty($this->MultipleActiveResultSets) OR $this->dsn .= ';MultipleActiveResultSets='.$this->MultipleActiveResultSets;
			empty($this->TraceFile) OR $this->dsn .= ';TraceFile='.$this->TraceFile;
			empty($this->WSID) OR $this->dsn .= ';WSID='.$this->WSID;
		}
		elseif (preg_match('/QuotedId=(0|1)/', $this->dsn, $match))
		{
			$this->_quoted_identifier = (bool) $match[1];
		}
	}

	// --------------------------------------------------------------------

	/**
	 * Database connection
	 *
	 * @param	bool	$persistent
	 * @return	object
	 */
	public function db_connect($persistent = FALSE)
	{
		if ( ! empty($this->char_set) && preg_match('/utf[^8]*8/i', $this->char_set))
		{
			$this->options[PDO::SQLSRV_ENCODING_UTF8] = 1;
		}

		$this->conn_id = parent::db_connect($persistent);

		if ( ! is_object($this->conn_id) OR is_bool($this->_quoted_identifier))
		{
			return $this->conn_id;
		}

		// Determine how identifiers are escaped
		$query = $this->query('SELECT CASE WHEN (@@OPTIONS | 256) = @@OPTIONS THEN 1 ELSE 0 END AS qi');
		$query = $query->row_array();
		$this->_quoted_identifier = empty($query) ? FALSE : (bool) $query['qi'];
		$this->_escape_char = ($this->_quoted_identifier) ? '"' : array('[', ']');

		return $this->conn_id;
	}

	// --------------------------------------------------------------------

	/**
	 * Show table query
	 *
	 * Generates a platform-specific query string so that the table names can be fetched
	 *
	 * @param	bool	$prefix_limit
	 * @return	string
	 */
	protected function _list_tables($prefix_limit = FALSE)
	{
		$sql = 'SELECT '.$this->escape_identifiers('name')
			.' FROM '.$this->escape_identifiers('sysobjects')
			.' WHERE '.$this->escape_identifiers('type')." = 'U'";

		if ($prefix_limit === TRUE && $this->dbprefix !== '')
		{
			$sql .= ' AND '.$this->escape_identifiers('name')." LIKE '".$this->escape_like_str($this->dbprefix)."%' "
				.sprintf($this->_like_escape_str, $this->_like_escape_chr);
		}

		return $sql.' ORDER BY '.$this->escape_identifiers('name');
	}

	// --------------------------------------------------------------------

	/**
	 * Show column query
	 *
	 * Generates a platform-specific query string so that the column names can be fetched
	 *
	 * @param	string	$table
	 * @return	string
	 */
	protected function _list_columns($table = '')
	{
		return 'SELECT COLUMN_NAME
			FROM INFORMATION_SCHEMA.Columns
			WHERE UPPER(TABLE_NAME) = '.$this->escape(strtoupper($table));
	}

	// --------------------------------------------------------------------

	/**
	 * Returns an object with field data
	 *
	 * @param	string	$table
	 * @return	array
	 */
	public function field_data($table)
	{
		$sql = 'SELECT COLUMN_NAME, DATA_TYPE, CHARACTER_MAXIMUM_LENGTH, NUMERIC_PRECISION, COLUMN_DEFAULT
			FROM INFORMATION_SCHEMA.Columns
			WHERE UPPER(TABLE_NAME) = '.$this->escape(strtoupper($table));

		if (($query = $this->query($sql)) === FALSE)
		{
			return FALSE;
		}
		$query = $query->result_object();

		$retval = array();
		for ($i = 0, $c = count($query); $i < $c; $i++)
		{
			$retval[$i]			= new stdClass();
			$retval[$i]->name		= $query[$i]->COLUMN_NAME;
			$retval[$i]->type		= $query[$i]->DATA_TYPE;
			$retval[$i]->max_length		= ($query[$i]->CHARACTER_MAXIMUM_LENGTH > 0) ? $query[$i]->CHARACTER_MAXIMUM_LENGTH : $query[$i]->NUMERIC_PRECISION;
			$retval[$i]->default		= $query[$i]->COLUMN_DEFAULT;
		}

		return $retval;
	}

	// --------------------------------------------------------------------

	/**
	 * Update statement
	 *
	 * Generates a platform-specific update string from the supplied data
	 *
	 * @param	string	$table
	 * @param	array	$values
	 * @return	string
	 */
	protected function _update($table, $values)
	{
		$this->qb_limit = FALSE;
		$this->qb_orderby = array();
		return parent::_update($table, $values);
	}

	// --------------------------------------------------------------------

	/**
	 * Delete statement
	 *
	 * Generates a platform-specific delete string from the supplied data
	 *
	 * @param	string	$table
	 * @return	string
	 */
	protected function _delete($table)
	{
		if ($this->qb_limit)
		{
			return 'WITH ci_delete AS (SELECT TOP '.$this->qb_limit.' * FROM '.$table.$this->_compile_wh('qb_where').') DELETE FROM ci_delete';
		}

		return parent::_delete($table);
	}

	// --------------------------------------------------------------------

	/**
	 * LIMIT
	 *
	 * Generates a platform-specific LIMIT clause
	 *
	 * @param	string	$sql	SQL Query
	 * @return	string
	 */
	protected function _limit($sql)
	{
		// As of SQL Server 2012 (11.0.*) OFFSET is supported
		if (version_compare($this->version(), '11', '>='))
		{
			// SQL Server OFFSET-FETCH can be used only with the ORDER BY clause
			empty($this->qb_orderby) && $sql .= ' ORDER BY 1';

			return $sql.' OFFSET '.(int) $this->qb_offset.' ROWS FETCH NEXT '.$this->qb_limit.' ROWS ONLY';
		}

		$limit = $this->qb_offset + $this->qb_limit;

		// An ORDER BY clause is required for ROW_NUMBER() to work
		if ($this->qb_offset && ! empty($this->qb_orderby))
		{
			$orderby = $this->_compile_order_by();

			// We have to strip the ORDER BY clause
			$sql = trim(substr($sql, 0, strrpos($sql, $orderby)));

			// Get the fields to select from our subquery, so that we can avoid CI_rownum appearing in the actual results
			if (count($this->qb_select) === 0)
			{
				$select = '*'; // Inevitable
			}
			else
			{
				// Use only field names and their aliases, everything else is out of our scope.
				$select = array();
				$field_regexp = ($this->_quoted_identifier)
					? '("[^\"]+")' : '(\[[^\]]+\])';
				for ($i = 0, $c = count($this->qb_select); $i < $c; $i++)
				{
					$select[] = preg_match('/(?:\s|\.)'.$field_regexp.'$/i', $this->qb_select[$i], $m)
						? $m[1] : $this->qb_select[$i];
				}
				$select = implode(', ', $select);
			}

			return 'SELECT '.$select." FROM (\n\n"
				.preg_replace('/^(SELECT( DISTINCT)?)/i', '\\1 ROW_NUMBER() OVER('.trim($orderby).') AS '.$this->escape_identifiers('CI_rownum').', ', $sql)
				."\n\n) ".$this->escape_identifiers('CI_subquery')
				."\nWHERE ".$this->escape_identifiers('CI_rownum').' BETWEEN '.($this->qb_offset + 1).' AND '.$limit;
		}

		return preg_replace('/(^\SELECT (DISTINCT)?)/i','\\1 TOP '.$limit.' ', $sql);
	}

	// --------------------------------------------------------------------

	/**
	 * Insert batch statement
	 *
	 * Generates a platform-specific insert string from the supplied data.
	 *
	 * @param	string	$table	Table name
	 * @param	array	$keys	INSERT keys
	 * @param	array	$values	INSERT values
	 * @return	string|bool
	 */
	protected function _insert_batch($table, $keys, $values)
	{
		// Multiple-value inserts are only supported as of SQL Server 2008
		if (version_compare($this->version(), '10', '>='))
		{
			return parent::_insert_batch($table, $keys, $values);
		}

		return ($this->db->db_debug) ? $this->db->display_error('db_unsupported_feature') : FALSE;
	}

}


1		<?php
		0 ignored issues – show Coding Style Compatibility introduced 2016-02-16 16:43 UTC by Report Bug Copy Issue Report For compatibility and reusability of your code, PSR1 recommends that a file should introduce either new symbols (like classes, functions, etc.) or have side-effects (like outputting something, or including other files), but not both at the same time. The first symbol is defined on line 53 and the first side effect is on line 38. The PSR-1: Basic Coding Standard recommends that a file should either introduce new symbols, that is classes, functions, constants or similar, or have side effects. Side effects are anything that executes logic, like for example printing output, changing ini settings or writing to a file. The idea behind this recommendation is that merely auto-loading a class should not change the state of an application. It also promotes a cleaner style of programming and makes your code less prone to errors, because the logic is not spread out all over the place. To learn more about the PSR-1, please see the PHP-FIG site on the PSR-1. Loading history...
2		/**
3		* CodeIgniter
4		*
5		* An open source application development framework for PHP
6		*
7		* This content is released under the MIT License (MIT)
8		*
9		* Copyright (c) 2014 - 2015, British Columbia Institute of Technology
10		*
11		* Permission is hereby granted, free of charge, to any person obtaining a copy
12		* of this software and associated documentation files (the "Software"), to deal
13		* in the Software without restriction, including without limitation the rights
14		* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
15		* copies of the Software, and to permit persons to whom the Software is
16		* furnished to do so, subject to the following conditions:
17		*
18		* The above copyright notice and this permission notice shall be included in
19		* all copies or substantial portions of the Software.
20		*
21		* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
22		* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
23		* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
24		* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
25		* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
26		* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
27		* THE SOFTWARE.
28		*
29		* @package CodeIgniter
30		* @author EllisLab Dev Team
31		* @copyright Copyright (c) 2008 - 2014, EllisLab, Inc. (http://ellislab.com/)
32		* @copyright Copyright (c) 2014 - 2015, British Columbia Institute of Technology (http://bcit.ca/)
33		* @license http://opensource.org/licenses/MIT MIT License
34		* @link http://codeigniter.com
35		* @since Version 3.0.0
36		* @filesource
37		*/
38		defined('BASEPATH') OR exit('No direct script access allowed');
39
40		/**
41		* PDO SQLSRV Database Adapter Class
42		*
43		* Note: _DB is an extender class that the app controller
44		* creates dynamically based on whether the query builder
45		* class is being used or not.
46		*
47		* @package CodeIgniter
48		* @subpackage Drivers
49		* @category Database
50		* @author EllisLab Dev Team
51		* @link http://codeigniter.com/user_guide/database/
52		*/
53		class CI_DB_pdo_sqlsrv_driver extends CI_DB_pdo_driver {
54
55		/**
56		* Sub-driver
57		*
58		* @var string
59		*/
60		public $subdriver = 'sqlsrv';
61
62		// --------------------------------------------------------------------
63
64		/**
65		* ORDER BY random keyword
66		*
67		* @var array
68		*/
69		protected $_random_keyword = array('NEWID()', 'RAND(%d)');
70
71		/**
72		* Quoted identifier flag
73		*
74		* Whether to use SQL-92 standard quoted identifier
75		* (double quotes) or brackets for identifier escaping.
76		*
77		* @var bool
78		*/
79		protected $_quoted_identifier;
80
81		// --------------------------------------------------------------------
82
83		/**
84		* Class constructor
85		*
86		* Builds the DSN if not already set.
87		*
88		* @param array $params
89		* @return void
90		*/
91		public function __construct($params)
92		{
93		parent::__construct($params);
94
95		if (empty($this->dsn))
96		{
97		$this->dsn = 'sqlsrv:Server='.(empty($this->hostname) ? '127.0.0.1' : $this->hostname);
98
99		empty($this->port) OR $this->dsn .= ','.$this->port;
100		empty($this->database) OR $this->dsn .= ';Database='.$this->database;
101
102		// Some custom options
103
104		if (isset($this->QuotedId))
105		{
106		$this->dsn .= ';QuotedId='.$this->QuotedId;
107		$this->_quoted_identifier = (bool) $this->QuotedId;
108		}
109
110		if (isset($this->ConnectionPooling))
111		{
112		$this->dsn .= ';ConnectionPooling='.$this->ConnectionPooling;
113		}
114
115		if ($this->encrypt === TRUE)
116		{
117		$this->dsn .= ';Encrypt=1';
118		}
119
120		if (isset($this->TraceOn))
121		{
122		$this->dsn .= ';TraceOn='.$this->TraceOn;
123		}
124
125		if (isset($this->TrustServerCertificate))
126		{
127		$this->dsn .= ';TrustServerCertificate='.$this->TrustServerCertificate;
128		}
129
130		empty($this->APP) OR $this->dsn .= ';APP='.$this->APP;
131		empty($this->Failover_Partner) OR $this->dsn .= ';Failover_Partner='.$this->Failover_Partner;
132		empty($this->LoginTimeout) OR $this->dsn .= ';LoginTimeout='.$this->LoginTimeout;
133		empty($this->MultipleActiveResultSets) OR $this->dsn .= ';MultipleActiveResultSets='.$this->MultipleActiveResultSets;
134		empty($this->TraceFile) OR $this->dsn .= ';TraceFile='.$this->TraceFile;
135		empty($this->WSID) OR $this->dsn .= ';WSID='.$this->WSID;
136		}
137		elseif (preg_match('/QuotedId=(0\|1)/', $this->dsn, $match))
138		{
139		$this->_quoted_identifier = (bool) $match[1];
140		}
141		}
142
143		// --------------------------------------------------------------------
144
145		/**
146		* Database connection
147		*
148		* @param bool $persistent
149		* @return object
150		*/
151		public function db_connect($persistent = FALSE)
152		{
153		if ( ! empty($this->char_set) && preg_match('/utf[^8]*8/i', $this->char_set))
154		{
155		$this->options[PDO::SQLSRV_ENCODING_UTF8] = 1;
156		}
157
158		$this->conn_id = parent::db_connect($persistent);
159
160		if ( ! is_object($this->conn_id) OR is_bool($this->_quoted_identifier))
161		{
162		return $this->conn_id;
163		}
164
165		// Determine how identifiers are escaped
166		$query = $this->query('SELECT CASE WHEN (@@OPTIONS \| 256) = @@OPTIONS THEN 1 ELSE 0 END AS qi');
167		$query = $query->row_array();
168		$this->_quoted_identifier = empty($query) ? FALSE : (bool) $query['qi'];
169		$this->_escape_char = ($this->_quoted_identifier) ? '"' : array('[', ']');
170
171		return $this->conn_id;
172		}
173
174		// --------------------------------------------------------------------
175
176		/**
177		* Show table query
178		*
179		* Generates a platform-specific query string so that the table names can be fetched
180		*
181		* @param bool $prefix_limit
182		* @return string
183		*/
184	View Code Duplication	protected function _list_tables($prefix_limit = FALSE)
185		{
186		$sql = 'SELECT '.$this->escape_identifiers('name')
187		.' FROM '.$this->escape_identifiers('sysobjects')
188		.' WHERE '.$this->escape_identifiers('type')." = 'U'";
189
190		if ($prefix_limit === TRUE && $this->dbprefix !== '')
191		{
192		$sql .= ' AND '.$this->escape_identifiers('name')." LIKE '".$this->escape_like_str($this->dbprefix)."%' "
193		.sprintf($this->_like_escape_str, $this->_like_escape_chr);
194		}
195
196		return $sql.' ORDER BY '.$this->escape_identifiers('name');
197		}
198
199		// --------------------------------------------------------------------
200
201		/**
202		* Show column query
203		*
204		* Generates a platform-specific query string so that the column names can be fetched
205		*
206		* @param string $table
207		* @return string
208		*/
209		protected function _list_columns($table = '')
210		{
211		return 'SELECT COLUMN_NAME
212		FROM INFORMATION_SCHEMA.Columns
213		WHERE UPPER(TABLE_NAME) = '.$this->escape(strtoupper($table));
214		}
215
216		// --------------------------------------------------------------------
217
218		/**
219		* Returns an object with field data
220		*
221		* @param string $table
222		* @return array
223		*/
224	View Code Duplication	public function field_data($table)
225		{
226		$sql = 'SELECT COLUMN_NAME, DATA_TYPE, CHARACTER_MAXIMUM_LENGTH, NUMERIC_PRECISION, COLUMN_DEFAULT
227		FROM INFORMATION_SCHEMA.Columns
228		WHERE UPPER(TABLE_NAME) = '.$this->escape(strtoupper($table));
229
230		if (($query = $this->query($sql)) === FALSE)
231		{
232		return FALSE;
233		}
234		$query = $query->result_object();
235
236		$retval = array();
237		for ($i = 0, $c = count($query); $i < $c; $i++)
238		{
239		$retval[$i] = new stdClass();
240		$retval[$i]->name = $query[$i]->COLUMN_NAME;
241		$retval[$i]->type = $query[$i]->DATA_TYPE;
242		$retval[$i]->max_length = ($query[$i]->CHARACTER_MAXIMUM_LENGTH > 0) ? $query[$i]->CHARACTER_MAXIMUM_LENGTH : $query[$i]->NUMERIC_PRECISION;
243		$retval[$i]->default = $query[$i]->COLUMN_DEFAULT;
244		}
245
246		return $retval;
247		}
248
249		// --------------------------------------------------------------------
250
251		/**
252		* Update statement
253		*
254		* Generates a platform-specific update string from the supplied data
255		*
256		* @param string $table
257		* @param array $values
258		* @return string
259		*/
260		protected function _update($table, $values)
261		{
262		$this->qb_limit = FALSE;
263		$this->qb_orderby = array();
264		return parent::_update($table, $values);
265		}
266
267		// --------------------------------------------------------------------
268
269		/**
270		* Delete statement
271		*
272		* Generates a platform-specific delete string from the supplied data
273		*
274		* @param string $table
275		* @return string
276		*/
277	View Code Duplication	protected function _delete($table)
278		{
279		if ($this->qb_limit)
280		{
281		return 'WITH ci_delete AS (SELECT TOP '.$this->qb_limit.' * FROM '.$table.$this->_compile_wh('qb_where').') DELETE FROM ci_delete';
282		}
283
284		return parent::_delete($table);
285		}
286
287		// --------------------------------------------------------------------
288
289		/**
290		* LIMIT
291		*
292		* Generates a platform-specific LIMIT clause
293		*
294		* @param string $sql SQL Query
295		* @return string
296		*/
297	View Code Duplication	protected function _limit($sql)
298		{
299		// As of SQL Server 2012 (11.0.*) OFFSET is supported
300		if (version_compare($this->version(), '11', '>='))
301		{
302		// SQL Server OFFSET-FETCH can be used only with the ORDER BY clause
303		empty($this->qb_orderby) && $sql .= ' ORDER BY 1';
304
305		return $sql.' OFFSET '.(int) $this->qb_offset.' ROWS FETCH NEXT '.$this->qb_limit.' ROWS ONLY';
306		}
307
308		$limit = $this->qb_offset + $this->qb_limit;
309
310		// An ORDER BY clause is required for ROW_NUMBER() to work
311		if ($this->qb_offset && ! empty($this->qb_orderby))
312		{
313		$orderby = $this->_compile_order_by();
314
315		// We have to strip the ORDER BY clause
316		$sql = trim(substr($sql, 0, strrpos($sql, $orderby)));
317
318		// Get the fields to select from our subquery, so that we can avoid CI_rownum appearing in the actual results
319		if (count($this->qb_select) === 0)
320		{
321		$select = '*'; // Inevitable
322		}
323		else
324		{
325		// Use only field names and their aliases, everything else is out of our scope.
326		$select = array();
327		$field_regexp = ($this->_quoted_identifier)
328		? '("[^\"]+")' : '(\[[^\]]+\])';
329		for ($i = 0, $c = count($this->qb_select); $i < $c; $i++)
330		{
331		$select[] = preg_match('/(?:\s\|\.)'.$field_regexp.'$/i', $this->qb_select[$i], $m)
332		? $m[1] : $this->qb_select[$i];
333		}
334		$select = implode(', ', $select);
335		}
336
337		return 'SELECT '.$select." FROM (\n\n"
338		.preg_replace('/^(SELECT( DISTINCT)?)/i', '\\1 ROW_NUMBER() OVER('.trim($orderby).') AS '.$this->escape_identifiers('CI_rownum').', ', $sql)
339		."\n\n) ".$this->escape_identifiers('CI_subquery')
340		."\nWHERE ".$this->escape_identifiers('CI_rownum').' BETWEEN '.($this->qb_offset + 1).' AND '.$limit;
341		}
342
343		return preg_replace('/(^\SELECT (DISTINCT)?)/i','\\1 TOP '.$limit.' ', $sql);
344		}
345
346		// --------------------------------------------------------------------
347
348		/**
349		* Insert batch statement
350		*
351		* Generates a platform-specific insert string from the supplied data.
352		*
353		* @param string $table Table name
354		* @param array $keys INSERT keys
355		* @param array $values INSERT values
356		* @return string\|bool
357		*/
358	View Code Duplication	protected function _insert_batch($table, $keys, $values)
359		{
360		// Multiple-value inserts are only supported as of SQL Server 2008
361		if (version_compare($this->version(), '10', '>='))
362		{
363		return parent::_insert_batch($table, $keys, $values);
364		}
365
366		return ($this->db->db_debug) ? $this->db->display_error('db_unsupported_feature') : FALSE;
367		}
368
369		}
370

ci-bonfire / Sprint

GitHub Access Token became invalid

CI_DB_pdo_sqlsrv_driver B last analyzed 2016-08-09 21:23 UTC