AdodbPreparedStatement.php

Go to the documentation of this file.

<?php
namespace TYPO3\CMS\Dbal\Database;

use TYPO3\CMS\Core\Utility\GeneralUtility;

class AdodbPreparedStatement extends \TYPO3\CMS\Dbal\Database\DatabaseConnection {

    protected $databaseConnection;

    protected $query;

    protected $queryComponents;

    protected $parameters;

    protected $recordSet;

    public function __construct($query, array $queryComponents, \TYPO3\CMS\Dbal\Database\DatabaseConnection $databaseConnection) {
        $this->databaseConnection = $databaseConnection;
        $this->query = $query;
        $this->queryComponents = $queryComponents;
        $this->parameters = array();
    }

    public function prepare() {
        // TODO: actually prepare the query with ADOdb, if supported by the underlying DBMS
        // see: http://phplens.com/lens/adodb/docs-adodb.htm#prepare
        return TRUE;
    }

    public function store_result() {
        return TRUE;
    }

    public function bind_param($types, $var1, $_ = NULL) {
        $numberOfVariables = strlen($types);
        if (func_num_args() !== $numberOfVariables + 1) {
            return FALSE;
        }

        $this->parameters = array(
            array(
                'type' => $types{0},
                'value' => $var1
            ),
        );
        for ($i = 1; $i < $numberOfVariables; $i++) {
            $this->parameters[] = array(
                'type' => $types{$i},
                'value' => func_get_arg($i + 1),
            );
        }

        return TRUE;
    }

    public function reset() {
        return TRUE;
    }

    public function execute() {
        $queryParts = $this->queryComponents['queryParts'];
        $numberOfParameters = count($this->parameters);
        for ($i = 0; $i < $numberOfParameters; $i++) {
            $value = $this->parameters[$i]['value'];
            switch ($this->parameters[$i]['type']) {
                case 's':
                    if ($value !== NULL) {
                        $value = $this->databaseConnection->fullQuoteStr($value, $this->queryComponents['ORIG_tableName']);
                    }
                    break;
                case 'i':
                    $value = (int)$value;
                    break;
                default:
                    // Same error as in \TYPO3\CMS\Core\Database\PreparedStatement::execute()
                    throw new \InvalidArgumentException(sprintf('Unknown type %s used for parameter %s.', $this->parameters[$i]['type'], $i + 1), 1281859196);
            }

            $queryParts[$i * 2 + 1] = $value;
        }

        // Standard query from now on
        $query = implode('', $queryParts);

        $limit = $this->queryComponents['LIMIT'];
        if ($this->databaseConnection->runningADOdbDriver('postgres')) {
            // Possibly rewrite the LIMIT to be PostgreSQL-compatible
            $splitLimit = GeneralUtility::intExplode(',', $limit);
            // Splitting the limit values:
            if ($splitLimit[1]) {
                // If there are two parameters, do mapping differently than otherwise:
                $numRows = $splitLimit[1];
                $offset = $splitLimit[0];
                $limit = $numRows . ' OFFSET ' . $offset;
            }
        }
        if ($limit !== '') {
            $splitLimit = GeneralUtility::intExplode(',', $limit);
            // Splitting the limit values:
            if ($splitLimit[1]) {
                // If there are two parameters, do mapping differently than otherwise:
                $numRows = $splitLimit[1];
                $offset = $splitLimit[0];
            } else {
                $numRows = $splitLimit[0];
                $offset = 0;
            }
            $this->recordSet = $this->databaseConnection->handlerInstance[$this->databaseConnection->lastHandlerKey]->SelectLimit($query, $numRows, $offset);
            $this->databaseConnection->lastQuery = $this->recordSet->sql;
        } else {
            $this->databaseConnection->lastQuery = $query;
            $this->recordSet = $this->databaseConnection->handlerInstance[$this->databaseConnection->lastHandlerKey]->_Execute($this->databaseConnection->lastQuery);
        }

        if ($this->recordSet !== FALSE) {
            $success = TRUE;
            $this->recordSet->TYPO3_DBAL_handlerType = 'adodb';
            // Setting handler type in result object (for later recognition!)
            //$this->recordSet->TYPO3_DBAL_tableList = $queryComponents['ORIG_tableName'];
        } else {
            $success = FALSE;
        }

        return $success;
    }

    public function fetch_fields() {
        return $this->recordSet !== FALSE ? $this->recordSet->_fieldobjects : array();
    }

    public function fetch() {
        $row = $this->databaseConnection->sql_fetch_assoc($this->recordSet);
        return $row;
    }

    public function data_seek($offset) {
        return $this->databaseConnection->sql_data_seek($this->recordSet, $offset);
    }

    public function close() {
        return $this->databaseConnection->sql_free_result($this->recordSet);
    }

    public function __get($name) {
        switch ($name) {
            case 'errno':
                $output = $this->databaseConnection->sql_errno();
                break;
            case 'error':
                $output = $this->databaseConnection->sql_error();
                break;
            case 'num_rows':
                $output = $this->databaseConnection->sql_num_rows($this->recordSet);
                break;
            default:
                throw new \RuntimeException('Cannot access property ' . $name, 1394631927);
        }
        return $output;
    }

}