2013-12-07 17:44:23 +04:00
|
|
|
<?php
|
|
|
|
/**
|
|
|
|
* Copyright (c) 2013 Bart Visscher <bartv@thisnet.nl>
|
|
|
|
* This file is licensed under the Affero General Public License version 3 or
|
|
|
|
* later.
|
|
|
|
* See the COPYING-README file.
|
|
|
|
*
|
|
|
|
*/
|
|
|
|
|
|
|
|
namespace OC\Core\Command\Db;
|
|
|
|
|
|
|
|
use Symfony\Component\Console\Command\Command;
|
|
|
|
use Symfony\Component\Console\Input\InputArgument;
|
|
|
|
use Symfony\Component\Console\Input\InputInterface;
|
|
|
|
use Symfony\Component\Console\Input\InputOption;
|
|
|
|
use Symfony\Component\Console\Output\OutputInterface;
|
|
|
|
|
|
|
|
class ConvertFromSqlite extends Command {
|
2013-12-24 16:36:32 +04:00
|
|
|
/**
|
|
|
|
* @var \OC\Config $config
|
|
|
|
*/
|
|
|
|
protected $config;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @param \OC\Config $config
|
|
|
|
*/
|
|
|
|
public function __construct($config) {
|
|
|
|
$this->config = $config;
|
|
|
|
parent::__construct();
|
|
|
|
}
|
|
|
|
|
2013-12-07 17:44:23 +04:00
|
|
|
protected function configure() {
|
|
|
|
$this
|
|
|
|
->setName('db:convert-from-sqlite')
|
|
|
|
->setDescription('Convert the owncloud sqlite database to the newly configured one')
|
|
|
|
->addArgument(
|
|
|
|
'type',
|
|
|
|
InputArgument::REQUIRED,
|
|
|
|
'the type of the database to convert to'
|
|
|
|
)
|
|
|
|
->addArgument(
|
|
|
|
'username',
|
|
|
|
InputArgument::REQUIRED,
|
|
|
|
'the username of the database to convert to'
|
|
|
|
)
|
|
|
|
->addArgument(
|
|
|
|
'hostname',
|
|
|
|
InputArgument::REQUIRED,
|
|
|
|
'the hostname of the database to convert to'
|
|
|
|
)
|
|
|
|
->addArgument(
|
|
|
|
'database',
|
|
|
|
InputArgument::REQUIRED,
|
|
|
|
'the name of the database to convert to'
|
|
|
|
)
|
|
|
|
->addOption(
|
|
|
|
'port',
|
|
|
|
null,
|
|
|
|
InputOption::VALUE_REQUIRED,
|
|
|
|
'the port of the database to convert to'
|
|
|
|
)
|
|
|
|
->addOption(
|
|
|
|
'password',
|
|
|
|
null,
|
|
|
|
InputOption::VALUE_REQUIRED,
|
|
|
|
'the password of the database to convert to. Will be asked when not specified'
|
|
|
|
)
|
|
|
|
;
|
|
|
|
}
|
|
|
|
|
|
|
|
private static $type2driver = array(
|
|
|
|
'mysql' => 'pdo_mysql',
|
|
|
|
'pgsql' => 'pdo_pgsql',
|
|
|
|
'oci' => 'oci8',
|
|
|
|
'mssql' => 'pdo_sqlsrv',
|
|
|
|
);
|
|
|
|
protected function execute(InputInterface $input, OutputInterface $output) {
|
|
|
|
// connect 'from' database
|
2013-12-24 16:36:32 +04:00
|
|
|
$datadir = $this->config->getValue( "datadirectory", \OC::$SERVERROOT.'/data' );
|
|
|
|
$name = $this->config->getValue( "dbname", "owncloud" );
|
2013-12-07 17:44:23 +04:00
|
|
|
$dbfile = $datadir.'/'.$name.'.db';
|
|
|
|
$connectionParams = array(
|
|
|
|
'path' => $dbfile,
|
|
|
|
'driver' => 'pdo_sqlite',
|
|
|
|
);
|
|
|
|
$fromDB = \Doctrine\DBAL\DriverManager::getConnection($connectionParams);
|
|
|
|
|
|
|
|
// connect 'to' database
|
|
|
|
$type = $input->getArgument('type');
|
|
|
|
$username = $input->getArgument('username');
|
|
|
|
$hostname = $input->getArgument('hostname');
|
|
|
|
$dbname = $input->getArgument('database');
|
|
|
|
|
|
|
|
if ($input->getOption('password')) {
|
|
|
|
$password = $input->getOption('password');
|
|
|
|
} else {
|
|
|
|
// TODO: should be moved to the interact function
|
|
|
|
$dialog = $this->getHelperSet()->get('dialog');
|
|
|
|
$password = $dialog->askHiddenResponse(
|
|
|
|
$output,
|
|
|
|
'What is the database password?',
|
|
|
|
false
|
|
|
|
);
|
|
|
|
}
|
|
|
|
$connectionParams = array(
|
|
|
|
'driver' => self::$type2driver[$type],
|
|
|
|
'user' => $username,
|
|
|
|
'password' => $password,
|
|
|
|
'host' => $hostname,
|
|
|
|
'dbname' => $dbname,
|
|
|
|
);
|
|
|
|
if ($input->getOption('port')) {
|
|
|
|
$connectionParams['port'] = $input->getOption('port');
|
|
|
|
}
|
2013-12-07 18:09:36 +04:00
|
|
|
switch ($type) {
|
|
|
|
case 'mysql':
|
|
|
|
case 'mssql':
|
|
|
|
$connectionParams['charset'] = 'UTF8';
|
|
|
|
break;
|
|
|
|
case 'oci':
|
|
|
|
$connectionParams['charset'] = 'AL32UTF8';
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
2013-12-07 17:44:23 +04:00
|
|
|
$toDB = \Doctrine\DBAL\DriverManager::getConnection($connectionParams);
|
|
|
|
|
|
|
|
// create tables in new database
|
|
|
|
$schemaManager = new \OC\DB\MDB2SchemaManager($toDB);
|
|
|
|
$schemaManager->createDbFromStructure(\OC::$SERVERROOT.'/db_structure.xml');
|
|
|
|
$apps = \OC_App::getEnabledApps();
|
|
|
|
foreach($apps as $app) {
|
|
|
|
if(file_exists(\OC_App::getAppPath($app).'/appinfo/database.xml')) {
|
|
|
|
$schemaManager->createDbFromStructure(\OC_App::getAppPath($app).'/appinfo/database.xml');
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// get tables from 'to' database
|
|
|
|
$toTables = $this->getTables($toDB);
|
|
|
|
// get tables from 'from' database
|
|
|
|
$fromTables = $this->getTables($fromDB);
|
|
|
|
// warn/fail if there are more tables in 'from' database
|
|
|
|
$tables = array_diff($fromTables, $toTables);
|
|
|
|
if (!empty($tables)) {
|
|
|
|
$output->writeln('<error>The following tables do NOT exist any more: '.join(', ', $tables).'</error>');
|
|
|
|
$dialog = $this->getHelperSet()->get('dialog');
|
|
|
|
if (!$dialog->askConfirmation(
|
|
|
|
$output,
|
|
|
|
'<question>Continue with the convertion?</question>',
|
|
|
|
false
|
|
|
|
)) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
2013-12-07 18:14:54 +04:00
|
|
|
// enable maintenance mode to prevent changes
|
2013-12-24 16:36:32 +04:00
|
|
|
$this->config->setValue('maintenance', true);
|
2013-12-07 18:14:54 +04:00
|
|
|
try {
|
|
|
|
// copy table rows
|
|
|
|
$tables = array_intersect($toTables, $fromTables);
|
|
|
|
foreach($tables as $table) {
|
|
|
|
$output->writeln($table);
|
|
|
|
$this->copyTable($fromDB, $toDB, $table, $output);
|
|
|
|
}
|
|
|
|
// save new database config
|
|
|
|
$dbhost = $hostname;
|
|
|
|
if ($input->getOption('port')) {
|
|
|
|
$dbhost = $hostname.':'.$input->getOption('port');
|
|
|
|
}
|
2013-12-24 16:36:32 +04:00
|
|
|
$this->config->setValue('dbtype', $type);
|
|
|
|
$this->config->setValue('dbname', $dbname);
|
|
|
|
$this->config->setValue('dbhost', $dbhost);
|
|
|
|
$this->config->setValue('dbuser', $username);
|
|
|
|
$this->config->setValue('dbpassword', $password);
|
2013-12-07 18:14:54 +04:00
|
|
|
} catch(Exception $e) {
|
2013-12-24 16:36:32 +04:00
|
|
|
$this->config->setValue('maintenance', false);
|
2013-12-07 18:14:54 +04:00
|
|
|
throw $e;
|
2013-12-07 17:44:23 +04:00
|
|
|
}
|
2013-12-24 16:36:32 +04:00
|
|
|
$this->config->setValue('maintenance', false);
|
2013-12-07 17:44:23 +04:00
|
|
|
}
|
|
|
|
|
|
|
|
private function getTables($db) {
|
|
|
|
$schemaManager = $db->getSchemaManager();
|
|
|
|
return $schemaManager->listTableNames();
|
|
|
|
}
|
|
|
|
|
|
|
|
private function copyTable($fromDB, $toDB, $table, $output) {
|
|
|
|
$progress = $this->getHelperSet()->get('progress');
|
2013-12-24 16:44:35 +04:00
|
|
|
$query = 'SELECT COUNT(*) FROM '.$table;
|
2013-12-07 17:44:23 +04:00
|
|
|
$count = $fromDB->fetchColumn($query);
|
2013-12-24 16:44:35 +04:00
|
|
|
$query = 'SELECT * FROM '.$table;
|
2013-12-07 17:44:23 +04:00
|
|
|
$statement = $fromDB->executeQuery($query);
|
|
|
|
$query = 'DELETE FROM '.$table;
|
|
|
|
$toDB->executeUpdate($query);
|
|
|
|
$progress->start($output, $count);
|
2013-12-24 16:44:35 +04:00
|
|
|
$progress->setRedrawFrequency($count > 100 ? 5 : 1);
|
2013-12-07 17:44:23 +04:00
|
|
|
while($row = $statement->fetch()) {
|
|
|
|
$progress->advance();
|
|
|
|
$toDB->insert($table, $row);
|
|
|
|
}
|
|
|
|
$progress->finish();
|
|
|
|
}
|
2013-12-24 16:44:35 +04:00
|
|
|
}
|