8
8
* @file
9
9
* @ingroup Extensions
10
10
*/
11
-
11
+
12
12
class IDProviderFunctions {
13
13
14
14
@@ -95,11 +95,10 @@ private static function calculateIncrement($prefix) {
95
95
// Get DB with read access
96
96
// > MW 1.27
97
97
if ( class_exists ( '\MediaWiki\MediaWikiServices ' ) && method_exists ( '\MediaWiki\MediaWikiServices ' , 'getDBLoadBalancerFactory ' ) ) {
98
- $ factory = \MediaWiki \MediaWikiServices::getInstance ()->getDBLoadBalancerFactory ();
99
- $ mainLB = $ factory ->getMainLB ();
100
- $ dbw = $ mainLB ->getConnectionRef ( DB_MASTER );
101
- $ factory ->beginMasterChanges (__METHOD__ );
102
- } else {
98
+ $ lb = \MediaWiki \MediaWikiServices::getInstance ()->getDBLoadBalancerFactory ()->newMainLB ();
99
+ $ dbw = $ lb ->getConnection ( DB_MASTER );
100
+ $ dbw ->clearFlag ( DBO_TRX );
101
+ } else {
103
102
$ dbw = wfGetDB (DB_MASTER );
104
103
$ dbw ->begin ();
105
104
}
@@ -125,7 +124,7 @@ private static function calculateIncrement($prefix) {
125
124
);
126
125
// > MW 1.27
127
126
if ( class_exists ( '\MediaWiki\MediaWikiServices ' ) && method_exists ( '\MediaWiki\MediaWikiServices ' , 'getDBLoadBalancerFactory ' ) ) {
128
- $ factory -> commitMasterChanges ( __METHOD__ );
127
+ $ lb -> disable ();
129
128
} else {
130
129
$ dbw ->commit ();
131
130
}
@@ -149,12 +148,12 @@ private static function calculateIncrement($prefix) {
149
148
);
150
149
// > MW 1.27
151
150
if ( class_exists ( '\MediaWiki\MediaWikiServices ' ) && method_exists ( '\MediaWiki\MediaWikiServices ' , 'getDBLoadBalancerFactory ' ) ) {
152
- $ factory -> commitMasterChanges ( __METHOD__ );
151
+ $ lb -> disable ();
153
152
} else {
154
153
$ dbw ->commit ();
155
154
}
156
- }
157
-
155
+ }
156
+
158
157
if (!$ increment ) {
159
158
throw new Exception ('Could not calculate the increment! ' );
160
159
}
@@ -415,4 +414,4 @@ public static function toJSON($obj) {
415
414
die ();
416
415
}
417
416
418
- }
417
+ }
0 commit comments