@ -110,10 +110,7 @@ class Schema extends \yii\db\Schema
*/
protected function findColumns($table)
{
$schemaName = $table->schemaName;
$tableName = $table->name;
$sql = < < < EOD
$sql = < < < SQL
SELECT a.column_name, a.data_type, a.data_precision, a.data_scale, a.data_length,
a.nullable, a.data_default,
( SELECT D.constraint_type
@ -128,14 +125,17 @@ FROM ALL_TAB_COLUMNS A
inner join ALL_OBJECTS B ON b.owner = a.owner and ltrim(B.OBJECT_NAME) = ltrim(A.TABLE_NAME)
LEFT JOIN all_col_comments com ON (A.owner = com.owner AND A.table_name = com.table_name AND A.column_name = com.column_name)
WHERE
a.owner = '{$schemaName}'
and (b.object_type = 'TABLE' or b.object_type = 'VIEW' )
and b.object_name = '{$tableName}'
a.owner = :schemaName
and (b.object_type IN ('TABLE', 'VIEW') )
and b.object_name = :tableName
ORDER by a.column_id
EOD ;
SQL ;
try {
$columns = $this->db->createCommand($sql)->queryAll();
$columns = $this->db->createCommand($sql, [
':tableName' => $table->name,
':schemaName' => $table->schemaName,
])->queryAll();
} catch (\Exception $e) {
return false;
}
@ -161,19 +161,22 @@ EOD;
/**
* Sequence name of table
*
* @param $tablen ame
* @param $tableN ame
* @internal param \yii\db\TableSchema $table ->name the table schema
* @return string whether the sequence exists
*/
protected function getTableSequenceName($tablen ame)
protected function getTableSequenceName($tableN ame)
{
$seq_name_sql="select ud.referenced_name as sequence_name
from user_dependencies ud
join user_triggers ut on (ut.trigger_name = ud.name)
where ut.table_name='{$tablename}'
and ud.type='TRIGGER'
and ud.referenced_type='SEQUENCE'";
$sequenceName = $this->db->createCommand($seq_name_sql)->queryScalar();
$seq_name_sql = < < < SQL
SELECT ud.referenced_name as sequence_name
FROM user_dependencies ud
JOIN user_triggers ut on (ut.trigger_name = ud.name)
WHERE ut.table_name = :tableName
AND ud.type='TRIGGER'
AND ud.referenced_type='SEQUENCE'
SQL;
$sequenceName = $this->db->createCommand($seq_name_sql, [':tableName' => $tableName])->queryScalar();
return $sequenceName === false ? null : $sequenceName;
}
@ -249,35 +252,35 @@ EOD;
*/
protected function findConstraints($table)
{
$sql = < < < EOD
SELECT D.constraint_type as CONSTRAINT_TYPE, C.COLUMN_NAME, C.position, D.constraint_name, D.r_constraint_name,
E.table_name as table_ref, f.column_name as column_ref,
C.table_name
FROM ALL_CONS_COLUMNS C
inner join ALL_constraints D on D.OWNER = C.OWNER and D.constraint_name = C.constraint_name
left join ALL_constraints E on E.OWNER = D.r_OWNER and E.constraint_name = D.r_constraint_name
left join ALL_cons_columns F on F.OWNER = E.OWNER and F.constraint_name = E.constraint_name and F.position = c.position
WHERE C.OWNER = '{$table->schemaName}'
and C.table_name = '{$table->name}'
and D.constraint_type < > 'P'
order by d.constraint_name, c.position
EOD;
$command = $this->db->createCommand($sql);
$constraints = [];
$sql = < < < SQL
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,
C.table_name
FROM ALL_CONS_COLUMNS C
INNER JOIN ALL_constraints D on D.OWNER = C.OWNER and D.constraint_name = C.constraint_name
LEFT JOIN ALL_constraints E on E.OWNER = D.r_OWNER and E.constraint_name = D.r_constraint_name
LEFT JOIN ALL_cons_columns F on F.OWNER = E.OWNER and F.constraint_name = E.constraint_name and F.position = c.position
WHERE C.OWNER = :schemaName
AND C.table_name = :tableName
AND D.constraint_type = 'R'
ORDER BY d.constraint_name, c.position
SQL;
$command = $this->db->createCommand($sql, [
':tableName' => $table->name,
':schemaName' => $table->schemaName,
]);
foreach ($command->queryAll() as $row) {
if ($this->db->slavePdo->getAttribute(\PDO::ATTR_CASE) === \PDO::CASE_LOWER) {
$row = array_change_key_case($row, CASE_UPPER);
}
if ($row['CONSTRAINT_TYPE'] === 'R') {
$name = $row['CONSTRAINT_NAME'];
if (!isset($constraints[$name])) {
$constraints[$name] = [
'tableName' => $row["TABLE_REF"],
'columns' => [],
];
}
$constraints[$name]['columns'][$row["COLUMN_NAME"]] = $row["COLUMN_REF"];
$name = $row['CONSTRAINT_NAME'];
if (!isset($constraints[$name])) {
$constraints[$name] = [
'tableName' => $row["TABLE_REF"],
'columns' => [],
];
}
$constraints[$name]['columns'][$row["COLUMN_NAME"]] = $row["COLUMN_REF"];
}
foreach ($constraints as $constraint) {
$table->foreignKeys[] = array_merge([$constraint['tableName']], $constraint['columns']);
@ -290,17 +293,17 @@ EOD;
protected function findTableNames($schema = '')
{
if ($schema === '') {
$sql = < < < EOD
SELECT table_name, '{$schema}' as table_schema FROM user_tables
EOD ;
$sql = < < < SQL
SELECT table_name FROM user_tables
SQL ;
$command = $this->db->createCommand($sql);
} else {
$sql = < < < EOD
SELECT object_name as table_name, owner as table_schema FROM all_objects
$sql = < < < SQL
SELECT object_name as table_name
FROM all_objects
WHERE object_type = 'TABLE' AND owner=:schema
EOD;
$command = $this->db->createCommand($sql);
$command->bindParam(':schema', $schema);
SQL;
$command = $this->db->createCommand($sql, [':schema' => $schema]);
}
$rows = $command->queryAll();
@ -311,11 +314,46 @@ EOD;
}
$names[] = $row['TABLE_NAME'];
}
return $names;
}
/**
* Returns all unique indexes for the given table.
* Each array element is of the following structure:
*
* ~~~
* [
* 'IndexName1' => ['col1' [, ...]],
* 'IndexName2' => ['col2' [, ...]],
* ]
* ~~~
*
* @param TableSchema $table the table metadata
* @return array all unique indexes for the given table.
*/
public function findUniqueIndexes($table)
{
$query = < < < SQL
SELECT dic.INDEX_NAME, dic.COLUMN_NAME
FROM ALL_INDEXES di
INNER JOIN ALL_IND_COLUMNS dic ON di.TABLE_NAME = dic.TABLE_NAME AND di.INDEX_NAME = dic.INDEX_NAME
WHERE di.UNIQUENESS = 'UNIQUE'
AND dic.TABLE_OWNER = :schemaName
AND dic.TABLE_NAME = :tableName
ORDER BY dic.TABLE_NAME, dic.INDEX_NAME, dic.COLUMN_POSITION
SQL;
$result = [];
$command = $this->db->createCommand($query, [
':tableName' => $table->name,
':schemaName' => $table->schemaName,
]);
foreach ($command->queryAll() as $row) {
$result[$row['INDEX_NAME']][] = $row['COLUMN_NAME'];
}
return $result;
}
/**
* Extracts the data types for the given column
* @param ColumnSchema $column
* @param string $dbType DB type