|
- <?php
-
-
- namespace yii\db\mysql;
-
- use yii\base\InvalidParamException;
- use yii\db\Exception;
- use yii\db\Expression;
-
-
- class QueryBuilder extends \yii\db\QueryBuilder
- {
-
-
- public $typeMap = [
- Schema::TYPE_PK => 'int(11) NOT NULL AUTO_INCREMENT PRIMARY KEY',
- Schema::TYPE_UPK => 'int(10) UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY',
- Schema::TYPE_BIGPK => 'bigint(20) NOT NULL AUTO_INCREMENT PRIMARY KEY',
- Schema::TYPE_UBIGPK => 'bigint(20) UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY',
- Schema::TYPE_CHAR => 'char(1)',
- Schema::TYPE_STRING => 'varchar(255)',
- Schema::TYPE_TEXT => 'text',
- Schema::TYPE_SMALLINT => 'smallint(6)',
- Schema::TYPE_INTEGER => 'int(11)',
- Schema::TYPE_BIGINT => 'bigint(20)',
- Schema::TYPE_FLOAT => 'float',
- Schema::TYPE_DOUBLE => 'double',
- Schema::TYPE_DECIMAL => 'decimal(10,0)',
- Schema::TYPE_DATETIME => 'datetime',
- Schema::TYPE_TIMESTAMP => 'timestamp',
- Schema::TYPE_TIME => 'time',
- Schema::TYPE_DATE => 'date',
- Schema::TYPE_BINARY => 'blob',
- Schema::TYPE_BOOLEAN => 'tinyint(1)',
- Schema::TYPE_MONEY => 'decimal(19,4)',
- ];
-
-
-
-
- public function renameColumn($table, $oldName, $newName)
- {
- $quotedTable = $this->db->quoteTableName($table);
- $row = $this->db->createCommand('SHOW CREATE TABLE ' . $quotedTable)->queryOne();
- if ($row === false) {
- throw new Exception("Unable to find column '$oldName' in table '$table'.");
- }
- if (isset($row['Create Table'])) {
- $sql = $row['Create Table'];
- } else {
- $row = array_values($row);
- $sql = $row[1];
- }
- if (preg_match_all('/^\s*`(.*?)`\s+(.*?),?$/m', $sql, $matches)) {
- foreach ($matches[1] as $i => $c) {
- if ($c === $oldName) {
- return "ALTER TABLE $quotedTable CHANGE "
- . $this->db->quoteColumnName($oldName) . ' '
- . $this->db->quoteColumnName($newName) . ' '
- . $matches[2][$i];
- }
- }
- }
-
- return "ALTER TABLE $quotedTable CHANGE "
- . $this->db->quoteColumnName($oldName) . ' '
- . $this->db->quoteColumnName($newName);
- }
-
-
-
- public function createIndex($name, $table, $columns, $unique = false)
- {
- return 'ALTER TABLE '
- . $this->db->quoteTableName($table)
- . ($unique ? ' ADD UNIQUE INDEX ' : ' ADD INDEX ')
- . $this->db->quoteTableName($name)
- . ' (' . $this->buildColumns($columns) . ')';
- }
-
-
-
- public function dropForeignKey($name, $table)
- {
- return 'ALTER TABLE ' . $this->db->quoteTableName($table)
- . ' DROP FOREIGN KEY ' . $this->db->quoteColumnName($name);
- }
-
-
-
- public function dropPrimaryKey($name, $table)
- {
- return 'ALTER TABLE ' . $this->db->quoteTableName($table) . ' DROP PRIMARY KEY';
- }
-
-
-
- public function resetSequence($tableName, $value = null)
- {
- $table = $this->db->getTableSchema($tableName);
- if ($table !== null && $table->sequenceName !== null) {
- $tableName = $this->db->quoteTableName($tableName);
- if ($value === null) {
- $key = reset($table->primaryKey);
- $value = $this->db->createCommand("SELECT MAX(`$key`) FROM $tableName")->queryScalar() + 1;
- } else {
- $value = (int) $value;
- }
-
- return "ALTER TABLE $tableName AUTO_INCREMENT=$value";
- } elseif ($table === null) {
- throw new InvalidParamException("Table not found: $tableName");
- } else {
- throw new InvalidParamException("There is no sequence associated with table '$tableName'.");
- }
- }
-
-
-
- public function checkIntegrity($check = true, $schema = '', $table = '')
- {
- return 'SET FOREIGN_KEY_CHECKS = ' . ($check ? 1 : 0);
- }
-
-
-
- public function buildLimit($limit, $offset)
- {
- $sql = '';
- if ($this->hasLimit($limit)) {
- $sql = 'LIMIT ' . $limit;
- if ($this->hasOffset($offset)) {
- $sql .= ' OFFSET ' . $offset;
- }
- } elseif ($this->hasOffset($offset)) {
-
-
-
- $sql = "LIMIT $offset, 18446744073709551615";
- }
-
- return $sql;
- }
-
-
-
- public function insert($table, $columns, &$params)
- {
- $schema = $this->db->getSchema();
- if (($tableSchema = $schema->getTableSchema($table)) !== null) {
- $columnSchemas = $tableSchema->columns;
- } else {
- $columnSchemas = [];
- }
- $names = [];
- $placeholders = [];
- foreach ($columns as $name => $value) {
- $names[] = $schema->quoteColumnName($name);
- if ($value instanceof Expression) {
- $placeholders[] = $value->expression;
- foreach ($value->params as $n => $v) {
- $params[$n] = $v;
- }
- } else {
- $phName = self::PARAM_PREFIX . count($params);
- $placeholders[] = $phName;
- $params[$phName] = !is_array($value) && isset($columnSchemas[$name]) ? $columnSchemas[$name]->dbTypecast($value) : $value;
- }
- }
- if (empty($names) && $tableSchema !== null) {
- $columns = !empty($tableSchema->primaryKey) ? $tableSchema->primaryKey : [reset($tableSchema->columns)->name];
- foreach ($columns as $name) {
- $names[] = $schema->quoteColumnName($name);
- $placeholders[] = 'DEFAULT';
- }
- }
-
- return 'INSERT INTO ' . $schema->quoteTableName($table)
- . (!empty($names) ? ' (' . implode(', ', $names) . ')' : '')
- . (!empty($placeholders) ? ' VALUES (' . implode(', ', $placeholders) . ')' : ' DEFAULT VALUES');
- }
-
-
-
- public function addCommentOnColumn($table, $column, $comment)
- {
- $definition = $this->getColumnDefinition($table, $column);
- $definition = trim(preg_replace("/COMMENT '(.*?)'/i", '', $definition));
-
- return 'ALTER TABLE ' . $this->db->quoteTableName($table)
- . ' CHANGE ' . $this->db->quoteColumnName($column)
- . ' ' . $this->db->quoteColumnName($column)
- . (empty($definition) ? '' : ' ' . $definition)
- . ' COMMENT ' . $this->db->quoteValue($comment);
- }
-
-
-
- public function addCommentOnTable($table, $comment)
- {
- return 'ALTER TABLE ' . $this->db->quoteTableName($table) . ' COMMENT ' . $this->db->quoteValue($comment);
- }
-
-
-
- public function dropCommentFromColumn($table, $column)
- {
- return $this->addCommentOnColumn($table, $column, '');
- }
-
-
-
- public function dropCommentFromTable($table)
- {
- return $this->addCommentOnTable($table, '');
- }
-
-
-
-
- private function getColumnDefinition($table, $column)
- {
- $quotedTable = $this->db->quoteTableName($table);
- $row = $this->db->createCommand('SHOW CREATE TABLE ' . $quotedTable)->queryOne();
- if ($row === false) {
- throw new Exception("Unable to find column '$column' in table '$table'.");
- }
- if (isset($row['Create Table'])) {
- $sql = $row['Create Table'];
- } else {
- $row = array_values($row);
- $sql = $row[1];
- }
- if (preg_match_all('/^\s*`(.*?)`\s+(.*?),?$/m', $sql, $matches)) {
- foreach ($matches[1] as $i => $c) {
- if ($c === $column) {
- return $matches[2][$i];
- }
- }
- }
- return null;
- }
- }
|