Inheritance diagram for Mysql:

Public Member Functions
	__construct (StringUtils $string, DateTime $dateTime, LoggerInterface $logger, SelectFactory $selectFactory, array $config=[], SerializerInterface $serializer=null)

	beginTransaction ()

	commit ()

	rollBack ()

	getTransactionLevel ()

	convertDate ($date)

	convertDateTime ($datetime)

	rawQuery ($sql)

	rawFetchRow ($sql, $field=null)

	query ($sql, $bind=[])

	multiQuery ($sql, $bind=[])

	proccessBindCallback ($matches)

	setQueryHook ($hook)

	dropForeignKey ($tableName, $fkName, $schemaName=null)

	purgeOrphanRecords ( $tableName, $columnName, $refTableName, $refColumnName, $onDelete=AdapterInterface::FK_ACTION_CASCADE)

	tableColumnExists ($tableName, $columnName, $schemaName=null)

	addColumn ($tableName, $columnName, $definition, $schemaName=null)

	dropColumn ($tableName, $columnName, $schemaName=null)

	changeColumn ( $tableName, $oldColumnName, $newColumnName, $definition, $flushData=false, $schemaName=null)

	modifyColumn ($tableName, $columnName, $definition, $flushData=false, $schemaName=null)

	showTableStatus ($tableName, $schemaName=null)

	getCreateTable ($tableName, $schemaName=null)

	getForeignKeys ($tableName, $schemaName=null)

	getForeignKeysTree ()

	modifyTables ($tables)

	getIndexList ($tableName, $schemaName=null)

	select ()

	quoteInto ($text, $value, $type=null, $count=null)

	loadDdlCache ($tableCacheKey, $ddlType)

	saveDdlCache ($tableCacheKey, $ddlType, $data)

	resetDdlCache ($tableName=null, $schemaName=null)

	disallowDdlCache ()

	allowDdlCache ()

	describeTable ($tableName, $schemaName=null)

	getColumnCreateByDescribe ($columnData)

	createTableByDdl ($tableName, $newTableName)

	modifyColumnByDdl ($tableName, $columnName, $definition, $flushData=false, $schemaName=null)

	changeTableEngine ($tableName, $engine, $schemaName=null)

	changeTableComment ($tableName, $comment, $schemaName=null)

	insertForce ($table, array $bind)

	insertOnDuplicate ($table, array $data, array $fields=[])

	insertMultiple ($table, array $data)

	insertArray ($table, array $columns, array $data, $strategy=0)

	setCacheAdapter (FrontendInterface $cacheAdapter)

	newTable ($tableName=null, $schemaName=null)

	createTable (Table $table)

	createTemporaryTable (\Magento\Framework\DB\Ddl\Table $table)

	createTemporaryTableLike ($temporaryTableName, $originTableName, $ifNotExists=false)

	renameTablesBatch (array $tablePairs)

	getColumnDefinitionFromDescribe ($options, $ddlType=null)

	dropTable ($tableName, $schemaName=null)

	dropTemporaryTable ($tableName, $schemaName=null)

	truncateTable ($tableName, $schemaName=null)

	isTableExists ($tableName, $schemaName=null)

	renameTable ($oldTableName, $newTableName, $schemaName=null)

	addIndex ( $tableName, $indexName, $fields, $indexType=AdapterInterface::INDEX_TYPE_INDEX, $schemaName=null)

	dropIndex ($tableName, $keyName, $schemaName=null)

	addForeignKey ( $fkName, $tableName, $columnName, $refTableName, $refColumnName, $onDelete=AdapterInterface::FK_ACTION_CASCADE, $purge=false, $schemaName=null, $refSchemaName=null)

	formatDate ($date, $includeTime=true)

	startSetup ()

	endSetup ()

	prepareSqlCondition ($fieldName, $condition)

	prepareColumnValue (array $column, $value)

	getCheckSql ($expression, $true, $false)

	getIfNullSql ($expression, $value=0)

	getCaseSql ($valueName, $casesResults, $defaultValue=null)

	getConcatSql (array $data, $separator=null)

	getLengthSql ($string)

	getLeastSql (array $data)

	getGreatestSql (array $data)

	getDateAddSql ($date, $interval, $unit)

	getDateSubSql ($date, $interval, $unit)

	getDateFormatSql ($date, $format)

	getDatePartSql ($date)

	getSubstringSql ($stringExpression, $pos, $len=null)

	getStandardDeviationSql ($expressionField)

	getDateExtractSql ($date, $unit)

	getTableName ($tableName)

	getTriggerName ($tableName, $time, $event)

	getIndexName ($tableName, $fields, $indexType='')

	getForeignKeyName ($priTableName, $priColumnName, $refTableName, $refColumnName)

	disableTableKeys ($tableName, $schemaName=null)

	enableTableKeys ($tableName, $schemaName=null)

	insertFromSelect (Select $select, $table, array $fields=[], $mode=false)

	selectsByRange ($rangeField, \Magento\Framework\DB\Select $select, $stepCount=100)

	updateFromSelect (Select $select, $table)

	deleteFromSelect (Select $select, $table)

	getTablesChecksum ($tableNames, $schemaName=null)

	supportStraightJoin ()

	orderRand (Select $select, $field=null)

	forUpdate ($sql)

	getPrimaryKeyName ($tableName, $schemaName=null)

	decodeVarbinary ($value)

	createTrigger (\Magento\Framework\DB\Ddl\Trigger $trigger)

	dropTrigger ($triggerName, $schemaName=null)

	__destruct ()

	getTables ($likeCondition=null)

	getAutoIncrementField ($tableName, $schemaName=null)

	getSchemaListener ()

Public Member Functions inherited from Zend_Db_Adapter_Pdo_Mysql
	getQuoteIdentifierSymbol ()

	listTables ()

	describeTable ($tableName, $schemaName=null)

	limit ($sql, $count, $offset=0)

Public Member Functions inherited from Zend_Db_Adapter_Pdo_Abstract
	isConnected ()

	closeConnection ()

	prepare ($sql)

	lastInsertId ($tableName=null, $primaryKey=null)

	query ($sql, $bind=array())

	exec ($sql)

	setFetchMode ($mode)

	supportsParameters ($type)

	getServerVersion ()

