. * */ namespace OCA\News\Db; use \OCA\AppFramework\Core\API; class FolderMapper extends Mapper implements IMapper { public function __construct(API $api) { parent::__construct($api, 'news_folders'); } public function find($id, $userId){ $sql = 'SELECT * FROM `*PREFIX*news_folders` ' . 'WHERE `id` = ? ' . 'AND `user_id` = ?'; return $this->findEntity($sql, array($id, $userId)); } public function findAllFromUser($userId){ $sql = 'SELECT * FROM `*PREFIX*news_folders` ' . 'WHERE `user_id` = ? ' . 'AND `deleted_at` = 0'; $params = array($userId); return $this->findEntities($sql, $params); } public function findByName($folderName, $userId){ $sql = 'SELECT * FROM `*PREFIX*news_folders` ' . 'WHERE `name` = ? ' . 'AND `user_id` = ?'; $params = array($folderName, $userId); return $this->findEntities($sql, $params); } public function delete(Entity $entity){ parent::delete($entity); // someone please slap me for doing this manually :P // we needz CASCADE + FKs please $sql = 'DELETE FROM `*PREFIX*news_feeds` WHERE `folder_id` = ?'; $params = array($entity->getId()); $this->execute($sql, $params); $sql = 'DELETE FROM `*PREFIX*news_items` WHERE `feed_id` NOT IN '. '(SELECT `feeds`.`id` FROM `*PREFIX*news_feeds` `feeds`)'; $this->execute($sql); } /** * @param int $deleteOlderThan if given gets all entries with a delete date * older than that timestamp * @param string $userId if given returns only entries from the given user * @return array with the database rows */ public function getToDelete($deleteOlderThan=null, $userId=null) { $sql = 'SELECT * FROM `*PREFIX*news_folders` ' . 'WHERE `deleted_at` > 0 '; $params = array(); // sometimes we want to delete all entries if ($deleteOlderThan !== null) { $sql .= 'AND `deleted_at` < ? '; array_push($params, $deleteOlderThan); } // we need to sometimes only delete feeds of a user if($userId !== null) { $sql .= 'AND `user_id` = ?'; array_push($params, $userId); } return $this->findEntities($sql, $params); } /** * Deletes all folders of a user * @param string $userId the name of the user */ public function deleteUser($userId) { $sql = 'DELETE FROM `*PREFIX*news_folders` WHERE `user_id` = ?'; $this->execute($sql, array($userId)); } }