Client::executeUpdate() - Code Metrics - Inspection of "Fix GH actions permissions issue" - tarantool-php/client - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 6f7bcb...984147 )

by Eugene

created 2023-03-08 21:33 UTC

Client::executeUpdate() A

↳ Parent: Client

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes

Metric	Value
eloc	2
dl	0
loc	5
ccs	3
cts	3
cp	1
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	2
crap	1

<?php

/**
 * This file is part of the tarantool/client package.
 *
 * (c) Eugene Leonovich <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Tarantool\Client;

use Tarantool\Client\Connection\StreamConnection;
use Tarantool\Client\Exception\RequestFailed;
use Tarantool\Client\Handler\DefaultHandler;
use Tarantool\Client\Handler\Handler;
use Tarantool\Client\Handler\MiddlewareHandler;
use Tarantool\Client\Middleware\AuthenticationMiddleware;
use Tarantool\Client\Middleware\Middleware;
use Tarantool\Client\Middleware\RetryMiddleware;
use Tarantool\Client\Packer\Packer;
use Tarantool\Client\Packer\PurePacker;
use Tarantool\Client\Request\CallRequest;
use Tarantool\Client\Request\EvaluateRequest;
use Tarantool\Client\Request\ExecuteRequest;
use Tarantool\Client\Request\PingRequest;
use Tarantool\Client\Request\PrepareRequest;
use Tarantool\Client\Schema\Criteria;
use Tarantool\Client\Schema\Space;

final class Client
{
    /** @var Handler */
    private $handler;

    /** @var array<array-key, Space> */

    private $spaces = [];

    public function __construct(Handler $handler)
    {
        $this->handler = $handler;
    }

    public static function fromDefaults() : self
    {
        return new self(new DefaultHandler(
            StreamConnection::createTcp(),
            PurePacker::fromAvailableExtensions()
        ));
    }

    public static function fromOptions(array $options, ?Packer $packer = null) : self
    {
        $connectionOptions = [];
        if (isset($options['connect_timeout'])) {
            $connectionOptions['connect_timeout'] = $options['connect_timeout'];
        }
        if (isset($options['socket_timeout'])) {
            $connectionOptions['socket_timeout'] = $options['socket_timeout'];
        }
        if (isset($options['tcp_nodelay'])) {
            $connectionOptions['tcp_nodelay'] = $options['tcp_nodelay'];
        }
        if (isset($options['persistent'])) {
            $connectionOptions['persistent'] = $options['persistent'];
        }

        $middleware = [];
        if (isset($options['max_retries']) && 0 !== $options['max_retries']) {
            $middleware[] = RetryMiddleware::linear($options['max_retries']);
        }
        if (isset($options['username'])) {
            $middleware[] = new AuthenticationMiddleware($options['username'], $options['password'] ?? '');
        }

        $connection = isset($options['uri'])
            ? StreamConnection::create($options['uri'], $connectionOptions)
            : StreamConnection::createTcp(StreamConnection::DEFAULT_TCP_URI, $connectionOptions);

        $handler = new DefaultHandler($connection, $packer ?? PurePacker::fromAvailableExtensions());

        return $middleware
            ? new self(MiddlewareHandler::append($handler, $middleware))
            : new self($handler);
    }

    public static function fromDsn(string $dsn, ?Packer $packer = null) : self
    {
        $dsn = Dsn::parse($dsn);

        $connectionOptions = [];
        if (null !== $timeout = $dsn->getFloat('connect_timeout')) {
            $connectionOptions['connect_timeout'] = $timeout;
        }
        if (null !== $timeout = $dsn->getFloat('socket_timeout')) {
            $connectionOptions['socket_timeout'] = $timeout;
        }
        if (null !== $tcpNoDelay = $dsn->getBool('tcp_nodelay')) {
            $connectionOptions['tcp_nodelay'] = $tcpNoDelay;
        }
        if (null !== $persistent = $dsn->getBool('persistent')) {
            $connectionOptions['persistent'] = $persistent;
        }

        $middleware = [];
        if ($maxRetries = $dsn->getInt('max_retries')) {
            $middleware[] = RetryMiddleware::linear($maxRetries);
        }
        if ($username = $dsn->getUsername()) {
            $middleware[] = new AuthenticationMiddleware($username, $dsn->getPassword() ?? '');
        }

        $connection = $dsn->isTcp()
            ? StreamConnection::createTcp($dsn->getConnectionUri(), $connectionOptions)
            : StreamConnection::createUds($dsn->getConnectionUri(), $connectionOptions);

        $handler = new DefaultHandler($connection, $packer ?? PurePacker::fromAvailableExtensions());

        return $middleware
            ? new self(MiddlewareHandler::append($handler, $middleware))
            : new self($handler);
    }

    public function withMiddleware(Middleware ...$middleware) : self
    {
        $new = clone $this;
        $new->handler = MiddlewareHandler::append($new->handler, $middleware);

        return $new;
    }

    public function withPrependedMiddleware(Middleware ...$middleware) : self
    {
        $new = clone $this;
        $new->handler = MiddlewareHandler::prepend($new->handler, $middleware);

        return $new;
    }

    public function getHandler() : Handler
    {
        return $this->handler;
    }

    public function getSpace(string $spaceName) : Space
    {
        if (isset($this->spaces[$spaceName])) {
            return $this->spaces[$spaceName];
        }

        $spaceId = $this->getSpaceIdByName($spaceName);

        return $this->spaces[$spaceName] = $this->spaces[$spaceId] = new Space($this->handler, $spaceId);
    }

    public function getSpaceById(int $spaceId) : Space
    {
        if (isset($this->spaces[$spaceId])) {
            return $this->spaces[$spaceId];
        }

        return $this->spaces[$spaceId] = new Space($this->handler, $spaceId);
    }

    public function ping() : void
    {
        $this->handler->handle(new PingRequest());
    }

    /**
     * @param mixed ...$args
     */
    public function call(string $funcName, ...$args) : array
    {
        return $this->handler->handle(new CallRequest($funcName, $args))
            ->getBodyField(Keys::DATA);
    }

    /**
     * @param mixed ...$args
     */
    public function evaluate(string $expr, ...$args) : array
    {
        return $this->handler->handle(new EvaluateRequest($expr, $args))
            ->getBodyField(Keys::DATA);
    }

    /**
     * @param mixed ...$params
     */
    public function execute(string $sql, ...$params) : Response
    {
        return $this->handler->handle(ExecuteRequest::fromSql($sql, $params));
    }

    /**
     * @param mixed ...$params
     */
    public function executeQuery(string $sql, ...$params) : SqlQueryResult
    {
        $response = $this->handler->handle(ExecuteRequest::fromSql($sql, $params));

        return new SqlQueryResult(
            $response->getBodyField(Keys::DATA),
            $response->getBodyField(Keys::METADATA)
        );
    }

    /**
     * @param mixed ...$params
     */
    public function executeUpdate(string $sql, ...$params) : SqlUpdateResult
    {
        $response = $this->handler->handle(ExecuteRequest::fromSql($sql, $params));

        return new SqlUpdateResult($response->getBodyField(Keys::SQL_INFO));
    }

    public function prepare(string $sql) : PreparedStatement
    {
        $response = $this->handler->handle(PrepareRequest::fromSql($sql));

        return new PreparedStatement(
            $this->handler,
            $response->getBodyField(Keys::STMT_ID),
            $response->getBodyField(Keys::BIND_COUNT),
            $response->getBodyField(Keys::BIND_METADATA),
            $response->tryGetBodyField(Keys::METADATA, [])
        );
    }

    public function flushSpaces() : void
    {
        $this->spaces = [];
    }

    public function __clone()
    {
        $this->spaces = [];
    }

    private function getSpaceIdByName(string $spaceName) : int
    {
        $schema = $this->getSpaceById(Space::VSPACE_ID);
        $data = $schema->select(Criteria::key([$spaceName])->andIndex(Space::VSPACE_NAME_INDEX));

        if ($data) {

            return $data[0][0];
        }

        throw RequestFailed::unknownSpace($spaceName);
    }
}


