BasicDbEntityService::load() - 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-17 15:11 UTC

BasicDbEntityService::load() B

↳ Parent: BasicDbEntityService

Complexity

Conditions	3
Paths	3

Size

Total Lines	25
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	12
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	25
ccs	12
cts	12
cp	1
rs	8.8571
c	0
b	0
f	0
cc	3
eloc	12
nc	3
nop	1
crap	3

<?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
            );

            // Update entity with auto increment value
            if (!is_array($dbEntity->getPrimaryDbPropertyKey())
                && !empty($lastInsertId = $this->db->getLastInsertId())
            ) {
                $dbEntity->setPrimaryDbValue($lastInsertId);
            } else {
                // For entities with for example string primary keys, we update primary value
                // with value/values from db data, indicating that the entity is now
                // in database/loaded.
                $dbEntity->updatePrimaryDbValueFromDbData();
            }
        // 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	7	&& $dbEntity->getDbPropertyMaxLength($propertyName)
107	7	&& 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	7	} 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	7	&& $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		// Update entity with auto increment value
134	1	if (!is_array($dbEntity->getPrimaryDbPropertyKey())
135	1	&& !empty($lastInsertId = $this->db->getLastInsertId())
136		) {
137		$dbEntity->setPrimaryDbValue($lastInsertId);
138		} else {
139		// For entities with for example string primary keys, we update primary value
140		// with value/values from db data, indicating that the entity is now
141		// in database/loaded.
142	1	$dbEntity->updatePrimaryDbValueFromDbData();
143		}
144		// Update existing database row
145		} else {
146	2	$this->db->update(
147	2	$dbEntity->getDbTableName(),
148	2	$sqlData,
149	2	$this->getPrimaryKeyWhereSql($dbEntity),
150	2	$this->getPrimaryKeyWhereParameters($dbEntity)
151
152		);
153		}
154
155	3	$dbEntity->clearModifiedDbProperties();
156	3	$dbEntity->setForceDbInsertOnSave(false);
157
158	3	return true;
159		}
160
161		/**
162		* Delete entity's corresponding database row.
163		*
164		* @param AbstractDbEntity $dbEntity
165		*/
166	3	public function delete(AbstractDbEntity $dbEntity)
167		{
168	3	if (!$dbEntity->getPrimaryDbValue()) {
169	1	throw new \InvalidArgumentException('Primary database value not set');
170		}
171
172	2	$this->db->exec(
173	2	'DELETE FROM `' . $dbEntity->getDbTableName() . '` WHERE ' . $this->getPrimaryKeyWhereSql($dbEntity),
174	2	$this->getPrimaryKeyWhereParameters($dbEntity)
175		);
176
177	2	$dbEntity->setDeleted();
178	2	}
179
180		/**
181		* @param AbstractDbEntity $dbEntity
182		* @return string
183		*/
184	6	protected function getPrimaryKeyWhereSql(AbstractDbEntity $dbEntity)
185		{
186	6	if (is_array($dbEntity->getPrimaryDbPropertyKey())) {
187	1	$whereStrings = [];
188	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...
189	1	$whereStrings[] = '`' . $primaryKeyPart . '` = ?';
190		}
191	1	$whereSql = implode(' AND ', $whereStrings);
192		} else {
193	5	$whereSql = '`' . $dbEntity->getPrimaryDbFieldKey() . '` = ?';
194		}
195
196	6	return $whereSql;
197		}
198
199		/**
200		* @param AbstractDbEntity $dbEntity
201		* @return array
202		*/
203	6	protected function getPrimaryKeyWhereParameters(AbstractDbEntity $dbEntity)
204		{
205	6	if (is_array($dbEntity->getPrimaryDbPropertyKey())) {
206	1	$whereParameters = $dbEntity->getPrimaryDbValue();
207		} else {
208	5	$whereParameters = [$dbEntity->getPrimaryDbValue()];
209		}
210
211	6	return $whereParameters;
212		}
213		}
214

starweb / starlit-db

GitHub Access Token became invalid

Pull Request — master (#10)

BasicDbEntityService::load() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like