JAQB\QueryBuilder

Complexity

Total Complexity

17

Size/Duplication

Total Lines	165
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getPDO()	0	4	1
A	select()	0	10	2
A	insert()	0	10	2
A	update()	0	10	2
A	delete()	0	10	2
A	raw()	0	10	2
A	beginTransaction()	0	4	1
A	commit()	0	4	1
A	rollBack()	0	4	1
A	inTransaction()	0	4	1
A	lastInsertId()	0	4	1

<?php

/**
 * @author Jared King <j@jaredtking.com>
 *
 * @see http://jaredtking.com
 *
 * @copyright 2015 Jared King
 * @license MIT
 */

namespace JAQB;

use PDO;

class QueryBuilder
{
    /**
     * @var PDO
     */
    protected $pdo;

    /**
     * @param PDO $pdo
     */
    public function __construct(PDO $pdo = null)
    {
        $this->pdo = $pdo;
    }

    /**
     * Returns the PDO instance.
     *
     * @return PDO
     */
    public function getPDO()
    {
        return $this->pdo;
    }

    /**
     * Creates a SELECT query.
     *
     * @param string|array $fields select fields
     *
     * @return \JAQB\Query\SelectQuery
     */
    public function select($fields = '*')
    {
        $query = new Query\SelectQuery();

        if ($this->pdo) {
            $query->setPDO($this->pdo);
        }

        return $query->select($fields);
    }

    /**
     * Creates an INSERT query.
     *
     * @param array $values insert values
     *
     * @return \JAQB\Query\InsertQuery
     */
    public function insert(array $values)
    {
        $query = new Query\InsertQuery();

        if ($this->pdo) {
            $query->setPDO($this->pdo);
        }

        return $query->values($values);
    }

    /**
     * Creates an UPDATE query.
     *
     * @param string $table update table
     *
     * @return \JAQB\Query\UpdateQuery
     */
    public function update($table)
    {
        $query = new Query\UpdateQuery();

        if ($this->pdo) {
            $query->setPDO($this->pdo);
        }

        return $query->table($table);
    }

    /**
     * Creates a DELETE query.
     *
     * @param string $from delete table
     *
     * @return \JAQB\Query\DeleteQuery
     */
    public function delete($from)
    {
        $query = new Query\DeleteQuery();

        if ($this->pdo) {
            $query->setPDO($this->pdo);
        }

        return $query->from($from);
    }

    /**
     * Creates a raw SQL query.
     *
     * @param string $sql SQL statement
     *
     * @return \JAQB\Query\SqlQuery
     */
    public function raw($sql)
    {
        $query = new Query\SqlQuery();

        if ($this->pdo) {
            $query->setPDO($this->pdo);
        }

        return $query->raw($sql);
    }

    /**
     * Starts a transaction.
     *
     * @return bool
     */
    public function beginTransaction()
    {
        return $this->pdo->beginTransaction();
    }

    /**
     * Commits the transaction.
     *
     * @return bool
     */
    public function commit()
    {
        return $this->pdo->commit();
    }

    /**
     * Rolls back the transaction.
     *
     * @return bool
     */
    public function rollBack()
    {
        return $this->pdo->rollBack();
    }

    /**
     * Checks if the query is in a transaction.
     *
     * @return bool
     */
    public function inTransaction()
    {
        return $this->pdo->inTransaction();
    }

    /**
     * Gets the last inserted ID.
     *
     * @return mixed
     */
    public function lastInsertId()
    {
        return $this->pdo->lastInsertId();
    }
}