Public Member Functions inherited from Zend_Db_Adapter_Abstract
	__construct ($config)

	getConnection ()

	getConfig ()

	setProfiler ($profiler)

	getProfiler ()

	getStatementClass ()

	setStatementClass ($class)

	query ($sql, $bind=array())

	beginTransaction ()

	commit ()

	rollBack ()

	insert ($table, array $bind)

	update ($table, array $bind, $where='')

	delete ($table, $where='')

	select ()

	getFetchMode ()

	fetchAll ($sql, $bind=array(), $fetchMode=null)

	fetchRow ($sql, $bind=array(), $fetchMode=null)

	fetchAssoc ($sql, $bind=array())

	fetchCol ($sql, $bind=array())

	fetchPairs ($sql, $bind=array())

	fetchOne ($sql, $bind=array())

	quote ($value, $type=null)

	quoteInto ($text, $value, $type=null, $count=null)

	quoteIdentifier ($ident, $auto=false)

	quoteColumnAs ($ident, $alias, $auto=false)

	quoteTableAs ($ident, $alias=null, $auto=false)

	getQuoteIdentifierSymbol ()

	lastSequenceId ($sequenceName)

	nextSequenceId ($sequenceName)

	foldCase ($key)

	__sleep ()

	__wakeup ()

	listTables ()

	describeTable ($tableName, $schemaName=null)

	isConnected ()

	closeConnection ()

	prepare ($sql)

	lastInsertId ($tableName=null, $primaryKey=null)

	setFetchMode ($mode)

	limit ($sql, $count, $offset=0)

	supportsParameters ($type)

	getServerVersion ()

Public Member Functions inherited from AdapterInterface
	createTemporaryTable (Table $table)

	insertArray ($table, array $columns, array $data)

	insert ($table, array $bind)

	update ($table, array $bind, $where='')

	delete ($table, $where='')

	fetchAll ($sql, $bind=[], $fetchMode=null)

	fetchRow ($sql, $bind=[], $fetchMode=null)

	fetchAssoc ($sql, $bind=[])

	fetchCol ($sql, $bind=[])

	fetchPairs ($sql, $bind=[])

	fetchOne ($sql, $bind=[])

	quote ($value, $type=null)

	quoteIdentifier ($ident, $auto=false)

	quoteColumnAs ($ident, $alias, $auto=false)

	quoteTableAs ($ident, $alias=null, $auto=false)

	setCacheAdapter (\Magento\Framework\Cache\FrontendInterface $cacheAdapter)

	insertFromSelect (\Magento\Framework\DB\Select $select, $table, array $fields=[], $mode=false)

	updateFromSelect (\Magento\Framework\DB\Select $select, $table)

	deleteFromSelect (\Magento\Framework\DB\Select $select, $table)

	orderRand (\Magento\Framework\DB\Select $select, $field=null)

Data Fields
const	TIMESTAMP_FORMAT = 'Y-m-d H:i:s'

const	DATETIME_FORMAT = 'Y-m-d H:i:s'

const	DATE_FORMAT = 'Y-m-d'

const	DDL_DESCRIBE = 1

const	DDL_CREATE = 2

const	DDL_INDEX = 3

const	DDL_FOREIGN_KEY = 4

const	DDL_CACHE_PREFIX = 'DB_PDO_MYSQL_DDL'

const	DDL_CACHE_TAG = 'DB_PDO_MYSQL_DDL'

const	LENGTH_TABLE_NAME = 64

const	LENGTH_INDEX_NAME = 64

const	LENGTH_FOREIGN_NAME = 64

const	ENGINE_MEMORY = 'MEMORY'

const	MAX_CONNECTION_RETRIES = 10

Data Fields inherited from AdapterInterface
const	INDEX_TYPE_PRIMARY = 'primary'

const	INDEX_TYPE_UNIQUE = 'unique'

const	INDEX_TYPE_INDEX = 'index'

const	INDEX_TYPE_FULLTEXT = 'fulltext'

const	FK_ACTION_CASCADE = 'CASCADE'

const	FK_ACTION_SET_NULL = 'SET NULL'

const	FK_ACTION_NO_ACTION = 'NO ACTION'

const	FK_ACTION_RESTRICT = 'RESTRICT'

const	FK_ACTION_SET_DEFAULT = 'SET DEFAULT'

const	INSERT_ON_DUPLICATE = 1

const	INSERT_IGNORE = 2

const	REPLACE = 4

const	ISO_DATE_FORMAT = 'yyyy-MM-dd'

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

const	INTERVAL_SECOND = 'SECOND'

const	INTERVAL_MINUTE = 'MINUTES'

const	INTERVAL_HOUR = 'HOURS'

const	INTERVAL_DAY = 'DAYS'

const	INTERVAL_MONTH = 'MONTHS'

const	INTERVAL_YEAR = 'YEARS'

const	ERROR_DDL_MESSAGE = 'DDL statements are not allowed in transactions'

const	ERROR_ROLLBACK_INCOMPLETE_MESSAGE = 'Rolled back transaction has not been completed correctly.'

const	ERROR_ASYMMETRIC_ROLLBACK_MESSAGE = 'Asymmetric transaction rollback.'

const	ERROR_ASYMMETRIC_COMMIT_MESSAGE = 'Asymmetric transaction commit.'

Protected Member Functions
	_connect ()

	_checkDdlTransaction ($sql)

	_prepareQuery (&$sql, &$bind=[])

	_unQuote ($string)

	_convertMixedBind (&$sql, &$bind)

	_splitMultiQuery ($sql)

	_getIndexByColumns ($tableName, array $columns, $schemaName)

	_removeDuplicateEntry ($table, $fields, $ids)

	_getTableName ($tableName, $schemaName=null)

	_getCacheId ($tableKey, $ddlType)

	_getColumnTypeByDdl ($column)

	_getColumnsDefinition (Table $table)

	_getIndexesDefinition (Table $table)

	isNdb (Table $table)

	_getForeignKeysDefinition (Table $table)

	_getOptionsDefinition (Table $table)

	_getColumnDefinition ($options, $ddlType=null)

	_prepareQuotedSqlCondition ($text, $value, $fieldName)

	_transformStringSqlCondition ($conditionKey, $value)

	_getIntervalUnitSql ($interval, $unit)

	_prepareInsertData ($row, &$bind)

	_getInsertSqlQuery ($tableName, array $columns, array $values, $strategy=null)

	_getReplaceSqlQuery ($tableName, array $columns, array $values)

	_getDdlType ($options)

	_getDdlAction ($action)

	_prepareSqlDateCondition ($condition, $key)

	_parseTextSize ($size)

Protected Member Functions inherited from Zend_Db_Adapter_Pdo_Mysql
	_dsn ()

	_connect ()

