|
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310 |
- <?php
- /**
- * @link http://www.yiiframework.com/
- * @copyright Copyright (c) 2008 Yii Software LLC
- * @license http://www.yiiframework.com/license/
- */
-
- namespace yii\db\cubrid;
-
- use yii\db\Expression;
- use yii\db\TableSchema;
- use yii\db\ColumnSchema;
- use yii\db\Transaction;
-
- /**
- * Schema is the class for retrieving metadata from a CUBRID database (version 9.3.x and higher).
- *
- * @author Carsten Brandt <mail@cebe.cc>
- * @since 2.0
- */
- class Schema extends \yii\db\Schema
- {
- /**
- * @var array mapping from physical column types (keys) to abstract column types (values)
- * Please refer to [CUBRID manual](http://www.cubrid.org/manual/91/en/sql/datatype.html) for
- * details on data types.
- */
- public $typeMap = [
- // Numeric data types
- 'short' => self::TYPE_SMALLINT,
- 'smallint' => self::TYPE_SMALLINT,
- 'int' => self::TYPE_INTEGER,
- 'integer' => self::TYPE_INTEGER,
- 'bigint' => self::TYPE_BIGINT,
- 'numeric' => self::TYPE_DECIMAL,
- 'decimal' => self::TYPE_DECIMAL,
- 'float' => self::TYPE_FLOAT,
- 'real' => self::TYPE_FLOAT,
- 'double' => self::TYPE_DOUBLE,
- 'double precision' => self::TYPE_DOUBLE,
- 'monetary' => self::TYPE_MONEY,
- // Date/Time data types
- 'date' => self::TYPE_DATE,
- 'time' => self::TYPE_TIME,
- 'timestamp' => self::TYPE_TIMESTAMP,
- 'datetime' => self::TYPE_DATETIME,
- // String data types
- 'char' => self::TYPE_CHAR,
- 'varchar' => self::TYPE_STRING,
- 'char varying' => self::TYPE_STRING,
- 'nchar' => self::TYPE_CHAR,
- 'nchar varying' => self::TYPE_STRING,
- 'string' => self::TYPE_STRING,
- // BLOB/CLOB data types
- 'blob' => self::TYPE_BINARY,
- 'clob' => self::TYPE_BINARY,
- // Bit string data types
- 'bit' => self::TYPE_INTEGER,
- 'bit varying' => self::TYPE_INTEGER,
- // Collection data types (considered strings for now)
- 'set' => self::TYPE_STRING,
- 'multiset' => self::TYPE_STRING,
- 'list' => self::TYPE_STRING,
- 'sequence' => self::TYPE_STRING,
- 'enum' => self::TYPE_STRING,
- ];
- /**
- * @var array map of DB errors and corresponding exceptions
- * If left part is found in DB error message exception class from the right part is used.
- */
- public $exceptionMap = [
- 'Operation would have caused one or more unique constraint violations' => 'yii\db\IntegrityException',
- ];
-
-
- /**
- * @inheritdoc
- */
- public function releaseSavepoint($name)
- {
- // does nothing as cubrid does not support this
- }
-
- /**
- * Quotes a table name for use in a query.
- * A simple table name has no schema prefix.
- * @param string $name table name
- * @return string the properly quoted table name
- */
- public function quoteSimpleTableName($name)
- {
- return strpos($name, '"') !== false ? $name : '"' . $name . '"';
- }
-
- /**
- * Quotes a column name for use in a query.
- * A simple column name has no prefix.
- * @param string $name column name
- * @return string the properly quoted column name
- */
- public function quoteSimpleColumnName($name)
- {
- return strpos($name, '"') !== false || $name === '*' ? $name : '"' . $name . '"';
- }
-
- /**
- * Creates a query builder for the CUBRID database.
- * @return QueryBuilder query builder instance
- */
- public function createQueryBuilder()
- {
- return new QueryBuilder($this->db);
- }
-
- /**
- * Loads the metadata for the specified table.
- * @param string $name table name
- * @return TableSchema driver dependent table metadata. Null if the table does not exist.
- */
- protected function loadTableSchema($name)
- {
- $pdo = $this->db->getSlavePdo();
-
- $tableInfo = $pdo->cubrid_schema(\PDO::CUBRID_SCH_TABLE, $name);
-
- if (!isset($tableInfo[0]['NAME'])) {
- return null;
- }
-
- $table = new TableSchema();
- $table->fullName = $table->name = $tableInfo[0]['NAME'];
-
- $sql = 'SHOW FULL COLUMNS FROM ' . $this->quoteSimpleTableName($table->name);
- $columns = $this->db->createCommand($sql)->queryAll();
-
- foreach ($columns as $info) {
- $column = $this->loadColumnSchema($info);
- $table->columns[$column->name] = $column;
- }
-
- $primaryKeys = $pdo->cubrid_schema(\PDO::CUBRID_SCH_PRIMARY_KEY, $table->name);
- foreach ($primaryKeys as $key) {
- $column = $table->columns[$key['ATTR_NAME']];
- $column->isPrimaryKey = true;
- $table->primaryKey[] = $column->name;
- if ($column->autoIncrement) {
- $table->sequenceName = '';
- }
- }
-
- $foreignKeys = $pdo->cubrid_schema(\PDO::CUBRID_SCH_IMPORTED_KEYS, $table->name);
- foreach ($foreignKeys as $key) {
- if (isset($table->foreignKeys[$key['FK_NAME']])) {
- $table->foreignKeys[$key['FK_NAME']][$key['FKCOLUMN_NAME']] = $key['PKCOLUMN_NAME'];
- } else {
- $table->foreignKeys[$key['FK_NAME']] = [
- $key['PKTABLE_NAME'],
- $key['FKCOLUMN_NAME'] => $key['PKCOLUMN_NAME'],
- ];
- }
- }
- $table->foreignKeys = array_values($table->foreignKeys);
-
- return $table;
- }
-
- /**
- * Loads the column information into a [[ColumnSchema]] object.
- * @param array $info column information
- * @return ColumnSchema the column schema object
- */
- protected function loadColumnSchema($info)
- {
- $column = $this->createColumnSchema();
-
- $column->name = $info['Field'];
- $column->allowNull = $info['Null'] === 'YES';
- $column->isPrimaryKey = false; // primary key will be set by loadTableSchema() later
- $column->autoIncrement = stripos($info['Extra'], 'auto_increment') !== false;
-
- $column->dbType = $info['Type'];
- $column->unsigned = strpos($column->dbType, 'unsigned') !== false;
-
- $column->type = self::TYPE_STRING;
- if (preg_match('/^([\w ]+)(?:\(([^\)]+)\))?$/', $column->dbType, $matches)) {
- $type = strtolower($matches[1]);
- $column->dbType = $type . (isset($matches[2]) ? "({$matches[2]})" : '');
- if (isset($this->typeMap[$type])) {
- $column->type = $this->typeMap[$type];
- }
- if (!empty($matches[2])) {
- if ($type === 'enum') {
- $values = preg_split('/\s*,\s*/', $matches[2]);
- foreach ($values as $i => $value) {
- $values[$i] = trim($value, "'");
- }
- $column->enumValues = $values;
- } else {
- $values = explode(',', $matches[2]);
- $column->size = $column->precision = (int) $values[0];
- if (isset($values[1])) {
- $column->scale = (int) $values[1];
- }
- if ($column->size === 1 && $type === 'bit') {
- $column->type = 'boolean';
- } elseif ($type === 'bit') {
- if ($column->size > 32) {
- $column->type = 'bigint';
- } elseif ($column->size === 32) {
- $column->type = 'integer';
- }
- }
- }
- }
- }
-
- $column->phpType = $this->getColumnPhpType($column);
-
- if ($column->isPrimaryKey) {
- return $column;
- }
-
- if ($column->type === 'timestamp' && $info['Default'] === 'SYS_TIMESTAMP' ||
- $column->type === 'datetime' && $info['Default'] === 'SYS_DATETIME' ||
- $column->type === 'date' && $info['Default'] === 'SYS_DATE' ||
- $column->type === 'time' && $info['Default'] === 'SYS_TIME'
- ) {
- $column->defaultValue = new Expression($info['Default']);
- } elseif (isset($type) && $type === 'bit') {
- $column->defaultValue = hexdec(trim($info['Default'], 'X\''));
- } else {
- $column->defaultValue = $column->phpTypecast($info['Default']);
- }
-
- return $column;
- }
-
- /**
- * Returns all table names in the database.
- * @param string $schema the schema of the tables. Defaults to empty string, meaning the current or default schema.
- * @return array all table names in the database. The names have NO schema name prefix.
- */
- protected function findTableNames($schema = '')
- {
- $pdo = $this->db->getSlavePdo();
- $tables = $pdo->cubrid_schema(\PDO::CUBRID_SCH_TABLE);
- $tableNames = [];
- foreach ($tables as $table) {
- // do not list system tables
- if ($table['TYPE'] != 0) {
- $tableNames[] = $table['NAME'];
- }
- }
-
- return $tableNames;
- }
-
- /**
- * Determines the PDO type for the given PHP data value.
- * @param mixed $data the data whose PDO type is to be determined
- * @return integer the PDO type
- * @see http://www.php.net/manual/en/pdo.constants.php
- */
- public function getPdoType($data)
- {
- static $typeMap = [
- // php type => PDO type
- 'boolean' => \PDO::PARAM_INT, // PARAM_BOOL is not supported by CUBRID PDO
- 'integer' => \PDO::PARAM_INT,
- 'string' => \PDO::PARAM_STR,
- 'resource' => \PDO::PARAM_LOB,
- 'NULL' => \PDO::PARAM_NULL,
- ];
- $type = gettype($data);
-
- return isset($typeMap[$type]) ? $typeMap[$type] : \PDO::PARAM_STR;
- }
-
- /**
- * @inheritdoc
- * @see http://www.cubrid.org/manual/91/en/sql/transaction.html#database-concurrency
- */
- public function setTransactionIsolationLevel($level)
- {
- // translate SQL92 levels to CUBRID levels:
- switch ($level) {
- case Transaction::SERIALIZABLE:
- $level = '6'; // SERIALIZABLE
- break;
- case Transaction::REPEATABLE_READ:
- $level = '5'; // REPEATABLE READ CLASS with REPEATABLE READ INSTANCES
- break;
- case Transaction::READ_COMMITTED:
- $level = '4'; // REPEATABLE READ CLASS with READ COMMITTED INSTANCES
- break;
- case Transaction::READ_UNCOMMITTED:
- $level = '3'; // REPEATABLE READ CLASS with READ UNCOMMITTED INSTANCES
- break;
- }
- parent::setTransactionIsolationLevel($level);
- }
-
- /**
- * @inheritdoc
- */
- public function createColumnSchemaBuilder($type, $length = null)
- {
- return new ColumnSchemaBuilder($type, $length, $this->db);
- }
- }
|