diff options
author | Morris Jobke <hey@morrisjobke.de> | 2016-01-07 10:18:38 +0100 |
---|---|---|
committer | Morris Jobke <hey@morrisjobke.de> | 2016-01-07 14:54:55 +0100 |
commit | 0a41cfefe38e8bf352895f2b87dd9a04fd627094 (patch) | |
tree | b965a0cc879ba604915a0d8b0d890888317dcf0e /lib/private | |
parent | 3917d888bde42336abb1d2ecbef04ae7530e5c14 (diff) | |
download | nextcloud-server-0a41cfefe38e8bf352895f2b87dd9a04fd627094.tar.gz nextcloud-server-0a41cfefe38e8bf352895f2b87dd9a04fd627094.zip |
Remove beginTransaction, commit, rollback from OC_DB
Diffstat (limited to 'lib/private')
-rw-r--r-- | lib/private/db.php | 21 | ||||
-rw-r--r-- | lib/private/files/cache/scanner.php | 6 |
2 files changed, 3 insertions, 24 deletions
diff --git a/lib/private/db.php b/lib/private/db.php index bac0f600e95..f5f0c8798cd 100644 --- a/lib/private/db.php +++ b/lib/private/db.php @@ -173,27 +173,6 @@ class OC_DB { } /** - * Start a transaction - */ - public static function beginTransaction() { - return \OC::$server->getDatabaseConnection()->beginTransaction(); - } - - /** - * Commit the database changes done during a transaction that is in progress - */ - public static function commit() { - return \OC::$server->getDatabaseConnection()->commit(); - } - - /** - * Rollback the database changes done during a transaction that is in progress - */ - public static function rollback() { - return \OC::$server->getDatabaseConnection()->rollback(); - } - - /** * saves database schema to xml file * @param string $file name of file * @param int $mode diff --git a/lib/private/files/cache/scanner.php b/lib/private/files/cache/scanner.php index 983e12d7639..88bb57d2b5c 100644 --- a/lib/private/files/cache/scanner.php +++ b/lib/private/files/cache/scanner.php @@ -336,7 +336,7 @@ class Scanner extends BasicEmitter { $newChildren = $this->getNewChildren($path); if ($this->useTransactions) { - \OC_DB::beginTransaction(); + \OC::$server->getDatabaseConnection()->beginTransaction(); } $exceptionOccurred = false; foreach ($newChildren as $file) { @@ -361,7 +361,7 @@ class Scanner extends BasicEmitter { $exceptionOccurred = true; } catch (\OCP\Lock\LockedException $e) { if ($this->useTransactions) { - \OC_DB::rollback(); + \OC::$server->getDatabaseConnection()->rollback(); } throw $e; } @@ -372,7 +372,7 @@ class Scanner extends BasicEmitter { $this->removeFromCache($child); } if ($this->useTransactions) { - \OC_DB::commit(); + \OC::$server->getDatabaseConnection()->commit(); } if ($exceptionOccurred) { // It might happen that the parallel scan process has already |