FM / SQLSrv

/var/www/cobraambalaj/vendor/doctrine/dbal/src/Driver/SQLSrv/

/var/www/cobraambalaj/vendor/doctrine/dbal/src/Driver/SQLSrv

Name	Size	Mode	Actions
Exception/	-	0755	rm
Connection.php	3564	0644	edit dl rm
Driver.php	1392	0644	edit dl rm
LastInsertId.php	400	0644	edit dl rm
Result.php	2704	0644	edit dl rm
Statement.php	5074	0644	edit dl rm

Edit: /var/www/cobraambalaj/vendor/doctrine/dbal/src/Driver/SQLSrv/Connection.php (3564B)

<?php

namespace Doctrine\DBAL\Driver\SQLSrv;

use Doctrine\DBAL\Driver\Exception;
use Doctrine\DBAL\Driver\Result as ResultInterface;
use Doctrine\DBAL\Driver\ServerInfoAwareConnection;
use Doctrine\DBAL\Driver\SQLSrv\Exception\Error;
use Doctrine\DBAL\Driver\Statement as DriverStatement;
use Doctrine\DBAL\ParameterType;

use function is_float;
use function is_int;
use function sprintf;
use function sqlsrv_begin_transaction;
use function sqlsrv_commit;
use function sqlsrv_configure;
use function sqlsrv_connect;
use function sqlsrv_query;
use function sqlsrv_rollback;
use function sqlsrv_rows_affected;
use function sqlsrv_server_info;
use function str_replace;

final class Connection implements ServerInfoAwareConnection
{
    /** @var resource */
    protected $conn;

/** @var LastInsertId */
    protected $lastInsertId;

/**
     * @internal The connection can be only instantiated by its driver.
     *
     * @param string  $serverName
     * @param mixed[] $connectionOptions
     *
     * @throws Exception
     */
    public function __construct($serverName, $connectionOptions)
    {
        if (! sqlsrv_configure('WarningsReturnAsErrors', 0)) {
            throw Error::new();
        }

$conn = sqlsrv_connect($serverName, $connectionOptions);

if ($conn === false) {
            throw Error::new();
        }

$this->conn         = $conn;
        $this->lastInsertId = new LastInsertId();
    }

/**
     * {@inheritdoc}
     */
    public function getServerVersion()
    {
        $serverInfo = sqlsrv_server_info($this->conn);

return $serverInfo['SQLServerVersion'];
    }

public function prepare(string $sql): DriverStatement
    {
        return new Statement($this->conn, $sql, $this->lastInsertId);
    }

public function query(string $sql): ResultInterface
    {
        return $this->prepare($sql)->execute();
    }

/**
     * {@inheritDoc}
     */
    public function quote($value, $type = ParameterType::STRING)
    {
        if (is_int($value)) {
            return $value;
        }

if (is_float($value)) {
            return sprintf('%F', $value);
        }

return "'" . str_replace("'", "''", $value) . "'";
    }

public function exec(string $sql): int
    {
        $stmt = sqlsrv_query($this->conn, $sql);

if ($stmt === false) {
            throw Error::new();
        }

$rowsAffected = sqlsrv_rows_affected($stmt);

if ($rowsAffected === false) {
            throw Error::new();
        }

return $rowsAffected;
    }

/**
     * {@inheritDoc}
     */
    public function lastInsertId($name = null)
    {
        if ($name !== null) {
            $result = $this->prepare('SELECT CONVERT(VARCHAR(MAX), current_value) FROM sys.sequences WHERE name = ?')
                ->execute([$name]);
        } else {
            $result = $this->query('SELECT @@IDENTITY');
        }

return $result->fetchOne();
    }

/**
     * {@inheritDoc}
     */
    public function beginTransaction()
    {
        if (! sqlsrv_begin_transaction($this->conn)) {
            throw Error::new();
        }

return true;
    }

/**
     * {@inheritDoc}
     */
    public function commit()
    {
        if (! sqlsrv_commit($this->conn)) {
            throw Error::new();
        }

return true;
    }

/**
     * {@inheritDoc}
     */
    public function rollBack()
    {
        if (! sqlsrv_rollback($this->conn)) {
            throw Error::new();
        }

return true;
    }
}

conn = $conn; $this->lastInsertId = new LastInsertId(); } /** * {@inheritdoc} */ public function getServerVersion() { $serverInfo = sqlsrv_server_info($this->conn); return $serverInfo['SQLServerVersion']; } public function prepare(string $sql): DriverStatement { return new Statement($this->conn, $sql, $this->lastInsertId); } public function query(string $sql): ResultInterface { return $this->prepare($sql)->execute(); } /** * {@inheritDoc} */ public function quote($value, $type = ParameterType::STRING) { if (is_int($value)) { return $value; } if (is_float($value)) { return sprintf('%F', $value); } return "'" . str_replace("'", "''", $value) . "'"; } public function exec(string $sql): int { $stmt = sqlsrv_query($this->conn, $sql); if ($stmt === false) { throw Error::new(); } $rowsAffected = sqlsrv_rows_affected($stmt); if ($rowsAffected === false) { throw Error::new(); } return $rowsAffected; } /** * {@inheritDoc} */ public function lastInsertId($name = null) { if ($name !== null) { $result = $this->prepare('SELECT CONVERT(VARCHAR(MAX), current_value) FROM sys.sequences WHERE name = ?') ->execute([$name]); } else { $result = $this->query('SELECT @@IDENTITY'); } return $result->fetchOne(); } /** * {@inheritDoc} */ public function beginTransaction() { if (! sqlsrv_begin_transaction($this->conn)) { throw Error::new(); } return true; } /** * {@inheritDoc} */ public function commit() { if (! sqlsrv_commit($this->conn)) { throw Error::new(); } return true; } /** * {@inheritDoc} */ public function rollBack() { if (! sqlsrv_rollback($this->conn)) { throw Error::new(); } return true; } }