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

Completed

Pull Request — master (#138)

unknown

created 2018-04-13 08:19 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
{

    /**
     * close connection
     */
    public function close()
    {
        $this->connection = null;
    }

    /**
     * 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);
    }

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

FoolCode / SphinxQL-Query-Builder

Pull Request — master (#138)

Connection::connect() D

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like