MediaWiki master
AtomicSectionUpdate.php
Go to the documentation of this file.
1<?php
2
4
6
13 private $dbw;
15 private $fname;
17 private $callback;
18
26 public function __construct( IDatabase $dbw, $fname, callable $callback, array $conns = [] ) {
27 $this->dbw = $dbw;
28 $this->fname = $fname;
29 $this->callback = $callback;
30 // Register DB connections for which uncommitted changes are related to this update
31 $conns[] = $dbw;
32 foreach ( $conns as $conn ) {
33 if ( $conn->trxLevel() ) {
34 $conn->onTransactionResolution( [ $this, 'cancelOnRollback' ], $fname );
35 }
36 }
37 }
38
39 public function doUpdate() {
40 if ( $this->callback ) {
41 $this->dbw->doAtomicSection( $this->fname, $this->callback );
42 }
43 }
44
49 public function cancelOnRollback( $trigger ) {
50 if ( $trigger === IDatabase::TRIGGER_ROLLBACK ) {
51 $this->callback = null;
52 }
53 }
54
55 public function getOrigin() {
56 return $this->fname;
57 }
58}
59
61class_alias( AtomicSectionUpdate::class, 'AtomicSectionUpdate' );
Deferrable Update for closure/callback updates via IDatabase::doAtomicSection()
__construct(IDatabase $dbw, $fname, callable $callback, array $conns=[])
Callback wrapper that has an originating method.
Interface that deferrable updates should implement.
Basic database interface for live and lazy-loaded relation database handles.
Definition IDatabase.php:36
onTransactionResolution(callable $callback, $fname=__METHOD__)
Run a callback when the current transaction commits or rolls back.