Db::execute() - Code Metrics - Inspection of "only pdo wip" - Nickbur/Sunrise-CMS - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — develop ( 5c806e...7fd0a7 )

by Mykola

created 2019-07-24 14:36 UTC

Db::execute() A

↳ Parent: Db

Complexity

Conditions	6
Paths	12

Size

Total Lines	20
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	6
eloc	12
nc	12
nop	0
dl	0
loc	20
rs	9.2222
c	1
b	0
f	0

<?php

/* 	Sunrise CMS - Open source CMS for widespread use.
    Copyright (c) 2019 Mykola Burakov ([email protected])

    See SOURCE.txt for other and additional information.

    This file is part of Sunrise CMS.

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program. If not, see <http://www.gnu.org/licenses/>. */

namespace Sunrise\Engine\Library;

class Db
{
    private $connection;
    private $statement;
    // tracy
    private $log;

    public function __construct($hostname, $username, $password, $database, $port = '3306')
    {
        try {
            $this->connection = @new \PDO("mysql:host=" . $hostname . ";port=" . $port . ";dbname=" . $database, $username, $password, array(\PDO::ATTR_PERSISTENT => true));
        } catch (\PDOException $e) {
            throw new \Exception('Error: Could not make a database link using ' . $username . '@' . $hostname . '!');
        }

        $this->connection->exec("SET NAMES 'utf8mb4'");
        $this->connection->exec("SET CHARACTER SET utf8mb4");
        $this->connection->exec("SET CHARACTER_SET_CONNECTION=utf8mb4");
        $this->connection->exec("SET SQL_MODE = ''");

        // Tracy Debugger
        if (isset($_SESSION['_tracy']['sql_log'])) {
            unset($_SESSION['_tracy']['sql_log']);
        }
        $this->log = array();
        $this->log['page_url'] = (isset($_SERVER['QUERY_STRING']) && $_SERVER['QUERY_STRING']) ? $_SERVER['QUERY_STRING'] : 'index.php';
        $this->log['query_total_time'] = 0;
        //

        \Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::__construct');
    }

    public function query($sql, $params = array())
    {
        // Tracy Debugger
        $this->log['query_total_time'] = 0;

        $trace = debug_backtrace();
        $filename = (isset($trace[0]['file'])) ? $trace[0]['file'] : '---';
        $cmsPath = str_replace('upload/engine/', '', $_SERVER['DOCUMENT_ROOT'] . '/engine/');
        $cmsPath = str_replace('public/engine/', '', $cmsPath);
        $pureFile = str_replace($cmsPath, '', $filename);

        $bench = new \Ubench;
        $bench->start();
        //

        $this->statement = $this->connection->prepare($sql);

        $result = false;

        try {
            if ($this->statement && $this->statement->execute($params)) {
                $data = array();

                while ($row = $this->statement->fetch(\PDO::FETCH_ASSOC)) {
                    $data[] = $row;
                }

                $result = new \stdClass();
                $result->row = (isset($data[0]) ? $data[0] : array());
                $result->rows = $data;
                $result->num_rows = $this->statement->rowCount();
            }
        } catch (\PDOException $e) {
            throw new \Exception('Error: ' . $e->getMessage() . ' Error Code : ' . $e->getCode() . ' <br />' . $sql);
        }

        // Tracy Debugger
        $bench->end();
        $exec_time = $bench->getTime();

        if (!isset($this->log['query_total_time'])) {
            $this->log['query_total_time'] = 0;
        }

        $this->log['query_total_time'] = (float) $this->log['query_total_time'] + (float) $exec_time;
        $this->log['file']  = $pureFile;
        $this->log['time']  = $exec_time;
        $this->log['query'] = \SqlFormatter::format($sql);
        $_SESSION['_tracy']['sql_log'][] = $this->log;
        //

        if ($result) {
            return $result;
        } else {
            $result = new \stdClass();
            $result->row = array();
            $result->rows = array();
            $result->num_rows = 0;

            return $result;
        }

        \Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::query');
    }

