Connect($db_hostname,$db_username,$db_password)) {
$db_server_status = true;
$serverInfo = $conn->ServerInfo();
if($db_type=='mysql') {
$version = explode('-',$serverInfo);
$mysql_server_version=$version[0];
}
// test the connection to the old database
$olddb_conn = &NewADOConnection($db_type);
if(@$olddb_conn->Connect($db_hostname, $db_username, $db_password, $old_db_name))
{
$old_db_exist_status = true;
if(authenticate_user($user_name,$user_pwd)==true){
$is_admin = true;
}
else{
echo 'NOT_VALID_USER';
return false;
}
$olddb_conn->Close();
}
// test the connection to the new database
$newdb_conn = &NewADOConnection($db_type);
if(@$newdb_conn->Connect($db_hostname, $db_username, $db_password, $new_db_name))
{
$new_db_exist_status = true;
$_SESSION['migration_info']['db_utf8_support'] = check_db_utf8_support($newdb_conn);
$newdb_conn->Close();
}
}
$conn->Close();
}
if(!$db_type_status || !$db_server_status) {
$error_msg = 'ERR - Unable to connect to database Server. Invalid mySQL Connection Parameters specified';
$error_msg_info = 'This may be due to the following reasons:
- specified database user, password, hostname, database type, or port is invalid. More Information
- specified database user does not have access to connect to the database server from the host';
} elseif($db_type == 'mysql' && $mysql_server_version < '4.1') {
$error_msg = 'ERR - MySQL version '.$mysql_server_version.' is not supported, kindly connect to MySQL 4.1.x or above';
} elseif(!$old_db_exist_status) {
$error_msg = 'ERR - The Database "'.$old_db_name.'" is not found. Provide the correct database name';
} elseif(!$new_db_exist_status) {
$error_msg = 'ERR - The Database "'.$new_db_name.'" is not found. Provide the correct database name';
} else {
$_SESSION['authentication_key'] = md5(microtime());
return true;
}
echo $error_msg."\n".$error_msg_info;
return false;
}
}
class vtiger_DatabaseMigration{
function process(){
set_time_limit(0);//ADDED TO AVOID UNEXPECTED TIME OUT WHILE MIGRATING
$returnValue = vtiger_DatabaseMigration::initMigration();
if ($returnValue !== true) {
echo $returnValue;
return false;
}
global $dbconfig;
require (dirname(__FILE__) . '/config.inc.php');
$dbtype = $dbconfig['db_type'];
$host = $dbconfig['db_server'].$dbconfig['db_port'];
$dbname = $dbconfig['db_name'];
$username = $dbconfig['db_username'];
$passwd = $dbconfig['db_password'];
global $adb,$migrationlog;
$adb = new PearDatabase($dbtype,$host,$dbname,$username,$passwd);
// Why do we do this here? We shouldn't alter here if its not in UTF8.
$query = " ALTER DATABASE ".$dbname." DEFAULT CHARACTER SET utf8";
$adb->query($query);
$source_directory = $_SESSION['migration_info']['source_directory'];
if(file_exists($source_directory.'user_privileges/CustomInvoiceNo.php')) {
require_once($source_directory.'user_privileges/CustomInvoiceNo.php');
}
$versions_non_utf8 = array("50","501","502","503rc2","503","504rc");
$php_max_execution_time = 0;
$migrationlog =& LoggerManager::getLogger('MIGRATION');
if (isset($_SESSION['migration_info']['old_version'])) $source_version = $_SESSION['migration_info']['old_version'];
if(!isset($source_version) || empty($source_version)) {
//If source version is not set then we cannot proceed
echo " Source Version is not set. Please check vtigerversion.php and contiune the Patch Process";
exit;
}
$reach = 0;
include(dirname(__FILE__)."/modules/Migration/versions.php");
foreach($versions as $version => $label) {
if($version == $source_version || $reach == 1) {
$reach = 1;
$temp[] = $version;
}
}
$temp[] = $current_version;
global $adb, $dbname;
$_SESSION['adodb_current_object'] = $adb;
@ini_set('zlib.output_compression', 0);
@ini_set('output_buffering','off');
ob_implicit_flush(true);
echo '
';
echo "
Going to apply the Database Changes...
";
for($patch_count=0;$patch_count ".$temp[$patch_count+1]." Database changes -- Starts.".$end_tag;
include($filename);//include the file which contains the corresponding db changes
echo $start_tag.$temp[$patch_count]." ==> ".$temp[$patch_count+1]." Database changes -- Ends.".$end_tag;
}
}
//Here we have to update the version in table. so that when we do migration next time we will get the version
$res = $adb->query('SELECT * FROM vtiger_version');
global $vtiger_current_version;
require(dirname(__FILE__).'/vtigerversion.php');
if($adb->num_rows($res)) {
$res = ExecuteQuery("UPDATE vtiger_version SET old_version='$versions[$source_version]',current_version='$vtiger_current_version'");
$completed = true;
} else {
ExecuteQuery("INSERT INTO vtiger_version (id, old_version, current_version) values (".$adb->getUniqueID('vtiger_version').", '$versions[$source_version]', '$vtiger_current_version');");
$completed = true;
}
echo '
';
if($completed==true){
echo "";
}
create_tab_data_file();
create_parenttab_data_file();
if($completed ==true){
return true;
}
}
function initMigration() {
if(vtiger_DatabaseMigration::createConfigFile() == false) {
return "FAILURE: Writing to config file. check permissions.";
}
$migrationInfo = $_SESSION['migration_info'];
$sourceDirectory = $migrationInfo['source_directory'];
$destinationDirectory = $migrationInfo['root_directory'];
if (realpath($sourceDirectory) != realpath($destinationDirectory)) {
vtiger_DatabaseMigration::copyRequiredFiles($sourceDirectory, $destinationDirectory);
}
return true;
}
function createConfigFile() {
$migrationInfo = $_SESSION['migration_info'];
require_once($migrationInfo['source_directory'].'config.inc.php');
//Writing to Config file
if (is_file('config.inc.php'))
$is_writable = is_writable('config.inc.php');
else
$is_writable = is_writable('.');
$dbtype=$migrationInfo['db_type'];
$host=$migrationInfo['db_hostname'];
$dbname=$migrationInfo['new_dbname'];
$dbusername=$migrationInfo['db_username'];
$dbpasswd=$migrationInfo['db_password'];
$dbserver=$migrationInfo['db_server'];
$dbport=$migrationInfo['db_port'];
$root_directory = str_replace("\\\\","/",$migrationInfo['root_directory']);
$vt_charset = ($migrationInfo['db_utf8_support'])? "UTF-8" : "ISO-8859-1";
$admin_emailid = $migrationInfo['admin_emailid'];
$currency_name = $migrationInfo['currency_name'];
$cache_dir = "cache/";
$web_root = ($_SERVER["HTTP_HOST"]) ? $_SERVER["HTTP_HOST"]:$_SERVER['SERVER_NAME'].':'.$_SERVER['SERVER_PORT'];
$web_root .= $_SERVER["REQUEST_URI"];
$web_root = eregi_replace("/install.php(.)*", "", $web_root);
$site_URL = "http://".$web_root;
/* open template configuration file read only */
$templateFilename = 'config.template.php';
$templateHandle = fopen($templateFilename, "r");
if($templateHandle) {
/* open include configuration file write only */
$includeFilename = 'config.inc.php';
$includeHandle = fopen($includeFilename, "w");
if($includeHandle) {
while (!feof($templateHandle)) {
$buffer = fgets($templateHandle);
/* replace _DBC_ variable */
$buffer = str_replace( "_DBC_SERVER_", $dbserver, $buffer);
$buffer = str_replace( ":_DBC_PORT_", $dbport, $buffer);
$buffer = str_replace( "_DBC_USER_", $dbusername, $buffer);
$buffer = str_replace( "_DBC_PASS_", $dbpasswd, $buffer);
$buffer = str_replace( "_DBC_NAME_", $dbname, $buffer);
$buffer = str_replace( "_DBC_TYPE_", $dbtype, $buffer);
$buffer = str_replace( "_SITE_URL_", $site_URL, $buffer);
/* replace dir variable */
$buffer = str_replace( "_VT_ROOTDIR_", $root_directory, $buffer);
$buffer = str_replace( "_VT_CACHEDIR_", $cache_dir, $buffer);
$buffer = str_replace( "_VT_TMPDIR_", $cache_dir."images/", $buffer);
$buffer = str_replace( "_VT_UPLOADDIR_", $cache_dir."upload/", $buffer);
$buffer = str_replace( "_DB_STAT_", "true", $buffer);
/* replace charset variable */
$buffer = str_replace( "_VT_CHARSET_", $vt_charset, $buffer);
/* replace master currency variable */
$buffer = str_replace( "_MASTER_CURRENCY_", $currency_name, $buffer);
/* replace the application unique key variable */
$buffer = str_replace( "_VT_APP_UNIQKEY_", md5($root_directory), $buffer);
/* replace support email variable */
$buffer = str_replace( "_USER_SUPPORT_EMAIL_", $admin_emailid, $buffer);
fwrite($includeHandle, $buffer);
}
flush();
fclose($includeHandle);
}
fclose($templateHandle);
}
if (!($templateHandle && $includeHandle)) {
return false;
}
return true;
}
function copyRequiredFiles($sourceDirectory, $destinationDirectory) {
@get_files_from_folder($sourceDirectory."user_privileges/",$destinationDirectory."user_privileges/",
// Force copy these files - Overwrite if they exist in destination directory.
array($sourceDirectory."user_privileges/default_module_view.php")
);
@get_files_from_folder($sourceDirectory."storage/",$destinationDirectory."storage/");
}
}
function authenticate_user($user_name,$user_password){
$salt = substr($user_name, 0, 2);
$sql = mysql_query("SELECT * from vtiger_users WHERE user_name = '$user_name'");
$result = mysql_fetch_array($sql);
$crypt_type = $result['crypt_type'];
if($crypt_type == 'MD5') {
$salt = '$1$' . $salt . '$';
} else if($crypt_type == 'BLOWFISH') {
$salt = '$2$' . $salt . '$';
}
$encrypted_password = crypt($user_password, $salt);
$password = $result['user_password'];
$status = $result['status'];
$is_admin = $result['is_admin'];
if(!($password == $encrypted_password) || !($status=='Active') || !($is_admin=='on')){
return false;
}
return true;
}
function get_files_from_folder($source, $dest, $forcecopy=false) {
if(!$forcecopy) $forcecopy = Array();
if ($handle = opendir($source)) {
while (false != ($file = readdir($handle))) {
if (is_file($source.$file)) {
if(!file_exists($dest.$file) || in_array($source.$file, $forcecopy)){
$file_handle = fopen($dest.$file,'w');
fclose($file_handle);
copy($source.$file, $dest.$file);
}
} elseif ($file != '.' && $file != '..' && is_dir($source.$file)) {
mkdir($dest.$file.'/',0777);
get_files_from_folder($source.$file.'/', $dest.$file.'/');
}
}
}
@closedir($handle);
}
//Function used to execute the query and display the success/failure of the query
function ExecuteQuery($query)
{
global $adb;
global $conn, $query_count, $success_query_count, $failure_query_count, $success_query_array, $failure_query_array;
global $migrationlog;
//For third option migration we have to use the $conn object because the queries should be executed in 4.2.3 db
$status = $adb->query($query);
$query_count++;
if(is_object($status))
{
echo '