DatasetMapper::getOwner() - Code Metrics - Inspection of "Multiple reports per dataset #193" - Rello/analytics - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — master ( 0b1a33...6372a5 )

by Marcel
created 2021-10-13 21:13 UTC
DatasetMapper::getOwner() A

↳ Parent: DatasetMapper
Complexity

Conditions	1
Paths	1
Size

Total Lines	7
Code Lines	5
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	1
eloc	5
c	0
b	0
f	0
nc	1
nop	1
dl	0
loc	7
rs	10
<?php
/**
 * Analytics
 *
 * This file is licensed under the Affero General Public License version 3 or
 * later. See the LICENSE.md file.
 *
 * @author Marcel Scherello <[email protected]>
 * @copyright 2021 Marcel Scherello
 */

namespace OCA\Analytics\Db;

use OCP\DB\Exception;
use OCP\IDBConnection;
use Psr\Log\LoggerInterface;

class DatasetMapper
{
    private $userId;
    private $db;
    private $logger;
    const TABLE_NAME = 'analytics_dataset';

    public function __construct(
        $userId,
        IDBConnection $db,
        LoggerInterface $logger
    )
    {
        $this->userId = $userId;
        $this->db = $db;
        $this->logger = $logger;
    }

    /**
     * get datasets
     * @return array
     * @throws Exception
     */
    public function index(): array
    {
        $sql = $this->db->getQueryBuilder();
        $sql->from(self::TABLE_NAME)
            ->select('id')
            ->addSelect('name')
            ->addSelect('dimension1')
            ->addSelect('dimension2')
            ->addSelect('value')
            ->where($sql->expr()->eq('user_id', $sql->createNamedParameter($this->userId)))
            ->andWhere($sql->expr()->eq('type', $sql->createNamedParameter('2')))
            ->addOrderBy('name', 'ASC');
        $statement = $sql->execute();
        $statement = /** @scrutinizer ignore-deprecated */ $sql->execute();
        $result = $statement->fetchAll();
        $statement->closeCursor();
        return $result;
    }

    /**
     * create dataset
     * @param $name
     * @param $dimension1
     * @param $dimension2
     * @param $value
     * @return int
     * @throws Exception
     */
    public function create($name, $dimension1, $dimension2, $value): int
    {
        $sql = $this->db->getQueryBuilder();
        $sql->insert(self::TABLE_NAME)
            ->values([
                'user_id' => $sql->createNamedParameter($this->userId),
                'name' => $sql->createNamedParameter($name),
                'dimension1' => $sql->createNamedParameter($dimension1),
                'dimension2' => $sql->createNamedParameter($dimension2),
                'value' => $sql->createNamedParameter($value),
                'type' => $sql->createNamedParameter('2'),
            ]);
        $sql->execute();
        /** @scrutinizer ignore-deprecated */ $sql->execute();
        return $sql->getLastInsertId();
    }

    /**
     * get single dataset
     * @param int $id
     * @param string|null $user_id
     * @return array
     * @throws Exception
     */
    public function read(int $id, string $user_id = null): array
    {
        if ($user_id) $this->userId = $user_id;

        $sql = $this->db->getQueryBuilder();
        $sql->from(self::TABLE_NAME)
            ->select('*')
            ->where($sql->expr()->eq('id', $sql->createNamedParameter($id)))
            ->andWhere($sql->expr()->eq('user_id', $sql->createNamedParameter($this->userId)))
            ->orderBy('parent', 'ASC')
            ->addOrderBy('name', 'ASC');
        $statement = $sql->execute();
        $statement = /** @scrutinizer ignore-deprecated */ $sql->execute();
        $result = $statement->fetch();
        $statement->closeCursor();
        return $result;
    }

    /**
     * update dataset
     * @param $id
     * @param $name
     * @param $dimension1
     * @param $dimension2
     * @param $value
     * @return bool
     * @throws Exception
     */
    public function update($id, $name, $dimension1, $dimension2, $value): bool
    {
        $name = $this->truncate($name, 64);
        $sql = $this->db->getQueryBuilder();
        $sql->update(self::TABLE_NAME)
            ->set('name', $sql->createNamedParameter($name))
            ->set('dimension1', $sql->createNamedParameter($dimension1))
            ->set('dimension2', $sql->createNamedParameter($dimension2))
            ->set('value', $sql->createNamedParameter($value))
            ->where($sql->expr()->eq('user_id', $sql->createNamedParameter($this->userId)))
            ->andWhere($sql->expr()->eq('id', $sql->createNamedParameter($id)));
        $sql->execute();
        /** @scrutinizer ignore-deprecated */ $sql->execute();
        return true;
    }

    /**
     * delete dataset
     * @param $id
     * @return bool
     * @throws Exception
     */
    public function delete($id): bool
    {
        $sql = $this->db->getQueryBuilder();
        $sql->delete(self::TABLE_NAME)
            ->where($sql->expr()->eq('user_id', $sql->createNamedParameter($this->userId)))
            ->andWhere($sql->expr()->eq('id', $sql->createNamedParameter($id)));
        $sql->execute();
        /** @scrutinizer ignore-deprecated */ $sql->execute();
        return true;
    }

    /**
     * get the newest timestamp of the data of a dataset
     * @param $datasetId
     * @return int
     * @throws Exception
     */
    public function getLastUpdate($datasetId): int
    {
        $sql = $this->db->getQueryBuilder();
        $sql->from('analytics_facts')
            ->select($sql->func()->max('timestamp'))
            ->where($sql->expr()->eq('dataset', $sql->createNamedParameter($datasetId)));
        return (int)$sql->execute()->fetchOne();
        return (int)/** @scrutinizer ignore-deprecated */ $sql->execute()->fetchOne();
    }

    /**
     * get the report owner
     * @param $datasetId
     * @return string
     * @throws Exception
     */
    public function getOwner($datasetId): string
    {
        $sql = $this->db->getQueryBuilder();
        $sql->from(self::TABLE_NAME)
            ->select('user_id')
            ->where($sql->expr()->eq('id', $sql->createNamedParameter($datasetId)));
        return (string)$sql->execute()->fetchOne();
        return (string)/** @scrutinizer ignore-deprecated */ $sql->execute()->fetchOne();
    }

    /**
     * truncates fields do DB-field size
     *
     * @param $string
     * @param int $length
     * @param string $dots
     * @return string
     */
    private function truncate($string, int $length, string $dots = "..."): string
    {
        return (strlen($string) > $length) ? mb_strcut($string, 0, $length - strlen($dots)) . $dots : $string;
    }
}
Rello / analytics

Push — master ( 0b1a33...6372a5 )

DatasetMapper::getOwner() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
