*/ class DeviceMapper extends QBMapper { public function __construct(IDBConnection $db) { parent::__construct($db, 'f7push_devices', Device::class); } /** * @return Device[] */ public function findByUser(string $userId): array { $qb = $this->db->getQueryBuilder(); $qb->select('*') ->from($this->getTableName()) ->where($qb->expr()->eq('user_id', $qb->createNamedParameter($userId, IQueryBuilder::PARAM_STR))); return $this->findEntities($qb); } public function findByUserAndDevice(string $userId, string $deviceId): Device { $qb = $this->db->getQueryBuilder(); $qb->select('*') ->from($this->getTableName()) ->where($qb->expr()->eq('user_id', $qb->createNamedParameter($userId, IQueryBuilder::PARAM_STR))) ->andWhere($qb->expr()->eq('device_id', $qb->createNamedParameter($deviceId, IQueryBuilder::PARAM_STR))); return $this->findEntity($qb); } public function deleteByUserAndDevice(string $userId, string $deviceId): void { try { $device = $this->findByUserAndDevice($userId, $deviceId); $this->delete($device); } catch (DoesNotExistException|MultipleObjectsReturnedException) { } } public function deleteAllForUser(string $userId): void { $qb = $this->db->getQueryBuilder(); $qb->delete($this->getTableName()) ->where($qb->expr()->eq('user_id', $qb->createNamedParameter($userId, IQueryBuilder::PARAM_STR))); $qb->executeStatement(); } }