{
$td = $this->getTableDef($table);
- foreach ($td->columns as $cd) {
- if ($cd->name == $column) {
- return $cd;
+ if (!empty($td) && !empty($td->columns)) {
+ foreach ($td->columns as $cd) {
+ if ($cd->name == $column) {
+ return $cd;
+ }
}
}
}
}
- // Multi-value indexes are advisory and for best portability
- // should be created as separate statements.
+ // Wrap the CREATE TABLE around the main body chunks...
$statements = array();
$statements[] = $this->startCreateTable($name, $def) . "\n" .
implode($sql, ",\n") . "\n" .
$this->endCreateTable($name, $def);
+
+ // Multi-value indexes are advisory and for best portability
+ // should be created as separate statements.
if (!empty($def['indexes'])) {
foreach ($def['indexes'] as $col => $colDef) {
$this->appendCreateIndex($statements, $name, $col, $colDef);
}
}
+ if (!empty($def['fulltext indexes'])) {
+ foreach ($def['fulltext indexes'] as $col => $colDef) {
+ $this->appendCreateFulltextIndex($statements, $name, $col, $colDef);
+ }
+ }
return $statements;
}
*/
function appendForeignKeyDef(array &$sql, $name, array $def)
{
+ if (count($def) != 2) {
+ throw new Exception("Invalid foreign key def for $name: " . var_export($def, true));
+ }
list($refTable, $map) = $def;
$srcCols = array_keys($map);
$refCols = array_values($map);
$statements[] = "CREATE INDEX $name ON $table " . $this->buildIndexList($def);
}
+ /**
+ * Append an SQL statement with an index definition for a full-text search
+ * index over one or more columns on a table.
+ *
+ * @param array $statements
+ * @param string $table
+ * @param string $name
+ * @param array $def
+ */
+ function appendCreateFulltextIndex(array &$statements, $table, $name, array $def)
+ {
+ throw new Exception("Fulltext index not supported in this database");
+ }
+
/**
* Append an SQL statement to drop an index from a table.
*
public function dropTable($name)
{
+ global $_PEAR;
+
$res = $this->conn->query("DROP TABLE $name");
- if (PEAR::isError($res)) {
+ if ($_PEAR->isError($res)) {
throw new Exception($res->getMessage());
}
public function createIndex($table, $columnNames, $name=null)
{
+ global $_PEAR;
+
if (!is_array($columnNames)) {
$columnNames = array($columnNames);
}
"ADD INDEX $name (".
implode(",", $columnNames).")");
- if (PEAR::isError($res)) {
+ if ($_PEAR->isError($res)) {
throw new Exception($res->getMessage());
}
public function dropIndex($table, $name)
{
+ global $_PEAR;
+
$res = $this->conn->query("ALTER TABLE $table DROP INDEX $name");
- if (PEAR::isError($res)) {
+ if ($_PEAR->isError($res)) {
throw new Exception($res->getMessage());
}
public function addColumn($table, $columndef)
{
+ global $_PEAR;
+
$sql = "ALTER TABLE $table ADD COLUMN " . $this->_columnSql($columndef);
$res = $this->conn->query($sql);
- if (PEAR::isError($res)) {
+ if ($_PEAR->isError($res)) {
throw new Exception($res->getMessage());
}
public function modifyColumn($table, $columndef)
{
+ global $_PEAR;
+
$sql = "ALTER TABLE $table MODIFY COLUMN " .
$this->_columnSql($columndef);
$res = $this->conn->query($sql);
- if (PEAR::isError($res)) {
+ if ($_PEAR->isError($res)) {
throw new Exception($res->getMessage());
}
public function dropColumn($table, $columnName)
{
+ global $_PEAR;
+
$sql = "ALTER TABLE $table DROP COLUMN $columnName";
$res = $this->conn->query($sql);
- if (PEAR::isError($res)) {
+ if ($_PEAR->isError($res)) {
throw new Exception($res->getMessage());
}
*/
function runSqlSet(array $statements)
{
+ global $_PEAR;
+
$ok = true;
foreach ($statements as $sql) {
if (defined('DEBUG_INSTALLER')) {
}
$res = $this->conn->query($sql);
- if (PEAR::isError($res)) {
+ if ($_PEAR->isError($res)) {
throw new Exception($res->getMessage());
}
}
$uniques = $this->diffArrays($old, $def, 'unique keys');
$indexes = $this->diffArrays($old, $def, 'indexes');
$foreign = $this->diffArrays($old, $def, 'foreign keys');
+ $fulltext = $this->diffArrays($old, $def, 'fulltext indexes');
// Drop any obsolete or modified indexes ahead...
foreach ($indexes['del'] + $indexes['mod'] as $indexName) {
$this->appendDropIndex($statements, $tableName, $indexName);
}
+ // Drop any obsolete or modified fulltext indexes ahead...
+ foreach ($fulltext['del'] + $fulltext['mod'] as $indexName) {
+ $this->appendDropIndex($statements, $tableName, $indexName);
+ }
+
// For efficiency, we want this all in one
// query, instead of using our methods.
$this->appendAlterDropUnique($phrase, $keyName);
}
+ if (isset($old['primary key']) && (!isset($def['primary key']) || $def['primary key'] != $old['primary key'])) {
+ $this->appendAlterDropPrimary($phrase);
+ }
+
foreach ($fields['add'] as $columnName) {
$this->appendAlterAddColumn($phrase, $columnName,
$def['fields'][$columnName]);
$this->appendAlterDropColumn($phrase, $columnName);
}
+ if (isset($def['primary key']) && (!isset($old['primary key']) || $old['primary key'] != $def['primary key'])) {
+ $this->appendAlterAddPrimary($phrase, $def['primary key']);
+ }
+
foreach ($uniques['mod'] + $uniques['add'] as $keyName) {
$this->appendAlterAddUnique($phrase, $keyName, $def['unique keys'][$keyName]);
}
$this->appendAlterAddForeign($phrase, $keyName, $def['foreign keys'][$keyName]);
}
- $this->appendAlterExtras($phrase, $tableName);
+ $this->appendAlterExtras($phrase, $tableName, $def);
if (count($phrase) > 0) {
$sql = 'ALTER TABLE ' . $tableName . ' ' . implode(",\n", $phrase);
$this->appendCreateIndex($statements, $tableName, $indexName, $def['indexes'][$indexName]);
}
+ foreach ($fulltext['mod'] + $fulltext['add'] as $indexName) {
+ $colDef = $def['fulltext indexes'][$indexName];
+ $this->appendCreateFulltextIndex($statements, $tableName, $indexName, $colDef);
+ }
+
return $statements;
}
$phrase[] = implode(' ', $sql);
}
+ function appendAlterAddPrimary(array &$phrase, array $def)
+ {
+ $sql = array();
+ $sql[] = 'ADD';
+ $this->appendPrimaryKeyDef($sql, $def);
+ $phrase[] = implode(' ', $sql);
+ }
+
+ function appendAlterDropPrimary(array &$phrase)
+ {
+ $phrase[] = 'DROP CONSTRAINT PRIMARY KEY';
+ }
+
function appendAlterDropUnique(array &$phrase, $keyName)
{
$phrase[] = 'DROP CONSTRAINT ' . $keyName;
$phrase[] = 'DROP FOREIGN KEY ' . $keyName;
}
- function appendAlterExtras(array &$phrase, $tableName)
+ function appendAlterExtras(array &$phrase, $tableName, array $def)
{
// no-op
}
if (!$cd->nullable) {
$column['not null'] = true;
}
- if ($cd->autoincrement) {
+ if ($cd->auto_increment) {
$column['type'] = 'serial';
}
if ($cd->default) {
*/
function validateDef($tableName, array $def)
{
- if (count($defs) && $defs[0] instanceof ColumnDef) {
- $def = $this->oldToNew($tableName, $defs);
+ if (isset($def[0]) && $def[0] instanceof ColumnDef) {
+ $def = $this->oldToNew($tableName, $def);
}
// A few quick checks :D
if (!isset($def['fields'])) {
- throw new Exceptioni("Invalid table definition for $tableName: no fields.");
+ throw new Exception("Invalid table definition for $tableName: no fields.");
}
return $def;
*/
protected function fetchQueryData($sql)
{
+ global $_PEAR;
+
$res = $this->conn->query($sql);
- if (PEAR::isError($res)) {
+ if ($_PEAR->isError($res)) {
throw new Exception($res->getMessage());
}
projects / quix0rs-gnu-social.git / blobdiff