SQL::disconnect() - Code Metrics - Inspection of "basic realization of mongo driver is added" - drmvc/database - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 842882...29bedd )

by Mr

created 2018-03-31 02:47 UTC

SQL::disconnect() A

↳ Parent: SQL

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	4
c	0
b	0
f	0
rs	10
cc	1
eloc	2
nc	1
nop	0

<?php

namespace DrMVC\Database\Drivers;

use DrMVC\Database\SQLException;

abstract class SQL extends Driver
{
    /**
     * Initiate connection to database
     *
     * @return  DriverInterface
     */
    public function connect(): DriverInterface
    {
        try {
            $connection = new \PDO(
                $this->getDsn(),
                $this->getParam('username'),
                $this->getParam('password')
            );
            $this->setConnection($connection);

        } catch (SQLException $e) {
            // __construct
        }

        return $this;
    }

    /**
     * Run a select statement against the database
     *
     * @param   string $query
     * @param   array $data
     * @return  array|object
     */
    public function select(string $query, array $data = [])
    {
        // Set statement
        $statement = $this->getConnection()->prepare($query);

        // Parse parameters from array
        foreach ($data as $key => $value) {
            $value_type = \is_int($value) ? \PDO::PARAM_INT : \PDO::PARAM_STR;
            $statement->bindValue($key, $value, $value_type);
        }

        // Execute the statement
        $statement->execute();

        // Return result
        return $statement->fetchAll(\PDO::FETCH_OBJ);
    }

    /**
     * Exec query without return, create table for example
     *
     * @param   string $query
     * @return  mixed
     */
    public function exec(string $query)
    {
        return $this->getConnection()->exec($query);
    }

    /**
     * Generate INSERT query by array
     *
     * @param   array $data
     * @return  string
     */
    private function genInsert(array $data): string
    {
        // Current table
        $table = $this->getCollection();

        // Generate array of fields for insert
        $fieldNames = implode(',', array_keys($data));

        // Generate line with data for update
        $fieldDetails = ':' . implode(', :', array_keys($data));

        return "INSERT INTO $table ($fieldNames) VALUES ($fieldDetails)";
    }

    /**
     * Insert in database and return of inserted element
     *
     * @param   array $data array of columns and values
     * @param   string $id field name of ID which must be returned
     * @return  mixed
     */
    public function insert(array $data, string $id = null)
    {
        // Prepare query
        $query = $this->genInsert($data);
        $statement = $this->_connection->prepare($query);

        // Bind values
        foreach ($data as $key => $value) {
            $statement->bindValue(":$key", $value);
        }

        // Execute operation
        $statement->execute();

        return (null !== $id)
            // Return ID of inserted element
            ? $this->getConnection()->lastInsertId($id)
            // Return count of affected rows
            : $statement->rowCount();
    }

    /**
     * Generate the line by provided keys
     *
     * @param   array $array array with data
     * @param   string $glue by this glue need merge items
     * @param   string $name name of field for PDO->bindValue
     * @return  string
     */
    private function genLine(array $array, string $glue, string $name): string
    {
        $line = '';
        $i = 0;
        foreach ($array as $key => $value) {
            $line .= (($i !== 0) ? null : $glue) . "$key = :${name}_$key";
            $i = 1;
        }
        return $line;
    }

    /**
     * Generate set of fields
     *
     * @param   array $array
     * @return  string
     */
    private function genFields(array $array): string
    {
        return $this->genLine($array, ', ', 'field');
    }

    /**
     * Generate WHERE line
     *
     * @param   array $array
     * @return  string
     */
    private function genWhere(array $array): string
    {
        return $this->genLine($array, ' AND ', 'where');
    }

    /**
     * Generate update query
     *
     * @param   array $data
     * @param   array $where
     * @return  string
     */
    private function genUpdate(array $data, array $where): string
    {
        // Current table
        $table = $this->getConnection();

        // Generate line with data for update
        $fieldDetails = !empty($data)
            ? $this->genFields($data)
            : '';

        // Generate where line
        $whereDetails = !empty($where)
            ? ' WHERE ' . $this->genWhere($where)
            : '';

        return "UPDATE $table SET $fieldDetails $whereDetails";
    }

