47 $oldGroup = $this->
getArg( 0 );
48 $newGroup = $this->
getArg( 1 );
52 $start = $dbw->newSelectQueryBuilder()
53 ->select(
'MIN(ug_user)' )
54 ->from(
'user_groups' )
55 ->where( [
'ug_group' => $oldGroup ] )
56 ->caller( __FUNCTION__ )->fetchField();
57 $end = $dbw->newSelectQueryBuilder()
58 ->select(
'MAX(ug_user)' )
59 ->from(
'user_groups' )
60 ->where( [
'ug_group' => $oldGroup ] )
61 ->caller( __FUNCTION__ )->fetchField();
62 if ( $start ===
null ) {
63 $this->
fatalError(
"Nothing to do - no users in the '$oldGroup' group" );
66 $end += $batchSize - 1;
68 $blockEnd = $start + $batchSize - 1;
70 while ( $blockEnd <= $end ) {
72 $this->
output(
"Doing users $blockStart to $blockEnd\n" );
77 $usersAlreadyInNewGroup = $dbw->newSelectQueryBuilder()
79 ->from(
'user_groups' )
81 'ug_group' => $newGroup,
82 $dbw->expr(
'ug_user',
'>=', (
int)$blockStart ),
83 $dbw->expr(
'ug_user',
'<=', (
int)$blockEnd ),
85 ->caller( __METHOD__ )
89 $updateQueryBuilder = $dbw->newUpdateQueryBuilder()
90 ->update(
'user_groups' )
91 ->set( [
'ug_group' => $newGroup ] )
93 'ug_group' => $oldGroup,
94 $dbw->expr(
'ug_user',
'>=', (
int)$blockStart ),
95 $dbw->expr(
'ug_user',
'<=', (
int)$blockEnd ),
97 ->caller( __METHOD__ );
98 if ( count( $usersAlreadyInNewGroup ) ) {
99 $updateQueryBuilder->where( $dbw->expr(
'ug_user',
'!=', $usersAlreadyInNewGroup ) );
101 $updateQueryBuilder->execute();
102 $affected += $dbw->affectedRows();
106 if ( count( $usersAlreadyInNewGroup ) ) {
107 $dbw->newDeleteQueryBuilder()
108 ->deleteFrom(
'user_groups' )
110 'ug_group' => $oldGroup,
111 $dbw->expr(
'ug_user',
'=', $usersAlreadyInNewGroup ),
113 ->caller( __METHOD__ )->execute();
114 $affected += $dbw->affectedRows();
119 if ( $affected > 0 ) {
122 $res = $dbw->newSelectQueryBuilder()
123 ->select(
'ug_user' )
124 ->from(
'user_groups' )
126 'ug_group' => $newGroup,
127 $dbw->expr(
'ug_user',
'>=', (
int)$blockStart ),
128 $dbw->expr(
'ug_user',
'<=', (
int)$blockEnd ),
130 ->caller( __METHOD__ )->fetchResultSet();
131 if ( $res !==
false ) {
132 foreach ( $res as $row ) {
133 $user = User::newFromId( $row->ug_user );
134 $user->invalidateCache();
135 $userGroupManager->clearCache( $user );
141 $blockStart += $batchSize;
142 $blockEnd += $batchSize;
144 $this->
output(
"Done! $count users in group '$oldGroup' are now in '$newGroup' instead.\n" );