vakata\database\driver\postgre\Statement::execute()

Complexity

Conditions	7
Paths	32

Size

Total Lines	24
Code Lines	17

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function execute(array $data = []) : ResultInterface
    {
        if (!is_array($data)) {
            $data = array();
        }
        $temp = (is_array($data) && count($data)) ?
            \pg_query_params($this->driver, $this->statement, $data) :
            \pg_query_params($this->driver, $this->statement, array());
        if (!$temp) {
            throw new DBException('Could not execute query : '.\pg_last_error($this->driver).' <'.$this->statement.'>');
        }
        $iid = null;
        $aff = 0;
        if (preg_match('@^\s*(INSERT|REPLACE)\s+INTO@i', $this->statement)) {
            $iid = \pg_query($this->driver, 'SELECT lastval()');
            if ($iid) {
                $res = \pg_fetch_row($iid);
                $iid = $res[0];
            }
            $aff = \pg_affected_rows($temp);
        }

        return new Result($temp, $iid, $aff);
    }
}