Online PHP editor | refs for bTuOC

<?php namespace Drupal\Core\Database; interface StatementInterface extends \Traversable { //protected function __construct(Connection $dbh); public function execute($args = array(), $options = array()); public function getQueryString(); public function rowCount(); public function setFetchMode($mode, $a1 = NULL, $a2 = array()); public function fetch($mode = NULL, $cursor_orientation = NULL, $cursor_offset = NULL); public function fetchField($index = 0); public function fetchObject(); public function fetchAssoc(); public function fetchAll($mode = NULL, $column_index = NULL, $constructor_arguments = NULL); public function fetchCol($index = 0); public function fetchAllKeyed($key_index = 0, $value_index = 1); public function fetchAllAssoc($key, $fetch = NULL); } class Statement extends \PDOStatement implements StatementInterface { public $dbh; public $allowRowCount = FALSE; protected function __construct(Connection $dbh) { $this->dbh = $dbh; $this->setFetchMode(\PDO::FETCH_OBJ); } public function execute($args = array(), $options = array()) { if (isset($options['fetch'])) { if (is_string($options['fetch'])) { // \PDO::FETCH_PROPS_LATE tells __construct() to run before properties // are added to the object. $this->setFetchMode(\PDO::FETCH_CLASS | \PDO::FETCH_PROPS_LATE, $options['fetch']); } else { $this->setFetchMode($options['fetch']); } } $logger = $this->dbh->getLogger(); if (!empty($logger)) { $query_start = microtime(TRUE); } $return = parent::execute($args); if (!empty($logger)) { $query_end = microtime(TRUE); $logger->log($this, $args, $query_end - $query_start); } return $return; } public function getQueryString() { return $this->queryString; } public function fetchCol($index = 0) { return $this->fetchAll(\PDO::FETCH_COLUMN, $index); } public function fetchAllAssoc($key, $fetch = NULL) { $return = array(); if (isset($fetch)) { if (is_string($fetch)) { $this->setFetchMode(\PDO::FETCH_CLASS, $fetch); } else { $this->setFetchMode($fetch); } } foreach ($this as $record) { $record_key = is_object($record) ? $record->$key : $record[$key]; $return[$record_key] = $record; } return $return; } public function fetchAllKeyed($key_index = 0, $value_index = 1) { $return = array(); $this->setFetchMode(\PDO::FETCH_NUM); foreach ($this as $record) { $return[$record[$key_index]] = $record[$value_index]; } return $return; } public function fetchField($index = 0) { // Call \PDOStatement::fetchColumn to fetch the field. return $this->fetchColumn($index); } public function fetchAssoc() { // Call \PDOStatement::fetch to fetch the row. return $this->fetch(\PDO::FETCH_ASSOC); } /** * {@inheritdoc} */ public function rowCount() { // SELECT query should not use the method. if ($this->allowRowCount) { return parent::rowCount(); } else { throw new RowCountException(); } } /** * {@inheritdoc} */ public function setFetchMode($mode, $a1 = NULL, $a2 = array()) { parent::setFetchMode($mode); } /** * {@inheritdoc} */ public function fetchAll($mode = NULL, $column_index = NULL, $constructor_arguments = NULL) { parent::fetchAll($mode, $column_index, $constructor_arguments); } } class Connection {}