Error202
/
yii2-swiftmailer
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

clean up oci driver.

tags/2.0.0-beta
Qiang Xue 12 years ago
parent
7eabab0629
commit
8b375c3580
3 changed files with 320 additions and 444 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 92
      framework/yii/db/oci/ColumnSchema.php
  2. 179
      framework/yii/db/oci/QueryBuilder.php
  3. 493
      framework/yii/db/oci/Schema.php

92
framework/yii/db/oci/ColumnSchema.php
Unescape View File

@ -1,92 +0,0 @@
<?php
namespace yii\db\oci;
class ColumnSchema extends \yii\db\ColumnSchema
{
/**
* Initializes the column with its DB type and default value.
* This sets up the column's PHP type, size, precision, scale as well as default value.
*
* @param string $dbType
* the column's DB type
* @param mixed $defaultValue
* the default value
*/
public function extract($dbType, $defaultValue)
{
$this->dbType = $dbType;
$this->extractType($dbType);
$this->extractLimit($dbType);
if ($defaultValue !== null)
$this->extractDefault($defaultValue);
}
/**
* Extracts the PHP type from DB type.
*
* @param string $dbType
* DB type
* @return string
*/
protected function extractOraType($dbType)
{
if (strpos($dbType, 'FLOAT') !== false)
return 'double';
if (strpos($dbType, 'NUMBER') !== false || strpos($dbType, 'INTEGER') !== false) {
if (strpos($dbType, '(') && preg_match('/\((.*)\)/', $dbType, $matches)) {
$values = explode(',', $matches[1]);
if (isset($values[1]) and (((int) $values[1]) > 0))
return 'double';
else
return 'integer';
} else
return 'double';
} else
return 'string';
}
/**
* Extracts the PHP type from DB type.
*
* @param string $dbType
* DB type
*/
protected function extractType($dbType)
{
$this->type = $this->extractOraType($dbType);
}
/**
* Extracts size, precision and scale information from column's DB type.
*
* @param string $dbType
* the column's DB type
*/
protected function extractLimit($dbType)
{
if (strpos($dbType, '(') && preg_match('/\((.*)\)/', $dbType, $matches)) {
$values = explode(',', $matches[1]);
$this->size = $this->precision = (int) $values[0];
if (isset($values[1]))
$this->scale = (int) $values[1];
}
}
/**
* Extracts the default value for the column.
* The value is typecasted to correct PHP type.
*
* @param mixed $defaultValue
* the default value obtained from metadata
*/
protected function extractDefault($defaultValue)
{
if (stripos($defaultValue, 'timestamp') !== false) {
$this->defaultValue = null;
} else {
$this->defaultValue = $this->typecast($defaultValue);
}
}
}

179
framework/yii/db/oci/QueryBuilder.php
Unescape View File