    public function execute()
    {
        try {
            if ($this->statement && $this->statement->execute()) {
                $data = array();

                while ($row = $this->statement->fetch(\PDO::FETCH_ASSOC)) {
                    $data[] = $row;
                }

                $result = new \stdClass();
                $result->row = (isset($data[0])) ? $data[0] : array();
                $result->rows = $data;
                $result->num_rows = $this->statement->rowCount();
            }
        } catch (\PDOException $e) {
            throw new \Exception('Error: ' . $e->getMessage() . ' Error Code : ' . $e->getCode());
        }

        \Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::execute');
    }

    public function escape($value)
    {
        return str_replace(array("\\", "\0", "\n", "\r", "\x1a", "'", '"'), array("\\\\", "\\0", "\\n", "\\r", "\Z", "\'", '\"'), $value);

        \Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::escape');
    }

    public function prepare($sql)
    {
        $this->statement = $this->connection->prepare($sql);

        \Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::prepare');
    }

    public function bindParam($parameter, $variable, $data_type = \PDO::PARAM_STR, $length = 0)
    {
        if ($length) {
            $this->statement->bindParam($parameter, $variable, $data_type, $length);
        } else {
            $this->statement->bindParam($parameter, $variable, $data_type);
        }

        \Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::bindParam');
    }

    public function countAffected()
    {
        if ($this->statement) {
            return $this->statement->rowCount();
        } else {
            return 0;
        }

        \Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::countAffected');
    }

    public function getLastId()
    {
        return $this->connection->lastInsertId();

        \Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::getLastId');
    }

    public function isConnected()
    {
        if ($this->connection) {
            return true;
        } else {
            return false;
        }

        \Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::isConnected');
    }

    public function __destruct()
    {
        $this->connection = null;

        \Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::__destruct');
    }
}


