BasicDbEntityService::getPrimaryKeyWhereParameters() - Code Metrics - Inspection of "Allow entity primary value edit" - starweb/starlit-db - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#10)

by Andreas

created 2017-07-01 16:03 UTC

getPrimaryKeyWhereParameters() A

↳ Parent: BasicDbEntityService

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	10
ccs	5
cts	5
cp	1
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	6
nc	2
nop	1
crap	2

<?php
/**
 * Starlit Db.
 *
 * @copyright Copyright (c) 2016 Starweb AB
 * @license   BSD 3-Clause
 */

namespace Starlit\Db;

use Starlit\Db\Exception;

/**
 * A database entity service is intended to handle database operations for existing
 * entity objects, i.e. load, save and load secondary objects etc.
 *
 * @author Andreas Nilsson <http://github.com/jandreasn>
 */
class BasicDbEntityService
{
    /**
     * The database adapter/connection/handler.
     *
     * @var Db
     */
    protected $db;

    /**
     * Constructor.
     *
     * @param Db $db
     */
    public function __construct(Db $db)
    {
        $this->db = $db;
    }

    /**
     * Load object's values from database table.
     *
     * @param AbstractDbEntity $dbEntity
     * @throws Exception\EntityNotFoundException
     */
    public function load(AbstractDbEntity $dbEntity)
    {
        // Check that the primary key is set
        if (!$dbEntity->getPrimaryDbValue()) {
            throw new \InvalidArgumentException(
                'Database entity can not be loaded because primary value is not set'
            );
        }

        // Fetch ad from db
        $row = $this->db->fetchRow(
            '
                SELECT *
                FROM `' . $dbEntity->getDbTableName() . '`
                WHERE ' . $this->getPrimaryKeyWhereSql($dbEntity) . '
            ',
            $this->getPrimaryKeyWhereParameters($dbEntity)
        );

        if (!$row) {
            throw new Exception\EntityNotFoundException("Db entity[{$dbEntity->getPrimaryDbValue()}] does not exist");
        }

        $dbEntity->setDbDataFromRow($row);
    }

    /**
     * Save entity to database table.
     *
     * @param AbstractDbEntity $dbEntity
     * @return bool
     */
    public function save(AbstractDbEntity $dbEntity)
    {
        if ($dbEntity->shouldBeDeletedFromDbOnSave()) {
            // Only delete if previously saved to db
            if ($dbEntity->getPrimaryDbValue()) {
                $this->delete($dbEntity);
            }

            return false;
        }

        if ($dbEntity->shouldInsertOnDbSave()) {
            // Note that database data always contains all properties,
            // with defaults for non set properties
            $dataToSave = $dbEntity->getDbData();
        } else {
            if ($dbEntity->hasModifiedDbProperties()) {
                $dataToSave = $dbEntity->getModifiedDbData();
            } else {
                // Return if no value has been modified and it's not an insert
                // (we always want to insert if no id exist, since some child objects might
                // depend on the this primary id being available)
                return false;
            }
        }

        // Check data
        $sqlData = [];
        foreach ($dataToSave as $propertyName => $value) {
            if (!empty($value) && is_scalar($value)
                && $dbEntity->getDbPropertyMaxLength($propertyName)
                && mb_strlen($value) > $dbEntity->getDbPropertyMaxLength($propertyName)
            ) {
                throw new \RuntimeException(
                    "Database field \"{$propertyName}\" exceeds field max length (value: \"{$value}\")"
                );
            } elseif (empty($value) && $dbEntity->getDbPropertyNonEmpty($propertyName)) {
                throw new \RuntimeException("Database field \"{$propertyName}\" is empty and required");
            } elseif (((is_scalar($value) && ((string) $value) === '') || (!is_scalar($value) && empty($value)))
                && $dbEntity->getDbPropertyRequired($propertyName)
            ) {
                throw new \RuntimeException("Database field \"{$propertyName}\" is required to be set");
            }

            // Set data keys db field format
            $fieldName = $dbEntity->getDbFieldName($propertyName);
            $sqlData[$fieldName] = $value;
        }


        // Insert new database row
        if ($dbEntity->shouldInsertOnDbSave()) {
            $this->db->insert(
                $dbEntity->getDbTableName(),
                $sqlData
            );

            if (!is_array($dbEntity->getPrimaryDbPropertyKey())
                && !empty($lastInsertId = $this->db->getLastInsertId())
            ) {
                $dbEntity->setPrimaryDbValue($lastInsertId);
            }
        // Update existing database row
        } else {
            $this->db->update(
                $dbEntity->getDbTableName(),
                $sqlData,
                $this->getPrimaryKeyWhereSql($dbEntity),
                $this->getPrimaryKeyWhereParameters($dbEntity)

            );
        }

        $dbEntity->clearModifiedDbProperties();
        $dbEntity->setForceDbInsertOnSave(false);

        return true;
    }

