nextcloud / polls

use OCP\AppFramework\Db\Mapper;

use OCP\IDBConnection;

class NotificationMapper extends Mapper {

	public function __construct(IDBConnection $db) {

		parent::__construct($db, 'polls_notif', '\OCA\Polls\Db\Notification');

	}

	/**

	 * @param int $id

	 * @throws \OCP\AppFramework\Db\DoesNotExistException if not found

	 * @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException if more than one result

	 * @return Notification

	 */

	public function find($id) {

		$sql = 'SELECT * FROM ' . $this->getTableName() . ' WHERE id = ?';

		return $this->findEntity($sql, [$id]);

	}

	/**

	 * @param string $userId

	 * @param string $from

	 * @param string $until

	 * @param int $limit

	 * @param int $offset

	 * @return Notification[]

	 */

	public function findBetween($userId, $from, $until, $limit = null, $offset = null) {

		$sql = 'SELECT * FROM ' . $this->getTableName() . ' WHERE userId = ? AND timestamp BETWEEN ? AND ?';

		return $this->findEntities($sql, [$userId, $from, $until], $limit, $offset);

	}

	/**

	 * @param int $limit

	 * @param int $offset

	 * @return Notification[]

	 */

	public function findAll($limit = null, $offset = null) {

		$sql = 'SELECT * FROM ' . $this->getTableName();

		return $this->findEntities($sql, [], $limit, $offset);

	}

	/**

	 * @param string $pollId

	 * @param int $limit

	 * @param int $offset

	 * @return Notification[]

	 */

	public function findAllByPoll($pollId, $limit = null, $offset = null) {

		$sql = 'SELECT * FROM ' . $this->getTableName() . ' WHERE poll_id = ?';

		return $this->findEntities($sql, [$pollId], $limit, $offset);

	}

	/**

	 * @param string $pollId

	 * @param string $userId

	 * @return Notification if not found

	 */

	public function findByUserAndPoll($pollId, $userId) {

		$sql = 'SELECT * FROM ' . $this->getTableName() . ' WHERE poll_id = ? AND user_id = ?';

		return $this->findEntity($sql, [$pollId, $userId]);

	}

}

use OCP\AppFramework\Db\Mapper;

use OCP\IDBConnection;

class ParticipationMapper extends Mapper {

	/**

	 * ParticipationMapper constructor.

	 * @param IDBConnection $db

	 */

	public function __construct(IDBConnection $db) {

		parent::__construct($db, 'polls_particip', '\OCA\Polls\Db\Participation');

	}

	/**

	 * @param string $userId

	 * @param int $limit

	 * @param int $offset

	 * @return Participation[]

	 */

	public function findDistinctByUser($userId, $limit = null, $offset = null) {

		$sql = 'SELECT DISTINCT * FROM ' . $this->getTableName() . ' WHERE user_id = ?';

		return $this->findEntities($sql, [$userId], $limit, $offset);

	}

	/**

	 * @param string $pollId

	 * @param int $limit

	 * @param int $offset

	 * @return Participation[]

	 */

	public function findByPoll($pollId, $limit = null, $offset = null) {

		$sql = 'SELECT * FROM ' . $this->getTableName() . ' WHERE poll_id = ?';

		return $this->findEntities($sql, [$pollId], $limit, $offset);

	}

	/**

	 * @param string $pollId

	 * @param int $limit

	 * @param int $offset

	 */

	public function listParticipantsByPoll($pollId, $limit = null, $offset = null) {

		$sql = 'SELECT DISTINCT user_id FROM ' . $this->getTableName() . ' WHERE poll_id = ?';

		return $this->findEntities($sql, [$pollId], $limit, $offset);

	}

	/**

	 * @param string $pollId

	 */

	public function deleteByPoll($pollId) {

		$sql = 'DELETE FROM ' . $this->getTableName() . ' WHERE poll_id = ?';

		$this->execute($sql, [$pollId]);

	}

	/**

	 * @param string $pollId

	 * @param string $userId

	 */

	public function deleteByPollAndUser($pollId, $userId) {

		$sql = 'DELETE FROM ' . $this->getTableName() . ' WHERE poll_id = ? AND user_id = ?';

		$this->execute($sql, [$pollId, $userId]);

	}

}

use OCP\AppFramework\Db\Mapper;

use OCP\IDBConnection;

class ParticipationTextMapper extends Mapper {

	/**

	 * ParticipationTextMapper constructor.

	 * @param IDBConnection $db

	 */

	public function __construct(IDBConnection $db) {

		parent::__construct($db, 'polls_particip_text', '\OCA\Polls\Db\ParticipationText');

	}

	/**

	 * @param string $pollId

	 * @param int $limit

	 * @param int $offset

	 * @return ParticipationText[]

	 */

	public function findByPoll($pollId, $limit = null, $offset = null) {

		$sql = 'SELECT * FROM ' . $this->getTableName() . ' WHERE poll_id = ?';

		return $this->findEntities($sql, [$pollId], $limit, $offset);

	}

	/**

	 * @param string $userId

	 * @param int $limit

	 * @param int $offset

	 * @return ParticipationText[]

	 */

	public function findDistinctByUser($userId, $limit = null, $offset = null) {

		$sql = 'SELECT DISTINCT * FROM ' . $this->getTableName() . ' WHERE user_id = ?';

		return $this->findEntities($sql, [$userId], $limit, $offset);

	}

	/**

	 * @param string $pollId

	 * @param int $limit

	 * @param int $offset

	 */

	public function listParticipantsByPoll($pollId, $limit = null, $offset = null) {

		$sql = 'SELECT DISTINCT user_id FROM ' . $this->getTableName() . ' WHERE poll_id = ?';

		return $this->findEntities($sql, [$pollId], $limit, $offset);

	}

	/**

	 * @param string $pollId

	 */

	public function deleteByPoll($pollId) {

		$sql = 'DELETE FROM ' . $this->getTableName() . ' WHERE poll_id = ?';

		$this->execute($sql, [$pollId]);

	}

	/**

	 * @param string $pollId

	 * @param string $userId

	 */

	public function deleteByPollAndUser($pollId, $userId) {

		$sql = 'DELETE FROM ' . $this->getTableName() . ' WHERE poll_id = ? AND user_id = ?';

		$this->execute($sql, [$pollId, $userId]);

	}

}