Passed
Push — master ( 1b5db2...2445b9 )
by Morris
14:45 queued 11s
created
lib/private/Files/Storage/Temporary.php 1 patch
Indentation   +13 added lines, -13 removed lines patch added patch discarded remove patch
@@ -29,20 +29,20 @@
 block discarded – undo
29 29
  * local storage backend in temporary folder for testing purpose
30 30
  */
31 31
 class Temporary extends Local {
32
-	public function __construct($arguments = null) {
33
-		parent::__construct(['datadir' => \OC::$server->getTempManager()->getTemporaryFolder()]);
34
-	}
32
+    public function __construct($arguments = null) {
33
+        parent::__construct(['datadir' => \OC::$server->getTempManager()->getTemporaryFolder()]);
34
+    }
35 35
 
36
-	public function cleanUp() {
37
-		\OC_Helper::rmdirr($this->datadir);
38
-	}
36
+    public function cleanUp() {
37
+        \OC_Helper::rmdirr($this->datadir);
38
+    }
39 39
 
40
-	public function __destruct() {
41
-		parent::__destruct();
42
-		$this->cleanUp();
43
-	}
40
+    public function __destruct() {
41
+        parent::__destruct();
42
+        $this->cleanUp();
43
+    }
44 44
 
45
-	public function getDataDir() {
46
-		return $this->datadir;
47
-	}
45
+    public function getDataDir() {
46
+        return $this->datadir;
47
+    }
48 48
 }
Please login to merge, or discard this patch.
lib/private/Files/Storage/Home.php 2 patches
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -50,7 +50,7 @@
 block discarded – undo
50 50
 	public function __construct($arguments) {
51 51
 		$this->user = $arguments['user'];
52 52
 		$datadir = $this->user->getHome();
53
-		$this->id = 'home::' . $this->user->getUID();
53
+		$this->id = 'home::'.$this->user->getUID();
54 54
 
55 55
 		parent::__construct(['datadir' => $datadir]);
56 56
 	}
Please login to merge, or discard this patch.
Indentation   +67 added lines, -67 removed lines patch added patch discarded remove patch
@@ -33,80 +33,80 @@
 block discarded – undo
33 33
  * Specialized version of Local storage for home directory usage
34 34
  */
35 35
 class Home extends Local implements \OCP\Files\IHomeStorage {
36
-	/**
37
-	 * @var string
38
-	 */
39
-	protected $id;
36
+    /**
37
+     * @var string
38
+     */
39
+    protected $id;
40 40
 
41
-	/**
42
-	 * @var \OC\User\User $user
43
-	 */
44
-	protected $user;
41
+    /**
42
+     * @var \OC\User\User $user
43
+     */
44
+    protected $user;
45 45
 
46
-	/**
47
-	 * Construct a Home storage instance
48
-	 *
49
-	 * @param array $arguments array with "user" containing the
50
-	 * storage owner
51
-	 */
52
-	public function __construct($arguments) {
53
-		$this->user = $arguments['user'];
54
-		$datadir = $this->user->getHome();
55
-		$this->id = 'home::' . $this->user->getUID();
46
+    /**
47
+     * Construct a Home storage instance
48
+     *
49
+     * @param array $arguments array with "user" containing the
50
+     * storage owner
51
+     */
52
+    public function __construct($arguments) {
53
+        $this->user = $arguments['user'];
54
+        $datadir = $this->user->getHome();
55
+        $this->id = 'home::' . $this->user->getUID();
56 56
 
57
-		parent::__construct(['datadir' => $datadir]);
58
-	}
57
+        parent::__construct(['datadir' => $datadir]);
58
+    }
59 59
 
60
-	public function getId() {
61
-		return $this->id;
62
-	}
60
+    public function getId() {
61
+        return $this->id;
62
+    }
63 63
 
64
-	/**
65
-	 * @return \OC\Files\Cache\HomeCache
66
-	 */
67
-	public function getCache($path = '', $storage = null) {
68
-		if (!$storage) {
69
-			$storage = $this;
70
-		}
71
-		if (!isset($this->cache)) {
72
-			$this->cache = new \OC\Files\Cache\HomeCache($storage);
73
-		}
74
-		return $this->cache;
75
-	}
64
+    /**
65
+     * @return \OC\Files\Cache\HomeCache
66
+     */
67
+    public function getCache($path = '', $storage = null) {
68
+        if (!$storage) {
69
+            $storage = $this;
70
+        }
71
+        if (!isset($this->cache)) {
72
+            $this->cache = new \OC\Files\Cache\HomeCache($storage);
73
+        }
74
+        return $this->cache;
75
+    }
76 76
 
77
-	/**
78
-	 * get a propagator instance for the cache
79
-	 *
80
-	 * @param \OC\Files\Storage\Storage (optional) the storage to pass to the watcher
81
-	 * @return \OC\Files\Cache\Propagator
82
-	 */
83
-	public function getPropagator($storage = null) {
84
-		if (!$storage) {
85
-			$storage = $this;
86
-		}
87
-		if (!isset($this->propagator)) {
88
-			$this->propagator = new HomePropagator($storage, \OC::$server->getDatabaseConnection());
89
-		}
90
-		return $this->propagator;
91
-	}
77
+    /**
78
+     * get a propagator instance for the cache
79
+     *
80
+     * @param \OC\Files\Storage\Storage (optional) the storage to pass to the watcher
81
+     * @return \OC\Files\Cache\Propagator
82
+     */
83
+    public function getPropagator($storage = null) {
84
+        if (!$storage) {
85
+            $storage = $this;
86
+        }
87
+        if (!isset($this->propagator)) {
88
+            $this->propagator = new HomePropagator($storage, \OC::$server->getDatabaseConnection());
89
+        }
90
+        return $this->propagator;
91
+    }
92 92
 
93 93
 
94
-	/**
95
-	 * Returns the owner of this home storage
96
-	 *
97
-	 * @return \OC\User\User owner of this home storage
98
-	 */
99
-	public function getUser() {
100
-		return $this->user;
101
-	}
94
+    /**
95
+     * Returns the owner of this home storage
96
+     *
97
+     * @return \OC\User\User owner of this home storage
98
+     */
99
+    public function getUser() {
100
+        return $this->user;
101
+    }
102 102
 
103
-	/**
104
-	 * get the owner of a path
105
-	 *
106
-	 * @param string $path The path to get the owner
107
-	 * @return string uid or false
108
-	 */
109
-	public function getOwner($path) {
110
-		return $this->user->getUID();
111
-	}
103
+    /**
104
+     * get the owner of a path
105
+     *
106
+     * @param string $path The path to get the owner
107
+     * @return string uid or false
108
+     */
109
+    public function getOwner($path) {
110
+        return $this->user->getUID();
111
+    }
112 112
 }
Please login to merge, or discard this patch.
lib/private/Files/SimpleFS/SimpleFolder.php 2 patches
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -49,7 +49,7 @@
 block discarded – undo
