AdodbPreparedStatement.php

Go to the documentation of this file.

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

/*
 * This file is part of the TYPO3 CMS project.
 *
 * It is free software; you can redistribute it and/or modify it under
 * the terms of the GNU General Public License, either version 2
 * of the License, or any later version.
 *
 * For the full copyright and license information, please read the
 * LICENSE.txt file that was distributed with this source code.
 *
 * The TYPO3 project - inspiring people to share!
 */

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 = [];
    }

    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 = [
            [
                'type' => $types{0},
                'value' => $var1
            ],
        ];
        for ($i = 1; $i < $numberOfVariables; $i++) {
            $this->parameters[] = [
                '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 : [];
    }

    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;
    }
}