Phase\TakeATicket\DataSource\MySql

Complexity

Total Complexity

6

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	concatenateEscapedFields()	0	4	1
A	storeNewTicket()	0	15	2
A	fetchPerformerIdByName()	0	14	3

<?php
/**
 * Created by PhpStorm.
 * User: wechsler
 * Date: 04/10/15
 * Time: 21:08
 */

namespace Phase\TakeATicket\DataSource;

class MySql extends AbstractSql
{
    /**
     * {@inheritdoc}
     */
    protected function concatenateEscapedFields($fields)
    {
        return 'CONCAT('.implode(', ', $fields).')';
    }

    /**
     * Overridden to take advantage of autoIds
     *
     * @param $title
     * @param $songId
     *
     * @return int|false
     */
    public function storeNewTicket($title, $songId)
    {
        $conn = $this->getDbConn();
        $max = $conn->fetchAssoc('SELECT max(`offset`) AS o FROM tickets');

        $maxOffset = $max['o'];
        $ticket = [
            'title' => $title,
            'offset' => $maxOffset + 1,
            'songId' => $songId,
        ];
        $res = $conn->insert(self::TICKETS_TABLE, $ticket);

        return $res ? $conn->lastInsertId() : false;

The expression $res ? $conn->lastInsertId() : false; of type string|false adds the type string to the return on line 42 which is incompatible with the return type of the parent method Phase\TakeATicket\DataSource\AbstractSql::storeNewTicket of type integer|false.

    }

    /**
     * Overridden to take advantage of autoIds
     *
     * @param $performerName
     * @param bool|false    $createMissing
     *
     * @return mixed
     */
    public function fetchPerformerIdByName($performerName, $createMissing = false)
    {
        $conn = $this->getDbConn();
        $sql = 'SELECT id FROM performers p WHERE p.name LIKE :name LIMIT 1';
        $performerId = $conn->fetchColumn($sql, ['name' => $performerName]);

        if ($createMissing && !$performerId) {
            $conn->insert(self::PERFORMERS_TABLE, ['name' => ucwords($performerName)]);
            //add new performer row
            $performerId = $conn->lastInsertId();
        }

        return $performerId;
    }
}