Make sure blob columns are correctly converted as parameters

Signed-off-by: Joas Schilling <coding@schilljs.com>
This commit is contained in:
Joas Schilling 2017-03-26 17:11:57 +02:00
parent ec6853a2a6
commit 2961c735e3
No known key found for this signature in database
GPG Key ID: E166FD8976B3BAC8
1 changed files with 24 additions and 1 deletions

View File

@ -28,6 +28,7 @@
namespace OC\Core\Command\Db; namespace OC\Core\Command\Db;
use OCP\DB\QueryBuilder\IQueryBuilder;
use \OCP\IConfig; use \OCP\IConfig;
use OC\DB\Connection; use OC\DB\Connection;
use OC\DB\ConnectionFactory; use OC\DB\ConnectionFactory;
@ -54,6 +55,9 @@ class ConvertType extends Command implements CompletionAwareInterface {
*/ */
protected $connectionFactory; protected $connectionFactory;
/** @var array */
protected $columnTypes;
/** /**
* @param \OCP\IConfig $config * @param \OCP\IConfig $config
* @param \OC\DB\ConnectionFactory $connectionFactory * @param \OC\DB\ConnectionFactory $connectionFactory
@ -304,7 +308,7 @@ class ConvertType extends Command implements CompletionAwareInterface {
} }
foreach ($row as $key => $value) { foreach ($row as $key => $value) {
$insertQuery->setParameter($key, $value); $insertQuery->setParameter($key, $value, $this->getColumnType($table, $key));
} }
$insertQuery->execute(); $insertQuery->execute();
} }
@ -313,6 +317,25 @@ class ConvertType extends Command implements CompletionAwareInterface {
$progress->finish(); $progress->finish();
} }
protected function getColumnType($table, $column) {
if (isset($this->columnTypes[$table][$column])) {
return $this->columnTypes[$table][$column];
}
$prefix = $this->config->getSystemValue('dbtableprefix', 'oc_');
$this->columnTypes[$table][$column] = null;
if ($table === $prefix . 'cards' && $column === 'carddata') {
$this->columnTypes[$table][$column] = IQueryBuilder::PARAM_LOB;
} else if ($column === 'calendardata') {
if ($table === $prefix . 'calendarobjects' ||
$table === $prefix . 'schedulingobjects') {
$this->columnTypes[$table][$column] = IQueryBuilder::PARAM_LOB;
}
}
return $this->columnTypes[$table][$column];
}
protected function convertDB(Connection $fromDB, Connection $toDB, array $tables, InputInterface $input, OutputInterface $output) { protected function convertDB(Connection $fromDB, Connection $toDB, array $tables, InputInterface $input, OutputInterface $output) {
$this->config->setSystemValue('maintenance', true); $this->config->setSystemValue('maintenance', true);
try { try {