    /**
     * Delete entity's corresponding database row.
     *
     * @param AbstractDbEntity $dbEntity
     */
    public function delete(AbstractDbEntity $dbEntity)
    {
        if (!$dbEntity->getPrimaryDbValue()) {
            throw new \InvalidArgumentException('Primary database value not set');
        }

        $this->db->exec(
            'DELETE FROM `' . $dbEntity->getDbTableName() . '` WHERE ' . $this->getPrimaryKeyWhereSql($dbEntity),
            $this->getPrimaryKeyWhereParameters($dbEntity)
        );

        $dbEntity->setDeleted();
    }

    /**
     * @param AbstractDbEntity $dbEntity
     * @return string
     */
    protected function getPrimaryKeyWhereSql(AbstractDbEntity $dbEntity)
    {
        if (is_array($dbEntity->getPrimaryDbPropertyKey())) {
            $whereStrings = [];
            foreach ($dbEntity->getPrimaryDbFieldKey() as $primaryKeyPart) {
$collection = json_decode($data, true);
if ( ! is_array($collection)) {
    throw new \RuntimeException('$collection must be an array.');
}

foreach ($collection as $item) { /** ... */ }
                $whereStrings[] = '`' . $primaryKeyPart . '` = ?';
            }
            $whereSql = implode(' AND ', $whereStrings);
        } else {
            $whereSql = '`' . $dbEntity->getPrimaryDbFieldKey() . '` = ?';
        }

        return $whereSql;
    }

    /**
     * @param AbstractDbEntity $dbEntity
     * @return array
     */
    protected function getPrimaryKeyWhereParameters(AbstractDbEntity $dbEntity)
    {
        if (is_array($dbEntity->getPrimaryDbPropertyKey())) {
            $whereParameters = $dbEntity->getPrimaryDbValue();
        } else {
            $whereParameters = [$dbEntity->getPrimaryDbValue()];
        }

        return $whereParameters;
    }
}


