Varien_Db_Adapter_Mysqli Class Reference

List of all members.

Public Member Functions
	raw_query ($sql)
	convertDate ($date)
	convertDateTime ($datetime)
	raw_fetchRow ($sql, $field=null)
	multi_query ($sql)
	clear_result ()
	dropForeignKey ($table, $fk)
	dropKey ($table, $key)
	addConstraint ($fkName, $tableName, $keyName, $refTableName, $refKeyName, $onDelete= 'cascade', $onUpdate= 'cascade')
	tableColumnExists ($tableName, $columnName)
	addColumn ($tableName, $columnName, $definition)
	dropColumn ($tableName, $columnName)
	select ()
Public Attributes
const	ISO_DATE_FORMAT = 'yyyy-MM-dd'
const	ISO_DATETIME_FORMAT = 'yyyy-MM-dd HH-mm-ss'
Protected Member Functions
	_connect ()

---

Detailed Description

Definition at line 28 of file Mysqli.php.

---

Member Function Documentation

_connect

(

)

[protected]

Creates a real connection to the database with multi-query capability.

Returns:

void

Exceptions:

Zend_Db_Adapter_Mysqli_Exception

http://bugs.mysql.com/bug.php?id=18551

Definition at line 39 of file Mysqli.php.

    {
        if ($this->_connection) {
            return;
        }
        if (!extension_loaded('mysqli')) {
            throw new Zend_Db_Adapter_Exception('mysqli extension is not installed');
        }
        // Suppress connection warnings here.
        // Throw an exception instead.
        @$conn = new mysqli();
        if (false===$conn || mysqli_connect_errno()) {
            throw new Zend_Db_Adapter_Mysqli_Exception(mysqli_connect_errno());
        }

        $conn->init();
        $conn->options(MYSQLI_OPT_LOCAL_INFILE, true);
        #$conn->options(MYSQLI_CLIENT_MULTI_QUERIES, true);

        $port = !empty($this->_config['port']) ? $this->_config['port'] : null;
        $socket = !empty($this->_config['unix_socket']) ? $this->_config['unix_socket'] : null;
        // socket specified in host config
        if (strpos($this->_config['host'], '/')!==false) {
            $socket = $this->_config['host'];
            $this->_config['host'] = null;
        } elseif (strpos($this->_config['host'], ':')!==false) {
            list($this->_config['host'], $port) = explode(':', $this->_config['host']);
        }

#echo "<pre>".print_r($this->_config,1)."</pre>"; die;
        @$conn->real_connect(
            $this->_config['host'],
            $this->_config['username'],
            $this->_config['password'],
            $this->_config['dbname'],
            $port,
            $socket
        );
        if (mysqli_connect_errno()) {
            throw new Zend_Db_Adapter_Mysqli_Exception(mysqli_connect_error());
        }

        $this->_connection = $conn;

        /** @link http://bugs.mysql.com/bug.php?id=18551 */
        $this->_connection->query("SET SQL_MODE=''");
    }

addColumn	(	$	tableName,
		$	columnName,
		$	definition
	)

Definition at line 234 of file Mysqli.php.

    {
        if ($this->tableColumnExists($tableName, $columnName)) {
            return true;
        }
        $result = $this->raw_query("alter table `$tableName` add column `$columnName` ".$definition);
        return $result;
    }

addConstraint	(	$	fkName,
		$	tableName,
		$	keyName,
		$	refTableName,
		$	refKeyName,
		$	onDelete = 'cascade',
		$	onUpdate = 'cascade'
	)

ADD CONSTRAINT

Parameters:

	string	$fkName
	string	$tableName
	string	$keyName
	string	$refTableName
	string	$refKeyName
	string	$onUpdate
	string	$onDelete

Definition at line 206 of file Mysqli.php.

    {
        if (substr($fkName, 0, 3) != 'FK_') {
            $fkName = 'FK_' . $fkName;
        }

        $sql = 'ALTER TABLE `'.$tableName.'` ADD CONSTRAINT `'.$fkName.'`'
            . 'FOREIGN KEY (`'.$keyName.'`) REFERENCES `'.$refTableName.'` (`'.$refKeyName.'`)';
        if (!is_null($onDelete)) {
            $sql .= ' ON DELETE ' . strtoupper($onDelete);
        }
        if (!is_null($onUpdate)) {
            $sql .= ' ON UPDATE ' . strtoupper($onUpdate);
        }

        return $this->raw_query($sql);
    }

clear_result

(

)

Definition at line 163 of file Mysqli.php.

    {
        while ($this->getConnection()->next_result()) {
            if ($result = $this->getConnection()->store_result()) {
                $result->free_result();
            }
            elseif($this->getConnection()->error) {
                throw new Zend_Db_Adapter_Mysqli_Exception('clear_result: '.$this->getConnection()->error);
            }
        }

    }

