.-.-.-.-.-

<?php

/*
+---------------------------------------------------------------------------+
| Revive Adserver                                                           |
| http://www.revive-adserver.com                                            |
|                                                                           |
| Copyright: See the COPYRIGHT.txt file.                                    |
| License: GPLv2 or later, see the LICENSE.txt file.                        |
+---------------------------------------------------------------------------+
*/

require_once MAX_PATH.'/lib/OA/Upgrade/Upgrade.php';

/**
 * database vs schema integrity methods
 */
class OA_DB_Integrity
{

var $oUpgrader;
    var $oDBUpgrader;
    var $aTasksConstructiveAll;
    var $aTasksDestructiveAll;
    var $aTasksConstructiveSelected;
    var $aTasksDestructiveSelected;
    var $aMigrationMethods;

var $version;
    //var $OK = true;

function __construct()
    {

}

function getVersion()
    {
        $this->oUpgrader = new OA_Upgrade();
        if (!$this->oUpgrader->initDatabaseConnection())
        {
            return false;
        }
        $result = $this->oUpgrader->canUpgradeOrInstall();
        return array('canUpgrade'=>$result,'versionApp'=>$this->oUpgrader->versionInitialApplication,'versionSchema'=>$this->oUpgrader->versionInitialSchema['tables_core']);
    }

//function dumpData($versionSchema, $versionApp, $aExclude, $output='')
    function dumpData($aVariables)
    {
        $aResult = array();
        $aVariables['exclude']['hack'] = "(ad_category_assoc|campaigns_trackers|category|password_recovery|placement_zone_assoc|plugins_channel_delivery_assoc|plugins_channel_delivery_domains|plugins_channel_delivery_rules|targetstats|variable_publisher)";
        foreach ($aVariables['exclude'] AS $k => $pattern)
        {
            foreach ($this->oDBUpgrader->aDefinitionNew['tables'] AS $table => $aDef)
            {
                if (preg_match('/'.$pattern.'/', $table))
                {
                    unset($this->oDBUpgrader->aDefinitionNew['tables'][$table]);
                    $aResult[] = 'excluding table '.$table;
                }
            }
        }
        $this->oDBUpgrader->aDefinitionNew['name'] = $GLOBALS['_MAX']['CONF']['database']['name'];
        if (!$aVariables['output'])
        {
            $aVariables['output'] = MAX_PATH.'/var/'.$aVariables['appver'].'_data_tables_core_'.$aVariables['schema'].'_'.$this->oDBUpgrader->aDefinitionNew['name'].'.xml';
        }
        $prefix = $GLOBALS['_MAX']['CONF']['table']['prefix'];

$aResult[] = 'application version: '.$aVariables['appver'];
        $aResult[] = 'schema version: '.$aVariables['schema'];
        $aResult[] = 'source database: '.$GLOBALS['_MAX']['CONF']['database']['name'];
        $aResult[] = 'table prefix: '.$prefix;
        $aResult[] = 'output file: '.$aVariables['output'];

$options = array (
                            'output_mode'   =>    'file',
                            'output'        =>    $aVariables['output'],
                            'end_of_line'   =>    "\n",
                            'xsl_file'      =>    "",
                            'custom_tags'   => array('version'=>$aVariables['schema'], 'status'=>'final', 'application'=>$aVariables['appver']),
                            'prefix'        => $prefix,
                          );
        $error = $this->oDBUpgrader->oSchema->dumpDatabaseContent($this->oDBUpgrader->aDefinitionNew, $options);
        if (PEAR::isError($error))
        {
            $aResult[] = $error->getUserInfo();
        }
        $aDefinition = $this->oDBUpgrader->oSchema->parseDatabaseContentFile($aVariables['output'], array(), false, false, $this->oUpgrader->oTable->aDefinition);
        if (PEAR::isError($aDefinition))
        {
            $aResult[] = $aDefinition->getUserInfo();
        }
        foreach ($aDefinition['tables'] as $table_name => $aTable)
        {
            $count = count($aTable['initialization']);
            $aResult[] = $count.' rows dumped from table '.$prefix.$table_name;
        }
        return $aResult;
    }

if ($this->init($aVariables['schema'], $aVariables['dbname']))
            {
                if ($this->oUpgrader->oTable->init(MAX_PATH.'/etc/changes/schema_tables_core_'.$aVariables['schema'].'.xml'))
                {
                    $aDefinition = $this->oDBUpgrader->oSchema->parseDatabaseContentFile($aVariables['directory'].$aVariables['datafile'], array(), false, false, $this->oUpgrader->oTable->aDefinition);
                    if (PEAR::isError($aDefinition))
                    {
                        $aResult[] = $aDefinition->getUserInfo();
                        return $aResult;
                    }
                    if (!$aVariables['dryrun'])
                    {
                        $this->oUpgrader->oTable->dropAllTables();
                        if (!$this->oUpgrader->oTable->createAllTables())
                        {
                            $aResult[] = 'ERROR creating all tables';
                            return $aResult;
                        }
    /*                    $query = 'SET SQL_MODE="NO_AUTO_VALUE_ON_ZERO"';
                        $mdb2_result = $this->oUpgrader->oDbh->exec($query);
                        if (PEAR::isError($mdb2_result))
                        {
                            $aResult[] = $mdb2_result->getUserInfo();
                        }
    */                }
                    foreach ($aDefinition['tables'] as $table_name => $aTable)
                    {
                        if (empty($aTable['initialization'])) {
                            continue;
                        }
                        $count = count($aTable['initialization']);
                        if ($aVariables['dryrun'])
                        {
                            $aResult[] = $count.' rows to insert into table '.$aVariables['prefix'].$table_name;
                        }
                        else
                        {
                            $aTable['fields'] = $this->oUpgrader->oTable->aDefinition['tables'][$table_name]['fields'];
                            //$aTable['indexes'] = $this->oUpgrader->oTable->aDefinition['tables'][$table_name]['indexes'];
                            $rows = $this->oDBUpgrader->oSchema->initializeTable($aVariables['prefix'].$table_name, $aTable,true);
                            if (PEAR::isError($rows))
                            {
                                $aResult[] = $rows->getUserInfo();
                            }
                            else if ($rows['error'])
                            {
                                $aResult[] = $rows['error'];
                            }
                            else
                            {
                                $msg = $rows['count'].' / '.$count.' rows inserted into table '.$aVariables['prefix'].$table_name;
                                if ($rows['count'] <> $count)
                                {
                                    $msg = 'ERROR! '.$msg;
                                }
                                $aResult[] = $msg;
                            }
                        }
                    }
                }
                else
                {
                    $aResult[] = 'table initialisation error';
                }
            }
            else
            {
                $aResult[] = 'initialisation error';
            }
        }
        return $aResult;
    }