    /**
     * Update method
     *
     * @param  array $data array of columns and values
     * @param  array $where array of columns and values
     * @return mixed
     */
    public function update(array $data, array $where)
    {
        // Prepare query
        $query = $this->genUpdate($data, $where);
        $statement = $this->getConnection()->prepare($query);

        // Bind field values
        foreach ($data as $key => $value) {
            $statement->bindValue(":field_$key", $value);
        }

        // Bind where values
        foreach ($where as $key => $value) {
            $statement->bindValue(":where_$key", $value);
        }

        // Execute operation
        $statement->execute();

        // Return count of affected rows
        return $statement->rowCount();
    }

    /**
     * Delete rows from database
     *
     * @param   array $where
     * @return  mixed
     */
    public function delete(array $where)
    {
        // Current table
        $table = $this->getConnection();

        // Generate where line
        $whereDetails = !empty($where)
            ? ' WHERE ' . $this->genWhere($where)
            : '';

        // Prepare query
        $statement = $this->getConnection()->prepare("DELETE FROM $table $whereDetails");

        // Bind where values
        foreach ($where as $key => $value) {
            $statement->bindValue(":where_$key", $value);
        }

        // Execute operation
        $statement->execute();

        // Return count of affected rows
        return $statement->rowCount();
    }

    /**
     * Clean table function
     *
     * @return mixed
     */
    public function truncate()
    {
        // Current table
        $table = $this->getConnection();

        // Exec the truncate command
        return $this->exec("TRUNCATE TABLE $table");
    }
}


