Passed
Pull Request — master (#1284)
by René
04:02
created

Version0107Date20201210160301::changeSchema()   A

Complexity

Conditions 3
Paths 3

Size

Total Lines 31
Code Lines 20

Duplication

Lines 0
Ratio 0 %

Importance

Changes 2
Bugs 0 Features 0
Metric Value
eloc 20
c 2
b 0
f 0
dl 0
loc 31
rs 9.6
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
32
class Version0107Date20201210160301 extends SimpleMigrationStep {
33
34
	/** @var IDBConnection */
35
	protected $connection;
36
37
	public function __construct(IDBConnection $connection) {
38
		$this->connection = $connection;
39
	}
40
41
	public function changeSchema(IOutput $output, \Closure $schemaClosure, array $options) {
42
		/** @var ISchemaWrapper $schema */
43
		$schema = $schemaClosure();
44
45
		if ($schema->hasTable('polls_log')) {
46
			$table = $schema->getTable('polls_log');
47
			$table->changeColumn('poll_id', [
48
				'default' => 0
49
			]);
50
			$table->changeColumn('user_id', [
51
				'length' => 64,
52
				'notnull' => true,
53
				'default' => ''
54
			]);
55
			$table->changeColumn('message', [
56
				'length' => 128,
57
				'notnull' => true,
58
				'default' => ''
59
			]);
60
			$table->changeColumn('message_id', [
61
				'notnull' => true,
62
				'default' => ''
63
			]);
64
65
			try {
66
				$table->addUniqueIndex(['processed', 'poll_id', 'user_id', 'message_id', 'message'], 'UNIQ_unprocessed');
67
			} catch (SchemaException $e) {
68
				// catch silently, index is already present
69
			}
70
		}
71
		return $schema;
72
	}
73
}
74