convertDate

(

$

date

)

Definition at line 111 of file Mysqli.php.

    {
        if ($date instanceof Zend_Date) {
            return $date->toString(self::ISO_DATE_FORMAT);
        }
        return strftime('%Y-%m-%d', strtotime($date));
    }

convertDateTime

(

$

datetime

)

Definition at line 119 of file Mysqli.php.

    {
        if ($datetime instanceof Zend_Date) {
            return $datetime->toString(self::ISO_DATETIME_FORMAT);
        }
        return strftime('%Y-%m-%d %H:%M:%S', strtotime($datetime));
    }

dropColumn	(	$	tableName,
		$	columnName
	)

find foreign keys for column

Definition at line 243 of file Mysqli.php.

    {
        if (!$this->tableColumnExists($tableName, $columnName)) {
            return true;
        }

        $create = $this->raw_fetchRow('SHOW CREATE TABLE `'.$tableName.'`', 'Create Table');

        $alterDrop = array();
        $alterDrop[] = 'DROP COLUMN `'.$columnName.'`';

        /**
         * find foreign keys for column
         */
        $matches = array();
        preg_match_all('/CONSTRAINT `([^`]*)` FOREIGN KEY \(`([^`]*)`\)/', $create, $matches, PREG_SET_ORDER);
        foreach ($matches as $match) {
            if ($match[2] == $columnName) {
                $alterDrop[] = 'DROP FOREIGN KEY `'.$match[1].'`';
            }
        }

        return $this->raw_query('ALTER TABLE `'.$tableName.'` ' . join(', ', $alterDrop));
    }

dropForeignKey	(	$	table,
		$	fk
	)

Definition at line 176 of file Mysqli.php.

    {
        $create = $this->raw_fetchRow("show create table `$table`", 'Create Table');
        if (strpos($create, "CONSTRAINT `$fk` FOREIGN KEY (")!==false) {
            return $this->raw_query("ALTER TABLE `$table` DROP FOREIGN KEY `$fk`");
        }
        return true;
    }

dropKey	(	$	table,
		$	key
	)

Definition at line 185 of file Mysqli.php.

    {
        $create = $this->raw_fetchRow("show create table `$table`", 'Create Table');
        if (strpos($create, "KEY `$key` (")!==false) {
            return $this->raw_query("ALTER TABLE `$table` DROP KEY `$key`");
        }
        return true;
    }

multi_query

(

$

sql

)

Definition at line 144 of file Mysqli.php.

    {
        $this->beginTransaction();
        try {
            $this->clear_result();
            if ($this->getConnection()->multi_query($sql)) {
                $this->clear_result();
                $this->commit();
            } else {
                throw new Zend_Db_Adapter_Mysqli_Exception('multi_query: '.$this->getConnection()->error);
            }
        } catch (Exception $e) {
            $this->rollback();
            throw $e;
        }

        return true;
    }

raw_fetchRow	(	$	sql,
		$	field = null
	)

Definition at line 129 of file Mysqli.php.

    {
        if (!$result = $this->raw_query($sql)) {
            return false;
        }
        if (!$row = $result->fetch_assoc()) {
            return false;
        }
        if (empty($field)) {
            return $row;
        } else {
            return isset($row[$field]) ? $row[$field] : false;
        }
    }

raw_query

(

$

sql

)

Definition at line 87 of file Mysqli.php.

    {
        do {
            $retry = false;
            $tries = 0;
            try {
                $this->clear_result();
                $result = $this->getConnection()->query($sql);
                $this->clear_result();
            }
            catch (Exception $e) {
                if ($e->getMessage()=='SQLSTATE[HY000]: General error: 1205 Lock wait timeout exceeded; try restarting transaction') {
                    $retry = true;
                } else {
                    throw $e;
                }
                $tries++;
            }
        } while ($retry && $tries<10);

        return $result;
    }

select

(

)

Creates and returns a new Zend_Db_Select object for this adapter.

Returns:

Varien_Db_Select

Definition at line 273 of file Mysqli.php.

    {
        return new Varien_Db_Select($this);
    }

tableColumnExists	(	$	tableName,
		$	columnName
	)

Definition at line 224 of file Mysqli.php.

    {
        foreach ($this->fetchAll('DESCRIBE `'.$tableName.'`') as $row) {
            if ($row['Field'] == $columnName) {
                return true;
            }
        }
        return false;
    }

---

Member Data Documentation

const ISO_DATE_FORMAT = 'yyyy-MM-dd'

Definition at line 30 of file Mysqli.php.

const ISO_DATETIME_FORMAT = 'yyyy-MM-dd HH-mm-ss'

Definition at line 31 of file Mysqli.php.

---

The documentation for this class was generated from the following file:

• lib/Varien/Db/Adapter/Mysqli.php