Connection::connect() - Code Metrics - Inspection of "update php requirements >=5.6 (#138)" - FoolCode/SphinxQL-Query-Builder - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( cf0a8f...4a3709 )

by Hung

created 2018-04-13 13:32 UTC

Connection::connect() D

↳ Parent: Connection

Complexity

Conditions	10
Paths	48

Size

Total Lines	34
Code Lines	20

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	34
rs	4.8196
c	0
b	0
f	0
cc	10
eloc	20
nc	48
nop	1

How to fix Complexity

<?php

namespace Foolz\SphinxQL\Drivers\Pdo;

use Foolz\SphinxQL\Drivers\ConnectionBase;
use Foolz\SphinxQL\Exception\ConnectionException;
use Foolz\SphinxQL\Exception\DatabaseException;
use Foolz\SphinxQL\Exception\SphinxQLException;

/**
 * Class PdoConnection
 * @package Foolz\SphinxQL\Drivers
 */
class Connection extends ConnectionBase
{
    /**
     * Performs a query on the Sphinx server.
     *
     * @param string $query The query string
     *
     * @throws DatabaseException
     * @return array|int The result array or number of rows affected
     */
    public function query($query)
    {
        $this->ensureConnection();

        $stm = $this->connection->prepare($query);

        try{
            $stm->execute();
        }
        catch(\PDOException $exception){
            throw new DatabaseException($exception->getMessage() . ' [' . $query . ']');
        }

        return ResultSet::make($stm);
    }

    /**
     * @inheritdoc
     */
    public function connect($suppress_error = false)
    {
        $params = $this->getParams();

        $dsn = 'mysql:';
        if (isset($params['host']) && $params['host'] != '') {
            $dsn .= 'host=' . $params['host'] . ';';
        }
        if (isset($params['port'])) {
            $dsn .= 'port=' . $params['port'] . ';';
        }
        if (isset($params['charset'])) {
            $dsn .= 'charset=' . $params['charset'] . ';';
        }

        if (isset($params['socket']) && $params['socket'] != '') {
            $dsn .= 'unix_socket=' . $params['socket'] . ';';
        }

        try {
            $con = new \Pdo($dsn);
        } catch (\PDOException $exception) {
            if (!$suppress_error && !$this->silence_connection_warning) {
                trigger_error('connection error', E_USER_WARNING);
            }

            throw new ConnectionException($exception->getMessage());
        }

        $this->connection = $con;
        $this->connection->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);

        return true;
    }

    public function ping()
    {
        $this->ensureConnection();

        return $this->connection !== null;
    }

    /**
     * @param array $queue
     * @return \Foolz\SphinxQL\Drivers\Pdo\MultiResultSet
     * @throws DatabaseException
     * @throws SphinxQLException
     */
    public function multiQuery(array $queue)
    {
        $this->ensureConnection();

        if (count($queue) === 0) {
            throw new SphinxQLException('The Queue is empty.');
        }

        try {
            $statement = $this->connection->query(implode(';', $queue));
        } catch (\PDOException $exception) {
            throw new DatabaseException($exception->getMessage() .' [ '.implode(';', $queue).']');
        }

        return MultiResultSet::make($statement);
    }

    /**
     * @param string $value
     * @return string
     */
    public function escape($value)
    {
        $this->ensureConnection();

        return $this->connection->quote($value);
    }
}


1			<?php
2
3			namespace Foolz\SphinxQL\Drivers\Pdo;
4
5			use Foolz\SphinxQL\Drivers\ConnectionBase;
6			use Foolz\SphinxQL\Exception\ConnectionException;
7			use Foolz\SphinxQL\Exception\DatabaseException;
8			use Foolz\SphinxQL\Exception\SphinxQLException;
9
10			/**
11			* Class PdoConnection
12			* @package Foolz\SphinxQL\Drivers
13			*/
14			class Connection extends ConnectionBase
15			{
16			/**
17			* Performs a query on the Sphinx server.
18			*
19			* @param string $query The query string
20			*
21			* @throws DatabaseException
22			* @return array\|int The result array or number of rows affected
23			*/
24			public function query($query)
25			{
26			$this->ensureConnection();
27
28			$stm = $this->connection->prepare($query);
29
30			try{
31			$stm->execute();
32			}
33			catch(\PDOException $exception){
34			throw new DatabaseException($exception->getMessage() . ' [' . $query . ']');
35			}
36
37			return ResultSet::make($stm);
38			}
39
40			/**
41			* @inheritdoc
42			*/
43			public function connect($suppress_error = false)
44			{
45			$params = $this->getParams();
46
47			$dsn = 'mysql:';
48			if (isset($params['host']) && $params['host'] != '') {
49			$dsn .= 'host=' . $params['host'] . ';';
50			}
51			if (isset($params['port'])) {
52			$dsn .= 'port=' . $params['port'] . ';';
53			}
54			if (isset($params['charset'])) {
55			$dsn .= 'charset=' . $params['charset'] . ';';
56			}
57
58			if (isset($params['socket']) && $params['socket'] != '') {
59			$dsn .= 'unix_socket=' . $params['socket'] . ';';
60			}
61
62			try {
63			$con = new \Pdo($dsn);
64			} catch (\PDOException $exception) {
65			if (!$suppress_error && !$this->silence_connection_warning) {
66			trigger_error('connection error', E_USER_WARNING);
67			}
68
69			throw new ConnectionException($exception->getMessage());
70			}
71
72			$this->connection = $con;
73			$this->connection->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
74
75			return true;
76			}
77
78			public function ping()
79			{
80			$this->ensureConnection();
81
82			return $this->connection !== null;
83			}
84
85			/**
86			* @param array $queue
87			* @return \Foolz\SphinxQL\Drivers\Pdo\MultiResultSet
88			* @throws DatabaseException
89			* @throws SphinxQLException
90			*/
91			public function multiQuery(array $queue)
92			{
93			$this->ensureConnection();
94
95			if (count($queue) === 0) {
96			throw new SphinxQLException('The Queue is empty.');
97			}
98
99			try {
100			$statement = $this->connection->query(implode(';', $queue));
101			} catch (\PDOException $exception) {
102			throw new DatabaseException($exception->getMessage() .' [ '.implode(';', $queue).']');
103			}
104
105			return MultiResultSet::make($statement);
106			}
107
108			/**
109			* @param string $value
110			* @return string
111			*/
112			public function escape($value)
113			{
114			$this->ensureConnection();
115
116			return $this->connection->quote($value);
117			}
118			}
119

FoolCode / SphinxQL-Query-Builder

Push — master ( cf0a8f...4a3709 )

Connection::connect() D

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like