49 49
 	public function getDirectoryListing() {
50 50
 		$listing = $this->folder->getDirectoryListing();
51 51
 
52
-		$fileListing = array_map(function (Node $file) {
52
+		$fileListing = array_map(function(Node $file) {
53 53
 			if ($file instanceof File) {
54 54
 				return new SimpleFile($file);
55 55
 			}
Please login to merge, or discard this patch.
Indentation   +58 added lines, -58 removed lines patch added patch discarded remove patch
@@ -32,62 +32,62 @@
 block discarded – undo
32 32
 
33 33
 class SimpleFolder implements ISimpleFolder {
34 34
 
35
-	/** @var Folder */
36
-	private $folder;
37
-
38
-	/**
39
-	 * Folder constructor.
40
-	 *
41
-	 * @param Folder $folder
42
-	 */
43
-	public function __construct(Folder $folder) {
44
-		$this->folder = $folder;
45
-	}
46
-
47
-	public function getName() {
48
-		return $this->folder->getName();
49
-	}
50
-
51
-	public function getDirectoryListing() {
52
-		$listing = $this->folder->getDirectoryListing();
53
-
54
-		$fileListing = array_map(function (Node $file) {
55
-			if ($file instanceof File) {
56
-				return new SimpleFile($file);
57
-			}
58
-			return null;
59
-		}, $listing);
60
-
61
-		$fileListing = array_filter($fileListing);
62
-
63
-		return array_values($fileListing);
64
-	}
65
-
66
-	public function delete() {
67
-		$this->folder->delete();
68
-	}
69
-
70
-	public function fileExists($name) {
71
-		return $this->folder->nodeExists($name);
72
-	}
73
-
74
-	public function getFile($name) {
75
-		$file = $this->folder->get($name);
76
-
77
-		if (!($file instanceof File)) {
78
-			throw new NotFoundException();
79
-		}
80
-
81
-		return new SimpleFile($file);
82
-	}
83
-
84
-	public function newFile($name, $content = null) {
85
-		if ($content === null) {
86
-			// delay creating the file until it's written to
87
-			return new NewSimpleFile($this->folder, $name);
88
-		} else {
89
-			$file = $this->folder->newFile($name, $content);
90
-			return new SimpleFile($file);
91
-		}
92
-	}
35
+    /** @var Folder */
36
+    private $folder;
37
+
38
+    /**
39
+     * Folder constructor.
40
+     *
41
+     * @param Folder $folder
42
+     */
43
+    public function __construct(Folder $folder) {
44
+        $this->folder = $folder;
45
+    }
46
+
47
+    public function getName() {
48
+        return $this->folder->getName();
49
+    }
50
+
51
+    public function getDirectoryListing() {
52
+        $listing = $this->folder->getDirectoryListing();
53
+
54
+        $fileListing = array_map(function (Node $file) {
55
+            if ($file instanceof File) {
56
+                return new SimpleFile($file);
57
+            }
58
+            return null;
59
+        }, $listing);
60
+
61
+        $fileListing = array_filter($fileListing);
62
+
63
+        return array_values($fileListing);
64
+    }
65
+
66
+    public function delete() {
67
+        $this->folder->delete();
68
+    }
69
+
70
+    public function fileExists($name) {
71
+        return $this->folder->nodeExists($name);
72
+    }
73
+
74
+    public function getFile($name) {
75
+        $file = $this->folder->get($name);
76
+
77
+        if (!($file instanceof File)) {
78
+            throw new NotFoundException();
79
+        }
80
+
81
+        return new SimpleFile($file);
82
+    }
83
+
84
+    public function newFile($name, $content = null) {
85
+        if ($content === null) {
86
+            // delay creating the file until it's written to
87
+            return new NewSimpleFile($this->folder, $name);
88
+        } else {
89
+            $file = $this->folder->newFile($name, $content);
90
+            return new SimpleFile($file);
91
+        }
92
+    }
93 93
 }
Please login to merge, or discard this patch.
lib/private/Files/ObjectStore/HomeObjectStoreStorage.php 2 patches
Indentation   +33 added lines, -33 removed lines patch added patch discarded remove patch
@@ -28,40 +28,40 @@
 block discarded – undo
28 28
 
29 29
 class HomeObjectStoreStorage extends ObjectStoreStorage implements \OCP\Files\IHomeStorage {
30 30
 
31
-	/**
32
-	 * The home user storage requires a user object to create a unique storage id
33
-	 * @param array $params
34
-	 */
35
-	public function __construct($params) {
36
-		if (! isset($params['user']) || ! $params['user'] instanceof User) {
37
-			throw new \Exception('missing user object in parameters');
38
-		}
39
-		$this->user = $params['user'];
40
-		parent::__construct($params);
41
-	}
31
+    /**
32
+     * The home user storage requires a user object to create a unique storage id
33
+     * @param array $params
34
+     */
35
+    public function __construct($params) {
36
+        if (! isset($params['user']) || ! $params['user'] instanceof User) {
37
+            throw new \Exception('missing user object in parameters');
38
+        }
39
+        $this->user = $params['user'];
40
+        parent::__construct($params);
41
+    }
42 42
 
43
-	public function getId() {
44
-		return 'object::user:' . $this->user->getUID();
45
-	}
43
+    public function getId() {
44
+        return 'object::user:' . $this->user->getUID();
45
+    }
46 46
 
47
-	/**
48
-	 * get the owner of a path
49
-	 *
50
-	 * @param string $path The path to get the owner
51
-	 * @return false|string uid
52
-	 */
53
-	public function getOwner($path) {
54
-		if (is_object($this->user)) {
55
-			return $this->user->getUID();
56
-		}
57
-		return false;
58
-	}
47
+    /**
48
+     * get the owner of a path
49
+     *
50
+     * @param string $path The path to get the owner
51
+     * @return false|string uid
52
+     */
53
+    public function getOwner($path) {
54
+        if (is_object($this->user)) {
55
+            return $this->user->getUID();
56
+        }
57
+        return false;
58
+    }
59 59
 
60
-	/**
61
-	 * @param string $path, optional
62
-	 * @return \OC\User\User
63
-	 */
64
-	public function getUser($path = null) {
65
-		return $this->user;
66
-	}
60
+    /**
61
+     * @param string $path, optional
62
+     * @return \OC\User\User
63
+     */
64
+    public function getUser($path = null) {
65
+        return $this->user;
66
+    }
67 67
 }
Please login to merge, or discard this patch.
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -33,7 +33,7 @@  discard block
 block discarded – undo
33 33
 	 * @param array $params
34 34
 	 */
35 35
 	public function __construct($params) {
36
-		if (! isset($params['user']) || ! $params['user'] instanceof User) {
36
+		if (!isset($params['user']) || !$params['user'] instanceof User) {
37 37
 			throw new \Exception('missing user object in parameters');
38 38
 		}
39 39
 		$this->user = $params['user'];
@@ -41,7 +41,7 @@  discard block
 block discarded – undo
41 41
 	}
42 42
 
43 43
 	public function getId() {
44
-		return 'object::user:' . $this->user->getUID();
44
+		return 'object::user:'.$this->user->getUID();
45 45
 	}
46 46
 
47 47
 	/**
Please login to merge, or discard this patch.
lib/private/DB/MigrationException.php 1 patch
Indentation   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -24,17 +24,17 @@
 block discarded – undo
24 24
 namespace OC\DB;
25 25
 
26 26
 class MigrationException extends \Exception {
27
-	private $table;
27
+    private $table;
28 28
 
29
-	public function __construct($table, $message) {
30
-		$this->table = $table;
31
-		parent::__construct($message);
32
-	}
29
+    public function __construct($table, $message) {
30
+        $this->table = $table;
31
+        parent::__construct($message);
32
+    }
33 33
 
34
-	/**
35
-	 * @return string
36
-	 */
37
-	public function getTable() {
38
-		return $this->table;
39
-	}
34
+    /**
35
+     * @return string
36
+     */
37
+    public function getTable() {
38
+        return $this->table;
39
+    }
40 40
 }
Please login to merge, or discard this patch.
lib/private/DB/QueryBuilder/Literal.php 1 patch
Indentation   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -25,17 +25,17 @@
 block discarded – undo
25 25
 use OCP\DB\QueryBuilder\ILiteral;
26 26
 
27 27
 class Literal implements ILiteral {
28
-	/** @var mixed */
29
-	protected $literal;
28
+    /** @var mixed */
29
+    protected $literal;
30 30
 
31
-	public function __construct($literal) {
32
-		$this->literal = $literal;
33
-	}
31
+    public function __construct($literal) {
32
+        $this->literal = $literal;
33
+    }
34 34
 
35
-	/**
36
-	 * @return string
37
-	 */
38
-	public function __toString() {
39
-		return (string) $this->literal;
40
-	}
35
+    /**
36
+     * @return string
37
+     */
38
+    public function __toString() {
39
+        return (string) $this->literal;
40
+    }
41 41
 }
Please login to merge, or discard this patch.
lib/private/DB/MySQLMigrator.php 1 patch
Indentation   +38 added lines, -38 removed lines patch added patch discarded remove patch
@@ -29,47 +29,47 @@
 block discarded – undo
29 29
 use Doctrine\DBAL\Schema\Table;
30 30
 
31 31
 class MySQLMigrator extends Migrator {
32
-	/**
33
-	 * @param Schema $targetSchema
34
-	 * @param \Doctrine\DBAL\Connection $connection
35
-	 * @return \Doctrine\DBAL\Schema\SchemaDiff
36
-	 */
37
-	protected function getDiff(Schema $targetSchema, \Doctrine\DBAL\Connection $connection) {
38
-		$platform = $connection->getDatabasePlatform();
39
-		$platform->registerDoctrineTypeMapping('enum', 'string');
40
-		$platform->registerDoctrineTypeMapping('bit', 'string');
32
+    /**
33
+     * @param Schema $targetSchema
34
+     * @param \Doctrine\DBAL\Connection $connection
35
+     * @return \Doctrine\DBAL\Schema\SchemaDiff
36
+     */
37
+    protected function getDiff(Schema $targetSchema, \Doctrine\DBAL\Connection $connection) {
38
+        $platform = $connection->getDatabasePlatform();
39
+        $platform->registerDoctrineTypeMapping('enum', 'string');
40
+        $platform->registerDoctrineTypeMapping('bit', 'string');
41 41
 
42
-		$schemaDiff = parent::getDiff($targetSchema, $connection);
42
+        $schemaDiff = parent::getDiff($targetSchema, $connection);
43 43
 
44
-		// identifiers need to be quoted for mysql
45
-		foreach ($schemaDiff->changedTables as $tableDiff) {
46
-			$tableDiff->name = $this->connection->quoteIdentifier($tableDiff->name);
47
-			foreach ($tableDiff->changedColumns as $column) {
48
-				$column->oldColumnName = $this->connection->quoteIdentifier($column->oldColumnName);
49
-			}
50
-		}
44
+        // identifiers need to be quoted for mysql
45
+        foreach ($schemaDiff->changedTables as $tableDiff) {
46
+            $tableDiff->name = $this->connection->quoteIdentifier($tableDiff->name);
47
+            foreach ($tableDiff->changedColumns as $column) {
48
+                $column->oldColumnName = $this->connection->quoteIdentifier($column->oldColumnName);
49
+            }
50
+        }
51 51
 
52
-		return $schemaDiff;
53
-	}
52
+        return $schemaDiff;
53
+    }
54 54
 	
55
-	/**
56
-	 * Speed up migration test by disabling autocommit and unique indexes check
57
-	 *
58
-	 * @param \Doctrine\DBAL\Schema\Table $table
59
-	 * @throws \OC\DB\MigrationException
60
-	 */
61
-	protected function checkTableMigrate(Table $table) {
62
-		$this->connection->exec('SET autocommit=0');
63
-		$this->connection->exec('SET unique_checks=0');
55
+    /**
56
+     * Speed up migration test by disabling autocommit and unique indexes check
57
+     *
58
+     * @param \Doctrine\DBAL\Schema\Table $table
59
+     * @throws \OC\DB\MigrationException
60
+     */
61
+    protected function checkTableMigrate(Table $table) {
62
+        $this->connection->exec('SET autocommit=0');
63
+        $this->connection->exec('SET unique_checks=0');
64 64
 
65
-		try {
66
-			parent::checkTableMigrate($table);
67
-		} catch (\Exception $e) {
68
-			$this->connection->exec('SET unique_checks=1');
69
-			$this->connection->exec('SET autocommit=1');
70
-			throw new MigrationException($table->getName(), $e->getMessage());
71
-		}
72
-		$this->connection->exec('SET unique_checks=1');
73
-		$this->connection->exec('SET autocommit=1');
74
-	}
65
+        try {
66
+            parent::checkTableMigrate($table);
67
+        } catch (\Exception $e) {
68
+            $this->connection->exec('SET unique_checks=1');
69
+            $this->connection->exec('SET autocommit=1');
70
+            throw new MigrationException($table->getName(), $e->getMessage());
71
+        }
72
+        $this->connection->exec('SET unique_checks=1');
73
+        $this->connection->exec('SET autocommit=1');
74
+    }
75 75
 }
Please login to merge, or discard this patch.
lib/private/DB/AdapterSqlite.php 2 patches
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -64,14 +64,14 @@
 block discarded – undo
64 64
 		if (empty($compare)) {
65 65
 			$compare = array_keys($input);
66 66
 		}
67
-		$fieldList = '`' . implode('`,`', array_keys($input)) . '`';
67
+		$fieldList = '`'.implode('`,`', array_keys($input)).'`';
68 68
 		$query = "INSERT INTO `$table` ($fieldList) SELECT "
69 69
 			. str_repeat('?,', count($input) - 1).'? '
70 70
 			. " WHERE NOT EXISTS (SELECT 1 FROM `$table` WHERE ";
71 71
 
72 72
 		$inserts = array_values($input);
73 73
 		foreach ($compare as $key) {
74
-			$query .= '`' . $key . '`';
74
+			$query .= '`'.$key.'`';
75 75
 			if (is_null($input[$key])) {
76 76
 				$query .= ' IS NULL AND ';
77 77
 			} else {
Please login to merge, or discard this patch.
Indentation   +61 added lines, -61 removed lines patch added patch discarded remove patch
@@ -31,70 +31,70 @@
 block discarded – undo
31 31
 
32 32
 class AdapterSqlite extends Adapter {
33 33
 
34
-	/**
35
-	 * @param string $tableName
36
-	 */
37
-	public function lockTable($tableName) {
38
-		$this->conn->executeUpdate('BEGIN EXCLUSIVE TRANSACTION');
39
-	}
34
+    /**
35
+     * @param string $tableName
36
+     */
37
+    public function lockTable($tableName) {
38
+        $this->conn->executeUpdate('BEGIN EXCLUSIVE TRANSACTION');
39
+    }
40 40
 
41
-	public function unlockTable() {
42
-		$this->conn->executeUpdate('COMMIT TRANSACTION');
43
-	}
41
+    public function unlockTable() {
42
+        $this->conn->executeUpdate('COMMIT TRANSACTION');
43
+    }
44 44
 
45
-	public function fixupStatement($statement) {
46
-		$statement = preg_replace('/`(\w+)` ILIKE \?/', 'LOWER($1) LIKE LOWER(?)', $statement);
47
-		$statement = str_replace('`', '"', $statement);
48
-		$statement = str_ireplace('NOW()', 'datetime(\'now\')', $statement);
49
-		$statement = str_ireplace('GREATEST(', 'MAX(', $statement);
50
-		$statement = str_ireplace('UNIX_TIMESTAMP()', 'strftime(\'%s\',\'now\')', $statement);
51
-		return $statement;
52
-	}
45
+    public function fixupStatement($statement) {
46
+        $statement = preg_replace('/`(\w+)` ILIKE \?/', 'LOWER($1) LIKE LOWER(?)', $statement);
47
+        $statement = str_replace('`', '"', $statement);
48
+        $statement = str_ireplace('NOW()', 'datetime(\'now\')', $statement);
49
+        $statement = str_ireplace('GREATEST(', 'MAX(', $statement);
50
+        $statement = str_ireplace('UNIX_TIMESTAMP()', 'strftime(\'%s\',\'now\')', $statement);
51
+        return $statement;
52
+    }
53 53
 
54
-	/**
55
-	 * Insert a row if the matching row does not exists. To accomplish proper race condition avoidance
56
-	 * it is needed that there is also a unique constraint on the values. Then this method will
57
-	 * catch the exception and return 0.
58
-	 *
59
-	 * @param string $table The table name (will replace *PREFIX* with the actual prefix)
60
-	 * @param array $input data that should be inserted into the table  (column name => value)
61
-	 * @param array|null $compare List of values that should be checked for "if not exists"
62
-	 *				If this is null or an empty array, all keys of $input will be compared
63
-	 *				Please note: text fields (clob) must not be used in the compare array
64
-	 * @return int number of inserted rows
65
-	 * @throws \Doctrine\DBAL\Exception
66
-	 * @deprecated 15.0.0 - use unique index and "try { $db->insert() } catch (UniqueConstraintViolationException $e) {}" instead, because it is more reliable and does not have the risk for deadlocks - see https://github.com/nextcloud/server/pull/12371
67
-	 */
68
-	public function insertIfNotExist($table, $input, array $compare = null) {
69
-		if (empty($compare)) {
70
-			$compare = array_keys($input);
71
-		}
72
-		$fieldList = '`' . implode('`,`', array_keys($input)) . '`';
73
-		$query = "INSERT INTO `$table` ($fieldList) SELECT "
74
-			. str_repeat('?,', count($input) - 1).'? '
75
-			. " WHERE NOT EXISTS (SELECT 1 FROM `$table` WHERE ";
54
+    /**
55
+     * Insert a row if the matching row does not exists. To accomplish proper race condition avoidance
56
+     * it is needed that there is also a unique constraint on the values. Then this method will
57
+     * catch the exception and return 0.
58
+     *
59
+     * @param string $table The table name (will replace *PREFIX* with the actual prefix)
60
+     * @param array $input data that should be inserted into the table  (column name => value)
61
+     * @param array|null $compare List of values that should be checked for "if not exists"
62
+     *				If this is null or an empty array, all keys of $input will be compared
63
+     *				Please note: text fields (clob) must not be used in the compare array
64
+     * @return int number of inserted rows
65
+     * @throws \Doctrine\DBAL\Exception
66
+     * @deprecated 15.0.0 - use unique index and "try { $db->insert() } catch (UniqueConstraintViolationException $e) {}" instead, because it is more reliable and does not have the risk for deadlocks - see https://github.com/nextcloud/server/pull/12371
67
+     */
68
+    public function insertIfNotExist($table, $input, array $compare = null) {
69
+        if (empty($compare)) {
70
+            $compare = array_keys($input);
71
+        }
72
+        $fieldList = '`' . implode('`,`', array_keys($input)) . '`';
73
+        $query = "INSERT INTO `$table` ($fieldList) SELECT "
74
+            . str_repeat('?,', count($input) - 1).'? '
75
+            . " WHERE NOT EXISTS (SELECT 1 FROM `$table` WHERE ";
76 76
 
77
-		$inserts = array_values($input);
78
-		foreach ($compare as $key) {
79
-			$query .= '`' . $key . '`';
80
-			if (is_null($input[$key])) {
81
-				$query .= ' IS NULL AND ';
82
-			} else {
83
-				$inserts[] = $input[$key];
84
-				$query .= ' = ? AND ';
85
-			}
86
-		}
87
-		$query = substr($query, 0, -5);
88
-		$query .= ')';
77
+        $inserts = array_values($input);
78
+        foreach ($compare as $key) {
79
+            $query .= '`' . $key . '`';
80
+            if (is_null($input[$key])) {
81
+                $query .= ' IS NULL AND ';
82
+            } else {
83
+                $inserts[] = $input[$key];
84
+                $query .= ' = ? AND ';
85
+            }
86
+        }
87
+        $query = substr($query, 0, -5);
88
+        $query .= ')';
89 89
 
90
-		try {
91
-			return $this->conn->executeUpdate($query, $inserts);
92
-		} catch (UniqueConstraintViolationException $e) {
93
-			// if this is thrown then a concurrent insert happened between the insert and the sub-select in the insert, that should have avoided it
94
-			// it's fine to ignore this then
95
-			//
96
-			// more discussions about this can be found at https://github.com/nextcloud/server/pull/12315
97
-			return 0;
98
-		}
99
-	}
90
+        try {
91
+            return $this->conn->executeUpdate($query, $inserts);
92
+        } catch (UniqueConstraintViolationException $e) {
93
+            // if this is thrown then a concurrent insert happened between the insert and the sub-select in the insert, that should have avoided it
94
+            // it's fine to ignore this then
95
+            //
96
+            // more discussions about this can be found at https://github.com/nextcloud/server/pull/12315
97
+            return 0;
98
+        }
99
+    }
100 100
 }
Please login to merge, or discard this patch.
lib/private/DB/MDB2SchemaReader.php 2 patches
Spacing   +21 added lines, -21 removed lines patch added patch discarded remove patch
@@ -84,7 +84,7 @@  discard block
 block discarded – undo
84 84
 					$this->loadTable($schema, $child);
85 85
 					break;
86 86
 				default:
87
-					throw new \DomainException('Unknown element: ' . $child->getName());
87
+					throw new \DomainException('Unknown element: '.$child->getName());
88 88
 
89 89
 			}
90 90
 		}
@@ -104,7 +104,7 @@  discard block
 block discarded – undo
104 104
 			 */
105 105
 			switch ($child->getName()) {
106 106
 				case 'name':
107
-					$name = (string)$child;
107
+					$name = (string) $child;
108 108
 					$name = str_replace('*dbprefix*', $this->DBTABLEPREFIX, $name);
109 109
 					$name = $this->platform->quoteIdentifier($name);
110 110
 					$table = $schema->createTable($name);
@@ -120,7 +120,7 @@  discard block
 block discarded – undo
120 120
 					$this->loadDeclaration($table, $child);
121 121
 					break;
122 122
 				default:
123
-					throw new \DomainException('Unknown element: ' . $child->getName());
123
+					throw new \DomainException('Unknown element: '.$child->getName());
124 124
 
125 125
 			}
126 126
 		}
@@ -144,7 +144,7 @@  discard block
 block discarded – undo
144 144
 					$this->loadIndex($table, $child);
145 145
 					break;
146 146
 				default:
147
-					throw new \DomainException('Unknown element: ' . $child->getName());
147
+					throw new \DomainException('Unknown element: '.$child->getName());
148 148
 
149 149
 			}
150 150
 		}
@@ -156,18 +156,18 @@  discard block
 block discarded – undo
156 156
 	 * @throws \DomainException
157 157
 	 */
158 158
 	private function loadField($table, $xml) {
159
-		$options = [ 'notnull' => false ];
159
+		$options = ['notnull' => false];
160 160
 		foreach ($xml->children() as $child) {
161 161
 			/**
162 162
 			 * @var \SimpleXMLElement $child
163 163
 			 */
164 164
 			switch ($child->getName()) {
165 165
 				case 'name':
166
-					$name = (string)$child;
166
+					$name = (string) $child;
167 167
 					$name = $this->platform->quoteIdentifier($name);
168 168
 					break;
169 169
 				case 'type':
170
-					$type = (string)$child;
170
+					$type = (string) $child;
171 171
 					switch ($type) {
172 172
 						case 'text':
173 173
 							$type = 'string';
@@ -184,7 +184,7 @@  discard block
 block discarded – undo
184 184
 					}
185 185
 					break;
186 186
 				case 'length':
187
-					$length = (string)$child;
187
+					$length = (string) $child;
188 188
 					$options['length'] = $length;
189 189
 					break;
190 190
 				case 'unsigned':
@@ -200,11 +200,11 @@  discard block
 block discarded – undo
200 200
 					$options['autoincrement'] = $autoincrement;
201 201
 					break;
202 202
 				case 'default':
203
-					$default = (string)$child;
203
+					$default = (string) $child;
204 204
 					$options['default'] = $default;
205 205
 					break;
206 206
 				case 'comments':
207
-					$comment = (string)$child;
207
+					$comment = (string) $child;
208 208
 					$options['comment'] = $comment;
209 209
 					break;
210 210
 				case 'primary':
@@ -212,15 +212,15 @@  discard block
 block discarded – undo
212 212
 					$options['primary'] = $primary;
213 213
 					break;
214 214
 				case 'precision':
215
-					$precision = (string)$child;
215
+					$precision = (string) $child;
216 216
 					$options['precision'] = $precision;
217 217
 					break;
218 218
 				case 'scale':
219
-					$scale = (string)$child;
219
+					$scale = (string) $child;
220 220
 					$options['scale'] = $scale;
221 221
 					break;
222 222
 				default:
223
-					throw new \DomainException('Unknown element: ' . $child->getName());
223
+					throw new \DomainException('Unknown element: '.$child->getName());
224 224
 
225 225
 			}
226 226
 		}
@@ -242,7 +242,7 @@  discard block
 block discarded – undo
242 242
 				}
243 243
 			}
244 244
 			if ($type === 'integer' && isset($options['default'])) {
245
-				$options['default'] = (int)$options['default'];
245
+				$options['default'] = (int) $options['default'];
246 246
 			}
247 247
 			if ($type === 'integer' && isset($options['length'])) {
248 248
 				$length = $options['length'];
@@ -282,7 +282,7 @@  discard block
 block discarded – undo
282 282
 			 */
283 283
 			switch ($child->getName()) {
284 284
 				case 'name':
285
-					$name = (string)$child;
285
+					$name = (string) $child;
286 286
 					break;
287 287
 				case 'primary':
288 288
 					$primary = $this->asBool($child);
@@ -297,20 +297,20 @@  discard block
 block discarded – undo
297 297
 						 */
298 298
 						switch ($field->getName()) {
299 299
 							case 'name':
300
-								$field_name = (string)$field;
300
+								$field_name = (string) $field;
301 301
 								$field_name = $this->platform->quoteIdentifier($field_name);
302 302
 								$fields[] = $field_name;
303 303
 								break;
304 304
 							case 'sorting':
305 305
 								break;
306 306
 							default:
307
-								throw new \DomainException('Unknown element: ' . $field->getName());
307
+								throw new \DomainException('Unknown element: '.$field->getName());
308 308
 
309 309
 						}
310 310
 					}
311 311
 					break;
312 312
 				default:
313
-					throw new \DomainException('Unknown element: ' . $child->getName());
313
+					throw new \DomainException('Unknown element: '.$child->getName());
314 314
 
315 315
 			}
316 316
 		}
