16990778495

Committed 15 Aug 2025 01:16PM UTC coverage: 84.242% (-0.004%) from 84.246%

Build # 16990778495

Build Type

Pull #9677

github

Committed by

web-flow

Commit Message

Merge 7e8492afe into 5d8baed23

Pull Request Pull Request #9677: feat: uniform rendering of stack trace from failed DB operations

Run Details

70 of 72 new or added lines in 7 files covered. (97.22%)

6 existing lines in 1 file now uncovered.

20929 of 24844 relevant lines covered (84.24%)

194.44 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

77.47

/system/Database/SQLSRV/Connection.php

<?php

declare(strict_types=1);

/**
 * This file is part of CodeIgniter 4 framework.
 *
 * (c) CodeIgniter Foundation <admin@codeigniter.com>
 *
 * For the full copyright and license information, please view
 * the LICENSE file that was distributed with this source code.
 */

namespace CodeIgniter\Database\SQLSRV;

use CodeIgniter\Database\BaseConnection;
use CodeIgniter\Database\Exceptions\DatabaseException;
use CodeIgniter\Database\TableName;
use stdClass;

/**
 * Connection for SQLSRV
 *
 * @extends BaseConnection<resource, resource>
 */
class Connection extends BaseConnection
{
    /**
     * Database driver
     *
     * @var string
     */
    public $DBDriver = 'SQLSRV';

    /**
     * Database name
     *
     * @var string
     */
    public $database;

    /**
     * Scrollable flag
     *
     * Determines what cursor type to use when executing queries.
     *
     * FALSE or SQLSRV_CURSOR_FORWARD would increase performance,
     * but would disable num_rows() (and possibly insert_id())
     *
     * @var false|string
     */
    public $scrollable;

    /**
     * Identifier escape character
     *
     * @var string
     */
    public $escapeChar = '"';

    /**
     * Database schema
     *
     * @var string
     */
    public $schema = 'dbo';

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

    /**
     * List of reserved identifiers
     *
     * Identifiers that must NOT be escaped.
     *
     * @var list<string>
     */
    protected $_reserved_identifiers = ['*'];

    /**
     * Class constructor
     */
    public function __construct(array $params)
    {
        parent::__construct($params);

        // This is only supported as of SQLSRV 3.0
        if ($this->scrollable === null) {
            $this->scrollable = defined('SQLSRV_CURSOR_CLIENT_BUFFERED') ? SQLSRV_CURSOR_CLIENT_BUFFERED : false;
        }
    }

    /**
     * Connect to the database.
     *
     * @return false|resource
     *
     * @throws DatabaseException
     */
    public function connect(bool $persistent = false)
    {
        $charset = in_array(strtolower($this->charset), ['utf-8', 'utf8'], true) ? 'UTF-8' : SQLSRV_ENC_CHAR;

        $connection = [
            'UID'                  => empty($this->username) ? '' : $this->username,
            'PWD'                  => empty($this->password) ? '' : $this->password,
            'Database'             => $this->database,
            'ConnectionPooling'    => $persistent ? 1 : 0,
            'CharacterSet'         => $charset,
            'Encrypt'              => $this->encrypt === true ? 1 : 0,
            'ReturnDatesAsStrings' => 1,
        ];

        // If the username and password are both empty, assume this is a
        // 'Windows Authentication Mode' connection.
        if (empty($connection['UID']) && empty($connection['PWD'])) {
            unset($connection['UID'], $connection['PWD']);
        }

        if (! str_contains($this->hostname, ',') && $this->port !== '') {
            $this->hostname .= ', ' . $this->port;
        }

        sqlsrv_configure('WarningsReturnAsErrors', 0);
        $this->connID = sqlsrv_connect($this->hostname, $connection);

        if ($this->connID !== false) {
            // Determine how identifiers are escaped
            $query = $this->query('SELECT CASE WHEN (@@OPTIONS | 256) = @@OPTIONS THEN 1 ELSE 0 END AS qi');
            $query = $query->getResultObject();

            $this->_quoted_identifier = empty($query) ? false : (bool) $query[0]->qi;
            $this->escapeChar         = ($this->_quoted_identifier) ? '"' : ['[', ']'];

            return $this->connID;
        }

        throw new DatabaseException($this->getAllErrorMessages());
    }

    /**
     * For exception message
     *
     * @internal
     */
    public function getAllErrorMessages(): string
    {
        $errors = [];

        foreach (sqlsrv_errors() as $error) {
            $errors[] = sprintf(
                '%s SQLSTATE: %s, code: %s',
                $error['message'],
                $error['SQLSTATE'],
                $error['code'],
            );
        }

        return implode("\n", $errors);
    }

