. */ Doctrine::autoload('Doctrine_Import'); /** * @package Doctrine * @license http://www.opensource.org/licenses/lgpl-license.php LGPL * @author Konsta Vesterinen * @author Lukas Smith (PEAR MDB2 library) * @author Frank M. Kromann (PEAR MDB2 Mssql driver) * @author David Coallier (PEAR MDB2 Mssql driver) * @version $Revision$ * @category Object Relational Mapping * @link www.phpdoctrine.com * @since 1.0 */ class Doctrine_Import_Mssql extends Doctrine_Import { /** * lists all databases * * @return array */ public function listDatabases() { } /** * lists all availible database functions * * @return array */ public function listFunctions() { } /** * lists all database triggers * * @param string|null $database * @return array */ public function listTriggers($database = null) { } /** * lists all database sequences * * @param string|null $database * @return array */ public function listSequences($database = null) { $query = "SELECT name FROM sysobjects WHERE xtype = 'U'"; $table_names = $db->queryCol($query); if (PEAR::isError($table_names)) { return $table_names; } $result = array(); foreach ($table_names as $table_name) { if ($sqn = $this->_fixSequenceName($table_name, true)) { $result[] = $sqn; } } if ($db->options['portability'] & Doctrine::PORTABILITY_FIX_CASE) { $result = array_map(($db->options['field_case'] == CASE_LOWER ? 'strtolower' : 'strtoupper'), $result); } return $result; } /** * lists table constraints * * @param string $table database table name * @return array */ public function listTableConstraints($table) { } /** * lists table constraints * * @param string $table database table name * @return array */ public function listTableColumns($table) { $sql = 'EXEC sp_columns @table_name = ' . $this->quoteIdentifier($table); $result = $this->conn->fetchAssoc($sql); $columns = array(); foreach ($result as $key => $val) { if (strstr($val['type_name'], ' ')) { list($type, $identity) = explode(' ', $val['type_name']); } else { $type = $val['type_name']; $identity = ''; } if ($type == 'varchar') { $type .= '('.$val['length'].')'; } $description = array( 'name' => $val['column_name'], 'type' => $type, 'notnull' => (bool) ($val['is_nullable'] === 'NO'), 'default' => $val['column_def'], 'primary' => (strtolower($identity) == 'identity'), ); $columns[$val['column_name']] = $description; } return $columns; } /** * lists table constraints * * @param string $table database table name * @return array */ public function listTableIndexes($table) { } /** * lists tables * * @param string|null $database * @return array */ public function listTables($database = null) { $sql = "SELECT name FROM sysobjects WHERE type = 'U' ORDER BY name"; return $this->dbh->fetchCol($sql); } /** * lists table triggers * * @param string $table database table name * @return array */ public function listTableTriggers($table) { $table = $db->quote($table, 'text'); $query = "SELECT name FROM sysobjects WHERE xtype = 'TR'"; if (!is_null($table)) { $query .= "AND object_name(parent_obj) = $table"; } $result = $db->queryCol($query); if (PEAR::isError($results)) { return $result; } if ($db->options['portability'] & Doctrine::PORTABILITY_FIX_CASE && $db->options['field_case'] == CASE_LOWER) { $result = array_map(($db->options['field_case'] == CASE_LOWER ? 'strtolower' : 'strtoupper'), $result); } return $result; } /** * lists table views * * @param string $table database table name * @return array */ public function listTableViews($table) { $keyName = 'INDEX_NAME'; $pkName = 'PK_NAME'; if ($db->options['portability'] & Doctrine::PORTABILITY_FIX_CASE) { if ($db->options['field_case'] == CASE_LOWER) { $keyName = strtolower($keyName); $pkName = strtolower($pkName); } else { $keyName = strtoupper($keyName); $pkName = strtoupper($pkName); } } $table = $db->quote($table, 'text'); $query = 'EXEC sp_statistics @table_name = ' . $table; $indexes = $db->queryCol($query, 'text', $keyName); $query = 'EXEC sp_pkeys @table_name = ' . $table; $pkAll = $db->queryCol($query, 'text', $pkName); $result = array(); foreach ($indexes as $index) { if (!in_array($index, $pkAll) && $index != null) { $result[$this->_fixIndexName($index)] = true; } } if ($db->options['portability'] & Doctrine::PORTABILITY_FIX_CASE) { $result = array_change_key_case($result, $db->options['field_case']); } return array_keys($result); } /** * lists database users * * @return array */ public function listUsers() { } /** * lists database views * * @param string|null $database * @return array */ public function listViews($database = null) { $query = "SELECT name FROM sysobjects WHERE xtype = 'V'"; $result = $db->queryCol($query); if ($db->options['portability'] & Doctrine::PORTABILITY_FIX_CASE && $db->options['field_case'] == CASE_LOWER) { $result = array_map(($db->options['field_case'] == CASE_LOWER ? 'strtolower' : 'strtoupper'), $result); } return $result; } }