cookbook/lib/Db/RecipeDb.php

<?php

namespace OCA\Cookbook\Db;

use OCP\DB\QueryBuilder\IQueryBuilder;
use Doctrine\DBAL\Types\Type;
use OCP\Files\File;
use OCP\Files\Folder;
use OCP\IDBConnection;

class RecipeDb {
    private $db;

    public function __construct(IDBConnection $db) {
        $this->db = $db;
    }

    /**
     * @throws \OCP\AppFramework\Db\DoesNotExistException if not found
     * @deprecated
     */
    public function findRecipeById(int $id) {
        $qb = $this->db->getQueryBuilder();

        $qb->select('*')
            ->from('cookbook_recipe')
            ->where('id = :id');
        $qb->setParameter('id', $id, IQueryBuilder::PARAM_INT);

        $cursor = $qb->execute();
        $row = $cursor->fetch();
        $cursor->closeCursor();

        return $row;
    }
    
    public function deleteRecipeById(int $id) {
        $qb = $this->db->getQueryBuilder();

        $qb->delete('cookbook_names')
            ->where('recipe_id = :id');
        $qb->setParameter('id', $id, IQueryBuilder::PARAM_INT);
        
        $qb->execute();
        
        $qb->delete('cookbook_keywords')
            ->where('recipe_id = :id');
        $qb->setParameter('id', $id, IQueryBuilder::PARAM_INT);

        $qb->execute();
    }
    
    public function findAllRecipes(string $userId) {
        $qb = $this->db->getQueryBuilder();

        $qb->select('*')
            ->from('cookbook_names', 'r')
            ->where('user_id = :user')
            ->orderBy('r.name');
        $qb->setParameter('user', $userId, TYPE::STRING);

        $cursor = $qb->execute();
        $result = $cursor->fetchAll();
        $cursor->closeCursor();

        return $result;
    }

    public function findAllUncategorizedRecipes(string $userId) {
        $qb = $this->db->getQueryBuilder();

        $qb->select('r.*')
            ->from('cookbook_keywords', 'k')
            ->where('k.user_id = :user')
            ->andWhere("k.name = ''")
            ->orderBy('k.name');
        $qb->setParameter('user', $userId, TYPE::STRING);

        $qb->join('k', 'cookbook_names', 'r', 'k.recipe_id = r.recipe_id');

        $cursor = $qb->execute();
        $result = $cursor->fetchAll();
        $cursor->closeCursor();

        return $result;
    }

    public function findAllKeywords(string $userId) {
        $qb = $this->db->getQueryBuilder();

        $qb->select('k.name')
            ->from('cookbook_keywords', 'k')
            ->where('user_id = :user')
            ->groupBy('k.name')
            ->orderBy('k.name');
        $qb->setParameter('user', $userId, TYPE::STRING);

        $cursor = $qb->execute();
        $result = $cursor->fetchAll();
        $cursor->closeCursor();

        $result = array_unique($result, SORT_REGULAR);
        $result = array_filter($result);

        return $result;
    }
    
    /**
     * @throws \OCP\AppFramework\Db\DoesNotExistException if not found
     */
    public function findRecipes(array $keywords, string $userId) {
        $has_keywords = $keywords && is_array($keywords) && sizeof($keywords) > 0 && $keywords[0];

        if(!$has_keywords) { return $this->findAllRecipes($userId); }

        $qb = $this->db->getQueryBuilder();

        $qb->select(['r.recipe_id', 'r.name'])
            ->from('cookbook_keywords', 'k');
        
        $paramIdx = 1;
        $params = [];
        $types = [];
        
        foreach ($keywords as $keyword)
        {
            $lowerKeyword = strtolower($keyword);
            
            $qb->orWhere("LOWER(k.name) LIKE :keyword$paramIdx");
            $qb->orWhere("LOWER(r.name) LIKE :keyword$paramIdx");
            
            $params["keyword$paramIdx"] = "%$lowerKeyword%";
            $types["keyword$paramIdx"] = Type::STRING;
            $paramIdx++;
            
        }

        $qb->andWhere('k.user_id = :user');

        $qb->setParameters($params, $types);
        $qb->setParameter('user', $userId, TYPE::STRING);
        
        $qb->join('k', 'cookbook_names', 'r', 'k.recipe_id = r.recipe_id'); 

        $qb->groupBy(['r.name', 'r.recipe_id']);
        $qb->orderBy('r.name');

        $cursor = $qb->execute();
        $result = $cursor->fetchAll();
        $cursor->closeCursor();

        return $result;
    }
    
    public function emptySearchIndex(string $userId) {
        $qb = $this->db->getQueryBuilder();
        
        $qb->delete('cookbook_names')
            ->where('user_id = :user')
            ->orWhere('user_id = :empty');
        $qb->setParameter('user', $userId, TYPE::STRING);
        $qb->setParameter('empty', 'empty', TYPE::STRING);
        
        $qb->execute();
        
        $qb->delete('cookbook_keywords')
            ->where('user_id = :user')
            ->orWhere('user_id = :empty');
        $qb->setParameter('user', $userId, TYPE::STRING);
        $qb->setParameter('empty', 'empty', TYPE::STRING);
        
        $qb->execute();
    }

    private function isRecipeEmpty($json) {}

    public function indexRecipeFile(File $file, string $userId) {
        $json = json_decode($file->getContent(), true);

        if(!$json || !isset($json['name']) || $json['name'] === 'No name') { return; }

        $id = (int) $file->getParent()->getId();
        $json['id'] = $id;
        $qb = $this->db->getQueryBuilder();

        // Insert recipe 
        $qb->delete('cookbook_names')
            ->where('recipe_id = :id')
            ->andWhere('user_id = :user');
        $qb->setParameter('id', $id, IQueryBuilder::PARAM_INT);
        $qb->setParameter('user', $userId, TYPE::STRING);
        
        $qb->execute();

        $qb->insert('cookbook_names')
            ->values([
                'recipe_id' => ':id',
                'name' => ':name',
                'user_id' => ':user',
            ]);
        $qb->setParameter('id', $id, IQueryBuilder::PARAM_INT);
        $qb->setParameter('name', $json['name'], Type::STRING);
        $qb->setParameter('user', $userId, Type::STRING);
        $qb->execute();

        // Insert keywords 
        $qb->delete('cookbook_keywords')
            ->where('recipe_id = :id')
            ->andWhere('user_id = :user');
        $qb->setParameter('id', $id, IQueryBuilder::PARAM_INT);
        $qb->setParameter('user', $userId, TYPE::STRING);
        $qb->execute();
        
        if(isset($json['keywords'])) {
            foreach(explode(',', $json['keywords']) as $keyword) {
                $keyword = trim($keyword);   

                $qb->insert('cookbook_keywords')
                    ->values([
                        'recipe_id' => ':id',
                        'name' => ':keyword',
                        'user_id' => ':user',
                    ]);
                $qb->setParameter('id', $id, IQueryBuilder::PARAM_INT);
                $qb->setParameter('keyword', $keyword, Type::STRING);
                $qb->setParameter('user', $userId, Type::STRING);
                $qb->execute();
            }
        }
    }
}

?>