Protected Member Functions inherited from Zend_Db_Adapter_Pdo_Abstract
	_dsn ()

	_connect ()

	_quote ($value)

	_beginTransaction ()

	_commit ()

	_rollBack ()

Protected Member Functions inherited from Zend_Db_Adapter_Abstract
	_checkRequiredOptions (array $config)

	_whereExpr ($where)

	_quote ($value)

	_quoteIdentifierAs ($ident, $alias=null, $auto=false, $as=' AS ')

	_quoteIdentifier ($value, $auto=false)

	_connect ()

	_beginTransaction ()

	_commit ()

	_rollBack ()

Protected Attributes
	$_defaultStmtClass = \Magento\Framework\DB\Statement\Pdo\Mysql::class

	$_transactionLevel = 0

	$_isRolledBack = false

	$_connectionFlagsSet = false

	$_ddlCache = []

	$_bindParams = []

	$_bindIncrement = 0

	$_cacheAdapter

	$_isDdlCacheAllowed = true

	$_ddlColumnTypes

	$_ddlRoutines = ['alt', 'cre', 'ren', 'dro', 'tru']

	$_intervalUnits

	$_queryHook = null

	$string

	$dateTime

	$selectFactory

	$logger

Protected Attributes inherited from Zend_Db_Adapter_Pdo_Mysql
	$_pdoType = 'mysql'

	$_numericDataTypes

Protected Attributes inherited from Zend_Db_Adapter_Pdo_Abstract
	$_defaultStmtClass = 'Zend_Db_Statement_Pdo'

Protected Attributes inherited from Zend_Db_Adapter_Abstract
	$_config = array()

	$_fetchMode = Zend_Db::FETCH_ASSOC

	$_profiler

	$_defaultStmtClass = 'Zend_Db_Statement'

	$_defaultProfilerClass = 'Zend_Db_Profiler'

	$_connection = null

	$_caseFolding = Zend_Db::CASE_NATURAL

	$_autoQuoteIdentifiers = true

	$_numericDataTypes

	$_allowSerialization = true

	$_autoReconnectOnUnserialize = false

Detailed Description

MySQL database adapter

@api @SuppressWarnings(PHPMD.ExcessivePublicCount) @SuppressWarnings(PHPMD.TooManyFields) @SuppressWarnings(PHPMD.ExcessiveClassComplexity) @SuppressWarnings(PHPMD.CouplingBetweenObjects)

Since: 100.0.2

Definition at line 43 of file Mysql.php.

Constructor & Destructor Documentation

◆ __construct()

__construct	(	StringUtils	$string,
		DateTime	$dateTime,
		LoggerInterface	$logger,
		SelectFactory	$selectFactory,
		array	$config = `[]`,
		SerializerInterface	$serializer = `null`
	)

Constructor

Parameters

StringUtils	$string
DateTime	$dateTime
LoggerInterface	$logger
SelectFactory	$selectFactory
array	$config
SerializerInterface \| null	$serializer

Definition at line 237 of file Mysql.php.

       {
         $this->string = $string;
         $this->dateTime = $dateTime;
         $this->logger = $logger;
         $this->selectFactory = $selectFactory;
         $this->serializer = $serializer ?: ObjectManager::getInstance()->get(SerializerInterface::class);
         $this->exceptionMap = [
             // SQLSTATE[HY000]: General error: 2006 MySQL server has gone away
             2006 => ConnectionException::class,
             // SQLSTATE[HY000]: General error: 2013 Lost connection to MySQL server during query
             2013 => ConnectionException::class,
             // SQLSTATE[HY000]: General error: 1205 Lock wait timeout exceeded
             1205 => LockWaitException::class,
             // SQLSTATE[40001]: Serialization failure: 1213 Deadlock found when trying to get lock
             1213 => DeadlockException::class,
             // SQLSTATE[23000]: Integrity constraint violation: 1062 Duplicate entry
             1062 => DuplicateException::class,
         ];
         try {
             parent::__construct($config);
         } catch (\Zend_Db_Adapter_Exception $e) {
             throw new \InvalidArgumentException($e->getMessage(), $e->getCode(), $e);
         }
     }

◆ __destruct()

__destruct ( )

Check if all transactions have been committed

Returns: void

Definition at line 3952 of file Mysql.php.

     {
         if ($this->_transactionLevel > 0) {
             trigger_error('Some transactions have not been committed or rolled back', E_USER_ERROR);
         }
     }

Member Function Documentation

◆ _checkDdlTransaction()

_checkDdlTransaction ( $sql )

protected

Check transaction level in case of DDL query

Parameters

string | \Magento\Framework\DB\Select $sql

Returns: void

Exceptions

Definition at line 505 of file Mysql.php.

     {
         if ($this->getTransactionLevel() > 0) {
             $sql = ltrim(preg_replace('/\s+/', ' ', $sql));
             $sqlMessage = explode(' ', $sql, 3);
             $startSql = strtolower(substr($sqlMessage[0], 0, 3));
             if (in_array($startSql, $this->_ddlRoutines) && strcasecmp($sqlMessage[1], 'temporary') !== 0) {
                 throw new ConnectionException(AdapterInterface::ERROR_DDL_MESSAGE, E_USER_ERROR);
             }
         }
     }

◆ _connect()

_connect ( )

protected

Creates a PDO object and connects to the database.

@SuppressWarnings(PHPMD.CyclomaticComplexity) @SuppressWarnings(PHPMD.NPathComplexity)

Returns: void

Exceptions

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