    /**
     * Keep or establish the connection if no queries have been sent for
     * a length of time exceeding the server's idle timeout.
     *
     * @return void
     */
    public function reconnect()
    {
        $this->close();
        $this->initialize();
    }

    /**
     * Close the database connection.
     *
     * @return void
     */
    protected function _close()
    {
        sqlsrv_close($this->connID);
    }

    /**
     * Platform-dependant string escape
     */
    protected function _escapeString(string $str): string
    {
        return str_replace("'", "''", remove_invisible_characters($str, false));
    }

    /**
     * Insert ID
     */
    public function insertID(): int
    {
        return (int) ($this->query('SELECT SCOPE_IDENTITY() AS insert_id')->getRow()->insert_id ?? 0);
    }

    /**
     * Generates the SQL for listing tables in a platform-dependent manner.
     *
     * @param string|null $tableName If $tableName is provided will return only this table if exists.
     */
    protected function _listTables(bool $prefixLimit = false, ?string $tableName = null): string
    {
        $sql = 'SELECT [TABLE_NAME] AS "name"'
            . ' FROM [INFORMATION_SCHEMA].[TABLES] '
            . ' WHERE '
            . " [TABLE_SCHEMA] = '" . $this->schema . "'    ";

        if ($tableName !== null) {
            return $sql .= ' AND [TABLE_NAME] LIKE ' . $this->escape($tableName);
        }

        if ($prefixLimit && $this->DBPrefix !== '') {
            $sql .= " AND [TABLE_NAME] LIKE '" . $this->escapeLikeString($this->DBPrefix) . "%' "
                . sprintf($this->likeEscapeStr, $this->likeEscapeChar);
        }

        return $sql;
    }

    /**
     * Generates a platform-specific query string so that the column names can be fetched.
     *
     * @param string|TableName $table
     */
    protected function _listColumns($table = ''): string
    {
        if ($table instanceof TableName) {
            $tableName = $this->escape(strtolower($table->getActualTableName()));
        } else {
            $tableName = $this->escape($this->DBPrefix . strtolower($table));
        }

        return 'SELECT [COLUMN_NAME] '
            . ' FROM [INFORMATION_SCHEMA].[COLUMNS]'
            . ' WHERE  [TABLE_NAME] = ' . $tableName
            . ' AND [TABLE_SCHEMA] = ' . $this->escape($this->schema);
    }

    /**
     * Returns an array of objects with index data
     *
     * @return array<string, stdClass>
     *
     * @throws DatabaseException
     */
    protected function _indexData(string $table): array
    {
        $sql = 'EXEC sp_helpindex ' . $this->escape($this->schema . '.' . $table);

        if (($query = $this->query($sql)) === false) {
            throw new DatabaseException(lang('Database.failGetIndexData'));
        }
        $query = $query->getResultObject();

        $retVal = [];

        foreach ($query as $row) {
            $obj       = new stdClass();
            $obj->name = $row->index_name;

            $_fields     = explode(',', trim($row->index_keys));
            $obj->fields = array_map(static fn ($v): string => trim($v), $_fields);

            if (str_contains($row->index_description, 'primary key located on')) {
                $obj->type = 'PRIMARY';
            } else {
                $obj->type = (str_contains($row->index_description, 'nonclustered, unique')) ? 'UNIQUE' : 'INDEX';
            }

            $retVal[$obj->name] = $obj;
        }

        return $retVal;
    }

    /**
     * Returns an array of objects with Foreign key data
     * referenced_object_id  parent_object_id
     *
     * @return array<string, stdClass>
     *
     * @throws DatabaseException
     */
    protected function _foreignKeyData(string $table): array
    {
        $sql = 'SELECT
                f.name as constraint_name,
                OBJECT_NAME (f.parent_object_id) as table_name,
                COL_NAME(fc.parent_object_id,fc.parent_column_id) column_name,
                OBJECT_NAME(f.referenced_object_id) foreign_table_name,
                COL_NAME(fc.referenced_object_id,fc.referenced_column_id) foreign_column_name,
                rc.delete_rule,
                rc.update_rule,
                rc.match_option
                FROM
                sys.foreign_keys AS f
                INNER JOIN sys.foreign_key_columns AS fc ON f.OBJECT_ID = fc.constraint_object_id
                INNER JOIN sys.tables t ON t.OBJECT_ID = fc.referenced_object_id
                INNER JOIN INFORMATION_SCHEMA.REFERENTIAL_CONSTRAINTS rc ON rc.CONSTRAINT_NAME = f.name
                WHERE OBJECT_NAME (f.parent_object_id) = ' . $this->escape($table);

        if (($query = $this->query($sql)) === false) {
            throw new DatabaseException(lang('Database.failGetForeignKeyData'));
        }

        $query   = $query->getResultObject();
        $indexes = [];

        foreach ($query as $row) {
            $indexes[$row->constraint_name]['constraint_name']       = $row->constraint_name;
            $indexes[$row->constraint_name]['table_name']            = $row->table_name;
            $indexes[$row->constraint_name]['column_name'][]         = $row->column_name;
            $indexes[$row->constraint_name]['foreign_table_name']    = $row->foreign_table_name;
            $indexes[$row->constraint_name]['foreign_column_name'][] = $row->foreign_column_name;
            $indexes[$row->constraint_name]['on_delete']             = $row->delete_rule;
            $indexes[$row->constraint_name]['on_update']             = $row->update_rule;
            $indexes[$row->constraint_name]['match']                 = $row->match_option;
        }

        return $this->foreignKeyDataToObjects($indexes);
    }