@ -1,78 +1,137 @@
<?php <?php
/**
* @link http://www.yiiframework.com/
* @copyright Copyright (c) 2008 Yii Software LLC
* @license http://www.yiiframework.com/license/
*/
namespace yii\db\oci; namespace yii\db\oci;
use yii\db\Exception;
use yii\base\InvalidParamException; use yii\base\InvalidParamException;
/** /**
* QueryBuilder is the query builder for Oracle databases. * QueryBuilder is the query builder for Oracle databases.
* *
*/ */
class QueryBuilder extends \yii\db\QueryBuilder class QueryBuilder extends \yii\db\QueryBuilder
{ {
private $sql; private $sql;
public function build($query) public function build($query)
{ {
// var_dump($query);exit; // var_dump($query);exit;
$params = $query->params; $params = $query->params;
$clauses = [ $clauses = [
$this->buildSelect ( $query->select, $query->distinct, $query->selectOption ), $this->buildSelect($query->select, $query->distinct, $query->selectOption),
$this->buildFrom ( $query->from ), $this->buildFrom($query->from),
$this->buildJoin ( $query->join, $params ), $this->buildJoin($query->join, $params),
$this->buildWhere ( $query->where, $params ), $this->buildWhere($query->where, $params),
$this->buildGroupBy ( $query->groupBy ), $this->buildGroupBy($query->groupBy),
$this->buildHaving ( $query->having, $params ), $this->buildHaving($query->having, $params),
$this->buildUnion ( $query->union, $params ), $this->buildUnion($query->union, $params),
$this->buildOrderBy ( $query->orderBy ) $this->buildOrderBy($query->orderBy),
// $this->buildLimit($query->limit, $query->offset), ];
$this->sql = implode($this->separator, array_filter($clauses));
;
// var_dump( [implode($this->separator, array_filter($clauses)), $params]);exit; if ($query->limit !== null || $query->offset !== null) {
$this->sql = implode($this->separator, array_filter($clauses)); $this->sql = $this->buildLimit($query->limit, $query->offset);
}
if (! is_null($query->limit) && ! is_null($query->offset)) { return [$this->sql, $params];
$this->sql = $this->buildLimit($query->limit, $query->offset); }
}
return [ public function buildLimit($limit, $offset)
$this->sql, {
$params if (($limit < 0) && ($offset < 0)) {
]; return $this->sql;
// return [implode($this->separator, array_filter($clauses)), $params]; }
} $filters = array();
if ($offset > 0) {
public function buildLimit($limit, $offset) $filters[] = 'rowNumId > ' . (int)$offset;
{ }
// var_dump($limit >= 0);
// var_dump($offset);exit; if ($limit >= 0) {
// var_dump($limit, $offset); $filters[] = 'rownum <= ' . (int)$limit;
if (($limit < 0) && ($offset < 0)) { }
return $this->sql;
} if (count($filters) > 0) {
$filters = array(); $filter = implode(' and ', $filters);
if ($offset > 0) { $filter = " WHERE " . $filter;
$filters[] = 'rowNumId > ' . (int) $offset; } else {
} $filter = '';
}
if ($limit >= 0) {
$filters[] = 'rownum <= ' . (int) $limit; $sql = <<<EOD
}
if (count($filters) > 0) {
$filter = implode(' and ', $filters);
$filter = " WHERE " . $filter;
} else {
$filter = '';
}
$sql = <<<EOD
WITH USER_SQL AS ({$this->sql}), WITH USER_SQL AS ({$this->sql}),
PAGINATION AS (SELECT USER_SQL.*, rownum as rowNumId FROM USER_SQL) PAGINATION AS (SELECT USER_SQL.*, rownum as rowNumId FROM USER_SQL)
SELECT * SELECT *
FROM PAGINATION FROM PAGINATION
{$filter} {$filter}
EOD; EOD;
return $sql; return $sql;
} }
/**
* Builds a SQL statement for renaming a DB table.
*
* @param string $table the table to be renamed. The name will be properly quoted by the method.
* @param string $newName the new table name. The name will be properly quoted by the method.
* @return string the SQL statement for renaming a DB table.
*/
public function renameTable($table, $newName)
{
return 'ALTER TABLE ' . $this->db->quoteTableName($table) . ' RENAME TO ' . $this->db->quoteTableName($newName);
}
/**
* Builds a SQL statement for changing the definition of a column.
*
* @param string $table the table whose column is to be changed. The table name will be properly quoted by the method.
* @param string $column the name of the column to be changed. The name will be properly quoted by the method.
* @param string $type the new column type. The {@link getColumnType} method will be invoked to convert abstract column type (if any)
* into the physical one. Anything that is not recognized as abstract type will be kept in the generated SQL.
* For example, 'string' will be turned into 'varchar(255)', while 'string not null' will become 'varchar(255) not null'.
* @return string the SQL statement for changing the definition of a column.
*/
public function alterColumn($table, $column, $type)
{
$type = $this->getColumnType($type);
return 'ALTER TABLE ' . $this->db->quoteTableName($table) . ' MODIFY ' . $this->db->quoteColumnName($column) . ' ' . $this->getColumnType($type);
}
/**
* Builds a SQL statement for dropping an index.
*
* @param string $name the name of the index to be dropped. The name will be properly quoted by the method.
* @param string $table the table whose index is to be dropped. The name will be properly quoted by the method.
* @return string the SQL statement for dropping an index.
*/
public function dropIndex($name, $table)
{
return 'DROP INDEX ' . $this->db->quoteTableName($name);
}
/**
* @inheritdoc
*/
public function resetSequence($table, $value = null)
{
$tableSchema = $this->db->getTableSchema($table);
if ($tableSchema === null) {
throw new InvalidParamException("Unknown table: $table");
}
if ($tableSchema->sequenceName === null) {
return '';
}
if ($value !== null) {
$value = (int)$value;
} else {
$value = (int)$this->db->createCommand("SELECT MAX(\"{$tableSchema->primaryKey}\") FROM \"{$tableSchema->name}\"")->queryScalar();
$value++;
}
return "DROP SEQUENCE \"{$tableSchema->name}_SEQ\";"
. "CREATE SEQUENCE \"{$tableSchema->name}_SEQ\" START WITH {$value} INCREMENT BY 1 NOMAXVALUE NOCACHE";
}
} }

493
framework/yii/db/oci/Schema.php
Unescape View File

@ -1,137 +1,115 @@
<?php <?php
/**
* @link http://www.yiiframework.com/
* @copyright Copyright (c) 2008 Yii Software LLC
* @license http://www.yiiframework.com/license/
*/
namespace yii\db\oci; namespace yii\db\oci;
use yii\db\TableSchema; use yii\db\TableSchema;
use yii\db\oci\ColumnSchema; use yii\db\ColumnSchema;
/** /**
* Schema is the class for retrieving metadata information from an Oracle database. * Schema is the class for retrieving metadata from an Oracle database
* *
* @todo mapping from physical types to abstract types
*
* @author Qiang Xue <qiang.xue@gmail.com>
* @since 2.0
*/ */
class Schema extends \yii\db\Schema class Schema extends \yii\db\Schema
{ {
private $_defaultSchema;
private $_defaultSchema = ''; /**
* @inheritdoc
public function createQueryBuilder() */
{ public function quoteSimpleTableName($name)
return new QueryBuilder($this->db); {
} return '"' . $name . '"';
}
public function quoteTableName($name)
{
if (strpos($name, '.') === false) {
return $this->quoteSimpleTableName($name);
}
$parts = explode('.', $name);
foreach ($parts as $i => $part) {
$parts[$i] = $this->quoteSimpleTableName($part);
}
return implode('.', $parts);
}
public function quoteSimpleTableName($name) /**
{ * @inheritdoc
return '"' . $name . '"'; */
// return $name; public function quoteSimpleColumnName($name)
} {
return '"' . $name . '"';
}
public function quoteColumnName($name) /**
{ * @inheritdoc
if (($pos = strrpos($name, '.')) !== false) { */
$prefix = $this->quoteTableName(substr($name, 0, $pos)) . '.'; public function createQueryBuilder()
$name = substr($name, $pos + 1); {
} else { return new QueryBuilder($this->db);
$prefix = ''; }
}
return $prefix . ($name === '*' ? $name : $this->quoteSimpleColumnName($name));
}
public function quoteSimpleColumnName($name) /**
{ * @inheritdoc
return '"' . $name . '"'; */
// return $name; public function loadTableSchema($name)
} {
$table = new TableSchema();
$this->resolveTableNames($table, $name);
public function loadTableSchema($name) if ($this->findColumns($table)) {
{ $this->findConstraints($table);
$table = new TableSchema(); return $table;
$this->resolveTableNames($table, $name); } else {
// $this->findPrimaryKeys($table); return null;
if ($this->findColumns($table)) { }
// $this->findForeignKeys($table); }
$this->findConstraints($table);
return $table;
}
}
/** /**
* Resolves the table name and schema name (if any). * Resolves the table name and schema name (if any).
* *
* @param TableSchema $table * @param TableSchema $table the table metadata object
* the table metadata object * @param string $name the table name
* @param string $name */
* the table name protected function resolveTableNames($table, $name)
*/ {
protected function resolveTableNames($table, $name) $parts = explode('.', str_replace('"', '', $name));
{ if (isset($parts[1])) {
$parts = explode('.', str_replace('"', '', $name)); $table->schemaName = $parts[0];
if (isset($parts[1])) { $table->name = $parts[1];
$table->schemaName = $parts[0]; } else {
$table->name = $parts[1]; $table->schemaName = $this->getDefaultSchema();
} else { $table->name = $parts[0];
$table->name = $parts[0]; }
} }
if ($table->schemaName === null) {
$table->schemaName = $this->getDefaultSchema();
}
}
/** /**
* * @return string default schema.
* @return string default schema. */
*/ public function getDefaultSchema()
public function getDefaultSchema() {
{ if ($this->_defaultSchema === null) {
if (! strlen($this->_defaultSchema)) { $this->setDefaultSchema(strtoupper($this->db->username));
$this->setDefaultSchema(strtoupper($this->db->username)); }
} return $this->_defaultSchema;
}
return $this->_defaultSchema;
}
/** /**
* * @param string $schema default schema.
* @param string $schema */
* default schema. public function setDefaultSchema($schema)
*/ {
public function setDefaultSchema($schema) $this->_defaultSchema = $schema;
{ }
$this->_defaultSchema = $schema;
}
public function getLastInsertID($sequenceName = '') /**
{ * Collects the table column metadata.
if ($this->db->isActive) { * @param TableSchema $table the table schema
$sql = "select {$sequenceName}.currval from dual"; * @return boolean whether the table exists
return $this->db->createCommand($sql)->queryScalar(); */
} else { protected function findColumns($table)
throw new InvalidCallException('DB Connection is not active.'); {
} $schemaName = $table->schemaName;
} $tableName = $table->name;
/** $sql = <<<EOD
* Collects the table column metadata.
*
*/
protected function findColumns($table)
{
$schemaName = $table->schemaName;
$tableName = $table->name;
$sql = <<<EOD
SELECT a.column_name, a.data_type || SELECT a.column_name, a.data_type ||
case case
when data_precision is not null when data_precision is not null
@ -160,65 +138,48 @@ WHERE
and b.object_name = '{$tableName}' and b.object_name = '{$tableName}'
ORDER by a.column_id ORDER by a.column_id
EOD; EOD;
try {
$columns = $this->db->createCommand($sql)->queryAll();
} catch (\Exception $e) {
return false;
}
foreach ($columns as $column) {
$c = $this->createColumn($column);
$table->columns[$c->name] = $c;
if ($c->isPrimaryKey) {
if ($table->primaryKey === null) {
$table->primaryKey = $c->name;
} elseif (is_string($table->primaryKey)) {
$table->primaryKey = array(
$table->primaryKey,
$c->name
);
} else {
$table->primaryKey[] = $c->name;
}
$sql = "select sequence_name
from user_tables tabs
join user_triggers trigs
on trigs.table_name = tabs.table_name
join user_dependencies deps
on deps.name = trigs.trigger_name
join user_sequences seqs
on seqs.sequence_name = deps.referenced_name
where tabs.table_name = '{$tableName}'
and trigs.triggering_event = 'INSERT'";
try {
$seqName = $this->db->createCommand($sql)->queryScalar();
} catch (\Exception $e) {
return false;
}
$table->sequenceName = $seqName;
$c->autoIncrement = true;
}
}
return true;
}
protected function createColumn($column) try {
{ $columns = $this->db->createCommand($sql)->queryAll();
$c = new ColumnSchema(); } catch (\Exception $e) {
$c->name = $column['COLUMN_NAME']; return false;
$c->allowNull = $column['NULLABLE'] === 'Y'; }
$c->isPrimaryKey = strpos($column['KEY'], 'P') !== false;
$c->extract($column['DATA_TYPE'], $column['DATA_DEFAULT']); foreach ($columns as $column) {
$c->comment = $column['COLUMN_COMMENT'] === null ? '' : $column['COLUMN_COMMENT']; $c = $this->createColumn($column);
$table->columns[$c->name] = $c;
return $c; if ($c->isPrimaryKey) {
} $table->primaryKey[] = $c->name;
$table->sequenceName = '';
$c->autoIncrement = true;
}
}
return true;
}
protected function createColumn($column)
{
$c = new ColumnSchema();
$c->name = $column['COLUMN_NAME'];
$c->allowNull = $column['NULLABLE'] === 'Y';
$c->isPrimaryKey = strpos($column['KEY'], 'P') !== false;
$c->comment = $column['COLUMN_COMMENT'] === null ? '' : $column['COLUMN_COMMENT'];
$this->extractColumnType($c, $column['DATA_TYPE']);
$this->extractColumnSize($c, $column['DATA_TYPE']);
if (stripos($column['DATA_DEFAULT'], 'timestamp') !== false) {
$c->defaultValue = null;
} else {
$c->defaultValue = $c->typecast($column['DATA_DEFAULT']);
}
return $c;
}
protected function findConstraints($table) protected function findConstraints($table)
{ {
$sql = <<<EOD $sql = <<<EOD
SELECT D.constraint_type as CONSTRAINT_TYPE, C.COLUMN_NAME, C.position, D.r_constraint_name, SELECT D.constraint_type as CONSTRAINT_TYPE, C.COLUMN_NAME, C.position, D.r_constraint_name,
E.table_name as table_ref, f.column_name as column_ref, E.table_name as table_ref, f.column_name as column_ref,
C.table_name C.table_name
@ -231,134 +192,82 @@ where tabs.table_name = '{$tableName}'
and D.constraint_type <> 'P' and D.constraint_type <> 'P'
order by d.constraint_name, c.position order by d.constraint_name, c.position
EOD; EOD;
$command = $this->db->createCommand($sql); $command = $this->db->createCommand($sql);
foreach ($command->queryAll() as $row) { foreach ($command->queryAll() as $row) {
if ($row['CONSTRAINT_TYPE'] === 'R') { // foreign key if ($row['CONSTRAINT_TYPE'] === 'R') {
$name = $row["COLUMN_NAME"]; $name = $row["COLUMN_NAME"];
$table->foreignKeys[$name] = array( $table->foreignKeys[$name] = [$row["TABLE_REF"], $row["COLUMN_REF"]];
$row["TABLE_REF"], }
$row["COLUMN_REF"] }
); }
/*
* if (isset($table->columns[$name])) { $table->columns[$name]->isForeignKey = true; }
*/
}
}
}
/** /**
* Returns all table names in the database. * @inheritdoc
* */
* @param string $schema protected function findTableNames($schema = '')
* the schema of the tables. Defaults to empty string, meaning the current or default schema. {
* If not empty, the returned table names will be prefixed with the schema name. if ($schema === '') {
* @return array all table names in the database. $sql = <<<EOD
*/
protected function findTableNames($schema = '')
{
if ($schema === '') {
$sql = <<<EOD
SELECT table_name, '{$schema}' as table_schema FROM user_tables SELECT table_name, '{$schema}' as table_schema FROM user_tables
EOD; EOD;
$command = $this->db->createCommand($sql); $command = $this->db->createCommand($sql);
} else { } else {
$sql = <<<EOD $sql = <<<EOD
SELECT object_name as table_name, owner as table_schema FROM all_objects SELECT object_name as table_name, owner as table_schema FROM all_objects
WHERE object_type = 'TABLE' AND owner=:schema WHERE object_type = 'TABLE' AND owner=:schema
EOD; EOD;
$command = $this->db > createCommand($sql); $command = $this->db->createCommand($sql);
$command->bindParam(':schema', $schema); $command->bindParam(':schema', $schema);
} }
$rows = $command->queryAll();
$names = array();
foreach ($rows as $row) {
if ($schema === $this->getDefaultSchema() || $schema === '') {
$names[] = $row['TABLE_NAME'];
} else {
$names[] = $row['TABLE_SCHEMA'] . '.' . $row['TABLE_NAME'];
}
}
return $names;
}
/** $rows = $command->queryAll();
* Builds a SQL statement for renaming a DB table. $names = array();
* foreach ($rows as $row) {
* @param string $table $names[] = $row['TABLE_NAME'];
* the table to be renamed. The name will be properly quoted by the method. }
* @param string $newName return $names;
* the new table name. The name will be properly quoted by the method. }
* @return string the SQL statement for renaming a DB table.
* @since 1.1.6
*/
public function renameTable($table, $newName)
{
return 'ALTER TABLE ' . $this->quoteTableName($table) . ' RENAME TO ' . $this->quoteTableName($newName);
}
/** /**
* Builds a SQL statement for changing the definition of a column. * Extracts the data types for the given column
* * @param ColumnSchema $column
* @param string $table * @param string $dbType DB type
* the table whose column is to be changed. The table name will be properly quoted by the method. */
* @param string $column protected function extractColumnType($column, $dbType)
* the name of the column to be changed. The name will be properly quoted by the method. {
* @param string $type $column->dbType = $dbType;
* the new column type. The {@link getColumnType} method will be invoked to convert abstract column type (if any)
* into the physical one. Anything that is not recognized as abstract type will be kept in the generated SQL.
* For example, 'string' will be turned into 'varchar(255)', while 'string not null' will become 'varchar(255) not null'.
* @return string the SQL statement for changing the definition of a column.
* @since 1.1.6
*/
public function alterColumn($table, $column, $type)
{
$type = $this->getColumnType($type);
$sql = 'ALTER TABLE ' . $this->quoteTableName($table) . ' MODIFY ' . $this->quoteColumnName($column) . ' ' . $this->getColumnType($type);
return $sql;
}
/** if (strpos($dbType, 'FLOAT') !== false) {
* Builds a SQL statement for dropping an index. $column->type = 'double';
* } elseif (strpos($dbType, 'NUMBER') !== false || strpos($dbType, 'INTEGER') !== false) {
* @param string $name if (strpos($dbType, '(') && preg_match('/\((.*)\)/', $dbType, $matches)) {
* the name of the index to be dropped. The name will be properly quoted by the method. $values = explode(',', $matches[1]);
* @param string $table if (isset($values[1]) and (((int)$values[1]) > 0)) {
* the table whose index is to be dropped. The name will be properly quoted by the method. $column->type = 'double';
* @return string the SQL statement for dropping an index. } else {
* @since 1.1.6 $column->type = 'integer';
*/ }
public function dropIndex($name, $table) } else {
{ $column->type = 'double';
return 'DROP INDEX ' . $this->quoteTableName($name); }
} } else {
$column->type = 'string';
}
}
/** /**
* Resets the sequence value of a table's primary key. * Extracts size, precision and scale information from column's DB type.
* The sequence will be reset such that the primary key of the next new row inserted * @param ColumnSchema $column
* will have the specified value or 1. * @param string $dbType the column's DB type
* */
* @param CDbTableSchema $table protected function extractColumnSize($column, $dbType)
* the table schema whose primary key sequence will be reset {
* @param mixed $value if (strpos($dbType, '(') && preg_match('/\((.*)\)/', $dbType, $matches)) {
* the value for the primary key of the next new row inserted. If this is not set, $values = explode(',', $matches[1]);
* the next new row's primary key will have a value 1. $column->size = $column->precision = (int)$values[0];
* @since 1.1.13 if (isset($values[1])) {
*/ $column->scale = (int)$values[1];
public function resetSequence($table, $value = 1) }
{ }
$seq = $table->name . "_SEQ"; }
if ($table->sequenceName !== null) {
$this->db->createCommand("DROP SEQUENCE " . $seq)->execute();
$createSequenceSql = <<< SQL
create sequence $seq
start with $value
increment by 1
nomaxvalue
nocache
SQL;
$this->db->createCommand($createSequenceSql)->execute();
}
}
} }

Write Preview
Loading…
Cancel
Save