Definition at line 374 of file Mysql.php.

     {
         if ($this->_connection) {
             return;
         }
 
         if (!extension_loaded('pdo_mysql')) {
             throw new \Zend_Db_Adapter_Exception('pdo_mysql extension is not installed');
         }
 
         if (!isset($this->_config['host'])) {
             throw new \Zend_Db_Adapter_Exception('No host configured to connect');
         }
 
         if (isset($this->_config['port'])) {
             throw new \Zend_Db_Adapter_Exception('Port must be configured within host parameter (like localhost:3306');
         }
 
         unset($this->_config['port']);
 
         if (strpos($this->_config['host'], '/') !== false) {
             $this->_config['unix_socket'] = $this->_config['host'];
             unset($this->_config['host']);
         } elseif (strpos($this->_config['host'], ':') !== false) {
             list($this->_config['host'], $this->_config['port']) = explode(':', $this->_config['host']);
         }
 
         if (!isset($this->_config['driver_options'][\PDO::MYSQL_ATTR_MULTI_STATEMENTS])) {
             $this->_config['driver_options'][\PDO::MYSQL_ATTR_MULTI_STATEMENTS] = false;
         }
 
         $this->logger->startTimer();
         parent::_connect();
         $this->logger->logStats(LoggerInterface::TYPE_CONNECT, '');
 
         $this->_connection->query("SET SQL_MODE=''");
 
         // As we use default value CURRENT_TIMESTAMP for TIMESTAMP type columns we need to set GMT timezone
         $this->_connection->query("SET time_zone = '+00:00'");
 
         if (isset($this->_config['initStatements'])) {
             $statements = $this->_splitMultiQuery($this->_config['initStatements']);
             foreach ($statements as $statement) {
                 $this->_query($statement);
             }
         }
 
         if (!$this->_connectionFlagsSet) {
             $this->_connection->setAttribute(\PDO::ATTR_EMULATE_PREPARES, true);
             if (isset($this->_config['use_buffered_query']) && $this->_config['use_buffered_query'] === false) {
                 $this->_connection->setAttribute(\PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
             } else {
                 $this->_connection->setAttribute(\PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);
             }
             $this->_connectionFlagsSet = true;
         }
     }

◆ _convertMixedBind()

_convertMixedBind	(	&	$sql,
		&	$bind
	)

protected

Normalizes mixed positional-named bind to positional bind, and replaces named placeholders in query to '?' placeholders.

Parameters

string	$sql
array	$bind

Returns: $this

Definition at line 729 of file Mysql.php.

     {
         $positions  = [];
         $offset     = 0;
         // get positions
         while (true) {
             $pos = strpos($sql, '?', $offset);
             if ($pos !== false) {
                 $positions[] = $pos;
                 $offset      = ++$pos;
             } else {
                 break;
             }
         }
 
         $bindResult = [];
         $map = [];
         foreach ($bind as $k => $v) {
             // positional
             if (is_int($k)) {
                 if (!isset($positions[$k])) {
                     continue;
                 }
                 $bindResult[$positions[$k]] = $v;
             } else {
                 $offset = 0;
                 while (true) {
                     $pos = strpos($sql, $k, $offset);
                     if ($pos === false) {
                         break;
                     } else {
                         $offset = $pos + strlen($k);
                         $bindResult[$pos] = $v;
                     }
                 }
                 $map[$k] = '?';
             }
         }
 
         ksort($bindResult);
         $bind = array_values($bindResult);
         $sql = strtr($sql, $map);
 
         return $this;
     }

◆ _getCacheId()

_getCacheId	(	$tableKey,
		$ddlType
	)

protected

Retrieve Id for cache

Parameters

string	$tableKey
int	$ddlType

Returns: string

Definition at line 1511 of file Mysql.php.

     {
         return sprintf('%s_%s_%s', self::DDL_CACHE_PREFIX, $tableKey, $ddlType);
     }

◆ _getColumnDefinition()

_getColumnDefinition	(	$options,
		$ddlType = `null`
	)

protected

Retrieve column definition fragment

Parameters

array	$options
string	$ddlType	Table DDL Column type constant

Exceptions

Definition at line 2413 of file Mysql.php.

     {
         // convert keys to uppercase
         $options    = array_change_key_case($options, CASE_UPPER);
         $cType      = null;
         $cUnsigned  = false;
         $cNullable  = true;
         $cDefault   = false;
         $cIdentity  = false;
 
         // detect and validate column type
         if ($ddlType === null) {
             $ddlType = $this->_getDdlType($options);
         }
 
         if (empty($ddlType) || !isset($this->_ddlColumnTypes[$ddlType])) {
             throw new \Zend_Db_Exception('Invalid column definition data');
         }
 
         // column size
         $cType = $this->_ddlColumnTypes[$ddlType];
         switch ($ddlType) {
             case Table::TYPE_SMALLINT:
             case Table::TYPE_INTEGER:
             case Table::TYPE_BIGINT:
                 if (!empty($options['UNSIGNED'])) {
                     $cUnsigned = true;
                 }
                 break;
             case Table::TYPE_DECIMAL:
             case Table::TYPE_FLOAT:
             case Table::TYPE_NUMERIC:
                 $precision  = 10;
                 $scale      = 0;
                 $match      = [];
                 if (!empty($options['LENGTH']) && preg_match('#^\(?(\d+),(\d+)\)?$#', $options['LENGTH'], $match)) {
                     $precision  = $match[1];
                     $scale      = $match[2];
                 } else {
                     if (isset($options['SCALE']) && is_numeric($options['SCALE'])) {
                         $scale = $options['SCALE'];
                     }
                     if (isset($options['PRECISION']) && is_numeric($options['PRECISION'])) {
                         $precision = $options['PRECISION'];
                     }
                 }
                 $cType .= sprintf('(%d,%d)', $precision, $scale);
                 if (!empty($options['UNSIGNED'])) {
                     $cUnsigned = true;
                 }
                 break;
             case Table::TYPE_TEXT:
             case Table::TYPE_BLOB:
             case Table::TYPE_VARBINARY:
                 if (empty($options['LENGTH'])) {
                     $length = Table::DEFAULT_TEXT_SIZE;
                 } else {
                     $length = $this->_parseTextSize($options['LENGTH']);
                 }
                 if ($length <= 255) {
                     $cType = $ddlType == Table::TYPE_TEXT ? 'varchar' : 'varbinary';
                     $cType = sprintf('%s(%d)', $cType, $length);
                 } elseif ($length > 255 && $length <= 65536) {
                     $cType = $ddlType == Table::TYPE_TEXT ? 'text' : 'blob';
                 } elseif ($length > 65536 && $length <= 16777216) {
                     $cType = $ddlType == Table::TYPE_TEXT ? 'mediumtext' : 'mediumblob';
                 } else {
                     $cType = $ddlType == Table::TYPE_TEXT ? 'longtext' : 'longblob';
                 }
                 break;
         }
 
         if (array_key_exists('DEFAULT', $options)) {
             $cDefault = $options['DEFAULT'];
         }
         if (array_key_exists('NULLABLE', $options)) {
             $cNullable = (bool)$options['NULLABLE'];
         }
         if (!empty($options['IDENTITY']) || !empty($options['AUTO_INCREMENT'])) {
             $cIdentity = true;
         }
 
         /*  For cases when tables created from createTableByDdl()
          *  where default value can be quoted already.
          *  We need to avoid "double-quoting" here
          */
         if ($cDefault !== null && is_string($cDefault) && strlen($cDefault)) {
             $cDefault = str_replace("'", '', $cDefault);
         }
 
         // prepare default value string
         if ($ddlType == Table::TYPE_TIMESTAMP) {
             if ($cDefault === null) {
                 $cDefault = new \Zend_Db_Expr('NULL');
             } elseif ($cDefault == Table::TIMESTAMP_INIT) {
                 $cDefault = new \Zend_Db_Expr('CURRENT_TIMESTAMP');
             } elseif ($cDefault == Table::TIMESTAMP_UPDATE) {
                 $cDefault = new \Zend_Db_Expr('0 ON UPDATE CURRENT_TIMESTAMP');
             } elseif ($cDefault == Table::TIMESTAMP_INIT_UPDATE) {
                 $cDefault = new \Zend_Db_Expr('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP');
             } elseif ($cNullable && !$cDefault) {
                 $cDefault = new \Zend_Db_Expr('NULL');
             } else {
                 $cDefault = false;
             }
         } elseif ($cDefault === null && $cNullable) {
             $cDefault = new \Zend_Db_Expr('NULL');
         }
 
         if (empty($options['COMMENT'])) {
             $comment = '';
         } else {
             $comment = $options['COMMENT'];
         }
 
         //set column position
         $after = null;
         if (!empty($options['AFTER'])) {
             $after = $options['AFTER'];
         }
 
         return sprintf(
             '%s%s%s%s%s COMMENT %s %s',
             $cType,
             $cUnsigned ? ' UNSIGNED' : '',
             $cNullable ? ' NULL' : ' NOT NULL',
             $cDefault !== false ? $this->quoteInto(' default ?', $cDefault) : '',
             $cIdentity ? ' auto_increment' : '',
             $this->quote($comment),
             $after ? 'AFTER ' . $this->quoteIdentifier($after) : ''
         );
     }

◆ _getColumnsDefinition()

_getColumnsDefinition ( Table $table )

protected

Retrieve columns and primary keys definition array for create table

Parameters

Table $table

Returns: string[]

Exceptions

Definition at line 2225 of file Mysql.php.

     {
         $definition = [];
         $primary    = [];
         $columns    = $table->getColumns();
         if (empty($columns)) {
             throw new \Zend_Db_Exception('Table columns are not defined');
         }
 
         foreach ($columns as $columnData) {
             $columnDefinition = $this->_getColumnDefinition($columnData);
             if ($columnData['PRIMARY']) {
                 $primary[$columnData['COLUMN_NAME']] = $columnData['PRIMARY_POSITION'];
             }
 
             $definition[] = sprintf(
                 '  %s %s',
                 $this->quoteIdentifier($columnData['COLUMN_NAME']),
                 $columnDefinition
             );
         }
 
         // PRIMARY KEY
         if (!empty($primary)) {
             asort($primary, SORT_NUMERIC);
             $primary      = array_map([$this, 'quoteIdentifier'], array_keys($primary));
             $definition[] = sprintf('  PRIMARY KEY (%s)', implode(', ', $primary));
         }
 
         return $definition;
     }

◆ _getColumnTypeByDdl()

_getColumnTypeByDdl ( $column )

protected

Retrieve column data type by data from describe table

Parameters

array $column

Returns: string @SuppressWarnings(PHPMD.CyclomaticComplexity)

Definition at line 1824 of file Mysql.php.

     {
         switch ($column['DATA_TYPE']) {
             case 'bool':
                 return Table::TYPE_BOOLEAN;
             case 'tinytext':
             case 'char':
             case 'varchar':
             case 'text':
             case 'mediumtext':
             case 'longtext':
                 return Table::TYPE_TEXT;
             case 'blob':
             case 'mediumblob':
             case 'longblob':
                 return Table::TYPE_BLOB;
             case 'tinyint':
             case 'smallint':
                 return Table::TYPE_SMALLINT;
             case 'mediumint':
             case 'int':
                 return Table::TYPE_INTEGER;
             case 'bigint':
                 return Table::TYPE_BIGINT;
             case 'datetime':
                 return Table::TYPE_DATETIME;
             case 'timestamp':
                 return Table::TYPE_TIMESTAMP;
             case 'date':
                 return Table::TYPE_DATE;
             case 'float':
                 return Table::TYPE_FLOAT;
             case 'decimal':
             case 'numeric':
                 return Table::TYPE_DECIMAL;
         }
     }

◆ _getDdlAction()

_getDdlAction ( $action )

protected

Return DDL action

Parameters

string $action

Returns: string

Definition at line 3794 of file Mysql.php.

     {
         switch ($action) {
             case AdapterInterface::FK_ACTION_CASCADE:
                 return Table::ACTION_CASCADE;
             case AdapterInterface::FK_ACTION_SET_NULL:
                 return Table::ACTION_SET_NULL;
             case AdapterInterface::FK_ACTION_RESTRICT:
                 return Table::ACTION_RESTRICT;
             default:
                 return Table::ACTION_NO_ACTION;
         }
     }

◆ _getDdlType()

_getDdlType ( $options )

protected

Return ddl type

Parameters

array $options

Returns: string

Definition at line 3776 of file Mysql.php.

     {
         $ddlType = null;
         if (isset($options['TYPE'])) {
             $ddlType = $options['TYPE'];
         } elseif (isset($options['COLUMN_TYPE'])) {
             $ddlType = $options['COLUMN_TYPE'];
         }
 
         return $ddlType;
     }

◆ _getForeignKeysDefinition()

_getForeignKeysDefinition ( Table $table )

protected

Retrieve table foreign keys definition array for create table

Parameters

Table $table

Returns: string[]

Definition at line 2324 of file Mysql.php.

     {
         $definition = [];
         $relations  = $table->getForeignKeys();
 
         if (!empty($relations)) {
             foreach ($relations as $fkData) {
                 $onDelete = $this->_getDdlAction($fkData['ON_DELETE']);
                 $definition[] = sprintf(
                     '  CONSTRAINT %s FOREIGN KEY (%s) REFERENCES %s (%s) ON DELETE %s',
                     $this->quoteIdentifier($fkData['FK_NAME']),
                     $this->quoteIdentifier($fkData['COLUMN_NAME']),
                     $this->quoteIdentifier($fkData['REF_TABLE_NAME']),
                     $this->quoteIdentifier($fkData['REF_COLUMN_NAME']),
                     $onDelete
                 );
             }
         }
 
         return $definition;
     }

◆ _getIndexByColumns()

_getIndexByColumns	(		$tableName,
		array	$columns,
			$schemaName
	)

protected

Retrieve index information by indexed columns or return NULL, if there is no index for a column list

Parameters

string	$tableName
array	$columns
string \| null	$schemaName

Returns: array|null

Definition at line 1058 of file Mysql.php.

     {
         foreach ($this->getIndexList($tableName, $schemaName) as $idxData) {
             if ($idxData['COLUMNS_LIST'] === $columns) {
                 return $idxData;
             }
         }
         return null;
     }

◆ _getIndexesDefinition()

_getIndexesDefinition ( Table $table )

protected

Retrieve table indexes definition array for create table

Parameters

Table $table

Returns: string[]

Definition at line 2263 of file Mysql.php.

     {
         $definition = [];
         $indexes = $table->getIndexes();
         foreach ($indexes as $indexData) {
             if (!empty($indexData['TYPE'])) {
                 //Skipping not supported fulltext indexes for NDB
                 if (($indexData['TYPE'] == AdapterInterface::INDEX_TYPE_FULLTEXT) && $this->isNdb($table)) {
                     continue;
                 }
                 switch ($indexData['TYPE']) {
                     case AdapterInterface::INDEX_TYPE_PRIMARY:
                         $indexType = 'PRIMARY KEY';
                         unset($indexData['INDEX_NAME']);
                         break;
                     default:
                         $indexType = strtoupper($indexData['TYPE']);
                         break;
                 }
             } else {
                 $indexType = 'KEY';
             }
 
             $columns = [];
             foreach ($indexData['COLUMNS'] as $columnData) {
                 $column = $this->quoteIdentifier($columnData['NAME']);
                 if (!empty($columnData['SIZE'])) {
                     $column .= sprintf('(%d)', $columnData['SIZE']);
                 }
                 $columns[] = $column;
             }
             $indexName = isset($indexData['INDEX_NAME']) ? $this->quoteIdentifier($indexData['INDEX_NAME']) : '';
             $definition[] = sprintf(
                 '  %s %s (%s)',
                 $indexType,
                 $indexName,
                 implode(', ', $columns)
             );
         }
 
         return $definition;
     }

◆ _getInsertSqlQuery()

_getInsertSqlQuery	(		$tableName,
		array	$columns,
		array	$values,
			$strategy = `null`
	)

protected

Return insert sql query

Parameters

string	$tableName
array	$columns
array	$values
null \| int	$strategy

Returns: string

Definition at line 3736 of file Mysql.php.

     {
         $tableName = $this->quoteIdentifier($tableName, true);
         $columns   = array_map([$this, 'quoteIdentifier'], $columns);
         $columns   = implode(',', $columns);
         $values    = implode(', ', $values);
         $strategy = $strategy === self::INSERT_IGNORE ? 'IGNORE' : '';
 
         $insertSql = sprintf('INSERT %s INTO %s (%s) VALUES %s', $strategy, $tableName, $columns, $values);
 
         return $insertSql;
     }

◆ _getIntervalUnitSql()

_getIntervalUnitSql	(	$interval,
		$unit
	)

protected

Get Interval Unit SQL fragment

Parameters

int	$interval
string	$unit

Returns: string

Exceptions

Definition at line 3225 of file Mysql.php.

     {
         if (!isset($this->_intervalUnits[$unit])) {
             throw new \Zend_Db_Exception(sprintf('Undefined interval unit "%s" specified', $unit));
         }
 
         return sprintf('INTERVAL %d %s', $interval, $this->_intervalUnits[$unit]);
     }

◆ _getOptionsDefinition()

_getOptionsDefinition ( Table $table )

protected

Retrieve table options definition array for create table

Parameters

Table $table

Returns: string[]

Exceptions

Definition at line 2353 of file Mysql.php.

     {
         $definition = [];
         $comment    = $table->getComment();
         if (empty($comment)) {
             throw new \Zend_Db_Exception('Comment for table is required and must be defined');
         }
         $definition[] = $this->quoteInto('COMMENT=?', $comment);
 
         $tableProps = [
             'type'              => 'ENGINE=%s',
             'checksum'          => 'CHECKSUM=%d',
             'auto_increment'    => 'AUTO_INCREMENT=%d',
             'avg_row_length'    => 'AVG_ROW_LENGTH=%d',
             'max_rows'          => 'MAX_ROWS=%d',
             'min_rows'          => 'MIN_ROWS=%d',
             'delay_key_write'   => 'DELAY_KEY_WRITE=%d',
             'row_format'        => 'row_format=%s',
             'charset'           => 'charset=%s',
             'collate'           => 'COLLATE=%s',
         ];
         foreach ($tableProps as $key => $mask) {
             $v = $table->getOption($key);
             if ($v !== null) {
                 $definition[] = sprintf($mask, $v);
             }
         }
 
         return $definition;
     }

◆ _getReplaceSqlQuery()

_getReplaceSqlQuery	(		$tableName,
		array	$columns,
		array	$values
	)

protected

Return replace sql query

Parameters

string	$tableName
array	$columns
array	$values

Returns: string

Since: 101.0.0

Definition at line 3758 of file Mysql.php.

     {
         $tableName = $this->quoteIdentifier($tableName, true);
         $columns   = array_map([$this, 'quoteIdentifier'], $columns);
         $columns   = implode(',', $columns);
         $values    = implode(', ', $values);
 
         $replaceSql = sprintf('REPLACE INTO %s (%s) VALUES %s', $tableName, $columns, $values);
 
         return $replaceSql;
     }

◆ _getTableName()

_getTableName	(	$tableName,
		$schemaName = `null`
	)

protected

Retrieve ddl cache name

Parameters

string	$tableName
string	$schemaName

Returns: string

Definition at line 1499 of file Mysql.php.

     {
         return ($schemaName ? $schemaName . '.' : '') . $tableName;
     }

◆ _parseTextSize()

_parseTextSize ( $size )

protected

Parse text size Returns max allowed size if value great it

Parameters

string | int $size

Returns: int

Definition at line 3854 of file Mysql.php.

     {
         $size = trim($size);
         $last = strtolower(substr($size, -1));
 
         switch ($last) {
             case 'k':
                 $size = intval($size) * 1024;
                 break;
             case 'm':
                 $size = intval($size) * 1024 * 1024;
                 break;
             case 'g':
                 $size = intval($size) * 1024 * 1024 * 1024;
                 break;
         }
 
         if (empty($size)) {
             return Table::DEFAULT_TEXT_SIZE;
         }
         if ($size >= Table::MAX_TEXT_SIZE) {
             return Table::MAX_TEXT_SIZE;
         }
 
         return intval($size);
     }

◆ _prepareInsertData()

_prepareInsertData	(		$row,
		&	$bind
	)

protected

Prepare insert data

Parameters

mixed	$row
array	$bind

Returns: string

Definition at line 3710 of file Mysql.php.

     {
         $row = (array)$row;
         $line = [];
         foreach ($row as $value) {
             if ($value instanceof \Zend_Db_Expr) {
                 $line[] = $value->__toString();
             } else {
                 $line[] = '?';
                 $bind[] = $value;
             }
         }
         $line = implode(', ', $line);
 
         return sprintf('(%s)', $line);
     }

◆ _prepareQuery()

_prepareQuery	(	&	$sql,
		&	$bind = `[]`
	)

protected

Prepares SQL query by moving to bind all special parameters that can be confused with bind placeholders (e.g. "foo:bar"). And also changes named bind to positional one, because underlying library has problems with named binds.

Parameters

\Magento\Framework\DB\Select \| string	$sql
mixed	$bind

Returns: $this

Definition at line 647 of file Mysql.php.

     {
         $sql = (string) $sql;
         if (!is_array($bind)) {
             $bind = [$bind];
         }
 
         // Mixed bind is not supported - so remember whether it is named bind, to normalize later if required
         $isNamedBind = false;
         if ($bind) {
             foreach ($bind as $k => $v) {
                 if (!is_int($k)) {
                     $isNamedBind = true;
                     if ($k[0] != ':') {
                         $bind[":{$k}"] = $v;
                         unset($bind[$k]);
                     }
                 }
             }
         }
 
         // Special query hook
         if ($this->_queryHook) {
             $object = $this->_queryHook['object'];
             $method = $this->_queryHook['method'];
             $object->$method($sql, $bind);
         }
 
         return $this;
     }

◆ _prepareQuotedSqlCondition()

_prepareQuotedSqlCondition	(	$text,
		$value,
		$fieldName
	)

protected

Prepare Sql condition

Parameters

string	$text	Condition value
mixed	$value
string	$fieldName

Returns: string

Definition at line 2992 of file Mysql.php.

     {
         $sql = $this->quoteInto($text, $value);
         $sql = str_replace('{{fieldName}}', $fieldName, $sql);
         return $sql;
     }

◆ _prepareSqlDateCondition()

_prepareSqlDateCondition	(	$condition,
		$key
	)

protected

Prepare sql date condition

Parameters

array	$condition
string	$key

Returns: string

Definition at line 3815 of file Mysql.php.

     {
         if (empty($condition['date'])) {
             if (empty($condition['datetime'])) {
                 $result = $condition[$key];
             } else {
                 $result = $this->formatDate($condition[$key]);
             }
         } else {
             $result = $this->formatDate($condition[$key]);
         }
 
         return $result;
     }

◆ _removeDuplicateEntry()

_removeDuplicateEntry	(	$table,
		$fields,
		$ids
	)

protected

Remove duplicate entry for create key

Parameters

string	$table
array	$fields
	string[]	$ids

Returns: $this

Definition at line 1430 of file Mysql.php.

     {
         $where = [];
         $i = 0;
         foreach ($fields as $field) {
             $where[] = $this->quoteInto($field . '=?', $ids[$i++]);
         }
 
         if (!$where) {
             return $this;
         }
         $whereCond = implode(' AND ', $where);
         $sql = sprintf('SELECT COUNT(*) as `cnt` FROM `%s` WHERE %s', $table, $whereCond);
 
         $cnt = $this->rawFetchRow($sql, 'cnt');
         if ($cnt > 1) {
             $sql = sprintf(
                 'DELETE FROM `%s` WHERE %s LIMIT %d',
                 $table,
                 $whereCond,
                 $cnt - 1
             );
             $this->rawQuery($sql);
         }
 
         return $this;
     }

◆ _splitMultiQuery()

_splitMultiQuery ( $sql )

protected

Split multi statement query

Parameters

string $sql

Returns: array @SuppressWarnings(PHPMD.CyclomaticComplexity) @SuppressWarnings(PHPMD.NPathComplexity)

Deprecated:: 100.1.2

Definition at line 800 of file Mysql.php.

     {
         $parts = preg_split(
             '#(;|\'|"|\\\\|//|--|\n|/\*|\*/)#',
             $sql,
             null,
             PREG_SPLIT_NO_EMPTY | PREG_SPLIT_DELIM_CAPTURE
         );
 
         $q      = false;
         $c      = false;
         $stmts  = [];
         $s      = '';
 
         foreach ($parts as $i => $part) {
             // strings
             if (($part === "'" || $part === '"') && ($i === 0 || $parts[$i-1] !== '\\')) {
                 if ($q === false) {
                     $q = $part;
                 } elseif ($q === $part) {
                     $q = false;
                 }
             }
 
             // single line comments
             if (($part === '//' || $part === '--') && ($i === 0 || $parts[$i-1] === "\n")) {
                 $c = $part;
             } elseif ($part === "\n" && ($c === '//' || $c === '--')) {
                 $c = false;
             }
 
             // multi line comments
             if ($part === '/*' && $c === false) {
                 $c = '/*';
             } elseif ($part === '*/' && $c === '/*') {
                 $c = false;
             }
 
             // statements
             if ($part === ';' && $q === false && $c === false) {
                 if (trim($s) !== '') {
                     $stmts[] = trim($s);
                     $s = '';
                 }
             } else {
                 $s .= $part;
             }
         }
         if (trim($s) !== '') {
             $stmts[] = trim($s);
         }
 
         return $stmts;
     }

◆ _transformStringSqlCondition()

_transformStringSqlCondition	(	$conditionKey,
		$value
	)

protected

Transforms sql condition key 'seq' / 'sneq' that is used for comparing string values to its analog:

'null' / 'notnull' for empty strings
'eq' / 'neq' for non-empty strings

Parameters

string	$conditionKey
mixed	$value

Returns: string

Definition at line 3008 of file Mysql.php.

     {
         $value = (string) $value;
         if ($value == '') {
             return ($conditionKey == 'seq') ? 'null' : 'notnull';
         } else {
             return ($conditionKey == 'seq') ? 'eq' : 'neq';
         }
     }

◆ _unQuote()

_unQuote ( $string )

protected

Unquote raw string (use for auto-bind)

Parameters

string $string

Returns: string

Definition at line 707 of file Mysql.php.

     {
         $translate = [
             "\\000" => "\000",
             "\\n"   => "\n",
             "\\r"   => "\r",
             "\\\\"  => "\\",
             "\'"    => "'",
             "\\\""  => "\"",
             "\\032" => "\032",
         ];
         return strtr($string, $translate);
     }

◆ addColumn()

addColumn	(	$tableName,
		$columnName,
		$definition,
		$schemaName = `null`
	)

Adds new column to table.

Generally $defintion must be array with column data to keep this call cross-DB compatible. Using string as $definition is allowed only for concrete DB adapter. Adds primary key if needed

Parameters

string	$tableName
string	$columnName
array \| string	$definition	string specific or universal array DB Server definition
string	$schemaName

Returns: true|\Zend_Db_Statement_Pdo

Exceptions

addForeignKey	(	$fkName,
		$tableName,
		$columnName,
		$refTableName,
		$refColumnName,
		$onDelete = `AdapterInterface::FK_ACTION_CASCADE`,
		$purge = `false`,
		$schemaName = `null`,
		$refSchemaName = `null`
	)

string	$fkName
string	$tableName
string	$columnName
string	$refTableName
string	$refColumnName
string	$onDelete
bool	$purge	trying remove invalid data
string	$schemaName
string	$refSchemaName

addIndex	(	$tableName,
		$indexName,
		$fields,
		$indexType = `AdapterInterface::INDEX_TYPE_INDEX`,
		$schemaName = `null`
	)

changeColumn	(	$tableName,
		$oldColumnName,
		$newColumnName,
		$definition,
		$flushData = `false`,
		$schemaName = `null`
	)

changeTableComment	(	$tableName,
		$comment,
		$schemaName = `null`
	)

changeTableEngine	(	$tableName,
		$engine,
		$schemaName = `null`
	)

createTemporaryTableLike	(	$temporaryTableName,
		$originTableName,
		$ifNotExists = `false`
	)

string	$temporaryTableName
string	$originTableName
bool	$ifNotExists

Select	$select
string	$table	the table name or alias used in select

dropColumn	(	$tableName,
		$columnName,
		$schemaName = `null`
	)

dropForeignKey	(	$tableName,
		$fkName,
		$schemaName = `null`
	)

getCaseSql	(	$valueName,
		$casesResults,
		$defaultValue = `null`
	)

string	$valueName	Name of value to check
array	$casesResults	Cases and results
string	$defaultValue	value to use if value doesn't confirm to any cases

\Zend_Db_Expr \| \Magento\Framework\DB\Select \| string	$expression
string	$true	true value
string	$false	false value

getColumnDefinitionFromDescribe	(	$options,
		$ddlType = `null`
	)

\Zend_Db_Expr \| string	$date	quoted field name or SQL statement
int	$interval
string	$unit

string	$date	quoted date value or non quoted SQL statement(field)
string	$format

getForeignKeyName	(	$priTableName,
		$priColumnName,
		$refTableName,
		$refColumnName
	)

string	$priTableName
string	$priColumnName
string	$refTableName
string	$refColumnName

\Zend_Db_Expr \| \Magento\Framework\DB\Select \| string	$expression
string \| int	$value	OPTIONAL. Applies when $expression is NULL

Public Member Functions

Data Fields

Protected Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

◆ __construct()

◆ __destruct()

Member Function Documentation

◆ _checkDdlTransaction()

◆ _connect()

◆ _convertMixedBind()

◆ _getCacheId()

◆ _getColumnDefinition()

◆ _getColumnsDefinition()

◆ _getColumnTypeByDdl()

◆ _getDdlAction()

◆ _getDdlType()

◆ _getForeignKeysDefinition()

◆ _getIndexByColumns()

◆ _getIndexesDefinition()

◆ _getInsertSqlQuery()

◆ _getIntervalUnitSql()

◆ _getOptionsDefinition()

◆ _getReplaceSqlQuery()

◆ _getTableName()

◆ _parseTextSize()

◆ _prepareInsertData()

◆ _prepareQuery()

◆ _prepareQuotedSqlCondition()

◆ _prepareSqlDateCondition()

◆ _removeDuplicateEntry()

◆ _splitMultiQuery()

◆ _transformStringSqlCondition()

◆ _unQuote()

◆ addColumn()

◆ addForeignKey()

◆ addIndex()

◆ allowDdlCache()

◆ beginTransaction()

◆ changeColumn()

◆ changeTableComment()

◆ changeTableEngine()

◆ commit()

◆ convertDate()

◆ convertDateTime()

◆ createTable()

◆ createTableByDdl()

◆ createTemporaryTable()

◆ createTemporaryTableLike()

◆ createTrigger()

◆ decodeVarbinary()

◆ deleteFromSelect()

◆ describeTable()

◆ disableTableKeys()

◆ disallowDdlCache()

◆ dropColumn()

◆ dropForeignKey()

◆ dropIndex()

◆ dropTable()

◆ dropTemporaryTable()

◆ dropTrigger()

◆ enableTableKeys()

◆ endSetup()

◆ formatDate()

◆ forUpdate()

◆ getAutoIncrementField()

◆ getCaseSql()

◆ getCheckSql()

◆ getColumnCreateByDescribe()

◆ getColumnDefinitionFromDescribe()

◆ getConcatSql()

◆ getCreateTable()

◆ getDateAddSql()

◆ getDateExtractSql()

◆ getDateFormatSql()

◆ getDatePartSql()

◆ getDateSubSql()

◆ getForeignKeyName()

◆ getForeignKeys()

string	$tableName
	string\|string[]	$fields the columns list
string	$indexType

\Zend_Db_Expr \| string	$stringExpression	quoted field name or SQL statement
int \| string \| \Zend_Db_Expr	$pos
int \| string \| \Zend_Db_Expr \| null	$len

array \| string	$tableNames	array of tables names \| table name
string	$schemaName	schema name

string	$tableName	The table which is the subject of the trigger
string	$time	Either "before" or "after"
string	$event	The DB level event which activates the trigger, i.e. "update" or "insert"

insertArray	(		$table,
		array	$columns,
		array	$data,
			$strategy = `0`
	)

insertFromSelect	(	Select	$select,
			$table,
		array	$fields = `[]`,
			$mode = `false`
	)

string \| array \| \Zend_Db_Expr	$table	The table to insert data into.
array	$data	Column-value pairs or array of Column-value pairs.

insertOnDuplicate	(		$table,
		array	$data,
		array	$fields = `[]`
	)

string	$tableCacheKey	the table cache key
int	$ddlType	the DDL constant

modifyColumn	(	$tableName,
		$columnName,
		$definition,
		$flushData = `false`,
		$schemaName = `null`
	)