1		<?php
2
3		/**
4		* This file is part of the tarantool/client package.
5		*
6		* (c) Eugene Leonovich <[email protected]>
7		*
8		* For the full copyright and license information, please view the LICENSE
9		* file that was distributed with this source code.
10		*/
11
12		declare(strict_types=1);
13
14		namespace Tarantool\Client;
15
16		use Tarantool\Client\Connection\StreamConnection;
17		use Tarantool\Client\Exception\RequestFailed;
18		use Tarantool\Client\Handler\DefaultHandler;
19		use Tarantool\Client\Handler\Handler;
20		use Tarantool\Client\Handler\MiddlewareHandler;
21		use Tarantool\Client\Middleware\AuthenticationMiddleware;
22		use Tarantool\Client\Middleware\Middleware;
23		use Tarantool\Client\Middleware\RetryMiddleware;
24		use Tarantool\Client\Packer\Packer;
25		use Tarantool\Client\Packer\PurePacker;
26		use Tarantool\Client\Request\CallRequest;
27		use Tarantool\Client\Request\EvaluateRequest;
28		use Tarantool\Client\Request\ExecuteRequest;
29		use Tarantool\Client\Request\PingRequest;
30		use Tarantool\Client\Request\PrepareRequest;
31		use Tarantool\Client\Schema\Criteria;
32		use Tarantool\Client\Schema\Space;
33
34		final class Client
35		{
36		/** @var Handler */
37		private $handler;
38
39		/** @var array<array-key, Space> */
		0 ignored issues – show Documentation Bug introduced 2020-02-18 19:56 UTC by Report Bug Copy Issue Report The doc comment `array<array-key, Space>` at position `2` could not be parsed: Unknown type name 'array-key' at position 2 in array<array-key, Space>. Loading history...
40		private $spaces = [];
41
42	795	public function __construct(Handler $handler)
43		{
44	795	$this->handler = $handler;
45		}
46
47	4	public static function fromDefaults() : self
48		{
49	4	return new self(new DefaultHandler(
50	4	StreamConnection::createTcp(),
51	4	PurePacker::fromAvailableExtensions()
52	4	));
53		}
54
55	80	public static function fromOptions(array $options, ?Packer $packer = null) : self
56		{
57	80	$connectionOptions = [];
58	80	if (isset($options['connect_timeout'])) {
59	8	$connectionOptions['connect_timeout'] = $options['connect_timeout'];
60		}
61	80	if (isset($options['socket_timeout'])) {
62	8	$connectionOptions['socket_timeout'] = $options['socket_timeout'];
63		}
64	80	if (isset($options['tcp_nodelay'])) {
65	8	$connectionOptions['tcp_nodelay'] = $options['tcp_nodelay'];
66		}
67	80	if (isset($options['persistent'])) {
68	8	$connectionOptions['persistent'] = $options['persistent'];
69		}
70
71	80	$middleware = [];
72	80	if (isset($options['max_retries']) && 0 !== $options['max_retries']) {
73	16	$middleware[] = RetryMiddleware::linear($options['max_retries']);
74		}
75	68	if (isset($options['username'])) {
76	20	$middleware[] = new AuthenticationMiddleware($options['username'], $options['password'] ?? '');
77		}
78
79	52	$connection = isset($options['uri'])
80	20	? StreamConnection::create($options['uri'], $connectionOptions)
81	44	: StreamConnection::createTcp(StreamConnection::DEFAULT_TCP_URI, $connectionOptions);
82
83	12	$handler = new DefaultHandler($connection, $packer ?? PurePacker::fromAvailableExtensions());
84
85	12	return $middleware
86	4	? new self(MiddlewareHandler::append($handler, $middleware))
87	12	: new self($handler);
88		}
89
90	36	public static function fromDsn(string $dsn, ?Packer $packer = null) : self
91		{
92	36	$dsn = Dsn::parse($dsn);
93
94	36	$connectionOptions = [];
95	36	if (null !== $timeout = $dsn->getFloat('connect_timeout')) {
96		$connectionOptions['connect_timeout'] = $timeout;
97		}
98	32	if (null !== $timeout = $dsn->getFloat('socket_timeout')) {
99		$connectionOptions['socket_timeout'] = $timeout;
100		}
101	28	if (null !== $tcpNoDelay = $dsn->getBool('tcp_nodelay')) {
102		$connectionOptions['tcp_nodelay'] = $tcpNoDelay;
103		}
104	24	if (null !== $persistent = $dsn->getBool('persistent')) {
105		$connectionOptions['persistent'] = $persistent;
106		}
107
108	16	$middleware = [];
109	16	if ($maxRetries = $dsn->getInt('max_retries')) {
110		$middleware[] = RetryMiddleware::linear($maxRetries);
111		}
112	8	if ($username = $dsn->getUsername()) {
113		$middleware[] = new AuthenticationMiddleware($username, $dsn->getPassword() ?? '');
114		}
115
116	8	$connection = $dsn->isTcp()
117	8	? StreamConnection::createTcp($dsn->getConnectionUri(), $connectionOptions)
118	8	: StreamConnection::createUds($dsn->getConnectionUri(), $connectionOptions);
119
120	8	$handler = new DefaultHandler($connection, $packer ?? PurePacker::fromAvailableExtensions());
121
122	8	return $middleware
123		? new self(MiddlewareHandler::append($handler, $middleware))
124	8	: new self($handler);
125		}
126
127	36	public function withMiddleware(Middleware ...$middleware) : self
128		{
129	36	$new = clone $this;
130	36	$new->handler = MiddlewareHandler::append($new->handler, $middleware);
131
132	36	return $new;
133		}
134
135	4	public function withPrependedMiddleware(Middleware ...$middleware) : self
136		{
137	4	$new = clone $this;
138	4	$new->handler = MiddlewareHandler::prepend($new->handler, $middleware);
139
140	4	return $new;
141		}
142
143	114	public function getHandler() : Handler
144		{
145	114	return $this->handler;
146		}
147
148	239	public function getSpace(string $spaceName) : Space
149		{
150	239	if (isset($this->spaces[$spaceName])) {
151	4	return $this->spaces[$spaceName];
152		}
153
154	239	$spaceId = $this->getSpaceIdByName($spaceName);
155
156	231	return $this->spaces[$spaceName] = $this->spaces[$spaceId] = new Space($this->handler, $spaceId);
157		}
158
159	255	public function getSpaceById(int $spaceId) : Space
160		{
161	255	if (isset($this->spaces[$spaceId])) {
162		return $this->spaces[$spaceId];
163		}
164
165	255	return $this->spaces[$spaceId] = new Space($this->handler, $spaceId);
166		}
167
168	137	public function ping() : void
169		{
170	137	$this->handler->handle(new PingRequest());
171		}
172
173		/**
174		* @param mixed ...$args
175		*/
176	45	public function call(string $funcName, ...$args) : array
177		{
178	45	return $this->handler->handle(new CallRequest($funcName, $args))
179	45	->getBodyField(Keys::DATA);
180		}
181
182		/**
183		* @param mixed ...$args
184		*/
185	366	public function evaluate(string $expr, ...$args) : array
186		{
187	366	return $this->handler->handle(new EvaluateRequest($expr, $args))
188	366	->getBodyField(Keys::DATA);
189		}
190
191		/**
192		* @param mixed ...$params
193		*/
194	12	public function execute(string $sql, ...$params) : Response
195		{
196	12	return $this->handler->handle(ExecuteRequest::fromSql($sql, $params));
197		}
198
199		/**
200		* @param mixed ...$params
201		*/
202	45	public function executeQuery(string $sql, ...$params) : SqlQueryResult
203		{
204	45	$response = $this->handler->handle(ExecuteRequest::fromSql($sql, $params));
205
206	45	return new SqlQueryResult(
207	45	$response->getBodyField(Keys::DATA),
208	45	$response->getBodyField(Keys::METADATA)
209	45	);
210		}
211
212		/**
213		* @param mixed ...$params
214		*/
215	24	public function executeUpdate(string $sql, ...$params) : SqlUpdateResult
216		{
217	24	$response = $this->handler->handle(ExecuteRequest::fromSql($sql, $params));
218
219	24	return new SqlUpdateResult($response->getBodyField(Keys::SQL_INFO));
220		}
221
222	20	public function prepare(string $sql) : PreparedStatement
223		{
224	20	$response = $this->handler->handle(PrepareRequest::fromSql($sql));
225
226	20	return new PreparedStatement(
227	20	$this->handler,
228	20	$response->getBodyField(Keys::STMT_ID),
229	20	$response->getBodyField(Keys::BIND_COUNT),
230	20	$response->getBodyField(Keys::BIND_METADATA),
231	20	$response->tryGetBodyField(Keys::METADATA, [])
232	20	);
233		}
234
235	8	public function flushSpaces() : void
236		{
237	8	$this->spaces = [];
238		}
239
240	40	public function __clone()
241		{
242	40	$this->spaces = [];
243		}
244
245	239	private function getSpaceIdByName(string $spaceName) : int
246		{
247	239	$schema = $this->getSpaceById(Space::VSPACE_ID);
248	239	$data = $schema->select(Criteria::key([$spaceName])->andIndex(Space::VSPACE_NAME_INDEX));
249
250	239	if ($data) {
		0 ignored issues – show Bug Best Practice introduced 2020-01-31 22:08 UTC by Report Bug Copy Issue Report The expression `$data` of type `array` is implicitly converted to a boolean; are you sure this is intended? If so, consider using `! empty($expr)` instead to make it clear that you intend to check for an array without elements. This check marks implicit conversions of arrays to boolean values in a comparison. While in PHP an empty array is considered to be equal (but not identical) to false, this is not always apparent. Consider making the comparison explicit by using `empty(..)` or `! empty(...)` instead. Loading history...
251	231	return $data[0][0];
252		}
253
254	8	throw RequestFailed::unknownSpace($spaceName);
255		}
256		}
257

tarantool-php / client

Push — master ( 6f7bcb...984147 )

Client::executeUpdate() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like