* * and Miles Lott * * -------------------------------------------- * * 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 { var $m_oTranslator; var $m_oDeltaProc; var $m_odb; var $m_aTables; var $m_bDeltaOnly; function schema_proc($dbms) { $this->m_oTranslator = CreateObject('etemplate.schema_proc_' . $dbms); $this->m_oDeltaProc = CreateObject('etemplate.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 f($value) { if($this->m_bDeltaOnly) { // Don't care, since we are processing deltas only return False; } return $this->m_odb->f($value); } function num_rows() { if($this->m_bDeltaOnly) { // If not False, we will cause while loops calling us to hang return False; } return $this->m_odb->num_rows(); } function next_record() { if($this->m_bDeltaOnly) { // If not False, we will cause while loops calling us to hang return False; } return $this->m_odb->next_record(); } function query($sQuery, $line='', $file='') { if($this->m_bDeltaOnly) { // Don't run this query, since we are processing deltas only return True; } return $this->m_odb->query($sQuery, $line, $file); } function _GetTableSQL($sTableName, $aTableDef, &$sTableSQL, &$sSequenceSQL) { global $DEBUG; 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, $sSequenceSQL); if($sSequenceSQL != '') { $sTableSQL .= sprintf(" DEFAULT nextval('seq_%s')", $sTableName); } } } else { if($DEBUG) { 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) { global $DEBUG; if($DEBUG) { echo'
_GetFieldSQL(): Incoming ARRAY: '; var_dump($aField); } 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; if($DEBUG) { echo'
_GetFieldSQL(): Default="' . $sDefault . '"'; } break; case 'nullable': $bNullable = $vAttrVal; break; } } // Translate the type for the DBMS if($sFieldSQL = $this->m_oTranslator->TranslateType($sType, $iPrecision, $iScale)) { if($bNullable == False) { $sFieldSQL .= ' NOT NULL'; } if($sDefault != '') { if($DEBUG) { echo'
_GetFieldSQL(): Calling TranslateDefault for "' . $sDefault . '"'; } // Get default DDL - useful for differences in date defaults (eg, now() vs. getdate()) $sTranslatedDefault = $this->m_oTranslator->TranslateDefault($sDefault); $sFieldSQL .= " DEFAULT '$sTranslatedDefault'"; } elseif($sDefault == '0') { $sFieldSQL .= " DEFAULT '0'"; } if($DEBUG) { echo'
_GetFieldSQL(): Outgoing SQL: ' . $sFieldSQL; } return true; } if($DEBUG) { echo '
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; } } ?>