// this one is called from within OA_Upgrade during detectMax
    // OA_Upgrade assigns itself after instantiation
    // compiles constructive tasks but does not prune or execute
    function checkIntegrityQuick($version, $aSchema='')
    {
        $this->_clearProperties();
        $this->version                      = $version;
        $this->oDBUpgrader                  =  $this->oUpgrader->oDBUpgrader;
        $this->_initDBUpgrader($aSchema['schemaOld']);
        if (!$this->oDBUpgrader->buildSchemaDefinition())
        {
            return false;
        }
        if (!$this->oDBUpgrader->applySchemaDefinitionChanges($this->version))
        {
            return false;
        }
        if (! $this->oDBUpgrader->checkSchemaIntegrity($this->getFileChanges()))
        {
            return false;
        }
        if (!$this->oDBUpgrader->init('constructive', $aSchema['name'], $this->version, 'switchTiming'))
        {
            return false;
        }
        if (!$this->oDBUpgrader->_verifyTasks())
        {
            return false;
        }
        $this->aTasksConstructiveAll = $this->oDBUpgrader->aTaskList;
        return true;
    }

// this one is called via standalone util
    // which calls the init method to instantiate OA_Upgrade
    // compiles, prunes and executes constructive and destructive tasks
    function checkIntegrity()
    {
        if (! $this->oDBUpgrader->checkSchemaIntegrity($this->getFileChanges()))
        {
            return false;
        }
        if (!$this->oDBUpgrader->init('constructive', 'tables_core', $this->version, 'switchTiming'))
        {
            return false;
        }
        if (!$this->oDBUpgrader->_verifyTasks())
        {
            return false;
        }
        $this->aTasksConstructiveAll = $this->oDBUpgrader->aTaskList;
        if (!$this->oDBUpgrader->init('destructive', 'tables_core', $this->version, 'switchTiming'))
        {
            return false;
        }
        if (!$this->oDBUpgrader->_verifyTasks())
        {
            return false;
        }
        $this->aTasksDestructiveAll = $this->oDBUpgrader->aTaskList;

return true;
    }

function mockMigration()
    {
        require_once MAX_PATH.'/lib/simpletest/mock_objects.php';
        require_once MAX_PATH.'/lib/OA/Upgrade/Migration.php';
        Mock::generatePartial(
            'Migration',
            $mockMigrator = 'Migration_'.rand(),
            array_keys($this->aMigrationMethods)
        );
        $this->oDBUpgrader->oMigrator = new $mockMigrator($this);

foreach ($this->aMigrationMethods as $k => $v)
        {
            $this->oDBUpgrader->oMigrator->setReturnValue($k, $v);
            $this->oDBUpgrader->oMigrator->expectOnce($k);
        }
    }

function getMessages()
    {
        return $this->oUpgrader->getMessages();
    }

function getFileSchema()
    {
        return $this->oDBUpgrader->file_schema;
    }

function getFileChanges()
    {
        return $this->oDBUpgrader->file_changes;
    }

function getConstructiveOK()
    {
        return empty($this->aTasksConstructiveAll);
    }

function getDestructiveOK()
    {
        return empty($this->aTasksDestructiveAll);
    }

function _clearProperties()
    {
        $this->aTasksConstructiveAll        = array();
        $this->aTasksDestructiveAll         = array();
        $this->aTasksConstructiveSelected   = array();
        $this->aTasksDestructiveSelected    = array();
        $this->version                      = '';
    }

function _initDBUpgrader($schema='')
    {
        $this->oDBUpgrader->prefix          = $GLOBALS['_MAX']['CONF']['table']['prefix'];
        $this->oDBUpgrader->database        = $GLOBALS['_MAX']['CONF']['database']['name'];
        if (empty($schema))
        {
            $this->oDBUpgrader->path_schema     = MAX_PATH.'/etc/changes/';
            $this->oDBUpgrader->file_schema     = $this->oDBUpgrader->path_schema.$this->_getXMLFilename();
        }
        else
        {
            $this->oDBUpgrader->path_schema     = dirname($schema);
            $this->oDBUpgrader->file_schema     = $schema;
        }

$this->oDBUpgrader->path_changes    = MAX_PATH.'/var/';
        $this->oDBUpgrader->file_changes    = $this->oDBUpgrader->path_changes.$this->_getXMLFilename('changes');
    }

function _getXMLFilename($prefix='schema')
    {
        return $prefix.'_tables_core'.($this->version ? '_'.$this->version : '').'.xml';
    }

}

/home/pressec/www/ads--temp-pour-eviter-les-spams/lib/wact/../OA/Upgrade/DB_Integrity.php