* * 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_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 = ''; switch($sType) { case 'auto': $sTranslated = 'int(11) auto_increment not null'; 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 $sTranslated; } 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 = ''; 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"; break; 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"; */ $sTranslated = "'type' => 'varchar', 'precision' => $iPrecision"; 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 $sTranslated; } function GetPKSQL($sFields) { return "PRIMARY KEY($sFields)"; } function GetUCSQL($sFields) { return "UNIQUE($sFields)"; } function GetIXSQL($sFields,$options=False) { $type = 'INDEX'; $length = ''; if (strtoupper($options) == 'FULLTEXT') { $type = 'FULLTEXT'; } if (is_numeric($options)) { $length = "($options)"; } return "$type($sFields $length)"; } 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($colinfo[0] == 'enum') { /* set prec to length of longest enum-value */ for($prec=0; list($nul,$name) = @each($scales);) { if($prec < (strlen($name) - 2)) { /* -2 as name is like "'name'" */ $prec = (strlen($name) - 2); } } } elseif ($scales[1]) { $prec = $scales[0]; $scale = $scales[1]; } $type = $this->rTranslateType($colinfo[0], $prec, $scale); 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); } // index over multiple columns if ($oProc->m_odb->f(3) == 'MUL') { $this->ix[] = $oProc->m_odb->f(0); } */ } $this->_GetIndices($oProc,$sTableName,$this->pk,$this->ix,$this->uc,$this->fk); /* 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 _GetIndices($oProc,$sTableName,&$aPk,&$aIx,&$aUc,&$aFk) { $aPk = $aIx = $aUc = $aFk = array(); $seq = $ix = $uc = 0; $oProc->m_odb->query("show index from $sTableName"); while ($oProc->m_odb->next_record()) { if ($seq >= $oProc->m_odb->f('Seq_in_index')) // new index started { $$type += 1; } if ($oProc->m_odb->f('Key_name') == 'PRIMARY') // pk { $aPk[] = $oProc->m_odb->f('Column_name'); $type = 'pk'; } elseif ($oProc->m_odb->f('Non_unique')) // ix { $aIx[$ix][] = $oProc->m_odb->f('Column_name'); $type = 'ix'; if ($oProc->m_odb->f('Comment') == 'FULLTEXT') { $aIx[$ix]['options'] = array('mysql' => 'FULLTEXT'); } elseif (intval($oProc->m_odb->f('Sub_part'))) { $aIx[$ix]['options'] = array('mysql' => intval($oProc->m_odb->f('Sub_part'))); } } else // uc { $aUc[$uc][] = $oProc->m_odb->f('Column_name'); $type = 'uc'; } $seq = $oProc->m_odb->f('Seq_in_index'); } //echo "Indices from $sTableName
pk=".print_r($aPk,True)."\nix=".print_r($aIx,True)."\nuc=".print_r($aUc,True)."
\n"; } 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 $sNewTableName")); } function RenameColumn($oProc, &$aTables, $sTableName, $sOldColumnName, $sNewColumnName, $bCopyData = true) { /* TODO: This really needs testing - it can affect primary keys, and other table-related objects like sequences and such */ global $DEBUG; if ($DEBUG) { echo '
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 '
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 !!($oProc->m_odb->query("ALTER TABLE $sTableName CHANGE $sColumnName $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; } } ?>