Driver::insertBatch() - Code Metrics - aviat4ion/Query - Measure and Improve Code Quality continuously with Scrutinizer

Driver::insertBatch() B
last analyzed 2019-12-10 17:36 UTC

↳ Parent: Driver

Complexity

Conditions	5
Paths	6

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	5
nc	6
nop	2
dl	0
loc	40
rs	8.9688
c	0
b	0
f	0

<?php declare(strict_types=1);
/**
 * Query
 *
 * SQL Query Builder / Database Abstraction Layer
 *
 * PHP version 7.1
 *
 * @package     Query
 * @author      Timothy J. Warren <[email protected]>
 * @copyright   2012 - 2018 Timothy J. Warren
 * @license     http://www.opensource.org/licenses/mit-license.html  MIT License
 * @link        https://git.timshomepage.net/aviat4ion/Query
 */
namespace Query\Drivers\Sqlite;

use PDO;
use Query\Drivers\AbstractDriver;

/**
 * SQLite specific class
 */
class Driver extends AbstractDriver {

	/**
	 * SQLite has a truncate optimization,
	 * but no support for the actual keyword
	 * @var boolean
	 */
	protected $hasTruncate = FALSE;

	/**
	 * Open SQLite Database
	 *
	 * @param string $dsn
	 * @param string $user
	 * @param string $pass
	 * @param array $driverOptions
	 */
	public function __construct(string $dsn, string $user=NULL, string $pass=NULL, array $driverOptions=[])
	{
		if (strpos($dsn, 'sqlite:') === FALSE)
		{
			$dsn = "sqlite:{$dsn}";
		}

		parent::__construct($dsn, $user, $pass);
	}

	/**
	 * List tables for the current database
	 *
	 * @return mixed
	 */
	public function getTables(): array
	{
		$sql = $this->sql->tableList();
		$res = $this->query($sql);
		return dbFilter($res->fetchAll(PDO::FETCH_ASSOC), 'name');
	}

	/**
	 * Retrieve foreign keys for the table
	 *
	 * @param string $table
	 * @return array
	 */
	public function getFks($table): array
	{
		$returnRows = [];

		foreach(parent::getFks($table) as $row)
$collection = json_decode($data, true);
if ( ! is_array($collection)) {
    throw new \RuntimeException('$collection must be an array.');
}

foreach ($collection as $item) { /** ... */ }
		{
			$returnRows[] = [
				'child_column' => $row['from'],
				'parent_table' => $row['table'],
				'parent_column' => $row['to'],
				'update' => $row['on_update'],
				'delete' => $row['on_delete']
			];
		}

		return $returnRows;
	}

	/**
	 * Create sql for batch insert
	 *
	 * @codeCoverageIgnore
	 * @param string $table
	 * @param array $data
	 * @return array
	 */
	public function insertBatch(string $table, array $data=[]): array
	{
		// If greater than version 3.7.11, supports the same syntax as
		// MySQL and Postgres
		if (version_compare($this->getAttribute(PDO::ATTR_SERVER_VERSION), '3.7.11', '>='))
		{
			return parent::insertBatch($table, $data);
		}

		// --------------------------------------------------------------------------
		// Otherwise, do a union query as an analogue to a 'proper' batch insert
		// --------------------------------------------------------------------------

		// Each member of the data array needs to be an array
		if ( ! \is_array(current($data)))
		{
			return NULL;
		}

		// Start the block of sql statements
		$table = $this->quoteTable($table);
		$sql = "INSERT INTO {$table} \n";

		// Create a key-value mapping for each field
		$first = array_shift($data);
		$cols = [];
		foreach($first as $colname => $datum)
		{
			$cols[] = $this->_quote($datum) . ' AS ' . $this->quoteIdent($colname);
		}
		$sql .= 'SELECT ' . implode(', ', $cols) . "\n";

		foreach($data as $union)
		{
			$vals = array_map([$this, 'quote'], $union);
			$sql .= 'UNION SELECT ' . implode(',', $vals) . "\n";
		}

		return [$sql, NULL];
	}
}