1		<?php
2		/**
3		* Starlit Db.
4		*
5		* @copyright Copyright (c) 2016 Starweb AB
6		* @license BSD 3-Clause
7		*/
8
9		namespace Starlit\Db;
10
11		use Starlit\Db\Exception;
12
13		/**
14		* A database entity service is intended to handle database operations for existing
15		* entity objects, i.e. load, save and load secondary objects etc.
16		*
17		* @author Andreas Nilsson <http://github.com/jandreasn>
18		*/
19		class BasicDbEntityService
20		{
21		/**
22		* The database adapter/connection/handler.
23		*
24		* @var Db
25		*/
26		protected $db;
27
28		/**
29		* Constructor.
30		*
31		* @param Db $db
32		*/
33	15	public function __construct(Db $db)
34		{
35	15	$this->db = $db;
36	15	}
37
38		/**
39		* Load object's values from database table.
40		*
41		* @param AbstractDbEntity $dbEntity
42		* @throws Exception\EntityNotFoundException
43		*/
44	3	public function load(AbstractDbEntity $dbEntity)
45		{
46		// Check that the primary key is set
47	3	if (!$dbEntity->getPrimaryDbValue()) {
48	1	throw new \InvalidArgumentException(
49	1	'Database entity can not be loaded because primary value is not set'
50		);
51		}
52
53		// Fetch ad from db
54	2	$row = $this->db->fetchRow(
55		'
56		SELECT *
57	2	FROM `' . $dbEntity->getDbTableName() . '`
58	2	WHERE ' . $this->getPrimaryKeyWhereSql($dbEntity) . '
59		',
60	2	$this->getPrimaryKeyWhereParameters($dbEntity)
61		);
62
63	2	if (!$row) {
64	1	throw new Exception\EntityNotFoundException("Db entity[{$dbEntity->getPrimaryDbValue()}] does not exist");
65		}
66
67	1	$dbEntity->setDbDataFromRow($row);
68	1	}
69
70		/**
71		* Save entity to database table.
72		*
73		* @param AbstractDbEntity $dbEntity
74		* @return bool
75		*/
76	10	public function save(AbstractDbEntity $dbEntity)
77		{
78	10	if ($dbEntity->shouldBeDeletedFromDbOnSave()) {
79		// Only delete if previously saved to db
80	2	if ($dbEntity->getPrimaryDbValue()) {
81	1	$this->delete($dbEntity);
82		}
83
84	2	return false;
85		}
86
87	8	if ($dbEntity->shouldInsertOnDbSave()) {
88		// Note that database data always contains all properties,
89		// with defaults for non set properties
90	5	$dataToSave = $dbEntity->getDbData();
91		} else {
92	3	if ($dbEntity->hasModifiedDbProperties()) {
93	2	$dataToSave = $dbEntity->getModifiedDbData();
94		} else {
95		// Return if no value has been modified and it's not an insert
96		// (we always want to insert if no id exist, since some child objects might
97		// depend on the this primary id being available)
98	1	return false;
99		}
100		}
101
102		// Check data
103	7	$sqlData = [];
104	7	foreach ($dataToSave as $propertyName => $value) {
105	7	if (!empty($value) && is_scalar($value)
106	5	&& $dbEntity->getDbPropertyMaxLength($propertyName)
107	5	&& mb_strlen($value) > $dbEntity->getDbPropertyMaxLength($propertyName)
108		) {
109	1	throw new \RuntimeException(
110	1	"Database field \"{$propertyName}\" exceeds field max length (value: \"{$value}\")"
111		);
112	5	} elseif (empty($value) && $dbEntity->getDbPropertyNonEmpty($propertyName)) {
113	1	throw new \RuntimeException("Database field \"{$propertyName}\" is empty and required");
114	7	} elseif (((is_scalar($value) && ((string) $value) === '') \|\| (!is_scalar($value) && empty($value)))
115	2	&& $dbEntity->getDbPropertyRequired($propertyName)
116		) {
117	2	throw new \RuntimeException("Database field \"{$propertyName}\" is required to be set");
118		}
119
120		// Set data keys db field format
121	7	$fieldName = $dbEntity->getDbFieldName($propertyName);
122	7	$sqlData[$fieldName] = $value;
123		}
124
125
126		// Insert new database row
127	3	if ($dbEntity->shouldInsertOnDbSave()) {
128	1	$this->db->insert(
129	1	$dbEntity->getDbTableName(),
130	1	$sqlData
131		);
132
133	1	if (!is_array($dbEntity->getPrimaryDbPropertyKey())
134	1	&& !empty($lastInsertId = $this->db->getLastInsertId())
135		) {
136		$dbEntity->setPrimaryDbValue($lastInsertId);
137		}
138		// Update existing database row
139		} else {
140	2	$this->db->update(
141	2	$dbEntity->getDbTableName(),
142	2	$sqlData,
143	2	$this->getPrimaryKeyWhereSql($dbEntity),
144	2	$this->getPrimaryKeyWhereParameters($dbEntity)
145
146		);
147		}
148
149	3	$dbEntity->clearModifiedDbProperties();
150	3	$dbEntity->setForceDbInsertOnSave(false);
151
152	3	return true;
153		}
154
155		/**
156		* Delete entity's corresponding database row.
157		*
158		* @param AbstractDbEntity $dbEntity
159		*/
160	3	public function delete(AbstractDbEntity $dbEntity)
161		{
162	3	if (!$dbEntity->getPrimaryDbValue()) {
163	1	throw new \InvalidArgumentException('Primary database value not set');
164		}
165
166	2	$this->db->exec(
167	2	'DELETE FROM `' . $dbEntity->getDbTableName() . '` WHERE ' . $this->getPrimaryKeyWhereSql($dbEntity),
168	2	$this->getPrimaryKeyWhereParameters($dbEntity)
169		);
170
171	2	$dbEntity->setDeleted();
172	2	}
173
174		/**
175		* @param AbstractDbEntity $dbEntity
176		* @return string
177		*/
178	6	protected function getPrimaryKeyWhereSql(AbstractDbEntity $dbEntity)
179		{
180	6	if (is_array($dbEntity->getPrimaryDbPropertyKey())) {
181	1	$whereStrings = [];
182	1	foreach ($dbEntity->getPrimaryDbFieldKey() as $primaryKeyPart) {
		0 ignored issues – show Bug introduced 2017-03-25 18:39 UTC by Report Bug Copy Issue Report The expression `$dbEntity->getPrimaryDbFieldKey()` of type `array\|string` 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...
183	1	$whereStrings[] = '`' . $primaryKeyPart . '` = ?';
184		}
185	1	$whereSql = implode(' AND ', $whereStrings);
186		} else {
187	5	$whereSql = '`' . $dbEntity->getPrimaryDbFieldKey() . '` = ?';
188		}
189
190	6	return $whereSql;
191		}
192
193		/**
194		* @param AbstractDbEntity $dbEntity
195		* @return array
196		*/
197	6	protected function getPrimaryKeyWhereParameters(AbstractDbEntity $dbEntity)
198		{
199	6	if (is_array($dbEntity->getPrimaryDbPropertyKey())) {
200	1	$whereParameters = $dbEntity->getPrimaryDbValue();
201		} else {
202	5	$whereParameters = [$dbEntity->getPrimaryDbValue()];
203		}
204
205	6	return $whereParameters;
206		}
207		}
208

starweb / starlit-db

GitHub Access Token became invalid

Pull Request — master (#10)

getPrimaryKeyWhereParameters() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like