$sClass) {
if ($iRev > $iCurrRev) {
return $iRev;
}
}
}
if (!isset(self::$_aUpdateClasses[$iCurrRev])) {
return 0;
}
return $iCurrRev;
}
/**
* main updater entry
* @return null
*/
public static function updateStart()
{
$sCurrAction = oxRegistry::getConfig()->getRequestParameter( 'sCurrAction' );
$iCurrRevision = (int) oxRegistry::getConfig()->getRequestParameter( 'iCurrRevision' );
$iCurrRevision = self::findNextRevision($iCurrRevision);
if ($iCurrRevision == 0) {
echo "rev not found
\n";
exit(0);
}
$sClass = self::$_aUpdateClasses[$iCurrRevision];
if (class_exists($sClass)) {
$oClass = new $sClass;
if ($oClass instanceof updateBase) {
if (!$sCurrAction) {
$sCurrAction = $oClass->_sDefaultAction;
}
$iNextRev = $iCurrRevision;
$sNextAction = $oClass->update($sCurrAction);
if (!$sNextAction) {
$iNextRev = self::findNextRevision($iCurrRevision + 1);
}
$oClass->printUpdateUI($sCurrAction, $sNextAction, $iNextRev);
} else {
echo "unknown class found $sClass
\n";
}
} else {
echo "class not found $sClass
\n";
}
}
/**
* registers new class for update
*
* @param int $iRev
* @param string $sClass
* @return null
*/
public static function registerUpdate($iRev, $sClass)
{
self::$_aUpdateClasses[$iRev] = $sClass;
}
/**
* prints update UI
*
* @param $sCurrAction
* @param $sNextAction
* @param $iRev 'update from' revision, if 0, then done
*
* @return null
*/
protected function printUpdateUI($sCurrAction, $sNextAction, $iRev)
{
?>
Update script
translateString( 'charset', null, true );
?>
Update script
getRequestParameter( 'sCurrCharset' );
$sCharset = $sCharset ? trim( $sCharset ) : null;
if ( !$sCharset ) {
$this->showEncodingSelectionUi();
}
// testing if user passed charset name is valid
if ( iconv( $sCharset, "UTF-8", "test" ) === false ) {
$this->showEncodingSelectionUi( true );
}
$oxSession = oxRegistry::getSession();
$oxSession->start();
$oxSession->setVariable( 'sCurrCharset', $sCharset );
return 'backupConfigData';
}
/**
* Config data is very important, so we can only work with backuped
* data. Returns name of next function to execute
*
* @return string
*/
public function backupConfigData()
{
$sQ = "INSERT INTO oxconfig ( oxid, oxshopid, oxmodule, oxvarname, oxvartype, oxvarvalue )
SELECT CONCAT( '@#', SUBSTRING( MD5( CONCAT( oxid, oxvarname ) ), 2 ) ), oxshopid, oxmodule, oxvarname, oxvartype, oxvarvalue FROM oxconfig WHERE oxid NOT LIKE '@%'";
oxDb::getDb()->execute( $sQ );
return 'convertConfigData';
}
/**
* Converts config data. Returns name of next function to execute
*
* @return string
*/
public function convertConfigData()
{
$oDb = oxDb::getDb( true );
// checking if there is still what todo
$iUpdateCount = $oDb->getOne( "SELECT 1 FROM oxconfig WHERE oxid LIKE '@#%'" );
// work is done ?
if ( !$iUpdateCount ) {
return 'previewConvertedConfigData';
}
// continuing update ..
$sQ = "SELECT oxid, oxvartype, HEX(DECODE( oxvarvalue, '".$this->getConfig()->getConfigParam( 'sConfigKey' )."')) AS oxvarvalue FROM oxconfig
WHERE oxid LIKE '@#%'";
$iUpdateCnt = 0;
$oRs = oxDb::getDb(oxDB::FETCH_MODE_ASSOC)->Execute( $sQ );
if ( $oRs != false && $oRs->recordCount() > 0) {
while ( !$oRs->EOF ) {
// updating limited count of records per tick ..
if ( $iUpdateCnt > $this->_iRecPerTick ) {
break;
}
$sVarId = $oRs->fields['oxid'];
$sVarType = $oRs->fields['oxvartype'];
$sVarVal = pack( "H*", $oRs->fields['oxvarvalue'] );
switch ( $sVarType ) {
case 'arr':
case 'aarr':
$this->_encodeConfigArray( $sVarId, $sVarType, $sVarVal );
break;
case 'str':
$this->_encodeConfigString( $sVarId, $sVarType, $sVarVal );
break;
default:
$this->_markAsUpdated( $sVarId, $sVarType );
}
$oRs->moveNext();
$iUpdateCnt++;
}
}
return 'convertConfigData';
}
/**
* Return config instance
*
* @return oxconfig
*/
public function getConfig()
{
return oxRegistry::getConfig();
}
/**
* Returns user chosen charset
*
* @return string
*/
protected function _getInCharset()
{
$sCharset = oxRegistry::getSession()->getVariable( 'sCurrCharset' );
return $sCharset;
}
/**
* Returns charset used to encode config data
*
* @return string
*/
protected function _getOutCharset()
{
return "UTF-8";
}
/**
* Updates config value
*
* @param string $sVarId variable id
* @param string $sVarType variable type
* @param string $sVarVal variable value
*
* @return null
*/
protected function _updateConfigValue( $sVarId, $sVarType, $sVarVal )
{
// updating and marking as updated
$sQ = "UPDATE oxconfig SET oxvarvalue = ENCODE( '$sVarVal', '".$this->getConfig()->getConfigParam('sConfigKey')."'), oxid = CONCAT( '@', SUBSTRING( oxid, 3 ) ) WHERE oxid = '$sVarId' AND oxvartype = '$sVarType'";
oxDb::getDb()->execute( $sQ );
}
/**
* Marks config field as updated
*
* @return null
*/
protected function _markAsUpdated( $sVarId, $sVarType )
{
// updating and marking as updated
$sQ = "UPDATE oxconfig SET oxid = CONCAT( '@', SUBSTRING( oxid, 3 ) ) WHERE oxid = '$sVarId' AND oxvartype = '$sVarType'";
oxDb::getDb()->execute( $sQ );
}
/**
* Returns encoded value
*
* @param string $sVal value to encode
*
* @return string
*/
protected function _getEncodedVal( $sVal )
{
return iconv( $this->_getInCharset(), $this->_getOutCharset(), $sVal );
}
/**
* Recursivelly encodes config array and returns it
*
* @param array $aVarVal config array
*
* @return array
*/
protected function _encodeArray( $aVarVal )
{
$aNewVal = array();
foreach ( $aVarVal as $sArrKey => $sArrValue ) {
if ( is_array( $sArrValue ) ) {
$sArrValue = $this->_encodeArray( $sArrValue );
} else {
$sArrValue = $this->_getEncodedVal( $sArrValue );
}
$aNewVal[ $this->_getEncodedVal( $sArrKey ) ] = $sArrValue;
}
return $aNewVal;
}
/**
* ReEncodes array
*
* @param string $sVarId variable id
* @param string $sVarType variable type
* @param string $sVarVal variable value
*
* @return null
*/
protected function _encodeConfigArray( $sVarId, $sVarType, $sVarVal )
{
if ( ( $aVarVal = unserialize( $sVarVal ) ) !== false && is_array( $aVarVal ) ) {
$this->_updateConfigValue( $sVarId, $sVarType, serialize( $this->_encodeArray( $aVarVal ) ) );
} else {
$this->_markAsUpdated( $sVarId, $sVarType );
}
}
/**
* ReEncodes string value
*
* @param string $sVarId variable id
* @param string $sVarType variable type
* @param string $sVarVal variable value
*
* @return null
*/
protected function _encodeConfigString( $sVarId, $sVarType, $sVarVal )
{
$sVarVal = $this->_getEncodedVal( $sVarVal );
$this->_updateConfigValue( $sVarId, $sVarType, $sVarVal );
}
/**
* Deleting old config data
*
* @return null
*/
public function previewConvertedConfigData()
{
// selecting fields which were changed for user preview
$sQ = "SELECT test1.oxshopid, test1.oxvartype as oxvartype, test1.oxvarname as oxvarname, HEX(DECODE( test1.oxvarvalue, '".$this->getConfig()->getConfigParam( 'sConfigKey' )."')) AS oxvarvalue
FROM `oxconfig` AS test1, `oxconfig` AS test2
WHERE test1.oxvarname = test2.oxvarname AND
test1.oxshopid = test2.oxshopid AND
test1.oxvarvalue != test2.oxvarvalue AND
test1.oxid LIKE '@%' ORDER BY test1.oxshopid";
?>
Update script
";
$sCurrShopId = null;
$oRs = oxDb::getDb(oxDB::FETCH_MODE_ASSOC)->Execute( $sQ );
if ( $oRs != false && $oRs->recordCount() > 0) {
$iCnt = 0;
while ( !$oRs->EOF ) {
$sShopId = $oRs->fields['oxshopid'];
$sVarType = $oRs->fields['oxvartype'];
$sVarName = $oRs->fields['oxvarname'];
$sVarVal = pack( "H*", $oRs->fields['oxvarvalue'] );
if ( $sCurrShopId != $sShopId && $sShopId != 'oxbaseshop' ) {
echo "| Shop id: {$sShopId} |
";
$sCurrShopId = $sShopId;
}
echo "| {$sVarName} | ";
switch ( $sVarType ) {
case 'arr':
case 'aarr':
print_r( unserialize( $sVarVal ) );
break;
default:
echo $sVarVal;
}
echo " |
";
$oRs->moveNext();
$iCnt++;
if ( $iCnt > 1 ) {
$iCnt = 0;
}
}
}
echo "";
?>
execute( $sQ );
exit;
}
public function proceedToNextStep()
{
}
/**
* revisioned updater entry
* returns next action
*
* @param string $sAction
*
* @return string
*/
public function update($sAction)
{
return $this->$sAction();
}
}
updateBase::registerUpdate(1, 'update_utf8');
updateBase::updateStart();