Passed
Pull Request — master (#1284)
by René
06:52 queued 03:10
created

Version0107Date20201210213303::changeSchema()   A

Complexity

Conditions 3
Paths 3

Size

Total Lines 23
Code Lines 14

Duplication

Lines 0
Ratio 0 %

Importance

Changes 2
Bugs 0 Features 2
Metric Value
eloc 14
c 2
b 0
f 2
dl 0
loc 23
rs 9.7998
cc 3
nc 3
nop 3
1
<?php
2
/**
3
 * @copyright Copyright (c) 2017 René Gieling <[email protected]>
4
 *
5
 * @author René Gieling <[email protected]>
6
 *
7
 * @license GNU AGPL version 3 or any later version
8
 *
9
 *  This program is free software: you can redistribute it and/or modify
10
 *  it under the terms of the GNU Affero General Public License as
11
 *  published by the Free Software Foundation, either version 3 of the
12
 *  License, or (at your option) any later version.
13
 *
14
 *  This program is distributed in the hope that it will be useful,
15
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
16
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
17
 *  GNU Affero General Public License for more details.
18
 *
19
 *  You should have received a copy of the GNU Affero General Public License
20
 *  along with this program.  If not, see <http://www.gnu.org/licenses/>.
21
 *
22
 */
23
24
namespace OCA\Polls\Migration;
25
26
use OCP\DB\ISchemaWrapper;
27
use OCP\Migration\IOutput;
28
use OCP\IDBConnection;
29
use OCP\Migration\SimpleMigrationStep;
30
use Doctrine\DBAL\Schema\SchemaException;
31
use OCA\Polls\Db\VoteMapper;
32
33
class Version0107Date20201210213303 extends SimpleMigrationStep {
34
35
	/** @var VoteMapper */
36
	private $voteMapper;
37
	/** @var IDBConnection */
38
	protected $connection;
39
40
	public function __construct(IDBConnection $connection, VoteMapper $voteMapper) {
41
		$this->connection = $connection;
42
		$this->voteMapper = $voteMapper;
43
	}
44
45
	public function changeSchema(IOutput $output, \Closure $schemaClosure, array $options) {
46
		$this->voteMapper->removeDuplicates();
47
		/** @var ISchemaWrapper $schema */
48
		$schema = $schemaClosure();
49
50
		if ($schema->hasTable('polls_votes')) {
51
			$table = $schema->getTable('polls_votes');
52
			$table->changeColumn('user_id', [
53
				'notnull' => true,
54
				'default' => ''
55
			]);
56
			$table->changeColumn('vote_option_text', [
57
				'notnull' => true,
58
				'default' => ''
59
			]);
60
61
			try {
62
				$table->addUniqueIndex(['poll_id', 'user_id', 'vote_option_text'], 'UNIQ_votes');
63
			} catch (SchemaException $e) {
64
				//catch silently, index is already present
65
			}
66
		}
67
		return $schema;
68
	}
69
}
70