diff options
author | rojaro <> | 2009-07-15 07:58:26 +0000 |
---|---|---|
committer | rojaro <> | 2009-07-15 07:58:26 +0000 |
commit | f1c27f46100582a1e52a27b616bf468e849068e7 (patch) | |
tree | 2d9a569495b67c57302c483b37beb81c5a9800b8 /framework/Db/Schema/pgsql | |
parent | 2ecfe49532dbfc53d75a32e68df643b7af13dc1f (diff) |
moved System.Db to System.Testing.Data and updated classes accordingly
Diffstat (limited to 'framework/Db/Schema/pgsql')
-rwxr-xr-x | framework/Db/Schema/pgsql/TPgsqlColumnSchema.php | 58 | ||||
-rwxr-xr-x | framework/Db/Schema/pgsql/TPgsqlSchema.php | 284 | ||||
-rwxr-xr-x | framework/Db/Schema/pgsql/TPgsqlTableSchema.php | 27 |
3 files changed, 0 insertions, 369 deletions
diff --git a/framework/Db/Schema/pgsql/TPgsqlColumnSchema.php b/framework/Db/Schema/pgsql/TPgsqlColumnSchema.php deleted file mode 100755 index 3677cd44..00000000 --- a/framework/Db/Schema/pgsql/TPgsqlColumnSchema.php +++ /dev/null @@ -1,58 +0,0 @@ -<?php -/** - * TPgsqlColumnSchema class file. - * - * @author Qiang Xue <qiang.xue@gmail.com> - * @link http://www.yiiframework.com/ - * @copyright Copyright © 2008-2009 Yii Software LLC - * @license http://www.yiiframework.com/license/ - */ - -prado::using('System.Db.Schema.TDbColumnSchema'); - -/** - * TPgsqlColumnSchema class describes the column meta data of a PostgreSQL table. - * - * @author Qiang Xue <qiang.xue@gmail.com> - * @version $Id: TPgsqlColumnSchema.php 2679 2009-06-15 07:49:42Z Christophe.Boulain $ - * @package System.Db.Schema.pgsql - * @since 1.0 - */ -class TPgsqlColumnSchema extends TDbColumnSchema -{ - /** - * Extracts the PHP type from DB type. - * @param string DB type - */ - protected function extractType($dbType) - { - if(strpos($dbType,'integer')!==false || strpos($dbType,'oid')===0) - $this->type='integer'; - else if(strpos($dbType,'bool')!==false) - $this->type='boolean'; - else if(preg_match('/(real|float|double)/',$dbType)) - $this->type='double'; - else - $this->type='string'; - } - - /** - * Extracts the default value for the column. - * The value is typecasted to correct PHP type. - * @param mixed the default value obtained from metadata - */ - protected function extractDefault($defaultValue) - { - if($defaultValue==='true') - $this->defaultValue=true; - else if($defaultValue==='false') - $this->defaultValue=false; - else if(strpos($defaultValue,'nextval')===0) - $this->defaultValue=null; - else if(preg_match('/\'(.*)\'::/',$defaultValue,$matches)) - $this->defaultValue=$this->typecast(str_replace("''","'",$matches[1])); - else if(preg_match('/^-?\d+(\.\d*)?$/',$defaultValue,$matches)) - $this->defaultValue=$this->typecast($defaultValue); - // else is null - } -} diff --git a/framework/Db/Schema/pgsql/TPgsqlSchema.php b/framework/Db/Schema/pgsql/TPgsqlSchema.php deleted file mode 100755 index 5f009208..00000000 --- a/framework/Db/Schema/pgsql/TPgsqlSchema.php +++ /dev/null @@ -1,284 +0,0 @@ -<?php -/** - * TPgsqlSchema class file. - * - * @author Qiang Xue <qiang.xue@gmail.com> - * @link http://www.yiiframework.com/ - * @copyright Copyright © 2008-2009 Yii Software LLC - * @license http://www.yiiframework.com/license/ - */ - -prado::using('System.Db.Schema.TDbSchema'); - -/** - * TPgsqlSchema is the class for retrieving metadata information from a PostgreSQL database. - * - * @author Qiang Xue <qiang.xue@gmail.com> - * @version $Id: TPgsqlSchema.php 2679 2009-06-15 07:49:42Z Christophe.Boulain $ - * @package System.Db.Schema.pgsql - * @since 1.0 - */ -class TPgsqlSchema extends TDbSchema -{ - const DEFAULT_SCHEMA='public'; - private $_sequences=array(); - - /** - * Quotes a table name for use in a query. - * @param string table name - * @return string the properly quoted table name - */ - public function quoteTableName($name) - { - return '"'.$name.'"'; - } - - /** - * Creates a table instance representing the metadata for the named table. - * @return TDbTableSchema driver dependent table metadata. - */ - protected function createTable($name) - { - $table=new TPgsqlTableSchema; - $this->resolveTableNames($table,$name); - if(!$this->findColumns($table)) - return null; - $this->findConstraints($table); - - if(is_string($table->primaryKey) && isset($this->_sequences[$table->primaryKey])) - $table->sequenceName=$this->_sequences[$table->primaryKey]; - - return $table; - } - - /** - * Generates various kinds of table names. - * @param TPgsqlTableSchema the table instance - * @param string the unquoted table name - */ - protected function resolveTableNames($table,$name) - { - $parts=explode('.',str_replace('"','',$name)); - if(isset($parts[1])) - { - $schemaName=$parts[0]; - $tableName=$parts[1]; - } - else - { - $schemaName=self::DEFAULT_SCHEMA; - $tableName=$parts[0]; - } - - $table->name=$tableName; - $table->schemaName=$schemaName; - if($schemaName===self::DEFAULT_SCHEMA) - $table->rawName=$this->quoteTableName($tableName); - else - $table->rawName=$this->quoteTableName($schemaName).'.'.$this->quoteTableName($tableName); - } - - /** - * Collects the table column metadata. - * @param TPgsqlTableSchema the table metadata - * @return boolean whether the table exists in the database - */ - protected function findColumns($table) - { - $sql=<<<EOD -SELECT a.attname, LOWER(format_type(a.atttypid, a.atttypmod)) AS type, d.adsrc, a.attnotnull, a.atthasdef -FROM pg_attribute a LEFT JOIN pg_attrdef d ON a.attrelid = d.adrelid AND a.attnum = d.adnum -WHERE a.attnum > 0 AND NOT a.attisdropped - AND a.attrelid = (SELECT oid FROM pg_catalog.pg_class WHERE relname=:table - AND relnamespace = (SELECT oid FROM pg_catalog.pg_namespace WHERE nspname = :schema)) -ORDER BY a.attnum -EOD; - $command=$this->getDbConnection()->createCommand($sql); - $command->bindValue(':table',$table->name); - $command->bindValue(':schema',$table->schemaName); - - if(($columns=$command->queryAll())===array()) - return false; - - foreach($columns as $column) - { - $c=$this->createColumn($column); - $table->columns[$c->name]=$c; - - if(stripos($column['adsrc'],'nextval')===0 && preg_match('/nextval\([^\']*\'([^\']+)\'[^\)]*\)/i',$column['adsrc'],$matches)) - { - if(strpos($matches[1],'.')!==false || $table->schemaName===self::DEFAULT_SCHEMA) - $this->_sequences[$c->name]=$matches[1]; - else - $this->_sequences[$c->name]=$table->schemaName.'.'.$matches[1]; - } - } - return true; - } - - /** - * Creates a table column. - * @param array column metadata - * @return TDbColumnSchema normalized column metadata - */ - protected function createColumn($column) - { - $c=new TPgsqlColumnSchema; - $c->name=$column['attname']; - $c->rawName=$this->quoteColumnName($c->name); - $c->allowNull=!$column['attnotnull']; - $c->isPrimaryKey=false; - $c->isForeignKey=false; - - $c->init($column['type'],$column['atthasdef'] ? $column['adsrc'] : null); - - return $c; - } - - /** - * Collects the primary and foreign key column details for the given table. - * @param TPgsqlTableSchema the table metadata - */ - protected function findConstraints($table) - { - $sql=<<<EOD -SELECT conname, consrc, contype, indkey FROM ( - SELECT - conname, - CASE WHEN contype='f' THEN - pg_catalog.pg_get_constraintdef(oid) - ELSE - 'CHECK (' || consrc || ')' - END AS consrc, - contype, - conrelid AS relid, - NULL AS indkey - FROM - pg_catalog.pg_constraint - WHERE - contype IN ('f', 'c') - UNION ALL - SELECT - pc.relname, - NULL, - CASE WHEN indisprimary THEN - 'p' - ELSE - 'u' - END, - pi.indrelid, - indkey - FROM - pg_catalog.pg_class pc, - pg_catalog.pg_index pi - WHERE - pc.oid=pi.indexrelid - AND EXISTS ( - SELECT 1 FROM pg_catalog.pg_depend d JOIN pg_catalog.pg_constraint c - ON (d.refclassid = c.tableoid AND d.refobjid = c.oid) - WHERE d.classid = pc.tableoid AND d.objid = pc.oid AND d.deptype = 'i' AND c.contype IN ('u', 'p') - ) -) AS sub -WHERE relid = (SELECT oid FROM pg_catalog.pg_class WHERE relname=:table - AND relnamespace = (SELECT oid FROM pg_catalog.pg_namespace - WHERE nspname=:schema)) -EOD; - $command=$this->getDbConnection()->createCommand($sql); - $command->bindValue(':table',$table->name); - $command->bindValue(':schema',$table->schemaName); - foreach($command->queryAll() as $row) - { - if($row['contype']==='p') // primary key - $this->findPrimaryKey($table,$row['indkey']); - else if($row['contype']==='f') // foreign key - $this->findForeignKey($table,$row['consrc']); - } - } - - /** - * Collects primary key information. - * @param TPgsqlTableSchema the table metadata - * @param string pgsql primary key index list - */ - protected function findPrimaryKey($table,$indices) - { - $indices=implode(', ',preg_split('/\s+/',$indices)); - $sql=<<<EOD -SELECT attnum, attname FROM pg_catalog.pg_attribute WHERE - attrelid=( - SELECT oid FROM pg_catalog.pg_class WHERE relname=:table AND relnamespace=( - SELECT oid FROM pg_catalog.pg_namespace WHERE nspname=:schema - ) - ) - AND attnum IN ({$indices}) -EOD; - $command=$this->getDbConnection()->createCommand($sql); - $command->bindValue(':table',$table->name); - $command->bindValue(':schema',$table->schemaName); - foreach($command->queryAll() as $row) - { - $name=$row['attname']; - if(isset($table->columns[$name])) - { - $table->columns[$name]->isPrimaryKey=true; - if($table->primaryKey===null) - $table->primaryKey=$name; - else if(is_string($table->primaryKey)) - $table->primaryKey=array($table->primaryKey,$name); - else - $table->primaryKey[]=$name; - } - } - } - - /** - * Collects foreign key information. - * @param TPgsqlTableSchema the table metadata - * @param string pgsql foreign key definition - */ - protected function findForeignKey($table,$src) - { - $matches=array(); - $brackets='\(([^\)]+)\)'; - $pattern="/FOREIGN\s+KEY\s+{$brackets}\s+REFERENCES\s+([^\(]+){$brackets}/i"; - if(preg_match($pattern,str_replace('"','',$src),$matches)) - { - $keys=preg_split('/,\s+/', $matches[1]); - $tableName=$matches[2]; - $fkeys=preg_split('/,\s+/', $matches[3]); - foreach($keys as $i=>$key) - { - $table->foreignKeys[$key]=array($tableName,$fkeys[$i]); - if(isset($table->columns[$key])) - $table->columns[$key]->isForeignKey=true; - } - } - } - - /** - * Returns all table names in the database. - * @return array all table names in the database. - * @since 1.0.2 - */ - protected function findTableNames($schema='') - { - if($schema==='') - $schema=self::DEFAULT_SCHEMA; - $sql=<<<EOD -SELECT table_name, table_schema FROM information_schema.tables -WHERE table_schema=:schema -EOD; - $command=$this->getDbConnection()->createCommand($sql); - $command->bindParam(':schema',$schema); - $rows=$command->queryAll(); - $names=array(); - foreach($rows as $row) - { - if($schema===self::DEFAULT_SCHEMA) - $names[]=$row['table_name']; - else - $names[]=$row['schema_name'].'.'.$row['table_name']; - } - return $names; - } -} diff --git a/framework/Db/Schema/pgsql/TPgsqlTableSchema.php b/framework/Db/Schema/pgsql/TPgsqlTableSchema.php deleted file mode 100755 index 9c14da28..00000000 --- a/framework/Db/Schema/pgsql/TPgsqlTableSchema.php +++ /dev/null @@ -1,27 +0,0 @@ -<?php -/** - * TPgsqlTable class file. - * - * @author Qiang Xue <qiang.xue@gmail.com> - * @link http://www.yiiframework.com/ - * @copyright Copyright © 2008-2009 Yii Software LLC - * @license http://www.yiiframework.com/license/ - */ - -prado::using('System.Db.Schema.TDbTableSchema'); - -/** - * TPgsqlTable represents the metadata for a PostgreSQL table. - * - * @author Qiang Xue <qiang.xue@gmail.com> - * @version $Id: TPgsqlTableSchema.php 2679 2009-06-15 07:49:42Z Christophe.Boulain $ - * @package System.Db.Schema.pgsql - * @since 1.0 - */ -class TPgsqlTableSchema extends TDbTableSchema -{ - /** - * @var string name of the schema that this table belongs to. - */ - public $schemaName; -} |