    /**
     * Disables foreign key checks temporarily.
     *
     * @return string
     */
    protected function _disableForeignKeyChecks()
    {
        return 'EXEC sp_MSforeachtable "ALTER TABLE ? NOCHECK CONSTRAINT ALL"';
    }

    /**
     * Enables foreign key checks temporarily.
     *
     * @return string
     */
    protected function _enableForeignKeyChecks()
    {
        return 'EXEC sp_MSforeachtable "ALTER TABLE ? WITH CHECK CHECK CONSTRAINT ALL"';
    }

    /**
     * Returns an array of objects with field data
     *
     * @return list<stdClass>
     *
     * @throws DatabaseException
     */
    protected function _fieldData(string $table): array
    {
        $sql = 'SELECT
                COLUMN_NAME, DATA_TYPE, CHARACTER_MAXIMUM_LENGTH, NUMERIC_PRECISION,
                COLUMN_DEFAULT, IS_NULLABLE
            FROM INFORMATION_SCHEMA.COLUMNS
            WHERE TABLE_NAME= ' . $this->escape(($table));

        if (($query = $this->query($sql)) === false) {
            throw new DatabaseException(lang('Database.failGetFieldData'));
        }

        $query  = $query->getResultObject();
        $retVal = [];

        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]->CHARACTER_MAXIMUM_LENGTH === -1
                    ? 'max'
                    : $query[$i]->NUMERIC_PRECISION
                );

            $retVal[$i]->nullable = $query[$i]->IS_NULLABLE !== 'NO';
            $retVal[$i]->default  = $query[$i]->COLUMN_DEFAULT;
        }

        return $retVal;
    }

    /**
     * Begin Transaction
     */
    protected function _transBegin(): bool
    {
        return sqlsrv_begin_transaction($this->connID);
    }

    /**
     * Commit Transaction
     */
    protected function _transCommit(): bool
    {
        return sqlsrv_commit($this->connID);
    }

    /**
     * Rollback Transaction
     */
    protected function _transRollback(): bool
    {
        return sqlsrv_rollback($this->connID);
    }

    /**
     * Returns the last error code and message.
     * Must return this format: ['code' => string|int, 'message' => string]
     * intval(code) === 0 means "no error".
     *
     * @return array<string, int|string>
     */
    public function error(): array
    {
        $error = [
            'code'    => '00000',
            'message' => '',
        ];

        $sqlsrvErrors = sqlsrv_errors(SQLSRV_ERR_ERRORS);

        if (! is_array($sqlsrvErrors)) {
            return $error;
        }

        $sqlsrvError = array_shift($sqlsrvErrors);
        if (isset($sqlsrvError['SQLSTATE'])) {
            $error['code'] = isset($sqlsrvError['code']) ? $sqlsrvError['SQLSTATE'] . '/' . $sqlsrvError['code'] : $sqlsrvError['SQLSTATE'];
        } elseif (isset($sqlsrvError['code'])) {
            $error['code'] = $sqlsrvError['code'];
        }

        if (isset($sqlsrvError['message'])) {
            $error['message'] = $sqlsrvError['message'];
        }

        return $error;
    }

    /**
     * Returns the total number of rows affected by this query.
     */
    public function affectedRows(): int
    {
        if ($this->resultID === false) {
            return 0;
        }

        return sqlsrv_rows_affected($this->resultID);
    }

    /**
     * Select a specific database table to use.
     *
     * @return bool
     */
    public function setDatabase(?string $databaseName = null)
    {
        if ($databaseName === null || $databaseName === '') {
            $databaseName = $this->database;
        }

        if (empty($this->connID)) {
            $this->initialize();
        }

        if ($this->execute('USE ' . $this->_escapeString($databaseName))) {
            $this->database  = $databaseName;
            $this->dataCache = [];

            return true;
        }

        return false;
    }

    /**
     * Executes the query against the database.
     *
     * @return false|resource
     */
    protected function execute(string $sql)
    {
        $stmt = ($this->scrollable === false || $this->isWriteType($sql))
            ? sqlsrv_query($this->connID, $sql)
            : sqlsrv_query($this->connID, $sql, [], ['Scrollable' => $this->scrollable]);

        if ($stmt === false) {
            $trace = debug_backtrace();
            $first = array_shift($trace);

            log_message('error', "{message}\nin {exFile} on line {exLine}.\n{trace}", [
                'message' => $this->getAllErrorMessages(),
                'exFile'  => clean_path($first['file']),
                'exLine'  => $first['line'],
                'trace'   => render_backtrace($trace),
            ]);

            if ($this->DBDebug) {
                throw new DatabaseException($this->getAllErrorMessages());
            }
        }

        return $stmt;
    }

    /**
     * Returns the last error encountered by this connection.
     *
     * @return array<string, int|string>
     *
     * @deprecated Use `error()` instead.
     */
    public function getError()
    {
        $error = [
            'code'    => '00000',
            'message' => '',
        ];

        $sqlsrvErrors = sqlsrv_errors(SQLSRV_ERR_ERRORS);

        if (! is_array($sqlsrvErrors)) {
            return $error;
        }

        $sqlsrvError = array_shift($sqlsrvErrors);
        if (isset($sqlsrvError['SQLSTATE'])) {
            $error['code'] = isset($sqlsrvError['code']) ? $sqlsrvError['SQLSTATE'] . '/' . $sqlsrvError['code'] : $sqlsrvError['SQLSTATE'];
        } elseif (isset($sqlsrvError['code'])) {
            $error['code'] = $sqlsrvError['code'];
        }

        if (isset($sqlsrvError['message'])) {
            $error['message'] = $sqlsrvError['message'];
        }

        return $error;
    }

    /**
     * The name of the platform in use (MySQLi, mssql, etc)
     */
    public function getPlatform(): string
    {
        return $this->DBDriver;
    }

    /**
     * Returns a string containing the version of the database being used.
     */
    public function getVersion(): string
    {
        $info = [];
        if (isset($this->dataCache['version'])) {
            return $this->dataCache['version'];
        }

        if (! $this->connID) {
            $this->initialize();
        }

        if (($info = sqlsrv_server_info($this->connID)) === []) {
            return '';
        }

        return isset($info['SQLServerVersion']) ? $this->dataCache['version'] = $info['SQLServerVersion'] : '';
    }

    /**
     * Determines if a query is a "write" type.
     *
     * Overrides BaseConnection::isWriteType, adding additional read query types.
     *
     * @param string $sql
     */
    public function isWriteType($sql): bool
    {
        if (preg_match('/^\s*"?(EXEC\s*sp_rename)\s/i', $sql)) {
            return true;
        }

        return parent::isWriteType($sql);
    }
}

