mirror/php-phpbb
1
0
Fork 0
mirror of https://github.com/phpbb/phpbb.git synced 2025-05-11 01:55:24 +02:00
Code Issues Releases Wiki Activity

[ticket/11691] Stagger user notification reconversion even more

Browse Source 
PHPBB3-11691
This commit is contained in:
Joas Schilling 2013-08-04 23:44:41 +02:00
parent a7af736b97
commit 29c84be40a
1 changed files with 24 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
phpBB/phpbb/db/migration/data/v310/notification_options_reconvert.php
View File

@ -23,12 +23,19 @@ class notification_options_reconvert extends \phpbb\db\migration\migration
); );
} }
public function convert_notifications() public function convert_notifications($start)
{ {
$insert_table = $this->table_prefix . 'user_notifications'; $insert_table = $this->table_prefix . 'user_notifications';
$insert_buffer = new \phpbb\db\sql_insert_buffer($this->db, $insert_table); $insert_buffer = new \phpbb\db\sql_insert_buffer($this->db, $insert_table);
$this->perform_conversion($insert_buffer, $insert_table); $start = (int) $start;
if ($start == 0)
{
$sql = 'DELETE FROM ' . $insert_table;
$this->db->sql_query($sql);
}
return $this->perform_conversion($insert_buffer, $insert_table, $start);
} }
/** /**
@ -37,17 +44,19 @@ class notification_options_reconvert extends \phpbb\db\migration\migration
* @param \phpbb\db\sql_insert_buffer $insert_buffer * @param \phpbb\db\sql_insert_buffer $insert_buffer
* @param string $insert_table * @param string $insert_table
*/ */
public function perform_conversion(\phpbb\db\sql_insert_buffer $insert_buffer, $insert_table) public function perform_conversion(\phpbb\db\sql_insert_buffer $insert_buffer, $insert_table, $start)
{ {
$sql = 'DELETE FROM ' . $insert_table; $limit = 250;
$this->db->sql_query($sql); $converted_users = 0;
$sql = 'SELECT user_id, user_notify_type, user_notify_pm $sql = 'SELECT user_id, user_notify_type, user_notify_pm
FROM ' . USERS_TABLE; FROM ' . USERS_TABLE . '
$result = $this->db->sql_query($sql); ORDER BY user_id';
$result = $this->db->sql_query_limit($sql, $limit, $start);
while ($row = $this->db->sql_fetchrow($result)) while ($row = $this->db->sql_fetchrow($result))
{ {
$converted_users++;
$notification_methods = array(); $notification_methods = array();
// In-board notification // In-board notification
@ -91,6 +100,14 @@ class notification_options_reconvert extends \phpbb\db\migration\migration
$this->db->sql_freeresult($result); $this->db->sql_freeresult($result);
$insert_buffer->flush(); $insert_buffer->flush();
if ($converted_users < $limit)
{
// No more users left, we are done...
return;
}
return $start + $limit;
} }
/** /**