gbili/bsrdb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: allow overriding the default output test

Browse Source
This commit is contained in:
Guillermo Pages
2021-09-27 12:06:32 +02:00
parent e65701fa56
commit 27e80613c7
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/Db/Connection.php
View File

@@ -23,7 +23,7 @@ class Connection
* @return OdbcResultSet|resource|string * @return OdbcResultSet|resource|string
* @throws SqlException * @throws SqlException
*/ */
public static function execute($sql, $values = array(), $fetchMode = \PDO::FETCH_ASSOC) public static function execute($sql, $values = array(), $fetchMode = \PDO::FETCH_ASSOC, $hasOutput = null)
{ {
$statement = PDOWithFilters::prepare($sql); $statement = PDOWithFilters::prepare($sql);
$success = $statement->execute(!empty($values) ? $values : null); $success = $statement->execute(!empty($values) ? $values : null);
@@ -32,7 +32,7 @@ class Connection
throw new SqlException('SQL There was an error executing the request'); throw new SqlException('SQL There was an error executing the request');
} }
if (strpos($sql, "SELECT") !== false || strpos($sql, "OUTPUT INSERTED") !== false) { if ((strpos($sql, "SELECT") < 6 || strpos($sql, "OUTPUT INSERTED") !== false) && (($hasOutput !== null && $hasOutput !== false) || $hasOutput === null)) {
$rows = $statement->fetchAll($fetchMode); $rows = $statement->fetchAll($fetchMode);
if (!is_array($rows)) { if (!is_array($rows)) {
throw new SqlException('PDO Unable to retrieve the result'); throw new SqlException('PDO Unable to retrieve the result');