@@ -328,7 +328,7 @@  discard block
 block discarded – undo
328 328
 				}
329 329
 			}
330 330
 		} else {
331
-			throw new \DomainException('Empty index definition: ' . $name . ' options:' . print_r($fields, true));
331
+			throw new \DomainException('Empty index definition: '.$name.' options:'.print_r($fields, true));
332 332
 		}
333 333
 	}
334 334
 
@@ -337,12 +337,12 @@  discard block
 block discarded – undo
337 337
 	 * @return bool
338 338
 	 */
339 339
 	private function asBool($xml) {
340
-		$result = (string)$xml;
340
+		$result = (string) $xml;
341 341
 		if ($result == 'true') {
342 342
 			$result = true;
343 343
 		} elseif ($result == 'false') {
344 344
 			$result = false;
345 345
 		}
346
-		return (bool)$result;
346
+		return (bool) $result;
347 347
 	}
348 348
 }
Please login to merge, or discard this patch.
Indentation   +300 added lines, -300 removed lines patch added patch discarded remove patch
@@ -36,320 +36,320 @@
 block discarded – undo
36 36
 
37 37
 class MDB2SchemaReader {
38 38
 
39
-	/**
40
-	 * @var string $DBTABLEPREFIX
41
-	 */
42
-	protected $DBTABLEPREFIX;
39
+    /**
40
+     * @var string $DBTABLEPREFIX
41
+     */
42
+    protected $DBTABLEPREFIX;
43 43
 
44
-	/**
45
-	 * @var \Doctrine\DBAL\Platforms\AbstractPlatform $platform
46
-	 */
47
-	protected $platform;
44
+    /**
45
+     * @var \Doctrine\DBAL\Platforms\AbstractPlatform $platform
46
+     */
47
+    protected $platform;
48 48
 
49
-	/** @var IConfig */
50
-	protected $config;
49
+    /** @var IConfig */
50
+    protected $config;
51 51
 
52
-	/**
53
-	 * @param \OCP\IConfig $config
54
-	 * @param \Doctrine\DBAL\Platforms\AbstractPlatform $platform
55
-	 */
56
-	public function __construct(IConfig $config, AbstractPlatform $platform) {
57
-		$this->platform = $platform;
58
-		$this->config = $config;
59
-		$this->DBTABLEPREFIX = $config->getSystemValue('dbtableprefix', 'oc_');
60
-	}
52
+    /**
53
+     * @param \OCP\IConfig $config
54
+     * @param \Doctrine\DBAL\Platforms\AbstractPlatform $platform
55
+     */
56
+    public function __construct(IConfig $config, AbstractPlatform $platform) {
57
+        $this->platform = $platform;
58
+        $this->config = $config;
59
+        $this->DBTABLEPREFIX = $config->getSystemValue('dbtableprefix', 'oc_');
60
+    }
61 61
 
62
-	/**
63
-	 * @param string $file
64
-	 * @param Schema $schema
65
-	 * @return Schema
66
-	 * @throws \DomainException
67
-	 */
68
-	public function loadSchemaFromFile($file, Schema $schema) {
69
-		$loadEntities = libxml_disable_entity_loader(false);
70
-		$xml = simplexml_load_file($file);
71
-		libxml_disable_entity_loader($loadEntities);
72
-		foreach ($xml->children() as $child) {
73
-			/**
74
-			 * @var \SimpleXMLElement $child
75
-			 */
76
-			switch ($child->getName()) {
77
-				case 'name':
78
-				case 'create':
79
-				case 'overwrite':
80
-				case 'charset':
81
-					break;
82
-				case 'table':
83
-					$this->loadTable($schema, $child);
84
-					break;
85
-				default:
86
-					throw new \DomainException('Unknown element: ' . $child->getName());
62
+    /**
63
+     * @param string $file
64
+     * @param Schema $schema
65
+     * @return Schema
66
+     * @throws \DomainException
67
+     */
68
+    public function loadSchemaFromFile($file, Schema $schema) {
69
+        $loadEntities = libxml_disable_entity_loader(false);
70
+        $xml = simplexml_load_file($file);
71
+        libxml_disable_entity_loader($loadEntities);
72
+        foreach ($xml->children() as $child) {
73
+            /**
74
+             * @var \SimpleXMLElement $child
75
+             */
76
+            switch ($child->getName()) {
77
+                case 'name':
78
+                case 'create':
79
+                case 'overwrite':
80
+                case 'charset':
81
+                    break;
82
+                case 'table':
83
+                    $this->loadTable($schema, $child);
84
+                    break;
85
+                default:
86
+                    throw new \DomainException('Unknown element: ' . $child->getName());
87 87
 
88
-			}
89
-		}
90
-		return $schema;
91
-	}
88
+            }
89
+        }
90
+        return $schema;
91
+    }
92 92
 
93
-	/**
94
-	 * @param \Doctrine\DBAL\Schema\Schema $schema
95
-	 * @param \SimpleXMLElement $xml
96
-	 * @throws \DomainException
97
-	 */
98
-	private function loadTable($schema, $xml) {
99
-		$table = null;
100
-		foreach ($xml->children() as $child) {
101
-			/**
102
-			 * @var \SimpleXMLElement $child
103
-			 */
104
-			switch ($child->getName()) {
105
-				case 'name':
106
-					$name = (string)$child;
107
-					$name = str_replace('*dbprefix*', $this->DBTABLEPREFIX, $name);
108
-					$name = $this->platform->quoteIdentifier($name);
109
-					$table = $schema->createTable($name);
110
-					break;
111
-				case 'create':
112
-				case 'overwrite':
113
-				case 'charset':
114
-					break;
115
-				case 'declaration':
116
-					if (is_null($table)) {
117
-						throw new \DomainException('Table declaration before table name');
118
-					}
119
-					$this->loadDeclaration($table, $child);
120
-					break;
121
-				default:
122
-					throw new \DomainException('Unknown element: ' . $child->getName());
93
+    /**
94
+     * @param \Doctrine\DBAL\Schema\Schema $schema
95
+     * @param \SimpleXMLElement $xml
96
+     * @throws \DomainException
97
+     */
98
+    private function loadTable($schema, $xml) {
99
+        $table = null;
100
+        foreach ($xml->children() as $child) {
101
+            /**
102
+             * @var \SimpleXMLElement $child
103
+             */
104
+            switch ($child->getName()) {
105
+                case 'name':
106
+                    $name = (string)$child;
107
+                    $name = str_replace('*dbprefix*', $this->DBTABLEPREFIX, $name);
108
+                    $name = $this->platform->quoteIdentifier($name);
109
+                    $table = $schema->createTable($name);
110
+                    break;
111
+                case 'create':
112
+                case 'overwrite':
113
+                case 'charset':
114
+                    break;
115
+                case 'declaration':
116
+                    if (is_null($table)) {
117
+                        throw new \DomainException('Table declaration before table name');
118
+                    }
119
+                    $this->loadDeclaration($table, $child);
120
+                    break;
121
+                default:
122
+                    throw new \DomainException('Unknown element: ' . $child->getName());
123 123
 
124
-			}
125
-		}
126
-	}
124
+            }
125
+        }
126
+    }
127 127
 
128
-	/**
129
-	 * @param \Doctrine\DBAL\Schema\Table $table
130
-	 * @param \SimpleXMLElement $xml
131
-	 * @throws \DomainException
132
-	 */
133
-	private function loadDeclaration($table, $xml) {
134
-		foreach ($xml->children() as $child) {
135
-			/**
136
-			 * @var \SimpleXMLElement $child
137
-			 */
138
-			switch ($child->getName()) {
139
-				case 'field':
140
-					$this->loadField($table, $child);
141
-					break;
142
-				case 'index':
143
-					$this->loadIndex($table, $child);
144
-					break;
145
-				default:
146
-					throw new \DomainException('Unknown element: ' . $child->getName());
128
+    /**
129
+     * @param \Doctrine\DBAL\Schema\Table $table
130
+     * @param \SimpleXMLElement $xml
131
+     * @throws \DomainException
132
+     */
133
+    private function loadDeclaration($table, $xml) {
134
+        foreach ($xml->children() as $child) {
135
+            /**
136
+             * @var \SimpleXMLElement $child
137
+             */
138
+            switch ($child->getName()) {
139
+                case 'field':
140
+                    $this->loadField($table, $child);
141
+                    break;
142
+                case 'index':
143
+                    $this->loadIndex($table, $child);
144
+                    break;
145
+                default:
146
+                    throw new \DomainException('Unknown element: ' . $child->getName());
147 147
 
148
-			}
149
-		}
150
-	}
148
+            }
149
+        }
150
+    }
151 151
 
152
-	/**
153
-	 * @param \Doctrine\DBAL\Schema\Table $table
154
-	 * @param \SimpleXMLElement $xml
155
-	 * @throws \DomainException
156
-	 */
157
-	private function loadField($table, $xml) {
158
-		$options = [ 'notnull' => false ];
159
-		foreach ($xml->children() as $child) {
160
-			/**
161
-			 * @var \SimpleXMLElement $child
162
-			 */
163
-			switch ($child->getName()) {
164
-				case 'name':
165
-					$name = (string)$child;
166
-					$name = $this->platform->quoteIdentifier($name);
167
-					break;
168
-				case 'type':
169
-					$type = (string)$child;
170
-					switch ($type) {
171
-						case 'text':
172
-							$type = 'string';
173
-							break;
174
-						case 'clob':
175
-							$type = 'text';
176
-							break;
177
-						case 'timestamp':
178
-							$type = 'datetime';
179
-							break;
180
-						case 'numeric':
181
-							$type = 'decimal';
182
-							break;
183
-					}
184
-					break;
185
-				case 'length':
186
-					$length = (string)$child;
187
-					$options['length'] = $length;
188
-					break;
189
-				case 'unsigned':
190
-					$unsigned = $this->asBool($child);
191
-					$options['unsigned'] = $unsigned;
192
-					break;
193
-				case 'notnull':
194
-					$notnull = $this->asBool($child);
195
-					$options['notnull'] = $notnull;
196
-					break;
197
-				case 'autoincrement':
198
-					$autoincrement = $this->asBool($child);
199
-					$options['autoincrement'] = $autoincrement;
200
-					break;
201
-				case 'default':
202
-					$default = (string)$child;
203
-					$options['default'] = $default;
204
-					break;
205
-				case 'comments':
206
-					$comment = (string)$child;
207
-					$options['comment'] = $comment;
208
-					break;
209
-				case 'primary':
210
-					$primary = $this->asBool($child);
211
-					$options['primary'] = $primary;
212
-					break;
213
-				case 'precision':
214
-					$precision = (string)$child;
215
-					$options['precision'] = $precision;
216
-					break;
217
-				case 'scale':
218
-					$scale = (string)$child;
219
-					$options['scale'] = $scale;
220
-					break;
221
-				default:
222
-					throw new \DomainException('Unknown element: ' . $child->getName());
152
+    /**
153
+     * @param \Doctrine\DBAL\Schema\Table $table
154
+     * @param \SimpleXMLElement $xml
155
+     * @throws \DomainException
156
+     */
157
+    private function loadField($table, $xml) {
158
+        $options = [ 'notnull' => false ];
159
+        foreach ($xml->children() as $child) {
160
+            /**
161
+             * @var \SimpleXMLElement $child
162
+             */
163
+            switch ($child->getName()) {
164
+                case 'name':
165
+                    $name = (string)$child;
166
+                    $name = $this->platform->quoteIdentifier($name);
167
+                    break;
168
+                case 'type':
169
+                    $type = (string)$child;
170
+                    switch ($type) {
171
+                        case 'text':
172
+                            $type = 'string';
173
+                            break;
174
+                        case 'clob':
175
+                            $type = 'text';
176
+                            break;
177
+                        case 'timestamp':
178
+                            $type = 'datetime';
179
+                            break;
180
+                        case 'numeric':
181
+                            $type = 'decimal';
182
+                            break;
183
+                    }
184
+                    break;
185
+                case 'length':
186
+                    $length = (string)$child;
187
+                    $options['length'] = $length;
188
+                    break;
189
+                case 'unsigned':
190
+                    $unsigned = $this->asBool($child);
191
+                    $options['unsigned'] = $unsigned;
192
+                    break;
193
+                case 'notnull':
194
+                    $notnull = $this->asBool($child);
195
+                    $options['notnull'] = $notnull;
196
+                    break;
197
+                case 'autoincrement':
198
+                    $autoincrement = $this->asBool($child);
199
+                    $options['autoincrement'] = $autoincrement;
200
+                    break;
201
+                case 'default':
202
+                    $default = (string)$child;
203
+                    $options['default'] = $default;
204
+                    break;
205
+                case 'comments':
206
+                    $comment = (string)$child;
207
+                    $options['comment'] = $comment;
208
+                    break;
209
+                case 'primary':
210
+                    $primary = $this->asBool($child);
211
+                    $options['primary'] = $primary;
212
+                    break;
213
+                case 'precision':
214
+                    $precision = (string)$child;
215
+                    $options['precision'] = $precision;
216
+                    break;
217
+                case 'scale':
218
+                    $scale = (string)$child;
219
+                    $options['scale'] = $scale;
220
+                    break;
221
+                default:
222
+                    throw new \DomainException('Unknown element: ' . $child->getName());
223 223
 
224
-			}
225
-		}
226
-		if (isset($name) && isset($type)) {
227
-			if (isset($options['default']) && empty($options['default'])) {
228
-				if (empty($options['notnull']) || !$options['notnull']) {
229
-					unset($options['default']);
230
-					$options['notnull'] = false;
231
-				} else {
232
-					$options['default'] = '';
233
-				}
234
-				if ($type == 'integer' || $type == 'decimal') {
235
-					$options['default'] = 0;
236
-				} elseif ($type == 'boolean') {
237
-					$options['default'] = false;
238
-				}
239
-				if (!empty($options['autoincrement']) && $options['autoincrement']) {
240
-					unset($options['default']);
241
-				}
242
-			}
243
-			if ($type === 'integer' && isset($options['default'])) {
244
-				$options['default'] = (int)$options['default'];
245
-			}
246
-			if ($type === 'integer' && isset($options['length'])) {
247
-				$length = $options['length'];
248
-				if ($length < 4) {
249
-					$type = 'smallint';
250
-				} elseif ($length > 4) {
251
-					$type = 'bigint';
252
-				}
253
-			}
254
-			if ($type === 'boolean' && isset($options['default'])) {
255
-				$options['default'] = $this->asBool($options['default']);
256
-			}
257
-			if (!empty($options['autoincrement'])
258
-				&& !empty($options['notnull'])
259
-			) {
260
-				$options['primary'] = true;
261
-			}
224
+            }
225
+        }
226
+        if (isset($name) && isset($type)) {
227
+            if (isset($options['default']) && empty($options['default'])) {
228
+                if (empty($options['notnull']) || !$options['notnull']) {
229
+                    unset($options['default']);
230
+                    $options['notnull'] = false;
231
+                } else {
232
+                    $options['default'] = '';
233
+                }
234
+                if ($type == 'integer' || $type == 'decimal') {
235
+                    $options['default'] = 0;
236
+                } elseif ($type == 'boolean') {
237
+                    $options['default'] = false;
238
+                }
239
+                if (!empty($options['autoincrement']) && $options['autoincrement']) {
240
+                    unset($options['default']);
241
+                }
242
+            }
243
+            if ($type === 'integer' && isset($options['default'])) {
244
+                $options['default'] = (int)$options['default'];
245
+            }
246
+            if ($type === 'integer' && isset($options['length'])) {
247
+                $length = $options['length'];
248
+                if ($length < 4) {
249
+                    $type = 'smallint';
250
+                } elseif ($length > 4) {
251
+                    $type = 'bigint';
252
+                }
253
+            }
254
+            if ($type === 'boolean' && isset($options['default'])) {
255
+                $options['default'] = $this->asBool($options['default']);
256
+            }
257
+            if (!empty($options['autoincrement'])
258
+                && !empty($options['notnull'])
259
+            ) {
260
+                $options['primary'] = true;
261
+            }
262 262
 
263
-			# not used anymore in the options argument
264
-			# see https://github.com/doctrine/dbal/commit/138eb85234a1faeaa2e6a32cd7bcc66bb51c64e8#diff-300f55366adb50a32a40882ebdc95c163b141f64cba5f45f20bda04a907b3eb3L82
265
-			# therefore it's read before and then unset right before the addColumn call
266
-			$setPrimaryKey = false;
267
-			if (!empty($options['primary']) && $options['primary']) {
268
-				$setPrimaryKey = true;
269
-			}
270
-			unset($options['primary']);
271
-			$table->addColumn($name, $type, $options);
272
-			if ($setPrimaryKey) {
273
-				$table->setPrimaryKey([$name]);
274
-			}
275
-		}
276
-	}
263
+            # not used anymore in the options argument
264
+            # see https://github.com/doctrine/dbal/commit/138eb85234a1faeaa2e6a32cd7bcc66bb51c64e8#diff-300f55366adb50a32a40882ebdc95c163b141f64cba5f45f20bda04a907b3eb3L82
265
+            # therefore it's read before and then unset right before the addColumn call
266
+            $setPrimaryKey = false;
267
+            if (!empty($options['primary']) && $options['primary']) {
268
+                $setPrimaryKey = true;
269
+            }
270
+            unset($options['primary']);
271
+            $table->addColumn($name, $type, $options);
272
+            if ($setPrimaryKey) {
273
+                $table->setPrimaryKey([$name]);
274
+            }
275
+        }
276
+    }
277 277
 
278
-	/**
279
-	 * @param \Doctrine\DBAL\Schema\Table $table
280
-	 * @param \SimpleXMLElement $xml
281
-	 * @throws \DomainException
282
-	 */
283
-	private function loadIndex($table, $xml) {
284
-		$name = null;
285
-		$fields = [];
286
-		foreach ($xml->children() as $child) {
287
-			/**
288
-			 * @var \SimpleXMLElement $child
289
-			 */
290
-			switch ($child->getName()) {
291
-				case 'name':
292
-					$name = (string)$child;
293
-					break;
294
-				case 'primary':
295
-					$primary = $this->asBool($child);
296
-					break;
297
-				case 'unique':
298
-					$unique = $this->asBool($child);
299
-					break;
300
-				case 'field':
301
-					foreach ($child->children() as $field) {
302
-						/**
303
-						 * @var \SimpleXMLElement $field
304
-						 */
305
-						switch ($field->getName()) {
306
-							case 'name':
307
-								$field_name = (string)$field;
308
-								$field_name = $this->platform->quoteIdentifier($field_name);
309
-								$fields[] = $field_name;
310
-								break;
311
-							case 'sorting':
312
-								break;
313
-							default:
314
-								throw new \DomainException('Unknown element: ' . $field->getName());
278
+    /**
279
+     * @param \Doctrine\DBAL\Schema\Table $table
280
+     * @param \SimpleXMLElement $xml
281
+     * @throws \DomainException
282
+     */
283
+    private function loadIndex($table, $xml) {
284
+        $name = null;
285
+        $fields = [];
286
+        foreach ($xml->children() as $child) {
287
+            /**
288
+             * @var \SimpleXMLElement $child
289
+             */
290
+            switch ($child->getName()) {
291
+                case 'name':
292
+                    $name = (string)$child;
293
+                    break;
294
+                case 'primary':
295
+                    $primary = $this->asBool($child);
296
+                    break;
297
+                case 'unique':
298
+                    $unique = $this->asBool($child);
299
+                    break;
300
+                case 'field':
301
+                    foreach ($child->children() as $field) {
302
+                        /**
303
+                         * @var \SimpleXMLElement $field
304
+                         */
305
+                        switch ($field->getName()) {
306
+                            case 'name':
307
+                                $field_name = (string)$field;
308
+                                $field_name = $this->platform->quoteIdentifier($field_name);
309
+                                $fields[] = $field_name;
310
+                                break;
311
+                            case 'sorting':
312
+                                break;
313
+                            default:
314
+                                throw new \DomainException('Unknown element: ' . $field->getName());
315 315
 
316
-						}
317
-					}
318
-					break;
319
-				default:
320
-					throw new \DomainException('Unknown element: ' . $child->getName());
316
+                        }
317
+                    }
318
+                    break;
319
+                default:
320
+                    throw new \DomainException('Unknown element: ' . $child->getName());
321 321
 
322
-			}
323
-		}
324
-		if (!empty($fields)) {
325
-			if (isset($primary) && $primary) {
326
-				if ($table->hasPrimaryKey()) {
327
-					return;
328
-				}
329
-				$table->setPrimaryKey($fields, $name);
330
-			} else {
331
-				if (isset($unique) && $unique) {
332
-					$table->addUniqueIndex($fields, $name);
333
-				} else {
334
-					$table->addIndex($fields, $name);
335
-				}
336
-			}
337
-		} else {
338
-			throw new \DomainException('Empty index definition: ' . $name . ' options:' . print_r($fields, true));
339
-		}
340
-	}
322
+            }
323
+        }
324
+        if (!empty($fields)) {
325
+            if (isset($primary) && $primary) {
326
+                if ($table->hasPrimaryKey()) {
327
+                    return;
328
+                }
329
+                $table->setPrimaryKey($fields, $name);
330
+            } else {
331
+                if (isset($unique) && $unique) {
332
+                    $table->addUniqueIndex($fields, $name);
333
+                } else {
334
+                    $table->addIndex($fields, $name);
335
+                }
336
+            }
337
+        } else {
338
+            throw new \DomainException('Empty index definition: ' . $name . ' options:' . print_r($fields, true));
339
+        }
340
+    }
341 341
 
342
-	/**
343
-	 * @param \SimpleXMLElement|string $xml
344
-	 * @return bool
345
-	 */
346
-	private function asBool($xml) {
347
-		$result = (string)$xml;
348
-		if ($result == 'true') {
349
-			$result = true;
350
-		} elseif ($result == 'false') {
351
-			$result = false;
352
-		}
353
-		return (bool)$result;
354
-	}
342
+    /**
343
+     * @param \SimpleXMLElement|string $xml
344
+     * @return bool
345
+     */
346
+    private function asBool($xml) {
347
+        $result = (string)$xml;
348
+        if ($result == 'true') {
349
+            $result = true;
350
+        } elseif ($result == 'false') {
351
+            $result = false;
352
+        }
353
+        return (bool)$result;
354
+    }
355 355
 }
Please login to merge, or discard this patch.