1			<?php
2
3			namespace DrMVC\Database\Drivers;
4
5			use DrMVC\Database\SQLException;
6
7			abstract class SQL extends Driver
8			{
9			/**
10			* Initiate connection to database
11			*
12			* @return DriverInterface
13			*/
14			public function connect(): DriverInterface
15			{
16			try {
17			$connection = new \PDO(
18			$this->getDsn(),
19			$this->getParam('username'),
20			$this->getParam('password')
21			);
22			$this->setConnection($connection);
23
24			} catch (SQLException $e) {
25			// __construct
26			}
27
28			return $this;
29			}
30
31			/**
32			* Run a select statement against the database
33			*
34			* @param string $query
35			* @param array $data
36			* @return array\|object
37			*/
38			public function select(string $query, array $data = [])
39			{
40			// Set statement
41			$statement = $this->getConnection()->prepare($query);
42
43			// Parse parameters from array
44			foreach ($data as $key => $value) {
45			$value_type = \is_int($value) ? \PDO::PARAM_INT : \PDO::PARAM_STR;
46			$statement->bindValue($key, $value, $value_type);
47			}
48
49			// Execute the statement
50			$statement->execute();
51
52			// Return result
53			return $statement->fetchAll(\PDO::FETCH_OBJ);
54			}
55
56			/**
57			* Exec query without return, create table for example
58			*
59			* @param string $query
60			* @return mixed
61			*/
62			public function exec(string $query)
63			{
64			return $this->getConnection()->exec($query);
65			}
66
67			/**
68			* Generate INSERT query by array
69			*
70			* @param array $data
71			* @return string
72			*/
73			private function genInsert(array $data): string
74			{
75			// Current table
76			$table = $this->getCollection();
77
78			// Generate array of fields for insert
79			$fieldNames = implode(',', array_keys($data));
80
81			// Generate line with data for update
82			$fieldDetails = ':' . implode(', :', array_keys($data));
83
84			return "INSERT INTO $table ($fieldNames) VALUES ($fieldDetails)";
85			}
86
87			/**
88			* Insert in database and return of inserted element
89			*
90			* @param array $data array of columns and values
91			* @param string $id field name of ID which must be returned
92			* @return mixed
93			*/
94			public function insert(array $data, string $id = null)
95			{
96			// Prepare query
97			$query = $this->genInsert($data);
98			$statement = $this->_connection->prepare($query);
99
100			// Bind values
101			foreach ($data as $key => $value) {
102			$statement->bindValue(":$key", $value);
103			}
104
105			// Execute operation
106			$statement->execute();
107
108			return (null !== $id)
109			// Return ID of inserted element
110			? $this->getConnection()->lastInsertId($id)
111			// Return count of affected rows
112			: $statement->rowCount();
113			}
114
115			/**
116			* Generate the line by provided keys
117			*
118			* @param array $array array with data
119			* @param string $glue by this glue need merge items
120			* @param string $name name of field for PDO->bindValue
121			* @return string
122			*/
123			private function genLine(array $array, string $glue, string $name): string
124			{
125			$line = '';
126			$i = 0;
127			foreach ($array as $key => $value) {
128			$line .= (($i !== 0) ? null : $glue) . "$key = :${name}_$key";
129			$i = 1;
130			}
131			return $line;
132			}
133
134			/**
135			* Generate set of fields
136			*
137			* @param array $array
138			* @return string
139			*/
140			private function genFields(array $array): string
141			{
142			return $this->genLine($array, ', ', 'field');
143			}
144
145			/**
146			* Generate WHERE line
147			*
148			* @param array $array
149			* @return string
150			*/
151			private function genWhere(array $array): string
152			{
153			return $this->genLine($array, ' AND ', 'where');
154			}
155
156			/**
157			* Generate update query
158			*
159			* @param array $data
160			* @param array $where
161			* @return string
162			*/
163			private function genUpdate(array $data, array $where): string
164			{
165			// Current table
166			$table = $this->getConnection();
167
168			// Generate line with data for update
169			$fieldDetails = !empty($data)
170			? $this->genFields($data)
171			: '';
172
173			// Generate where line
174			$whereDetails = !empty($where)
175			? ' WHERE ' . $this->genWhere($where)
176			: '';
177
178			return "UPDATE $table SET $fieldDetails $whereDetails";
179			}
180
181			/**
182			* Update method
183			*
184			* @param array $data array of columns and values
185			* @param array $where array of columns and values
186			* @return mixed
187			*/
188			public function update(array $data, array $where)
189			{
190			// Prepare query
191			$query = $this->genUpdate($data, $where);
192			$statement = $this->getConnection()->prepare($query);
193
194			// Bind field values
195			foreach ($data as $key => $value) {
196			$statement->bindValue(":field_$key", $value);
197			}
198
199			// Bind where values
200			foreach ($where as $key => $value) {
201			$statement->bindValue(":where_$key", $value);
202			}
203
204			// Execute operation
205			$statement->execute();
206
207			// Return count of affected rows
208			return $statement->rowCount();
209			}
210
211			/**
212			* Delete rows from database
213			*
214			* @param array $where
215			* @return mixed
216			*/
217			public function delete(array $where)
218			{
219			// Current table
220			$table = $this->getConnection();
221
222			// Generate where line
223			$whereDetails = !empty($where)
224			? ' WHERE ' . $this->genWhere($where)
225			: '';
226
227			// Prepare query
228			$statement = $this->getConnection()->prepare("DELETE FROM $table $whereDetails");
229
230			// Bind where values
231			foreach ($where as $key => $value) {
232			$statement->bindValue(":where_$key", $value);
233			}
234
235			// Execute operation
236			$statement->execute();
237
238			// Return count of affected rows
239			return $statement->rowCount();
240			}
241
242			/**
243			* Clean table function
244			*
245			* @return mixed
246			*/
247			public function truncate()
248			{
249			// Current table
250			$table = $this->getConnection();
251
252			// Exec the truncate command
253			return $this->exec("TRUNCATE TABLE $table");
254			}
255			}
256

drmvc / database

Push — master ( 842882...29bedd )

SQL::disconnect() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like