m_oTranslator = new phpgw_schema_proc_$dbms;");
include("./inc/phpgw_schema_proc_array.inc.php");
$this->m_oDeltaProc = new phpgw_schema_proc_array;
$this->m_aTables = array();
$this->m_bDeltaOnly = false; // Default to false here in case it's just a CreateTable script
}
function GenerateScripts($aTables, $bOutputHTML = false)
{
if (!is_array($aTables))
return false;
$this->m_aTables = $aTables;
reset($this->m_aTables);
$sAllTableSQL = "";
while (list($sTableName, $aTableDef) = each($this->m_aTables))
{
$sSequenceSQL = "";
if ($this->_GetTableSQL($sTableName, $aTableDef, $sTableSQL, $sSequenceSQL))
{
$sTableSQL = "CREATE TABLE $sTableName (\n$sTableSQL\n)"
. $this->m_oTranslator->m_sStatementTerminator;
if ($sSequenceSQL != "")
$sAllTableSQL .= $sSequenceSQL . "\n";
$sAllTableSQL .= $sTableSQL . "\n\n";
}
else
{
if ($bOutputHTML)
print("
Failed generating script for $sTableName
");
return false;
}
}
if ($bOutputHTML)
print("$sAllTableSQL
");
return true;
}
function ExecuteScripts($aTables, $bOutputHTML = false)
{
if (!is_array($aTables) || !IsSet($this->m_odb))
return false;
reset($aTables);
$this->m_aTables = $aTables;
while (list($sTableName, $aTableDef) = each($aTables))
{
if ($this->CreateTable($sTableName, $aTableDef))
{
if ($bOutputHTML)
echo "
Create Table $sTableName";
}
else
{
if ($bOutputHTML)
echo "
Create Table Failed For $sTableName";
return false;
}
}
return true;
}
function DropAllTables($aTables, $bOutputHTML = false)
{
if (!is_array($aTables) || !IsSet($this->m_odb))
return false;
$this->m_aTables = $aTables;
reset($this->m_aTables);
while (list($sTableName, $aTableDef) = each($this->m_aTables))
{
if ($this->DropTable($sTableName))
{
if ($bOutputHTML)
echo "
Drop Table $sTableSQL";
}
else
return false;
}
return true;
}
function DropTable($sTableName)
{
$retVal = $this->m_oDeltaProc->DropTable($this, $this->m_aTables, $sTableName);
if ($this->m_bDeltaOnly)
return $retVal;
return $retVal && $this->m_oTranslator->DropTable($this, $this->m_aTables, $sTableName);
}
function DropColumn($sTableName, $aTableDef, $sColumnName, $bCopyData = true)
{
$retVal = $this->m_oDeltaProc->DropColumn($this, $this->m_aTables, $sTableName, $aTableDef, $sColumnName, $bCopyData);
if ($this->m_bDeltaOnly)
return $retVal;
return $retVal && $this->m_oTranslator->DropColumn($this, $this->m_aTables, $sTableName, $aTableDef, $sColumnName, $bCopyData);
}
function RenameTable($sOldTableName, $sNewTableName)
{
$retVal = $this->m_oDeltaProc->RenameTable($this, $this->m_aTables, $sOldTableName, $sNewTableName);
if ($this->m_bDeltaOnly)
return $retVal;
return $retVal && $this->m_oTranslator->RenameTable($this, $this->m_aTables, $sOldTableName, $sNewTableName);
}
function RenameColumn($sTableName, $sOldColumnName, $sNewColumnName, $bCopyData = true)
{
$retVal = $this->m_oDeltaProc->RenameColumn($this, $this->m_aTables, $sTableName, $sOldColumnName, $sNewColumnName, $bCopyData);
if ($this->m_bDeltaOnly)
return $retVal;
return $retVal && $this->m_oTranslator->RenameColumn($this, $this->m_aTables, $sTableName, $sOldColumnName, $sNewColumnName, $bCopyData);
}
function AlterColumn($sTableName, $sColumnName, $aColumnDef, $bCopyData = true)
{
$retVal = $this->m_oDeltaProc->AlterColumn($this, $this->m_aTables, $sTableName, $sColumnName, $aColumnDef, $bCopyData);
if ($this->m_bDeltaOnly)
return $retVal;
return $retVal && $this->m_oTranslator->AlterColumn($this, $this->m_aTables, $sTableName, $sColumnName, $aColumnDef, $bCopyData);
}
function AddColumn($sTableName, $sColumnName, $aColumnDef)
{
$retVal = $this->m_oDeltaProc->AddColumn($this, $this->m_aTables, $sTableName, $sColumnName, $aColumnDef);
if ($this->m_bDeltaOnly)
return $retVal;
return $retVal && $this->m_oTranslator->AddColumn($this, $this->m_aTables, $sTableName, $sColumnName, $aColumnDef);
}
function CreateTable($sTableName, $aTableDef)
{
$retVal = $this->m_oDeltaProc->CreateTable($this, $this->m_aTables, $sTableName, $aTableDef);
if ($this->m_bDeltaOnly)
return $retVal;
return $retVal && $this->m_oTranslator->CreateTable($this, $this->m_aTables, $sTableName, $aTableDef);
}
function query($sQuery, $line = "", $file = "")
{
return $this->m_odb->query($sQuery, $line, $file);
}
function _GetTableSQL($sTableName, $aTableDef, &$sTableSQL, &$sSequenceSQL)
{
if (!is_array($aTableDef))
return false;
$sTableSQL = "";
reset($aTableDef["fd"]);
while (list($sFieldName, $aFieldAttr) = each($aTableDef["fd"]))
{
$sFieldSQL = "";
if ($this->_GetFieldSQL($aFieldAttr, $sFieldSQL))
{
if ($sTableSQL != "")
$sTableSQL .= ",\n";
$sTableSQL .= "$sFieldName $sFieldSQL";
if ($aFieldAttr["type"] == "auto")
{
$this->m_oTranslator->GetSequenceSQL($sTableName, $sFieldName, $sSequenceSQL);
if ($sSequenceSQL != "")
{
$sTableSQL .= sprintf(" DEFAULT nextval('%s_%s_seq')", $sTableName, $sFieldName);
}
}
}
else
{
echo "GetFieldSQL failed for $sFieldName";
return false;
}
}
$sUCSQL = "";
$sPKSQL = "";
if (count($aTableDef["pk"]) > 0)
{
if (!$this->_GetPK($aTableDef["pk"], $sPKSQL))
{
if ($bOutputHTML)
print("
Failed getting primary key
");
return false;
}
}
if (count($aTableDef["uc"]) > 0)
{
if (!$this->_GetUC($aTableDef["uc"], $sUCSQL))
{
if ($bOutputHTML)
print("
Failed getting unique constraint
");
return false;
}
}
if ($sPKSQL != "")
$sTableSQL .= ",\n" . $sPKSQL;
if ($sUCSQL != "")
$sTableSQL .= ",\n" . $sUCSQL;
return true;
}
// Get field DDL
function _GetFieldSQL($aField, &$sFieldSQL)
{
if (!is_array($aField))
return false;
$sType = "";
$iPrecision = 0;
$iScale = 0;
$sDefault = "";
$bNullable = true;
reset($aField);
while (list($sAttr, $vAttrVal) = each($aField))
{
switch ($sAttr)
{
case "type":
$sType = $vAttrVal;
break;
case "precision":
$iPrecision = (int)$vAttrVal;
break;
case "scale":
$iScale = (int)$vAttrVal;
break;
case "default":
$sDefault = $vAttrVal;
break;
case "nullable":
$bNullable = $vAttrVal;
break;
}
}
// Translate the type for the DBMS
if ($this->m_oTranslator->TranslateType($sType, $iPrecision, $iScale, $sFieldSQL))
{
if ($bNullable == false)
$sFieldSQL .= " NOT NULL";
if ($sDefault != "")
{
// Get default DDL - useful for differences in date defaults (eg, now() vs. getdate())
$sTranslatedDefault = $this->m_oTranslator->TranslateDefault($sDefault);
$sFieldSQL .= " DEFAULT '$sTranslatedDefault'";
}
return true;
}
print("
Failed to translate field: type[$sType] precision[$iPrecision] scale[$iScale]
");
return false;
}
function _GetPK($aFields, &$sPKSQL)
{
$sPKSQL = "";
if (count($aFields) < 1)
return true;
$sFields = "";
reset($aFields);
while (list($key, $sField) = each($aFields))
{
if ($sFields != "")
$sFields .= ",";
$sFields .= $sField;
}
$sPKSQL = $this->m_oTranslator->GetPKSQL($sFields);
return true;
}
function _GetUC($aFields, &$sUCSQL)
{
$sUCSQL = "";
if (count($aFields) < 1)
return true;
$sFields = "";
reset($aFields);
while (list($key, $sField) = each($aFields))
{
if ($sFields != "")
$sFields .= ",";
$sFields .= $sField;
}
$sUCSQL = $this->m_oTranslator->GetUCSQL($sFields);
return true;
}
}
?>