1			<?php
2
3			/* Sunrise CMS - Open source CMS for widespread use.
4			Copyright (c) 2019 Mykola Burakov ([email protected])
5
6			See SOURCE.txt for other and additional information.
7
8			This file is part of Sunrise CMS.
9
10			This program is free software: you can redistribute it and/or modify
11			it under the terms of the GNU General Public License as published by
12			the Free Software Foundation, either version 3 of the License, or
13			(at your option) any later version.
14
15			This program is distributed in the hope that it will be useful,
16			but WITHOUT ANY WARRANTY; without even the implied warranty of
17			MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18			GNU General Public License for more details.
19
20			You should have received a copy of the GNU General Public License
21			along with this program. If not, see <http://www.gnu.org/licenses/>. */
22
23			namespace Sunrise\Engine\Library;
24
25			class Db
26			{
27			private $connection;
28			private $statement;
29			// tracy
30			private $log;
31
32			public function __construct($hostname, $username, $password, $database, $port = '3306')
33			{
34			try {
35			$this->connection = @new \PDO("mysql:host=" . $hostname . ";port=" . $port . ";dbname=" . $database, $username, $password, array(\PDO::ATTR_PERSISTENT => true));
36			} catch (\PDOException $e) {
37			throw new \Exception('Error: Could not make a database link using ' . $username . '@' . $hostname . '!');
38			}
39
40			$this->connection->exec("SET NAMES 'utf8mb4'");
41			$this->connection->exec("SET CHARACTER SET utf8mb4");
42			$this->connection->exec("SET CHARACTER_SET_CONNECTION=utf8mb4");
43			$this->connection->exec("SET SQL_MODE = ''");
44
45			// Tracy Debugger
46			if (isset($_SESSION['_tracy']['sql_log'])) {
47			unset($_SESSION['_tracy']['sql_log']);
48			}
49			$this->log = array();
50			$this->log['page_url'] = (isset($_SERVER['QUERY_STRING']) && $_SERVER['QUERY_STRING']) ? $_SERVER['QUERY_STRING'] : 'index.php';
51			$this->log['query_total_time'] = 0;
52			//
53
54			\Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::__construct');
55			}
56
57			public function query($sql, $params = array())
58			{
59			// Tracy Debugger
60			$this->log['query_total_time'] = 0;
61
62			$trace = debug_backtrace();
63			$filename = (isset($trace[0]['file'])) ? $trace[0]['file'] : '---';
64			$cmsPath = str_replace('upload/engine/', '', $_SERVER['DOCUMENT_ROOT'] . '/engine/');
65			$cmsPath = str_replace('public/engine/', '', $cmsPath);
66			$pureFile = str_replace($cmsPath, '', $filename);
67
68			$bench = new \Ubench;
69			$bench->start();
70			//
71
72			$this->statement = $this->connection->prepare($sql);
73
74			$result = false;
75
76			try {
77			if ($this->statement && $this->statement->execute($params)) {
78			$data = array();
79
80			while ($row = $this->statement->fetch(\PDO::FETCH_ASSOC)) {
81			$data[] = $row;
82			}
83
84			$result = new \stdClass();
85			$result->row = (isset($data[0]) ? $data[0] : array());
86			$result->rows = $data;
87			$result->num_rows = $this->statement->rowCount();
88			}
89			} catch (\PDOException $e) {
90			throw new \Exception('Error: ' . $e->getMessage() . ' Error Code : ' . $e->getCode() . ' <br />' . $sql);
91			}
92
93			// Tracy Debugger
94			$bench->end();
95			$exec_time = $bench->getTime();
96
97			if (!isset($this->log['query_total_time'])) {
98			$this->log['query_total_time'] = 0;
99			}
100
101			$this->log['query_total_time'] = (float) $this->log['query_total_time'] + (float) $exec_time;
102			$this->log['file'] = $pureFile;
103			$this->log['time'] = $exec_time;
104			$this->log['query'] = \SqlFormatter::format($sql);
105			$_SESSION['_tracy']['sql_log'][] = $this->log;
106			//
107
108			if ($result) {
109			return $result;
110			} else {
111			$result = new \stdClass();
112			$result->row = array();
113			$result->rows = array();
114			$result->num_rows = 0;
115
116			return $result;
117			}
118
119			\Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::query');
120			}
121
122			public function execute()
123			{
124			try {
125			if ($this->statement && $this->statement->execute()) {
126			$data = array();
127
128			while ($row = $this->statement->fetch(\PDO::FETCH_ASSOC)) {
129			$data[] = $row;
130			}
131
132			$result = new \stdClass();
133			$result->row = (isset($data[0])) ? $data[0] : array();
134			$result->rows = $data;
135			$result->num_rows = $this->statement->rowCount();
136			}
137			} catch (\PDOException $e) {
138			throw new \Exception('Error: ' . $e->getMessage() . ' Error Code : ' . $e->getCode());
139			}
140
141			\Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::execute');
142			}
143
144			public function escape($value)
145			{
146			return str_replace(array("\\", "\0", "\n", "\r", "\x1a", "'", '"'), array("\\\\", "\\0", "\\n", "\\r", "\Z", "\'", '\"'), $value);
147
148			\Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::escape');
149			}
150
151			public function prepare($sql)
152			{
153			$this->statement = $this->connection->prepare($sql);
154
155			\Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::prepare');
156			}
157
158			public function bindParam($parameter, $variable, $data_type = \PDO::PARAM_STR, $length = 0)
159			{
160			if ($length) {
161			$this->statement->bindParam($parameter, $variable, $data_type, $length);
162			} else {
163			$this->statement->bindParam($parameter, $variable, $data_type);
164			}
165
166			\Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::bindParam');
167			}
168
169			public function countAffected()
170			{
171			if ($this->statement) {
172			return $this->statement->rowCount();
173			} else {
174			return 0;
175			}
176
177			\Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::countAffected');
178			}
179
180			public function getLastId()
181			{
182			return $this->connection->lastInsertId();
183
184			\Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::getLastId');
185			}
186
187			public function isConnected()
188			{
189			if ($this->connection) {
190			return true;
191			} else {
192			return false;
193			}
194
195			\Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::isConnected');
196			}
197
198			public function __destruct()
199			{
200			$this->connection = null;
201
202			\Zarganwar\PerformancePanel\Register::add('Sunrise\Engine\Library\Db::__destruct');
203			}
204			}
205

Nickbur / Sunrise-CMS

Push — develop ( 5c806e...7fd0a7 )

Db::execute() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like