1			<?php declare(strict_types=1);
2			/**
3			* Query
4			*
5			* SQL Query Builder / Database Abstraction Layer
6			*
7			* PHP version 7.1
8			*
9			* @package Query
10			* @author Timothy J. Warren <[email protected]>
11			* @copyright 2012 - 2018 Timothy J. Warren
12			* @license http://www.opensource.org/licenses/mit-license.html MIT License
13			* @link https://git.timshomepage.net/aviat4ion/Query
14			*/
15			namespace Query\Drivers\Sqlite;
16
17			use PDO;
18			use Query\Drivers\AbstractDriver;
19
20			/**
21			* SQLite specific class
22			*/
23			class Driver extends AbstractDriver {
24
25			/**
26			* SQLite has a truncate optimization,
27			* but no support for the actual keyword
28			* @var boolean
29			*/
30			protected $hasTruncate = FALSE;
31
32			/**
33			* Open SQLite Database
34			*
35			* @param string $dsn
36			* @param string $user
37			* @param string $pass
38			* @param array $driverOptions
39			*/
40			public function __construct(string $dsn, string $user=NULL, string $pass=NULL, array $driverOptions=[])
41			{
42			if (strpos($dsn, 'sqlite:') === FALSE)
43			{
44			$dsn = "sqlite:{$dsn}";
45			}
46
47			parent::__construct($dsn, $user, $pass);
48			}
49
50			/**
51			* List tables for the current database
52			*
53			* @return mixed
54			*/
55			public function getTables(): array
56			{
57			$sql = $this->sql->tableList();
58			$res = $this->query($sql);
59			return dbFilter($res->fetchAll(PDO::FETCH_ASSOC), 'name');
60			}
61
62			/**
63			* Retrieve foreign keys for the table
64			*
65			* @param string $table
66			* @return array
67			*/
68			public function getFks($table): array
69			{
70			$returnRows = [];
71
72			foreach(parent::getFks($table) as $row)
			0 ignored issues – show Bug introduced 2018-01-22 20:45 UTC by Report Bug Copy Issue Report The expression `parent::getFks($table)` of type `array\|null` is not guaranteed to be traversable. How about adding an additional type check? There are different options of fixing this problem. If you want to be on the safe side, you can add an additional type-check: $collection = json_decode($data, true); if ( ! is_array($collection)) { throw new \RuntimeException('$collection must be an array.'); } foreach ($collection as $item) { /** ... / } If you are sure that the expression is traversable, you might want to add a doc comment cast* to improve IDE auto-completion and static analysis: /** @var array $collection / $collection = json_decode($data, true); foreach ($collection as $item) { /* .. / } Mark the issue as a false-positive*: Just hover the remove button, in the top-right corner of this issue for more options. Loading history...
73			{
74			$returnRows[] = [
75			'child_column' => $row['from'],
76			'parent_table' => $row['table'],
77			'parent_column' => $row['to'],
78			'update' => $row['on_update'],
79			'delete' => $row['on_delete']
80			];
81			}
82
83			return $returnRows;
84			}
85
86			/**
87			* Create sql for batch insert
88			*
89			* @codeCoverageIgnore
90			* @param string $table
91			* @param array $data
92			* @return array
93			*/
94			public function insertBatch(string $table, array $data=[]): array
95			{
96			// If greater than version 3.7.11, supports the same syntax as
97			// MySQL and Postgres
98			if (version_compare($this->getAttribute(PDO::ATTR_SERVER_VERSION), '3.7.11', '>='))
99			{
100			return parent::insertBatch($table, $data);
101			}
102
103			// --------------------------------------------------------------------------
104			// Otherwise, do a union query as an analogue to a 'proper' batch insert
105			// --------------------------------------------------------------------------
106
107			// Each member of the data array needs to be an array
108			if ( ! \is_array(current($data)))
109			{
110			return NULL;
111			}
112
113			// Start the block of sql statements
114			$table = $this->quoteTable($table);
115			$sql = "INSERT INTO {$table} \n";
116
117			// Create a key-value mapping for each field
118			$first = array_shift($data);
119			$cols = [];
120			foreach($first as $colname => $datum)
121			{
122			$cols[] = $this->_quote($datum) . ' AS ' . $this->quoteIdent($colname);
123			}
124			$sql .= 'SELECT ' . implode(', ', $cols) . "\n";
125
126			foreach($data as $union)
127			{
128			$vals = array_map([$this, 'quote'], $union);
129			$sql .= 'UNION SELECT ' . implode(',', $vals) . "\n";
130			}
131
132			return [$sql, NULL];
133			}
134			}

aviat4ion / Query

Driver::insertBatch() B last analyzed 2019-12-10 17:36 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Driver::insertBatch() B
last analyzed 2019-12-10 17:36 UTC