forked from extern/egroupware
348 lines
8.8 KiB
PHP
348 lines
8.8 KiB
PHP
|
<?php
|
||
|
|
/**************************************************************************\
|
||
|
|
* phpGroupWare - Setup *
|
||
|
|
* http://www.phpgroupware.org *
|
||
|
|
* -------------------------------------------- *
|
||
|
|
* This program is free software; you can redistribute it and/or modify it *
|
||
|
|
* under the terms of the GNU General Public License as published by the *
|
||
|
|
* Free Software Foundation; either version 2 of the License, or (at your *
|
||
|
|
* option) any later version. *
|
||
|
|
\**************************************************************************/
|
||
|
|
|
||
|
|
/* $Id$ */
|
||
|
|
|
||
|
|
class schema_proc_mysql
|
||
|
|
{
|
||
|
|
var $m_sStatementTerminator;
|
||
|
|
// Following added to convert sql to array
|
||
|
|
var $sCol = array();
|
||
|
|
var $pk = array();
|
||
|
|
var $fk = array();
|
||
|
|
var $ix = array();
|
||
|
|
var $uc = array();
|
||
|
|
|
||
|
|
function schema_proc_mysql()
|
||
|
|
{
|
||
|
|
$this->m_sStatementTerminator = ";";
|
||
|
|
}
|
||
|
|
|
||
|
|
// Return a type suitable for DDL
|
||
|
|
function TranslateType($sType, $iPrecision = 0, $iScale = 0, &$sTranslated)
|
||
|
|
{
|
||
|
|
$sTranslated = "";
|
||
|
|
switch($sType)
|
||
|
|
{
|
||
|
|
case "auto":
|
||
|
|
$sTranslated = "int(11) auto_increment";
|
||
|
|
break;
|
||
|
|
case "blob":
|
||
|
|
$sTranslated = "blob";
|
||
|
|
break;
|
||
|
|
case "char":
|
||
|
|
if ($iPrecision > 0 && $iPrecision < 256)
|
||
|
|
{
|
||
|
|
$sTranslated = sprintf("char(%d)", $iPrecision);
|
||
|
|
}
|
||
|
|
if ($iPrecision > 255)
|
||
|
|
{
|
||
|
|
$sTranslated = "text";
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case "date":
|
||
|
|
$sTranslated = "date";
|
||
|
|
break;
|
||
|
|
case "decimal":
|
||
|
|
$sTranslated = sprintf("decimal(%d,%d)", $iPrecision, $iScale);
|
||
|
|
break;
|
||
|
|
case "float":
|
||
|
|
switch ($iPrecision)
|
||
|
|
{
|
||
|
|
case 4:
|
||
|
|
$sTranslated = "float";
|
||
|
|
break;
|
||
|
|
case 8:
|
||
|
|
$sTranslated = "double";
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case "int":
|
||
|
|
switch ($iPrecision)
|
||
|
|
{
|
||
|
|
case 2:
|
||
|
|
$sTranslated = "smallint";
|
||
|
|
break;
|
||
|
|
case 4:
|
||
|
|
$sTranslated = "int";
|
||
|
|
break;
|
||
|
|
case 8:
|
||
|
|
$sTranslated = "bigint";
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case "longtext":
|
||
|
|
$sTranslated = "longtext";
|
||
|
|
break;
|
||
|
|
case "text":
|
||
|
|
$sTranslated = "text";
|
||
|
|
break;
|
||
|
|
case "timestamp":
|
||
|
|
$sTranslated = "datetime";
|
||
|
|
break;
|
||
|
|
case "varchar":
|
||
|
|
if ($iPrecision > 0 && $iPrecision < 256)
|
||
|
|
{
|
||
|
|
$sTranslated = sprintf("varchar(%d)", $iPrecision);
|
||
|
|
}
|
||
|
|
if ($iPrecision > 255)
|
||
|
|
{
|
||
|
|
$sTranslated = "text";
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
return (strlen($sTranslated) > 0);
|
||
|
|
}
|
||
|
|
|
||
|
|
function TranslateDefault($sDefault)
|
||
|
|
{
|
||
|
|
switch ($sDefault)
|
||
|
|
{
|
||
|
|
case "current_date":
|
||
|
|
case "current_timestamp":
|
||
|
|
return "now";
|
||
|
|
}
|
||
|
|
|
||
|
|
return $sDefault;
|
||
|
|
}
|
||
|
|
|
||
|
|
// Inverse of above, convert sql column types to array info
|
||
|
|
function rTranslateType($sType, $iPrecision = 0, $iScale = 0, &$sTranslated)
|
||
|
|
{
|
||
|
|
$sTranslated = '';
|
||
|
|
if ($sType == 'int' || $sType == 'tinyint' || $sType == 'smallint' || $sType == 'bigint')
|
||
|
|
{
|
||
|
|
if ($iPrecision > 8)
|
||
|
|
{
|
||
|
|
$iPrecision = 8;
|
||
|
|
}
|
||
|
|
elseif($iPrecision > 4)
|
||
|
|
{
|
||
|
|
$iPrecision = 4;
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
$iPrecision = 2;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
switch($sType)
|
||
|
|
{
|
||
|
|
case "tinyint":
|
||
|
|
case "smallint":
|
||
|
|
$sTranslated = "'type' => 'int', 'precision' => 2";
|
||
|
|
break;
|
||
|
|
case "int":
|
||
|
|
$sTranslated = "'type' => 'int', 'precision' => 4";
|
||
|
|
break;
|
||
|
|
case "bigint":
|
||
|
|
$sTranslated = "'type' => 'int', 'precision' => 8";
|
||
|
|
case "char":
|
||
|
|
if ($iPrecision > 0 && $iPrecision < 256)
|
||
|
|
{
|
||
|
|
$sTranslated = "'type' => 'char', 'precision' => $iPrecision";
|
||
|
|
}
|
||
|
|
if ($iPrecision > 255)
|
||
|
|
{
|
||
|
|
$sTranslated = "'type' => 'text'";
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case "decimal":
|
||
|
|
$sTranslated = "'type' => 'decimal', 'precision' => $iPrecision, 'scale' => $iScale";
|
||
|
|
break;
|
||
|
|
case "float":
|
||
|
|
case "double":
|
||
|
|
$sTranslated = "'type' => 'float', 'precision' => $iPrecision";
|
||
|
|
break;
|
||
|
|
case "datetime":
|
||
|
|
$sTranslated = "'type' => 'timestamp'";
|
||
|
|
break;
|
||
|
|
case "enum":
|
||
|
|
// Here comes a nasty assumption
|
||
|
|
$sTranslated = "'type' => 'varchar', 'precision' => 255";
|
||
|
|
break;
|
||
|
|
case "varchar":
|
||
|
|
if ($iPrecision > 0 && $iPrecision < 256)
|
||
|
|
{
|
||
|
|
$sTranslated = "'type' => 'varchar', 'precision' => $iPrecision";
|
||
|
|
}
|
||
|
|
if ($iPrecision > 255)
|
||
|
|
{
|
||
|
|
$sTranslated = "'type' => 'text'";
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case "longtext":
|
||
|
|
case "text":
|
||
|
|
case "blob":
|
||
|
|
case "date":
|
||
|
|
$sTranslated = "'type' => '$sType'";
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
return (strlen($sTranslated) > 0);
|
||
|
|
}
|
||
|
|
|
||
|
|
function GetPKSQL($sFields)
|
||
|
|
{
|
||
|
|
return "PRIMARY KEY($sFields)";
|
||
|
|
}
|
||
|
|
|
||
|
|
function GetUCSQL($sFields)
|
||
|
|
{
|
||
|
|
return "UNIQUE($sFields)";
|
||
|
|
}
|
||
|
|
|
||
|
|
function _GetColumns($oProc, $sTableName, &$sColumns, $sDropColumn = "")
|
||
|
|
{
|
||
|
|
$sColumns = "";
|
||
|
|
$this->pk = array();
|
||
|
|
$this->fk = array();
|
||
|
|
$this->ix = array();
|
||
|
|
$this->uc = array();
|
||
|
|
|
||
|
|
// Field, Type, Null, Key, Default, Extra
|
||
|
|
$oProc->m_odb->query("describe $sTableName");
|
||
|
|
while ($oProc->m_odb->next_record())
|
||
|
|
{
|
||
|
|
$type = $default = $null = $nullcomma = $prec = $scale = $ret = $colinfo = $scales = '';
|
||
|
|
if ($sColumns != "")
|
||
|
|
{
|
||
|
|
$sColumns .= ",";
|
||
|
|
}
|
||
|
|
$sColumns .= $oProc->m_odb->f(0);
|
||
|
|
|
||
|
|
// The rest of this is used only for SQL->array
|
||
|
|
$colinfo = explode('(',$oProc->m_odb->f(1));
|
||
|
|
$prec = ereg_replace(')','',$colinfo[1]);
|
||
|
|
$scales = explode(',',$prec);
|
||
|
|
if ($scales[1])
|
||
|
|
{
|
||
|
|
$prec = $scales[0];
|
||
|
|
$scale = $scales[1];
|
||
|
|
}
|
||
|
|
$this->rTranslateType($colinfo[0], $prec, $scale, &$type);
|
||
|
|
|
||
|
|
if ($oProc->m_odb->f(2) == 'YES')
|
||
|
|
{
|
||
|
|
$null = "'nullable' => True";
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
$null = "'nullable' => False";
|
||
|
|
}
|
||
|
|
if ($oProc->m_odb->f(4))
|
||
|
|
{
|
||
|
|
$default = "'default' => '".$oProc->m_odb->f(4)."'";
|
||
|
|
$nullcomma = ',';
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
$default = '';
|
||
|
|
$nullcomma = '';
|
||
|
|
}
|
||
|
|
if ($oProc->m_odb->f(5))
|
||
|
|
{
|
||
|
|
$type = "'type' => 'auto'";
|
||
|
|
}
|
||
|
|
$this->sCol[] = "\t\t\t\t'" . $oProc->m_odb->f(0)."' => array(" . $type . ',' . $null . $nullcomma . $default . '),' . "\n";
|
||
|
|
if ($oProc->m_odb->f(3) == 'PRI')
|
||
|
|
{
|
||
|
|
$this->pk[] = $oProc->m_odb->f(0);
|
||
|
|
}
|
||
|
|
if ($oProc->m_odb->f(3) == 'UNI')
|
||
|
|
{
|
||
|
|
$this->uc[] = $oProc->m_odb->f(0);
|
||
|
|
}
|
||
|
|
// Hmmm, MUL could also mean unique, or not...
|
||
|
|
if ($oProc->m_odb->f(3) == 'MUL')
|
||
|
|
{
|
||
|
|
$this->ix[] = $oProc->m_odb->f(0);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// ugly as heck, but is here to chop the trailing comma on the last element (for php3)
|
||
|
|
$this->sCol[count($this->sCol) - 1] = substr($this->sCol[count($this->sCol) - 1],0,-2) . "\n";
|
||
|
|
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
|
||
|
|
function DropTable($oProc, &$aTables, $sTableName)
|
||
|
|
{
|
||
|
|
return !!($oProc->m_odb->query("DROP TABLE " . $sTableName));
|
||
|
|
}
|
||
|
|
|
||
|
|
function DropColumn($oProc, &$aTables, $sTableName, $aNewTableDef, $sColumnName, $bCopyData = true)
|
||
|
|
{
|
||
|
|
return !!($oProc->m_odb->query("ALTER TABLE $sTableName DROP COLUMN $sColumnName"));
|
||
|
|
}
|
||
|
|
|
||
|
|
function RenameTable($oProc, &$aTables, $sOldTableName, $sNewTableName)
|
||
|
|
{
|
||
|
|
return !!($oProc->m_odb->query("ALTER TABLE $sOldTableName RENAME TO $sNewTableName"));
|
||
|
|
}
|
||
|
|
|
||
|
|
function RenameColumn($oProc, &$aTables, $sTableName, $sOldColumnName, $sNewColumnName, $bCopyData = true)
|
||
|
|
{
|
||
|
|
// This really needs testing - it can affect primary keys, and other table-related objects
|
||
|
|
// like sequences and such
|
||
|
|
global $DEBUG;
|
||
|
|
if ($DEBUG) { echo '<br>RenameColumn: calling _GetFieldSQL for ' . $sNewColumnName; }
|
||
|
|
if ($oProc->_GetFieldSQL($aTables[$sTableName]["fd"][$sNewColumnName], $sNewColumnSQL))
|
||
|
|
{
|
||
|
|
return !!($oProc->m_odb->query("ALTER TABLE $sTableName CHANGE $sOldColumnName $sNewColumnName " . $sNewColumnSQL));
|
||
|
|
}
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
|
||
|
|
function AlterColumn($oProc, &$aTables, $sTableName, $sColumnName, &$aColumnDef, $bCopyData = true)
|
||
|
|
{
|
||
|
|
global $DEBUG;
|
||
|
|
if ($DEBUG) { echo '<br>AlterColumn: calling _GetFieldSQL for ' . $sNewColumnName; }
|
||
|
|
if ($oProc->_GetFieldSQL($aTables[$sTableName]["fd"][$sColumnName], $sNewColumnSQL))
|
||
|
|
{
|
||
|
|
return !!($oProc->m_odb->query("ALTER TABLE $sTableName MODIFY $sColumnName " . $sNewColumnSQL));
|
||
|
|
}
|
||
|
|
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
|
||
|
|
function AddColumn($oProc, &$aTables, $sTableName, $sColumnName, &$aColumnDef)
|
||
|
|
{
|
||
|
|
$oProc->_GetFieldSQL($aColumnDef, $sFieldSQL);
|
||
|
|
$query = "ALTER TABLE $sTableName ADD COLUMN $sColumnName $sFieldSQL";
|
||
|
|
|
||
|
|
return !!($oProc->m_odb->query($query));
|
||
|
|
}
|
||
|
|
|
||
|
|
function GetSequenceSQL($sTableName, &$sSequenceSQL)
|
||
|
|
{
|
||
|
|
$sSequenceSQL = "";
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
function CreateTable($oProc, &$aTables, $sTableName, $aTableDef)
|
||
|
|
{
|
||
|
|
if ($oProc->_GetTableSQL($sTableName, $aTableDef, $sTableSQL, $sSequenceSQL))
|
||
|
|
{
|
||
|
|
// create sequence first since it will be needed for default
|
||
|
|
if ($sSequenceSQL != "")
|
||
|
|
{
|
||
|
|
$oProc->m_odb->query($sSequenceSQL);
|
||
|
|
}
|
||
|
|
|
||
|
|
$query = "CREATE TABLE $sTableName ($sTableSQL)";
|
||
|
|
return !!($oProc->m_odb->query($query));
|
||
|
|
}
|
||
|
|
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
?>
|