1	<?php
2
3	declare(strict_types=1);
4
5	/**
6	* This file is part of CodeIgniter 4 framework.
7	*
8	* (c) CodeIgniter Foundation <admin@codeigniter.com>
9	*
10	* For the full copyright and license information, please view
11	* the LICENSE file that was distributed with this source code.
12	*/
13
14	namespace CodeIgniter\Database\SQLSRV;
15
16	use CodeIgniter\Database\BaseConnection;
17	use CodeIgniter\Database\Exceptions\DatabaseException;
18	use CodeIgniter\Database\TableName;
19	use stdClass;
20
21	/**
22	* Connection for SQLSRV
23	*
24	* @extends BaseConnection<resource, resource>
25	*/
26	class Connection extends BaseConnection
27	{
28	/**
29	* Database driver
30	*
31	* @var string
32	*/
33	public $DBDriver = 'SQLSRV';
34
35	/**
36	* Database name
37	*
38	* @var string
39	*/
40	public $database;
41
42	/**
43	* Scrollable flag
44	*
45	* Determines what cursor type to use when executing queries.
46	*
47	* FALSE or SQLSRV_CURSOR_FORWARD would increase performance,
48	* but would disable num_rows() (and possibly insert_id())
49	*
50	* @var false\|string
51	*/
52	public $scrollable;
53
54	/**
55	* Identifier escape character
56	*
57	* @var string
58	*/
59	public $escapeChar = '"';
60
61	/**
62	* Database schema
63	*
64	* @var string
65	*/
66	public $schema = 'dbo';
67
68	/**
69	* Quoted identifier flag
70	*
71	* Whether to use SQL-92 standard quoted identifier
72	* (double quotes) or brackets for identifier escaping.
73	*
74	* @var bool
75	*/
76	protected $_quoted_identifier = true;
77
78	/**
79	* List of reserved identifiers
80	*
81	* Identifiers that must NOT be escaped.
82	*
83	* @var list<string>
84	*/
85	protected $_reserved_identifiers = ['*'];
86
87	/**
88	* Class constructor
89	*/
90	public function __construct(array $params)
91	{
92	parent::__construct($params);	25✔
93
94	// This is only supported as of SQLSRV 3.0
95	if ($this->scrollable === null) {	25✔
96	$this->scrollable = defined('SQLSRV_CURSOR_CLIENT_BUFFERED') ? SQLSRV_CURSOR_CLIENT_BUFFERED : false;	25✔
97	}
98	}
99
100	/**
101	* Connect to the database.
102	*
103	* @return false\|resource
104	*
105	* @throws DatabaseException
106	*/
107	public function connect(bool $persistent = false)
108	{
109	$charset = in_array(strtolower($this->charset), ['utf-8', 'utf8'], true) ? 'UTF-8' : SQLSRV_ENC_CHAR;	25✔
110
111	$connection = [	25✔
112	'UID' => empty($this->username) ? '' : $this->username,	25✔
113	'PWD' => empty($this->password) ? '' : $this->password,	25✔
114	'Database' => $this->database,	25✔
115	'ConnectionPooling' => $persistent ? 1 : 0,	25✔
116	'CharacterSet' => $charset,	25✔
117	'Encrypt' => $this->encrypt === true ? 1 : 0,	25✔
118	'ReturnDatesAsStrings' => 1,	25✔
119	];	25✔
120
121	// If the username and password are both empty, assume this is a
122	// 'Windows Authentication Mode' connection.
123	if (empty($connection['UID']) && empty($connection['PWD'])) {	25✔
124	unset($connection['UID'], $connection['PWD']);	×
125	}
126
127	if (! str_contains($this->hostname, ',') && $this->port !== '') {	25✔
128	$this->hostname .= ', ' . $this->port;	24✔
129	}
130
131	sqlsrv_configure('WarningsReturnAsErrors', 0);	25✔
132	$this->connID = sqlsrv_connect($this->hostname, $connection);	25✔
133
134	if ($this->connID !== false) {	25✔
135	// Determine how identifiers are escaped
136	$query = $this->query('SELECT CASE WHEN (@@OPTIONS \| 256) = @@OPTIONS THEN 1 ELSE 0 END AS qi');	25✔
137	$query = $query->getResultObject();	24✔
138
139	$this->_quoted_identifier = empty($query) ? false : (bool) $query[0]->qi;	24✔
140	$this->escapeChar = ($this->_quoted_identifier) ? '"' : ['[', ']'];	24✔
141
142	return $this->connID;	24✔
143	}
144
145	throw new DatabaseException($this->getAllErrorMessages());	1✔
146	}
147
148	/**
149	* For exception message
150	*
151	* @internal
152	*/
153	public function getAllErrorMessages(): string
154	{
155	$errors = [];	33✔
156
157	foreach (sqlsrv_errors() as $error) {	33✔
158	$errors[] = sprintf(	33✔
159	'%s SQLSTATE: %s, code: %s',	33✔
160	$error['message'],	33✔
161	$error['SQLSTATE'],	33✔
162	$error['code'],	33✔
163	);	33✔
164	}
165
166	return implode("\n", $errors);	33✔
167	}
168
169	/**
170	* Keep or establish the connection if no queries have been sent for
171	* a length of time exceeding the server's idle timeout.
172	*
173	* @return void
174	*/
175	public function reconnect()
176	{
177	$this->close();	×
178	$this->initialize();	×
179	}
180
181	/**
182	* Close the database connection.
183	*
184	* @return void
185	*/
186	protected function _close()
187	{
188	sqlsrv_close($this->connID);	1✔
189	}
190
191	/**
192	* Platform-dependant string escape
193	*/
194	protected function _escapeString(string $str): string
195	{
196	return str_replace("'", "''", remove_invisible_characters($str, false));	648✔
197	}
198
199	/**
200	* Insert ID
201	*/
202	public function insertID(): int
203	{
204	return (int) ($this->query('SELECT SCOPE_IDENTITY() AS insert_id')->getRow()->insert_id ?? 0);	79✔
205	}
206
207	/**
208	* Generates the SQL for listing tables in a platform-dependent manner.
209	*
210	* @param string\|null $tableName If $tableName is provided will return only this table if exists.
211	*/
212	protected function _listTables(bool $prefixLimit = false, ?string $tableName = null): string
213	{
214	$sql = 'SELECT [TABLE_NAME] AS "name"'	593✔
215	. ' FROM [INFORMATION_SCHEMA].[TABLES] '	593✔
216	. ' WHERE '	593✔
217	. " [TABLE_SCHEMA] = '" . $this->schema . "' ";	593✔
218
219	if ($tableName !== null) {	593✔
220	return $sql .= ' AND [TABLE_NAME] LIKE ' . $this->escape($tableName);	593✔
221	}
222
223	if ($prefixLimit && $this->DBPrefix !== '') {	32✔
224	$sql .= " AND [TABLE_NAME] LIKE '" . $this->escapeLikeString($this->DBPrefix) . "%' "	×
225	. sprintf($this->likeEscapeStr, $this->likeEscapeChar);	×
226	}
227
228	return $sql;	32✔
229	}
230
231	/**
232	* Generates a platform-specific query string so that the column names can be fetched.
233	*
234	* @param string\|TableName $table
235	*/
236	protected function _listColumns($table = ''): string
237	{
238	if ($table instanceof TableName) {	8✔
239	$tableName = $this->escape(strtolower($table->getActualTableName()));	2✔
240	} else {
241	$tableName = $this->escape($this->DBPrefix . strtolower($table));	6✔
242	}
243
244	return 'SELECT [COLUMN_NAME] '	8✔
245	. ' FROM [INFORMATION_SCHEMA].[COLUMNS]'	8✔
246	. ' WHERE [TABLE_NAME] = ' . $tableName	8✔
247	. ' AND [TABLE_SCHEMA] = ' . $this->escape($this->schema);	8✔
248	}
249
250	/**
251	* Returns an array of objects with index data
252	*
253	* @return array<string, stdClass>
254	*
255	* @throws DatabaseException
256	*/
257	protected function _indexData(string $table): array
258	{
259	$sql = 'EXEC sp_helpindex ' . $this->escape($this->schema . '.' . $table);	39✔
260
261	if (($query = $this->query($sql)) === false) {	39✔
262	throw new DatabaseException(lang('Database.failGetIndexData'));	×
263	}
264	$query = $query->getResultObject();	39✔
265
266	$retVal = [];	39✔
267
268	foreach ($query as $row) {	39✔
269	$obj = new stdClass();	28✔
270	$obj->name = $row->index_name;	28✔
271
272	$_fields = explode(',', trim($row->index_keys));	28✔
273	$obj->fields = array_map(static fn ($v): string => trim($v), $_fields);	28✔
274
275	if (str_contains($row->index_description, 'primary key located on')) {	28✔
276	$obj->type = 'PRIMARY';	25✔
277	} else {
278	$obj->type = (str_contains($row->index_description, 'nonclustered, unique')) ? 'UNIQUE' : 'INDEX';	18✔
279	}
280
281	$retVal[$obj->name] = $obj;	28✔
282	}
283
284	return $retVal;	39✔
285	}
286
287	/**
288	* Returns an array of objects with Foreign key data
289	* referenced_object_id parent_object_id
290	*
291	* @return array<string, stdClass>
292	*
293	* @throws DatabaseException
294	*/
295	protected function _foreignKeyData(string $table): array
296	{
297	$sql = 'SELECT	5✔
298	f.name as constraint_name,
299	OBJECT_NAME (f.parent_object_id) as table_name,
300	COL_NAME(fc.parent_object_id,fc.parent_column_id) column_name,
301	OBJECT_NAME(f.referenced_object_id) foreign_table_name,
302	COL_NAME(fc.referenced_object_id,fc.referenced_column_id) foreign_column_name,
303	rc.delete_rule,
304	rc.update_rule,
305	rc.match_option
306	FROM
307	sys.foreign_keys AS f
308	INNER JOIN sys.foreign_key_columns AS fc ON f.OBJECT_ID = fc.constraint_object_id
309	INNER JOIN sys.tables t ON t.OBJECT_ID = fc.referenced_object_id
310	INNER JOIN INFORMATION_SCHEMA.REFERENTIAL_CONSTRAINTS rc ON rc.CONSTRAINT_NAME = f.name
311	WHERE OBJECT_NAME (f.parent_object_id) = ' . $this->escape($table);	5✔
312
313	if (($query = $this->query($sql)) === false) {	5✔
314	throw new DatabaseException(lang('Database.failGetForeignKeyData'));	×
315	}
316
317	$query = $query->getResultObject();	5✔
318	$indexes = [];	5✔
319
320	foreach ($query as $row) {	5✔
321	$indexes[$row->constraint_name]['constraint_name'] = $row->constraint_name;	4✔
322	$indexes[$row->constraint_name]['table_name'] = $row->table_name;	4✔
323	$indexes[$row->constraint_name]['column_name'][] = $row->column_name;	4✔
324	$indexes[$row->constraint_name]['foreign_table_name'] = $row->foreign_table_name;	4✔
325	$indexes[$row->constraint_name]['foreign_column_name'][] = $row->foreign_column_name;	4✔
326	$indexes[$row->constraint_name]['on_delete'] = $row->delete_rule;	4✔
327	$indexes[$row->constraint_name]['on_update'] = $row->update_rule;	4✔
328	$indexes[$row->constraint_name]['match'] = $row->match_option;	4✔
329	}
330
331	return $this->foreignKeyDataToObjects($indexes);	5✔
332	}
333
334	/**
335	* Disables foreign key checks temporarily.
336	*
337	* @return string
338	*/
339	protected function _disableForeignKeyChecks()
340	{
341	return 'EXEC sp_MSforeachtable "ALTER TABLE ? NOCHECK CONSTRAINT ALL"';	598✔
342	}
343
344	/**
345	* Enables foreign key checks temporarily.
346	*
347	* @return string
348	*/
349	protected function _enableForeignKeyChecks()
350	{
351	return 'EXEC sp_MSforeachtable "ALTER TABLE ? WITH CHECK CHECK CONSTRAINT ALL"';	598✔
352	}
353
354	/**
355	* Returns an array of objects with field data
356	*
357	* @return list<stdClass>
358	*
359	* @throws DatabaseException
360	*/
361	protected function _fieldData(string $table): array
362	{
363	$sql = 'SELECT	12✔
364	COLUMN_NAME, DATA_TYPE, CHARACTER_MAXIMUM_LENGTH, NUMERIC_PRECISION,
365	COLUMN_DEFAULT, IS_NULLABLE
366	FROM INFORMATION_SCHEMA.COLUMNS
367	WHERE TABLE_NAME= ' . $this->escape(($table));	12✔
368
369	if (($query = $this->query($sql)) === false) {	12✔
370	throw new DatabaseException(lang('Database.failGetFieldData'));	×
371	}
372
373	$query = $query->getResultObject();	12✔
374	$retVal = [];	12✔
375
376	for ($i = 0, $c = count($query); $i < $c; $i++) {	12✔
377	$retVal[$i] = new stdClass();	12✔
378
379	$retVal[$i]->name = $query[$i]->COLUMN_NAME;	12✔
380	$retVal[$i]->type = $query[$i]->DATA_TYPE;	12✔
381
382	$retVal[$i]->max_length = $query[$i]->CHARACTER_MAXIMUM_LENGTH > 0	12✔
383	? $query[$i]->CHARACTER_MAXIMUM_LENGTH	11✔
384	: (	12✔
385	$query[$i]->CHARACTER_MAXIMUM_LENGTH === -1	9✔
386	? 'max'	1✔
387	: $query[$i]->NUMERIC_PRECISION	9✔
388	);	12✔
389
390	$retVal[$i]->nullable = $query[$i]->IS_NULLABLE !== 'NO';	12✔
391	$retVal[$i]->default = $query[$i]->COLUMN_DEFAULT;	12✔
392	}
393
394	return $retVal;	12✔
395	}
396
397	/**
398	* Begin Transaction
399	*/
400	protected function _transBegin(): bool
401	{
402	return sqlsrv_begin_transaction($this->connID);	18✔
403	}
404
405	/**
406	* Commit Transaction
407	*/
408	protected function _transCommit(): bool
409	{
410	return sqlsrv_commit($this->connID);	5✔
411	}
412
413	/**
414	* Rollback Transaction
415	*/
416	protected function _transRollback(): bool
417	{
418	return sqlsrv_rollback($this->connID);	18✔
419	}
420
421	/**
422	* Returns the last error code and message.
423	* Must return this format: ['code' => string\|int, 'message' => string]
424	* intval(code) === 0 means "no error".
425	*
426	* @return array<string, int\|string>
427	*/
428	public function error(): array
429	{
430	$error = [	2✔
431	'code' => '00000',	2✔
432	'message' => '',	2✔
433	];	2✔
434
435	$sqlsrvErrors = sqlsrv_errors(SQLSRV_ERR_ERRORS);	2✔
436
437	if (! is_array($sqlsrvErrors)) {	2✔
438	return $error;	2✔
439	}
440
UNCOV 441	$sqlsrvError = array_shift($sqlsrvErrors);	×
UNCOV 442	if (isset($sqlsrvError['SQLSTATE'])) {	×
UNCOV 443	$error['code'] = isset($sqlsrvError['code']) ? $sqlsrvError['SQLSTATE'] . '/' . $sqlsrvError['code'] : $sqlsrvError['SQLSTATE'];	×
444	} elseif (isset($sqlsrvError['code'])) {	×
445	$error['code'] = $sqlsrvError['code'];	×
446	}
447
UNCOV 448	if (isset($sqlsrvError['message'])) {	×
UNCOV 449	$error['message'] = $sqlsrvError['message'];	×
450	}
451
UNCOV 452	return $error;	×
453	}
454
455	/**
456	* Returns the total number of rows affected by this query.
457	*/
458	public function affectedRows(): int
459	{
460	if ($this->resultID === false) {	48✔
461	return 0;	1✔
462	}
463
464	return sqlsrv_rows_affected($this->resultID);	47✔
465	}
466
467	/**
468	* Select a specific database table to use.
469	*
470	* @return bool
471	*/
472	public function setDatabase(?string $databaseName = null)
473	{
474	if ($databaseName === null \|\| $databaseName === '') {	×
475	$databaseName = $this->database;	×
476	}
477
478	if (empty($this->connID)) {	×
479	$this->initialize();	×
480	}
481
482	if ($this->execute('USE ' . $this->_escapeString($databaseName))) {	×
483	$this->database = $databaseName;	×
484	$this->dataCache = [];	×
485
486	return true;	×
487	}
488
489	return false;	×
490	}
491
492	/**
493	* Executes the query against the database.
494	*
495	* @return false\|resource
496	*/
497	protected function execute(string $sql)
498	{
499	$stmt = ($this->scrollable === false \|\| $this->isWriteType($sql))	674✔
500	? sqlsrv_query($this->connID, $sql)	641✔
501	: sqlsrv_query($this->connID, $sql, [], ['Scrollable' => $this->scrollable]);	674✔
502
503	if ($stmt === false) {	674✔
504	$trace = debug_backtrace();	32✔
505	$first = array_shift($trace);	32✔
506
507	log_message('error', "{message}\nin {exFile} on line {exLine}.\n{trace}", [	32✔
508	'message' => $this->getAllErrorMessages(),	32✔
509	'exFile' => clean_path($first['file']),	32✔
510	'exLine' => $first['line'],	32✔
511	'trace' => render_backtrace($trace),	32✔
512	]);	32✔
513
514	if ($this->DBDebug) {	32✔
515	throw new DatabaseException($this->getAllErrorMessages());	14✔
516	}
517	}
518
519	return $stmt;	674✔
520	}
521
522	/**
523	* Returns the last error encountered by this connection.
524	*
525	* @return array<string, int\|string>
526	*
527	* @deprecated Use `error()` instead.
528	*/
529	public function getError()
530	{
531	$error = [	×
532	'code' => '00000',	×
533	'message' => '',	×
534	];	×
535
536	$sqlsrvErrors = sqlsrv_errors(SQLSRV_ERR_ERRORS);	×
537
538	if (! is_array($sqlsrvErrors)) {	×
539	return $error;	×
540	}
541
542	$sqlsrvError = array_shift($sqlsrvErrors);	×
543	if (isset($sqlsrvError['SQLSTATE'])) {	×
544	$error['code'] = isset($sqlsrvError['code']) ? $sqlsrvError['SQLSTATE'] . '/' . $sqlsrvError['code'] : $sqlsrvError['SQLSTATE'];	×
545	} elseif (isset($sqlsrvError['code'])) {	×
546	$error['code'] = $sqlsrvError['code'];	×
547	}
548
549	if (isset($sqlsrvError['message'])) {	×
550	$error['message'] = $sqlsrvError['message'];	×
551	}
552
553	return $error;	×
554	}
555
556	/**
557	* The name of the platform in use (MySQLi, mssql, etc)
558	*/
559	public function getPlatform(): string
560	{
561	return $this->DBDriver;	10✔
562	}
563
564	/**
565	* Returns a string containing the version of the database being used.
566	*/
567	public function getVersion(): string
568	{
569	$info = [];	3✔
570	if (isset($this->dataCache['version'])) {	3✔
571	return $this->dataCache['version'];	1✔
572	}
573
574	if (! $this->connID) {	2✔
575	$this->initialize();	1✔
576	}
577
578	if (($info = sqlsrv_server_info($this->connID)) === []) {	2✔
579	return '';	×
580	}
581
582	return isset($info['SQLServerVersion']) ? $this->dataCache['version'] = $info['SQLServerVersion'] : '';	2✔
583	}
584
585	/**
586	* Determines if a query is a "write" type.
587	*
588	* Overrides BaseConnection::isWriteType, adding additional read query types.
589	*
590	* @param string $sql
591	*/
592	public function isWriteType($sql): bool
593	{
594	if (preg_match('/^\s"?(EXEC\ssp_rename)\s/i', $sql)) {	674✔
595	return true;	3✔
596	}
597
598	return parent::isWriteType($sql);	674✔
599	}
600	}

codeigniter4 / CodeIgniter4 / 16990778495

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous