ImageMapper::findImagesFromPerson() - Code Metrics - Inspection of "Merge pull request #243 from matiasdelellis/fix-te..." - matiasdelellis/facerecognition - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 132edd...186cf7 )

by Matias

created 2020-03-30 16:35 UTC

ImageMapper::findImagesFromPerson() A

↳ Parent: ImageMapper

Complexity

Conditions	1
Paths	1

Size

Total Lines	16
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
cc	1
eloc	13
c	2
b	0
f	0
nc	1
nop	3
dl	0
loc	16
ccs	0
cts	14
cp	0
crap	2
rs	9.8333

<?php
/**
 * @copyright Copyright (c) 2017-2020, Matias De lellis <[email protected]>
 * @copyright Copyright (c) 2018-2019, Branko Kokanovic <[email protected]>
 *
 * @author Branko Kokanovic <[email protected]>
 *
 * @license GNU AGPL version 3 or any later version
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 */
namespace OCA\FaceRecognition\Db;

use OCP\IDBConnection;
use OCP\IUser;

use OCP\AppFramework\Db\QBMapper;
use OCP\AppFramework\Db\DoesNotExistException;
use OCP\DB\QueryBuilder\IQueryBuilder;

class ImageMapper extends QBMapper {
	/** @var FaceMapper Face mapper*/
	private $faceMapper;

	public function __construct(IDBConnection $db, FaceMapper $faceMapper) {
		parent::__construct($db, 'facerecog_images', '\OCA\FaceRecognition\Db\Image');
		$this->faceMapper = $faceMapper;
	}

	/**
	 * @param string $userId Id of user
	 * @param int $imageId Id of Image to get
	 */
	public function find(string $userId, int $imageId) {
		$qb = $this->db->getQueryBuilder();
		$qb->select('id', 'file', 'is_processed', 'error', 'last_processed_time', 'processing_duration')
			->from($this->getTableName(), 'i')
			->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
			->andWhere($qb->expr()->eq('id', $qb->createNamedParameter($imageId)));
		return $this->findEntity($qb);
	}

	/**
	 * @param string $userId Id of user
	 * @param int $modelId Id of model
	 * @param int $fileId Id of file to get Image
	 */
	public function findFromFile(string $userId, int $modelId, int $fileId) {
		$qb = $this->db->getQueryBuilder();
		$qb->select('id', 'is_processed', 'error')
			->from($this->getTableName(), 'i')
			->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
			->andwhere($qb->expr()->eq('model', $qb->createNamedParameter($modelId)))
			->andWhere($qb->expr()->eq('file', $qb->createNamedParameter($fileId)));

		try {
			return $this->findEntity($qb);
		} catch (DoesNotExistException $e) {
			return null;
		}
	}

	public function imageExists(Image $image) {
		$qb = $this->db->getQueryBuilder();
		$query = $qb
			->select(['id'])
			->from($this->getTableName())
			->where($qb->expr()->eq('user', $qb->createParameter('user')))
			->andWhere($qb->expr()->eq('file', $qb->createParameter('file')))
			->andWhere($qb->expr()->eq('model', $qb->createParameter('model')))
			->setParameter('user', $image->getUser())
			->setParameter('file', $image->getFile())
			->setParameter('model', $image->getModel());
		$resultStatement = $query->execute();
		$row = $resultStatement->fetch();
		$resultStatement->closeCursor();
		return $row ? (int)$row['id'] : null;
	}

	public function countImages(int $model): int {
		$qb = $this->db->getQueryBuilder();
		$query = $qb
			->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
			->from($this->getTableName())
			->where($qb->expr()->eq('model', $qb->createParameter('model')))
			->setParameter('model', $model);
		$resultStatement = $query->execute();
		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
		$resultStatement->closeCursor();

		return (int)$data[0];
	}

	public function countProcessedImages(int $model): int {
		$qb = $this->db->getQueryBuilder();
		$query = $qb
			->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
			->from($this->getTableName())
			->where($qb->expr()->eq('model', $qb->createParameter('model')))
			->andWhere($qb->expr()->eq('is_processed', $qb->createParameter('is_processed')))
			->setParameter('model', $model)
			->setParameter('is_processed', True);
		$resultStatement = $query->execute();
		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
		$resultStatement->closeCursor();

		return (int)$data[0];
	}

	public function avgProcessingDuration(int $model): int {
		$qb = $this->db->getQueryBuilder();
		$query = $qb
			->select($qb->createFunction('AVG(' . $qb->getColumnName('processing_duration') . ')'))
			->from($this->getTableName())
			->where($qb->expr()->eq('model', $qb->createParameter('model')))
			->andWhere($qb->expr()->eq('is_processed', $qb->createParameter('is_processed')))
			->setParameter('model', $model)
			->setParameter('is_processed', True);
		$resultStatement = $query->execute();
		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
		$resultStatement->closeCursor();

		return (int)$data[0];
	}

	public function countUserImages(string $userId, $model): int {
		$qb = $this->db->getQueryBuilder();
		$query = $qb
			->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
			->from($this->getTableName())
			->where($qb->expr()->eq('user', $qb->createParameter('user')))
			->andWhere($qb->expr()->eq('model', $qb->createParameter('model')))
			->setParameter('user', $userId)
			->setParameter('model', $model);
		$resultStatement = $query->execute();
		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
		$resultStatement->closeCursor();

		return (int)$data[0];
	}

	public function countUserProcessedImages(string $userId, $model): int {
		$qb = $this->db->getQueryBuilder();
		$query = $qb
			->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
			->from($this->getTableName())
			->where($qb->expr()->eq('user', $qb->createParameter('user')))
			->andWhere($qb->expr()->eq('model', $qb->createParameter('model')))
			->andWhere($qb->expr()->eq('is_processed', $qb->createParameter('is_processed')))
			->setParameter('user', $userId)
			->setParameter('model', $model)
			->setParameter('is_processed', True);
		$resultStatement = $query->execute();
		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
		$resultStatement->closeCursor();

		return (int)$data[0];
	}

	/**
	 * @param IUser|null $user User for which to get images for. If not given, all images from instance are returned.
	 * @param int $modelId Model Id to get images for.
	 */
	public function findImagesWithoutFaces(IUser $user = null, int $modelId): array {
		$qb = $this->db->getQueryBuilder();
		$qb
			->select(['id', 'user', 'file', 'model'])
			->from($this->getTableName())
			->where($qb->expr()->eq('is_processed',  $qb->createParameter('is_processed')))
			->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($modelId)))
			->setParameter('is_processed', false, IQueryBuilder::PARAM_BOOL);
		if (!is_null($user)) {
			$qb->andWhere($qb->expr()->eq('user', $qb->createNamedParameter($user->getUID())));
		}
		return $this->findEntities($qb);
	}

	public function findImages(string $userId, int $model): array {
		$qb = $this->db->getQueryBuilder();
		$qb->select('i.id', 'i.file')
			->from($this->getTableName(), 'i')
			->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
			->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($model)));

		$images = $this->findEntities($qb);
		return $images;
	}

	public function findImagesFromPerson(string $userId, string $name, int $model): array {
		$qb = $this->db->getQueryBuilder();
		$qb->select('i.id', 'i.file')
			->from($this->getTableName(), 'i')
			->innerJoin('i', 'facerecog_faces', 'f', $qb->expr()->eq('f.image', 'i.id'))
			->innerJoin('i', 'facerecog_persons', 'p', $qb->expr()->eq('f.person', 'p.id'))
			->where($qb->expr()->eq('p.user', $qb->createNamedParameter($userId)))
			->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($model)))
			->andWhere($qb->expr()->eq('is_processed', $qb->createNamedParameter(True)))
			->andWhere($qb->expr()->like($qb->func()->lower('p.name'), $qb->createParameter('query')));

		$query = '%' . $this->db->escapeLikeParameter(strtolower($name)) . '%';
		$qb->setParameter('query', $query);

		$images = $this->findEntities($qb);
		return $images;
	}

	/**
	 * Writes to DB that image has been processed. Previously found faces are deleted and new ones are inserted.
	 * If there is exception, its stack trace is also updated.
	 *
	 * @param Image $image Image to be updated
	 * @param Face[] $faces Faces to insert
	 * @param int $duration Processing time, in milliseconds
	 * @param \Exception|null $e Any exception that happened during image processing
	 */
	public function imageProcessed(Image $image, array $faces, int $duration, \Exception $e = null) {
		$this->db->beginTransaction();
		try {
			// Update image itself
			//
			$error = null;
			if ($e !== null) {
				$error = substr($e->getMessage(), 0, 1024);
			}

			$qb = $this->db->getQueryBuilder();
			$qb->update($this->getTableName())
				->set("is_processed", $qb->createNamedParameter(true, IQueryBuilder::PARAM_BOOL))
				->set("error", $qb->createNamedParameter($error))
				->set("last_processed_time", $qb->createNamedParameter(new \DateTime(), IQueryBuilder::PARAM_DATE))
				->set("processing_duration", $qb->createNamedParameter($duration))
				->where($qb->expr()->eq('id', $qb->createNamedParameter($image->id)))
				->execute();

			// Delete all previous faces
			//
			$qb = $this->db->getQueryBuilder();
			$qb->delete('facerecog_faces')
				->where($qb->expr()->eq('image', $qb->createNamedParameter($image->id)))
				->execute();

			// Insert all faces
			//
			foreach ($faces as $face) {
				$this->faceMapper->insertFace($face, $this->db);
			}

			$this->db->commit();
		} catch (\Exception $e) {
			$this->db->rollBack();
			throw $e;
		}
	}

	/**
	 * Resets image by deleting all associated faces and prepares it to be processed again
	 *
	 * @param Image $image Image to reset
	 */
	public function resetImage(Image $image) {
		$qb = $this->db->getQueryBuilder();
		$qb->update($this->getTableName())
			->set("is_processed", $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL))
			->set("error", $qb->createNamedParameter(null))
			->set("last_processed_time", $qb->createNamedParameter(null))
			->where($qb->expr()->eq('user', $qb->createNamedParameter($image->getUser())))
			->andWhere($qb->expr()->eq('file', $qb->createNamedParameter($image->getFile())))
			->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($image->getModel())))
			->execute();
	}

	/**
	 * Resets all image with error from that user and prepares it to be processed again
	 *
	 * @param string $userId User to reset errors
	 */
	public function resetErrors(string $userId) {
		$qb = $this->db->getQueryBuilder();
		$qb->update($this->getTableName())
			->set("is_processed", $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL))
			->set("error", $qb->createNamedParameter(null))
			->set("last_processed_time", $qb->createNamedParameter(null))
			->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
			->andWhere($qb->expr()->isNotNull('error'))
			->execute();
	}

	/**
	 * Deletes all images from that user.
	 *
	 * @param string $userId User to drop images from table.
	 */
	public function deleteUserImages(string $userId) {
		$qb = $this->db->getQueryBuilder();
		$qb->delete($this->getTableName())
			->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
			->execute();
	}
}


1		<?php
2		/**
3		* @copyright Copyright (c) 2017-2020, Matias De lellis <[email protected]>
4		* @copyright Copyright (c) 2018-2019, Branko Kokanovic <[email protected]>
5		*
6		* @author Branko Kokanovic <[email protected]>
7		*
8		* @license GNU AGPL version 3 or any later version
9		*
10		* This program is free software: you can redistribute it and/or modify
11		* it under the terms of the GNU Affero General Public License as
12		* published by the Free Software Foundation, either version 3 of the
13		* License, or (at your option) any later version.
14		*
15		* This program is distributed in the hope that it will be useful,
16		* but WITHOUT ANY WARRANTY; without even the implied warranty of
17		* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18		* GNU Affero General Public License for more details.
19		*
20		* You should have received a copy of the GNU Affero General Public License
21		* along with this program. If not, see <http://www.gnu.org/licenses/>.
22		*
23		*/
24		namespace OCA\FaceRecognition\Db;
25
26		use OCP\IDBConnection;
27		use OCP\IUser;
28
29		use OCP\AppFramework\Db\QBMapper;
30		use OCP\AppFramework\Db\DoesNotExistException;
31		use OCP\DB\QueryBuilder\IQueryBuilder;
32
33		class ImageMapper extends QBMapper {
34		/** @var FaceMapper Face mapper*/
35		private $faceMapper;
36
37	1	public function __construct(IDBConnection $db, FaceMapper $faceMapper) {
38	1	parent::__construct($db, 'facerecog_images', '\OCA\FaceRecognition\Db\Image');
39	1	$this->faceMapper = $faceMapper;
40	1	}
41
42		/**
43		* @param string $userId Id of user
44		* @param int $imageId Id of Image to get
45		*/
46	4	public function find(string $userId, int $imageId) {
47	4	$qb = $this->db->getQueryBuilder();
48	4	$qb->select('id', 'file', 'is_processed', 'error', 'last_processed_time', 'processing_duration')
49	4	->from($this->getTableName(), 'i')
50	4	->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
51	4	->andWhere($qb->expr()->eq('id', $qb->createNamedParameter($imageId)));
52	4	return $this->findEntity($qb);
53		}
54
55		/**
56		* @param string $userId Id of user
57		* @param int $modelId Id of model
58		* @param int $fileId Id of file to get Image
59		*/
60		public function findFromFile(string $userId, int $modelId, int $fileId) {
61		$qb = $this->db->getQueryBuilder();
62		$qb->select('id', 'is_processed', 'error')
63		->from($this->getTableName(), 'i')
64		->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
65		->andwhere($qb->expr()->eq('model', $qb->createNamedParameter($modelId)))
66		->andWhere($qb->expr()->eq('file', $qb->createNamedParameter($fileId)));
67
68		try {
69		return $this->findEntity($qb);
70		} catch (DoesNotExistException $e) {
71		return null;
72		}
73		}
74
75	7	public function imageExists(Image $image) {
76	7	$qb = $this->db->getQueryBuilder();
77		$query = $qb
78	7	->select(['id'])
79	7	->from($this->getTableName())
80	7	->where($qb->expr()->eq('user', $qb->createParameter('user')))
81	7	->andWhere($qb->expr()->eq('file', $qb->createParameter('file')))
82	7	->andWhere($qb->expr()->eq('model', $qb->createParameter('model')))
83	7	->setParameter('user', $image->getUser())
84	7	->setParameter('file', $image->getFile())
85	7	->setParameter('model', $image->getModel());
86	7	$resultStatement = $query->execute();
87	7	$row = $resultStatement->fetch();
88	7	$resultStatement->closeCursor();
89	7	return $row ? (int)$row['id'] : null;
90		}
91
92		public function countImages(int $model): int {
93		$qb = $this->db->getQueryBuilder();
94		$query = $qb
95		->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
96		->from($this->getTableName())
97		->where($qb->expr()->eq('model', $qb->createParameter('model')))
98		->setParameter('model', $model);
99		$resultStatement = $query->execute();
100		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
101		$resultStatement->closeCursor();
102
103		return (int)$data[0];
104		}
105
106		public function countProcessedImages(int $model): int {
107		$qb = $this->db->getQueryBuilder();
108		$query = $qb
109		->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
110		->from($this->getTableName())
111		->where($qb->expr()->eq('model', $qb->createParameter('model')))
112		->andWhere($qb->expr()->eq('is_processed', $qb->createParameter('is_processed')))
113		->setParameter('model', $model)
114		->setParameter('is_processed', True);
115		$resultStatement = $query->execute();
116		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
117		$resultStatement->closeCursor();
118
119		return (int)$data[0];
120		}
121
122		public function avgProcessingDuration(int $model): int {
123		$qb = $this->db->getQueryBuilder();
124		$query = $qb
125		->select($qb->createFunction('AVG(' . $qb->getColumnName('processing_duration') . ')'))
126		->from($this->getTableName())
127		->where($qb->expr()->eq('model', $qb->createParameter('model')))
128		->andWhere($qb->expr()->eq('is_processed', $qb->createParameter('is_processed')))
129		->setParameter('model', $model)
130		->setParameter('is_processed', True);
131		$resultStatement = $query->execute();
132		$data = $resultStatement->fetch(\PDO::FETCH_NUM);
133		$resultStatement->closeCursor();
134
135		return (int)$data[0];
136		}
137
138	3	public function countUserImages(string $userId, $model): int {
139	3	$qb = $this->db->getQueryBuilder();
140		$query = $qb
141	3	->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
142	3	->from($this->getTableName())
143	3	->where($qb->expr()->eq('user', $qb->createParameter('user')))
144	3	->andWhere($qb->expr()->eq('model', $qb->createParameter('model')))
145	3	->setParameter('user', $userId)
146	3	->setParameter('model', $model);
147	3	$resultStatement = $query->execute();
148	3	$data = $resultStatement->fetch(\PDO::FETCH_NUM);
149	3	$resultStatement->closeCursor();
150
151	3	return (int)$data[0];
152		}
153
154	1	public function countUserProcessedImages(string $userId, $model): int {
155	1	$qb = $this->db->getQueryBuilder();
156		$query = $qb
157	1	->select($qb->createFunction('COUNT(' . $qb->getColumnName('id') . ')'))
158	1	->from($this->getTableName())
159	1	->where($qb->expr()->eq('user', $qb->createParameter('user')))
160	1	->andWhere($qb->expr()->eq('model', $qb->createParameter('model')))
161	1	->andWhere($qb->expr()->eq('is_processed', $qb->createParameter('is_processed')))
162	1	->setParameter('user', $userId)
163	1	->setParameter('model', $model)
164	1	->setParameter('is_processed', True);
165	1	$resultStatement = $query->execute();
166	1	$data = $resultStatement->fetch(\PDO::FETCH_NUM);
167	1	$resultStatement->closeCursor();
168
169	1	return (int)$data[0];
170		}
171
172		/**
173		* @param IUser\|null $user User for which to get images for. If not given, all images from instance are returned.
174		* @param int $modelId Model Id to get images for.
175		*/
176	9	public function findImagesWithoutFaces(IUser $user = null, int $modelId): array {
177	9	$qb = $this->db->getQueryBuilder();
178		$qb
179	9	->select(['id', 'user', 'file', 'model'])
180	9	->from($this->getTableName())
181	9	->where($qb->expr()->eq('is_processed', $qb->createParameter('is_processed')))
182	9	->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($modelId)))
183	9	->setParameter('is_processed', false, IQueryBuilder::PARAM_BOOL);
184	9	if (!is_null($user)) {
185	9	$qb->andWhere($qb->expr()->eq('user', $qb->createNamedParameter($user->getUID())));
186		}
187	9	return $this->findEntities($qb);
188		}
189
190	6	public function findImages(string $userId, int $model): array {
191	6	$qb = $this->db->getQueryBuilder();
192	6	$qb->select('i.id', 'i.file')
193	6	->from($this->getTableName(), 'i')
194	6	->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
195	6	->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($model)));
196
197	6	$images = $this->findEntities($qb);
198	6	return $images;
199		}
200
201		public function findImagesFromPerson(string $userId, string $name, int $model): array {
202		$qb = $this->db->getQueryBuilder();
203		$qb->select('i.id', 'i.file')
204		->from($this->getTableName(), 'i')
205		->innerJoin('i', 'facerecog_faces', 'f', $qb->expr()->eq('f.image', 'i.id'))
206		->innerJoin('i', 'facerecog_persons', 'p', $qb->expr()->eq('f.person', 'p.id'))
207		->where($qb->expr()->eq('p.user', $qb->createNamedParameter($userId)))
208		->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($model)))
209		->andWhere($qb->expr()->eq('is_processed', $qb->createNamedParameter(True)))
210		->andWhere($qb->expr()->like($qb->func()->lower('p.name'), $qb->createParameter('query')));
211
212		$query = '%' . $this->db->escapeLikeParameter(strtolower($name)) . '%';
213		$qb->setParameter('query', $query);
214
215		$images = $this->findEntities($qb);
216		return $images;
217		}
218
219		/**
220		* Writes to DB that image has been processed. Previously found faces are deleted and new ones are inserted.
221		* If there is exception, its stack trace is also updated.
222		*
223		* @param Image $image Image to be updated
224		* @param Face[] $faces Faces to insert
225		* @param int $duration Processing time, in milliseconds
226		* @param \Exception\|null $e Any exception that happened during image processing
227		*/
228	4	public function imageProcessed(Image $image, array $faces, int $duration, \Exception $e = null) {
229	4	$this->db->beginTransaction();
230		try {
231		// Update image itself
232		//
233	4	$error = null;
234	4	if ($e !== null) {
235	1	$error = substr($e->getMessage(), 0, 1024);
236		}
237
238	4	$qb = $this->db->getQueryBuilder();
239	4	$qb->update($this->getTableName())
240	4	->set("is_processed", $qb->createNamedParameter(true, IQueryBuilder::PARAM_BOOL))
241	4	->set("error", $qb->createNamedParameter($error))
242	4	->set("last_processed_time", $qb->createNamedParameter(new \DateTime(), IQueryBuilder::PARAM_DATE))
243	4	->set("processing_duration", $qb->createNamedParameter($duration))
244	4	->where($qb->expr()->eq('id', $qb->createNamedParameter($image->id)))
245	4	->execute();
246
247		// Delete all previous faces
248		//
249	4	$qb = $this->db->getQueryBuilder();
250	4	$qb->delete('facerecog_faces')
251	4	->where($qb->expr()->eq('image', $qb->createNamedParameter($image->id)))
252	4	->execute();
253
254		// Insert all faces
255		//
256	4	foreach ($faces as $face) {
257	1	$this->faceMapper->insertFace($face, $this->db);
258		}
259
260	4	$this->db->commit();
261		} catch (\Exception $e) {
262		$this->db->rollBack();
263		throw $e;
264		}
265	4	}
266
267		/**
268		* Resets image by deleting all associated faces and prepares it to be processed again
269		*
270		* @param Image $image Image to reset
271		*/
272		public function resetImage(Image $image) {
273		$qb = $this->db->getQueryBuilder();
274		$qb->update($this->getTableName())
275		->set("is_processed", $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL))
276		->set("error", $qb->createNamedParameter(null))
277		->set("last_processed_time", $qb->createNamedParameter(null))
278		->where($qb->expr()->eq('user', $qb->createNamedParameter($image->getUser())))
279		->andWhere($qb->expr()->eq('file', $qb->createNamedParameter($image->getFile())))
280		->andWhere($qb->expr()->eq('model', $qb->createNamedParameter($image->getModel())))
281		->execute();
282		}
283
284		/**
285		* Resets all image with error from that user and prepares it to be processed again
286		*
287		* @param string $userId User to reset errors
288		*/
289		public function resetErrors(string $userId) {
290		$qb = $this->db->getQueryBuilder();
291		$qb->update($this->getTableName())
292		->set("is_processed", $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL))
293		->set("error", $qb->createNamedParameter(null))
294		->set("last_processed_time", $qb->createNamedParameter(null))
295		->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
296		->andWhere($qb->expr()->isNotNull('error'))
297		->execute();
298		}
299
300		/**
301		* Deletes all images from that user.
302		*
303		* @param string $userId User to drop images from table.
304		*/
305	28	public function deleteUserImages(string $userId) {
306	28	$qb = $this->db->getQueryBuilder();
307	28	$qb->delete($this->getTableName())
308	28	->where($qb->expr()->eq('user', $qb->createNamedParameter($userId)))
309	28	->execute();
310	28	}
311		}
312

matiasdelellis / facerecognition

Push — master ( 132edd...186cf7 )

ImageMapper::findImagesFromPerson() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like