InsertQuery::getSQL() - Code Metrics - Inspection of "expose internal `PDO` instance" - mindplay-dk/sql - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( f5e696...7c0e7c )

by Rasmus

created 2017-05-19 11:07 UTC

InsertQuery::getSQL() A

↳ Parent: InsertQuery

Complexity

Conditions	2
Paths	2

Size

Total Lines	20
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	11
CRAP Score	2.0023

Importance

Changes

Metric	Value
dl	0
loc	20
ccs	11
cts	12
cp	0.9167
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	11
nc	2
nop	0
crap	2.0023

<?php

namespace mindplay\sql\model\query;

use mindplay\sql\model\Driver;
use mindplay\sql\model\schema\Column;
use mindplay\sql\model\schema\Table;
use mindplay\sql\model\TypeProvider;
use RuntimeException;

/**
 * This class represents an INSERT query.
 */
class InsertQuery extends Query
{
    /**
     * @var Driver
     */
    private $driver;

    /**
     * @var Table
     */
    private $table;

    /**
     * @var Column[]
     */
    private $columns;

    /**
     * @var string[] list of tuple expressions
     */
    private $tuples = [];

    /**
     * @param Driver       $driver
     * @param TypeProvider $types
     * @param Table        $table Table to INSERT into
     */
    public function __construct(Driver $driver, TypeProvider $types, Table $table)
    {
        parent::__construct($types);

        if ($table->getAlias()) {
''   == false // true
''   == null  // true
'ab' == false // false
'ab' == null  // false

// It is often better to use strict comparison
'' === false // false
'' === null  // false
            throw new RuntimeException("can't insert into a Table instance with an alias");
        }

        $this->driver = $driver;

        $this->table = $table;

        $this->columns = array_filter(
            $table->listColumns(),
            function (Column $column) {
                return $column->isAuto() === false;
            }
        );
    }


    /**
     * Add a record to this INSERT query.
     *
     * @param array $record record map (where Column name => value)
     *
     * @return $this
     */
    public function add(array $record)
    {
        $placeholders = [];

        $tuple_num = count($this->tuples);

        foreach ($this->columns as $col_index => $column) {
            $name = $column->getName();

            if (array_key_exists($name, $record)) {
                $value = $record[$name];
            } elseif ($column->isRequired() === false) {
                $value = $column->getDefault();
            } else {
                throw new RuntimeException("required value '{$name}' missing from tuple # {$tuple_num}");
            }

            $placeholder = "c{$tuple_num}_{$col_index}";

            $placeholders[] = ":{$placeholder}";

            $this->bind($placeholder, $value, $column->getType());
        }

        $this->tuples[] = "(" . implode(", ", $placeholders) . ")";

        return $this;
    }

    /**
     * @inheritdoc
     */
    public function getSQL()
    {
        if (count($this->tuples) === 0) {
            throw new RuntimeException("no records added to this query");
        }

        $table = "{$this->table}";

        $quoted_column_names = implode(
            ", ",
            array_map(
                function (Column $column) {
                    return $this->driver->quoteName($column->getName());
                },
                $this->columns
            )
        );

        return "INSERT INTO {$table} ({$quoted_column_names}) VALUES\n" . implode(",\n", $this->tuples);
    }
}


1		<?php
2
3		namespace mindplay\sql\model\query;
4
5		use mindplay\sql\model\Driver;
6		use mindplay\sql\model\schema\Column;
7		use mindplay\sql\model\schema\Table;
8		use mindplay\sql\model\TypeProvider;
9		use RuntimeException;
10
11		/**
12		* This class represents an INSERT query.
13		*/
14		class InsertQuery extends Query
15		{
16		/**
17		* @var Driver
18		*/
19		private $driver;
20
21		/**
22		* @var Table
23		*/
24		private $table;
25
26		/**
27		* @var Column[]
28		*/
29		private $columns;
30
31		/**
32		* @var string[] list of tuple expressions
33		*/
34		private $tuples = [];
35
36		/**
37		* @param Driver $driver
38		* @param TypeProvider $types
39		* @param Table $table Table to INSERT into
40		*/
41	1	public function __construct(Driver $driver, TypeProvider $types, Table $table)
42		{
43	1	parent::__construct($types);
44
45	1	if ($table->getAlias()) {
		0 ignored issues – show Bug Best Practice introduced 2016-04-29 10:35 UTC by Report Bug Copy Issue Report The expression `$table->getAlias()` of type `string\|null` is loosely compared to `true`; this is ambiguous if the string can be empty. You might want to explicitly use `!== null` instead. In PHP, under loose comparison (like `==`, or `!=`, or `switch` conditions), values of different types might be equal. For `string` values, the empty string `''` is a special case, in particular the following results might be unexpected: '' == false // true '' == null // true 'ab' == false // false 'ab' == null // false // It is often better to use strict comparison '' === false // false '' === null // false Loading history...
46		throw new RuntimeException("can't insert into a Table instance with an alias");
47		}
48
49	1	$this->driver = $driver;
50
51	1	$this->table = $table;
52
53	1	$this->columns = array_filter(
54	1	$table->listColumns(),
55		function (Column $column) {
56	1	return $column->isAuto() === false;
57	1	}
58		);
59	1	}
60
61
62		/**
63		* Add a record to this INSERT query.
64		*
65		* @param array $record record map (where Column name => value)
66		*
67		* @return $this
68		*/
69	1	public function add(array $record)
70		{
71	1	$placeholders = [];
72
73	1	$tuple_num = count($this->tuples);
74
75	1	foreach ($this->columns as $col_index => $column) {
76	1	$name = $column->getName();
77
78	1	if (array_key_exists($name, $record)) {
79	1	$value = $record[$name];
80		} elseif ($column->isRequired() === false) {
81		$value = $column->getDefault();
82		} else {
83		throw new RuntimeException("required value '{$name}' missing from tuple # {$tuple_num}");
84		}
85
86	1	$placeholder = "c{$tuple_num}_{$col_index}";
87
88	1	$placeholders[] = ":{$placeholder}";
89
90	1	$this->bind($placeholder, $value, $column->getType());
91		}
92
93	1	$this->tuples[] = "(" . implode(", ", $placeholders) . ")";
94
95	1	return $this;
96		}
97
98		/**
99		* @inheritdoc
100		*/
101	1	public function getSQL()
102		{
103	1	if (count($this->tuples) === 0) {
104		throw new RuntimeException("no records added to this query");
105		}
106
107	1	$table = "{$this->table}";
108
109	1	$quoted_column_names = implode(
110	1	", ",
111	1	array_map(
112	1	function (Column $column) {
113	1	return $this->driver->quoteName($column->getName());
114	1	},
115	1	$this->columns
116		)
117		);
118
119	1	return "INSERT INTO {$table} ({$quoted_column_names}) VALUES\n" . implode(",\n", $this->tuples);
120		}
121		}
122

mindplay-dk / sql

Push — master ( f5e696...7c0e7c )

InsertQuery::getSQL() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like