private function dbBeginTransaction()
    {
        if ($this->pendingConnection) {
            $this->connect();
        }

        $this->pendingTransactionBegin[$this->transLevel] = false;

        if ($this->dbTransLevel == 0) {
            //Top level transaction
            $res = pg_query($this->pgConn, 'begin');
        } else {
            $res = pg_query(
                $this->pgConn,
                'savepoint level' . $this->dbTransLevel . 'begin'
            );
        }

        if ($res === false) {
            $this->cleanAfterCommit();
            throw $this->createException();
        }

        $this->dbTransLevel++;

        return $res;
    }
private function dbBeginTransaction()
    {
        if ($this->pendingConnection) {
            $this->connect();
        }

        $this->pendingTransactionBegin[$this->transLevel] = false;

        if ($this->dbTransLevel == 0) {
            //Top level transaction
            $res = pg_query($this->pgConn, 'begin');
        } else {
            $res = pg_query(
                $this->pgConn,
                'savepoint level' . $this->dbTransLevel . 'begin'
            );
        }

        if ($res === false) {
            $this->cleanAfterCommit();
            throw $this->createException();
        }

        $this->dbTransLevel++;

        return $res;
    }
private function dbBeginTransaction ( ) { if ( $ this -> pendingConnection ) { $ this -> connect ( ) ; } $ this -> pendingTransactionBegin [ $ this -> transLevel ] = false ; if ( $ this -> dbTransLevel == 0 ) { //Top level transaction $ res = pg_query ( $ this -> pgConn , 'begin' ) ; } else { $ res = pg_query ( $ this -> pgConn , 'savepoint level' . $ this -> dbTransLevel . 'begin' ) ; } if ( $ res === false ) { $ this -> cleanAfterCommit ( ) ; throw $ this -> createException ( ) ; } $ this -> dbTransLevel ++ ; return $ res ; }
Begin transaction on the db side
Begin transaction on the db side