mirror of
https://github.com/phpbb/phpbb.git
synced 2025-06-28 14:18:52 +00:00
[ticket/14992] Add indexes to user_notifications table
[ticket/14992] Change how index length is checked [ticket/14992] Remove duplicates from user_notifications table [ticket/14992] Add unique index to user_notifications table [ticket/14992] Shorten unique index name [ticket/14992] Shorten another index for user notifications
This commit is contained in:
parent
9b4d455726
commit
e5eb702514
4 changed files with 157 additions and 8 deletions
|
@ -0,0 +1,50 @@
|
||||||
|
<?php
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* This file is part of the phpBB Forum Software package.
|
||||||
|
*
|
||||||
|
* @copyright (c) phpBB Limited <https://www.phpbb.com>
|
||||||
|
* @license GNU General Public License, version 2 (GPL-2.0)
|
||||||
|
*
|
||||||
|
* For full copyright and license information, please see
|
||||||
|
* the docs/CREDITS.txt file.
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
namespace phpbb\db\migration\data\v32x;
|
||||||
|
|
||||||
|
class user_notifications_table_indexes extends \phpbb\db\migration\migration
|
||||||
|
{
|
||||||
|
static public function depends_on()
|
||||||
|
{
|
||||||
|
return array(
|
||||||
|
'\phpbb\db\migration\data\v32x\cookie_notice_p2',
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function update_schema()
|
||||||
|
{
|
||||||
|
return array(
|
||||||
|
'add_index' => array(
|
||||||
|
$this->table_prefix . 'user_notifications' => array(
|
||||||
|
'user_id' => array('user_id'),
|
||||||
|
'user_id_item_id' => array('user_id', 'item_id'),
|
||||||
|
'user_itm_type_id' => array('user_id', 'item_type', 'item_id'),
|
||||||
|
),
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function revert_schema()
|
||||||
|
{
|
||||||
|
return array(
|
||||||
|
'drop_keys' => array(
|
||||||
|
$this->table_prefix . 'user_notifications' => array(
|
||||||
|
'user_id',
|
||||||
|
'user_id_item_id',
|
||||||
|
'user_itm_type_id',
|
||||||
|
),
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,55 @@
|
||||||
|
<?php
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* This file is part of the phpBB Forum Software package.
|
||||||
|
*
|
||||||
|
* @copyright (c) phpBB Limited <https://www.phpbb.com>
|
||||||
|
* @license GNU General Public License, version 2 (GPL-2.0)
|
||||||
|
*
|
||||||
|
* For full copyright and license information, please see
|
||||||
|
* the docs/CREDITS.txt file.
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
namespace phpbb\db\migration\data\v32x;
|
||||||
|
|
||||||
|
class user_notifications_table_remove_duplicates extends \phpbb\db\migration\migration
|
||||||
|
{
|
||||||
|
static public function depends_on()
|
||||||
|
{
|
||||||
|
return array(
|
||||||
|
'\phpbb\db\migration\data\v32x\user_notifications_table_indexes',
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function update_data()
|
||||||
|
{
|
||||||
|
return array(
|
||||||
|
array('custom', array(array($this, 'remove_duplicates'))),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function remove_duplicates()
|
||||||
|
{
|
||||||
|
$insert_buffer = new \phpbb\db\sql_insert_buffer($this->db, $this->table_prefix . 'user_notifications');
|
||||||
|
|
||||||
|
$sql = "SELECT item_type, item_id, user_id, method, MAX(notify) AS notify
|
||||||
|
FROM {$this->table_prefix}user_notifications
|
||||||
|
GROUP BY item_type, item_id, user_id, method
|
||||||
|
HAVING COUNT(item_type) > 1";
|
||||||
|
|
||||||
|
$result = $this->sql_query($sql);
|
||||||
|
while ($row = $this->db->sql_fetchrow($result))
|
||||||
|
{
|
||||||
|
// Delete the duplicate entries
|
||||||
|
$this->sql_query("DELETE FROM {$this->table_prefix}user_notifications
|
||||||
|
WHERE user_id = {$row['user_id']}
|
||||||
|
AND item_type = '{$row['item_type']}'
|
||||||
|
AND method = '{$row['method']}'");
|
||||||
|
|
||||||
|
// And re-insert as a single one
|
||||||
|
$insert_buffer->insert($row);
|
||||||
|
}
|
||||||
|
$this->db->sql_freeresult($result);
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,46 @@
|
||||||
|
<?php
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* This file is part of the phpBB Forum Software package.
|
||||||
|
*
|
||||||
|
* @copyright (c) phpBB Limited <https://www.phpbb.com>
|
||||||
|
* @license GNU General Public License, version 2 (GPL-2.0)
|
||||||
|
*
|
||||||
|
* For full copyright and license information, please see
|
||||||
|
* the docs/CREDITS.txt file.
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
namespace phpbb\db\migration\data\v32x;
|
||||||
|
|
||||||
|
class user_notifications_table_unique_index extends \phpbb\db\migration\migration
|
||||||
|
{
|
||||||
|
static public function depends_on()
|
||||||
|
{
|
||||||
|
return array(
|
||||||
|
'\phpbb\db\migration\data\v32x\user_notifications_table_remove_duplicates',
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function update_schema()
|
||||||
|
{
|
||||||
|
return array(
|
||||||
|
'add_unique_index' => array(
|
||||||
|
$this->table_prefix . 'user_notifications' => array(
|
||||||
|
'itm_usr_mthd' => array('item_type', 'item_id', 'user_id', 'method'),
|
||||||
|
),
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function revert_schema()
|
||||||
|
{
|
||||||
|
return array(
|
||||||
|
'drop_keys' => array(
|
||||||
|
$this->table_prefix . 'user_notifications' => array(
|
||||||
|
'itm_usr_mthd',
|
||||||
|
),
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
|
@ -1487,17 +1487,17 @@ class tools implements tools_interface
|
||||||
{
|
{
|
||||||
$statements = array();
|
$statements = array();
|
||||||
|
|
||||||
$this->check_index_name_length($table_name, $index_name);
|
|
||||||
|
|
||||||
switch ($this->sql_layer)
|
switch ($this->sql_layer)
|
||||||
{
|
{
|
||||||
case 'oracle':
|
case 'oracle':
|
||||||
case 'sqlite3':
|
case 'sqlite3':
|
||||||
|
$this->check_index_name_length($table_name, $table_name . '_' . $index_name);
|
||||||
$statements[] = 'CREATE UNIQUE INDEX ' . $table_name . '_' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';
|
$statements[] = 'CREATE UNIQUE INDEX ' . $table_name . '_' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case 'mysql_40':
|
case 'mysql_40':
|
||||||
case 'mysql_41':
|
case 'mysql_41':
|
||||||
|
$this->check_index_name_length($table_name, $index_name);
|
||||||
$statements[] = 'ALTER TABLE ' . $table_name . ' ADD UNIQUE INDEX ' . $index_name . '(' . implode(', ', $column) . ')';
|
$statements[] = 'ALTER TABLE ' . $table_name . ' ADD UNIQUE INDEX ' . $index_name . '(' . implode(', ', $column) . ')';
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
@ -1512,8 +1512,6 @@ class tools implements tools_interface
|
||||||
{
|
{
|
||||||
$statements = array();
|
$statements = array();
|
||||||
|
|
||||||
$this->check_index_name_length($table_name, $index_name);
|
|
||||||
|
|
||||||
// remove index length unless MySQL4
|
// remove index length unless MySQL4
|
||||||
if ('mysql_40' != $this->sql_layer)
|
if ('mysql_40' != $this->sql_layer)
|
||||||
{
|
{
|
||||||
|
@ -1524,6 +1522,7 @@ class tools implements tools_interface
|
||||||
{
|
{
|
||||||
case 'oracle':
|
case 'oracle':
|
||||||
case 'sqlite3':
|
case 'sqlite3':
|
||||||
|
$this->check_index_name_length($table_name, $table_name . '_' . $index_name);
|
||||||
$statements[] = 'CREATE INDEX ' . $table_name . '_' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';
|
$statements[] = 'CREATE INDEX ' . $table_name . '_' . $index_name . ' ON ' . $table_name . '(' . implode(', ', $column) . ')';
|
||||||
break;
|
break;
|
||||||
|
|
||||||
|
@ -1539,6 +1538,7 @@ class tools implements tools_interface
|
||||||
}
|
}
|
||||||
// no break
|
// no break
|
||||||
case 'mysql_41':
|
case 'mysql_41':
|
||||||
|
$this->check_index_name_length($table_name, $index_name);
|
||||||
$statements[] = 'ALTER TABLE ' . $table_name . ' ADD INDEX ' . $index_name . ' (' . implode(', ', $column) . ')';
|
$statements[] = 'ALTER TABLE ' . $table_name . ' ADD INDEX ' . $index_name . ' (' . implode(', ', $column) . ')';
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
@ -1554,11 +1554,9 @@ class tools implements tools_interface
|
||||||
*/
|
*/
|
||||||
protected function check_index_name_length($table_name, $index_name)
|
protected function check_index_name_length($table_name, $index_name)
|
||||||
{
|
{
|
||||||
$table_prefix = substr(CONFIG_TABLE, 0, -6); // strlen(config)
|
if (strlen($index_name) > 30)
|
||||||
if (strlen($table_name . $index_name) - strlen($table_prefix) > 24)
|
|
||||||
{
|
{
|
||||||
$max_length = strlen($table_prefix) + 24;
|
trigger_error("Index name '$index_name' on table '$table_name' is too long. The maximum is 30 characters.", E_USER_ERROR);
|
||||||
trigger_error("Index name '{$table_name}_$index_name' on table '$table_name' is too long. The maximum is $max_length characters.", E_USER_ERROR);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue